Source file src/github.com/emissary-ingress/emissary/v3/pkg/api/envoy/service/discovery/v2/sds.pb.go

Documentation: github.com/emissary-ingress/emissary/v3/pkg/api/envoy/service/discovery/v2

     1  // Code generated by protoc-gen-go. DO NOT EDIT.
     2  // versions:
     3  // 	protoc-gen-go v1.28.1
     4  // 	protoc        v3.21.12
     5  // source: envoy/service/discovery/v2/sds.proto
     6  
     7  package discoveryv2
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/xds/go/udpa/annotations"
    12  	_ "github.com/emissary-ingress/emissary/v3/pkg/api/envoy/annotations"
    13  	v2 "github.com/emissary-ingress/emissary/v3/pkg/api/envoy/api/v2"
    14  	_ "google.golang.org/genproto/googleapis/api/annotations"
    15  	grpc "google.golang.org/grpc"
    16  	codes "google.golang.org/grpc/codes"
    17  	status "google.golang.org/grpc/status"
    18  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    19  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    20  	reflect "reflect"
    21  	sync "sync"
    22  )
    23  
    24  const (
    25  	// Verify that this generated code is sufficiently up-to-date.
    26  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    27  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    28  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    29  )
    30  
    31  // [#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing
    32  // services: https://github.com/google/protobuf/issues/4221
    33  type SdsDummy struct {
    34  	state         protoimpl.MessageState
    35  	sizeCache     protoimpl.SizeCache
    36  	unknownFields protoimpl.UnknownFields
    37  }
    38  
    39  func (x *SdsDummy) Reset() {
    40  	*x = SdsDummy{}
    41  	if protoimpl.UnsafeEnabled {
    42  		mi := &file_envoy_service_discovery_v2_sds_proto_msgTypes[0]
    43  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    44  		ms.StoreMessageInfo(mi)
    45  	}
    46  }
    47  
    48  func (x *SdsDummy) String() string {
    49  	return protoimpl.X.MessageStringOf(x)
    50  }
    51  
    52  func (*SdsDummy) ProtoMessage() {}
    53  
    54  func (x *SdsDummy) ProtoReflect() protoreflect.Message {
    55  	mi := &file_envoy_service_discovery_v2_sds_proto_msgTypes[0]
    56  	if protoimpl.UnsafeEnabled && x != nil {
    57  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    58  		if ms.LoadMessageInfo() == nil {
    59  			ms.StoreMessageInfo(mi)
    60  		}
    61  		return ms
    62  	}
    63  	return mi.MessageOf(x)
    64  }
    65  
    66  // Deprecated: Use SdsDummy.ProtoReflect.Descriptor instead.
    67  func (*SdsDummy) Descriptor() ([]byte, []int) {
    68  	return file_envoy_service_discovery_v2_sds_proto_rawDescGZIP(), []int{0}
    69  }
    70  
    71  var File_envoy_service_discovery_v2_sds_proto protoreflect.FileDescriptor
    72  
    73  var file_envoy_service_discovery_v2_sds_proto_rawDesc = []byte{
    74  	0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
    75  	0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x2f, 0x73, 0x64, 0x73,
    76  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
    77  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e,
    78  	0x76, 0x32, 0x1a, 0x1c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32,
    79  	0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
    80  	0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e,
    81  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x20,
    82  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e,
    83  	0x73, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
    84  	0x1a, 0x1e, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f,
    85  	0x6e, 0x73, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
    86  	0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f,
    87  	0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22,
    88  	0x0a, 0x0a, 0x08, 0x53, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xec, 0x02, 0x0a, 0x16,
    89  	0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x53,
    90  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x5f, 0x0a, 0x0c, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x53,
    91  	0x65, 0x63, 0x72, 0x65, 0x74, 0x73, 0x12, 0x23, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61,
    92  	0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f,
    93  	0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x24, 0x2e, 0x65, 0x6e,
    94  	0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61,
    95  	0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
    96  	0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x56, 0x0a, 0x0d, 0x53, 0x74, 0x72, 0x65, 0x61,
    97  	0x6d, 0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x73, 0x12, 0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
    98  	0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
    99  	0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   100  	0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
   101  	0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12,
   102  	0x77, 0x0a, 0x0c, 0x46, 0x65, 0x74, 0x63, 0x68, 0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x73, 0x12,
   103  	0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44,
   104  	0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
   105  	0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44,
   106  	0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
   107  	0x22, 0x26, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x17, 0x22, 0x15, 0x2f, 0x76, 0x32, 0x2f, 0x64, 0x69,
   108  	0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x3a, 0x73, 0x65, 0x63, 0x72, 0x65, 0x74, 0x73, 0x82,
   109  	0xd3, 0xe4, 0x93, 0x02, 0x03, 0x3a, 0x01, 0x2a, 0x1a, 0x20, 0x8a, 0xa4, 0x96, 0xf3, 0x07, 0x1a,
   110  	0x0a, 0x18, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x61,
   111  	0x75, 0x74, 0x68, 0x2e, 0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x42, 0xaf, 0x01, 0x0a, 0x28, 0x69,
   112  	0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76,
   113  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f,
   114  	0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x42, 0x08, 0x53, 0x64, 0x73, 0x50, 0x72, 0x6f, 0x74,
   115  	0x6f, 0x50, 0x01, 0x5a, 0x4d, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
   116  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2f, 0x67, 0x6f, 0x2d, 0x63, 0x6f,
   117  	0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x2d, 0x70, 0x6c, 0x61, 0x6e, 0x65, 0x2f, 0x65, 0x6e, 0x76, 0x6f,
   118  	0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76,
   119  	0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x3b, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
   120  	0x76, 0x32, 0x88, 0x01, 0x01, 0xf2, 0x98, 0xfe, 0x8f, 0x05, 0x19, 0x12, 0x17, 0x65, 0x6e, 0x76,
   121  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x65, 0x63, 0x72, 0x65,
   122  	0x74, 0x2e, 0x76, 0x33, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x01, 0x62, 0x06, 0x70, 0x72,
   123  	0x6f, 0x74, 0x6f, 0x33,
   124  }
   125  
   126  var (
   127  	file_envoy_service_discovery_v2_sds_proto_rawDescOnce sync.Once
   128  	file_envoy_service_discovery_v2_sds_proto_rawDescData = file_envoy_service_discovery_v2_sds_proto_rawDesc
   129  )
   130  
   131  func file_envoy_service_discovery_v2_sds_proto_rawDescGZIP() []byte {
   132  	file_envoy_service_discovery_v2_sds_proto_rawDescOnce.Do(func() {
   133  		file_envoy_service_discovery_v2_sds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_discovery_v2_sds_proto_rawDescData)
   134  	})
   135  	return file_envoy_service_discovery_v2_sds_proto_rawDescData
   136  }
   137  
   138  var file_envoy_service_discovery_v2_sds_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
   139  var file_envoy_service_discovery_v2_sds_proto_goTypes = []interface{}{
   140  	(*SdsDummy)(nil),                  // 0: envoy.service.discovery.v2.SdsDummy
   141  	(*v2.DeltaDiscoveryRequest)(nil),  // 1: envoy.api.v2.DeltaDiscoveryRequest
   142  	(*v2.DiscoveryRequest)(nil),       // 2: envoy.api.v2.DiscoveryRequest
   143  	(*v2.DeltaDiscoveryResponse)(nil), // 3: envoy.api.v2.DeltaDiscoveryResponse
   144  	(*v2.DiscoveryResponse)(nil),      // 4: envoy.api.v2.DiscoveryResponse
   145  }
   146  var file_envoy_service_discovery_v2_sds_proto_depIdxs = []int32{
   147  	1, // 0: envoy.service.discovery.v2.SecretDiscoveryService.DeltaSecrets:input_type -> envoy.api.v2.DeltaDiscoveryRequest
   148  	2, // 1: envoy.service.discovery.v2.SecretDiscoveryService.StreamSecrets:input_type -> envoy.api.v2.DiscoveryRequest
   149  	2, // 2: envoy.service.discovery.v2.SecretDiscoveryService.FetchSecrets:input_type -> envoy.api.v2.DiscoveryRequest
   150  	3, // 3: envoy.service.discovery.v2.SecretDiscoveryService.DeltaSecrets:output_type -> envoy.api.v2.DeltaDiscoveryResponse
   151  	4, // 4: envoy.service.discovery.v2.SecretDiscoveryService.StreamSecrets:output_type -> envoy.api.v2.DiscoveryResponse
   152  	4, // 5: envoy.service.discovery.v2.SecretDiscoveryService.FetchSecrets:output_type -> envoy.api.v2.DiscoveryResponse
   153  	3, // [3:6] is the sub-list for method output_type
   154  	0, // [0:3] is the sub-list for method input_type
   155  	0, // [0:0] is the sub-list for extension type_name
   156  	0, // [0:0] is the sub-list for extension extendee
   157  	0, // [0:0] is the sub-list for field type_name
   158  }
   159  
   160  func init() { file_envoy_service_discovery_v2_sds_proto_init() }
   161  func file_envoy_service_discovery_v2_sds_proto_init() {
   162  	if File_envoy_service_discovery_v2_sds_proto != nil {
   163  		return
   164  	}
   165  	if !protoimpl.UnsafeEnabled {
   166  		file_envoy_service_discovery_v2_sds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   167  			switch v := v.(*SdsDummy); i {
   168  			case 0:
   169  				return &v.state
   170  			case 1:
   171  				return &v.sizeCache
   172  			case 2:
   173  				return &v.unknownFields
   174  			default:
   175  				return nil
   176  			}
   177  		}
   178  	}
   179  	type x struct{}
   180  	out := protoimpl.TypeBuilder{
   181  		File: protoimpl.DescBuilder{
   182  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   183  			RawDescriptor: file_envoy_service_discovery_v2_sds_proto_rawDesc,
   184  			NumEnums:      0,
   185  			NumMessages:   1,
   186  			NumExtensions: 0,
   187  			NumServices:   1,
   188  		},
   189  		GoTypes:           file_envoy_service_discovery_v2_sds_proto_goTypes,
   190  		DependencyIndexes: file_envoy_service_discovery_v2_sds_proto_depIdxs,
   191  		MessageInfos:      file_envoy_service_discovery_v2_sds_proto_msgTypes,
   192  	}.Build()
   193  	File_envoy_service_discovery_v2_sds_proto = out.File
   194  	file_envoy_service_discovery_v2_sds_proto_rawDesc = nil
   195  	file_envoy_service_discovery_v2_sds_proto_goTypes = nil
   196  	file_envoy_service_discovery_v2_sds_proto_depIdxs = nil
   197  }
   198  
   199  // Reference imports to suppress errors if they are not otherwise used.
   200  var _ context.Context
   201  var _ grpc.ClientConnInterface
   202  
   203  // This is a compile-time assertion to ensure that this generated file
   204  // is compatible with the grpc package it is being compiled against.
   205  const _ = grpc.SupportPackageIsVersion6
   206  
   207  // SecretDiscoveryServiceClient is the client API for SecretDiscoveryService service.
   208  //
   209  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   210  type SecretDiscoveryServiceClient interface {
   211  	DeltaSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_DeltaSecretsClient, error)
   212  	StreamSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_StreamSecretsClient, error)
   213  	FetchSecrets(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)
   214  }
   215  
   216  type secretDiscoveryServiceClient struct {
   217  	cc grpc.ClientConnInterface
   218  }
   219  
   220  func NewSecretDiscoveryServiceClient(cc grpc.ClientConnInterface) SecretDiscoveryServiceClient {
   221  	return &secretDiscoveryServiceClient{cc}
   222  }
   223  
   224  func (c *secretDiscoveryServiceClient) DeltaSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_DeltaSecretsClient, error) {
   225  	stream, err := c.cc.NewStream(ctx, &_SecretDiscoveryService_serviceDesc.Streams[0], "/envoy.service.discovery.v2.SecretDiscoveryService/DeltaSecrets", opts...)
   226  	if err != nil {
   227  		return nil, err
   228  	}
   229  	x := &secretDiscoveryServiceDeltaSecretsClient{stream}
   230  	return x, nil
   231  }
   232  
   233  type SecretDiscoveryService_DeltaSecretsClient interface {
   234  	Send(*v2.DeltaDiscoveryRequest) error
   235  	Recv() (*v2.DeltaDiscoveryResponse, error)
   236  	grpc.ClientStream
   237  }
   238  
   239  type secretDiscoveryServiceDeltaSecretsClient struct {
   240  	grpc.ClientStream
   241  }
   242  
   243  func (x *secretDiscoveryServiceDeltaSecretsClient) Send(m *v2.DeltaDiscoveryRequest) error {
   244  	return x.ClientStream.SendMsg(m)
   245  }
   246  
   247  func (x *secretDiscoveryServiceDeltaSecretsClient) Recv() (*v2.DeltaDiscoveryResponse, error) {
   248  	m := new(v2.DeltaDiscoveryResponse)
   249  	if err := x.ClientStream.RecvMsg(m); err != nil {
   250  		return nil, err
   251  	}
   252  	return m, nil
   253  }
   254  
   255  func (c *secretDiscoveryServiceClient) StreamSecrets(ctx context.Context, opts ...grpc.CallOption) (SecretDiscoveryService_StreamSecretsClient, error) {
   256  	stream, err := c.cc.NewStream(ctx, &_SecretDiscoveryService_serviceDesc.Streams[1], "/envoy.service.discovery.v2.SecretDiscoveryService/StreamSecrets", opts...)
   257  	if err != nil {
   258  		return nil, err
   259  	}
   260  	x := &secretDiscoveryServiceStreamSecretsClient{stream}
   261  	return x, nil
   262  }
   263  
   264  type SecretDiscoveryService_StreamSecretsClient interface {
   265  	Send(*v2.DiscoveryRequest) error
   266  	Recv() (*v2.DiscoveryResponse, error)
   267  	grpc.ClientStream
   268  }
   269  
   270  type secretDiscoveryServiceStreamSecretsClient struct {
   271  	grpc.ClientStream
   272  }
   273  
   274  func (x *secretDiscoveryServiceStreamSecretsClient) Send(m *v2.DiscoveryRequest) error {
   275  	return x.ClientStream.SendMsg(m)
   276  }
   277  
   278  func (x *secretDiscoveryServiceStreamSecretsClient) Recv() (*v2.DiscoveryResponse, error) {
   279  	m := new(v2.DiscoveryResponse)
   280  	if err := x.ClientStream.RecvMsg(m); err != nil {
   281  		return nil, err
   282  	}
   283  	return m, nil
   284  }
   285  
   286  func (c *secretDiscoveryServiceClient) FetchSecrets(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error) {
   287  	out := new(v2.DiscoveryResponse)
   288  	err := c.cc.Invoke(ctx, "/envoy.service.discovery.v2.SecretDiscoveryService/FetchSecrets", in, out, opts...)
   289  	if err != nil {
   290  		return nil, err
   291  	}
   292  	return out, nil
   293  }
   294  
   295  // SecretDiscoveryServiceServer is the server API for SecretDiscoveryService service.
   296  type SecretDiscoveryServiceServer interface {
   297  	DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error
   298  	StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error
   299  	FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
   300  }
   301  
   302  // UnimplementedSecretDiscoveryServiceServer can be embedded to have forward compatible implementations.
   303  type UnimplementedSecretDiscoveryServiceServer struct {
   304  }
   305  
   306  func (*UnimplementedSecretDiscoveryServiceServer) DeltaSecrets(SecretDiscoveryService_DeltaSecretsServer) error {
   307  	return status.Errorf(codes.Unimplemented, "method DeltaSecrets not implemented")
   308  }
   309  func (*UnimplementedSecretDiscoveryServiceServer) StreamSecrets(SecretDiscoveryService_StreamSecretsServer) error {
   310  	return status.Errorf(codes.Unimplemented, "method StreamSecrets not implemented")
   311  }
   312  func (*UnimplementedSecretDiscoveryServiceServer) FetchSecrets(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) {
   313  	return nil, status.Errorf(codes.Unimplemented, "method FetchSecrets not implemented")
   314  }
   315  
   316  func RegisterSecretDiscoveryServiceServer(s *grpc.Server, srv SecretDiscoveryServiceServer) {
   317  	s.RegisterService(&_SecretDiscoveryService_serviceDesc, srv)
   318  }
   319  
   320  func _SecretDiscoveryService_DeltaSecrets_Handler(srv interface{}, stream grpc.ServerStream) error {
   321  	return srv.(SecretDiscoveryServiceServer).DeltaSecrets(&secretDiscoveryServiceDeltaSecretsServer{stream})
   322  }
   323  
   324  type SecretDiscoveryService_DeltaSecretsServer interface {
   325  	Send(*v2.DeltaDiscoveryResponse) error
   326  	Recv() (*v2.DeltaDiscoveryRequest, error)
   327  	grpc.ServerStream
   328  }
   329  
   330  type secretDiscoveryServiceDeltaSecretsServer struct {
   331  	grpc.ServerStream
   332  }
   333  
   334  func (x *secretDiscoveryServiceDeltaSecretsServer) Send(m *v2.DeltaDiscoveryResponse) error {
   335  	return x.ServerStream.SendMsg(m)
   336  }
   337  
   338  func (x *secretDiscoveryServiceDeltaSecretsServer) Recv() (*v2.DeltaDiscoveryRequest, error) {
   339  	m := new(v2.DeltaDiscoveryRequest)
   340  	if err := x.ServerStream.RecvMsg(m); err != nil {
   341  		return nil, err
   342  	}
   343  	return m, nil
   344  }
   345  
   346  func _SecretDiscoveryService_StreamSecrets_Handler(srv interface{}, stream grpc.ServerStream) error {
   347  	return srv.(SecretDiscoveryServiceServer).StreamSecrets(&secretDiscoveryServiceStreamSecretsServer{stream})
   348  }
   349  
   350  type SecretDiscoveryService_StreamSecretsServer interface {
   351  	Send(*v2.DiscoveryResponse) error
   352  	Recv() (*v2.DiscoveryRequest, error)
   353  	grpc.ServerStream
   354  }
   355  
   356  type secretDiscoveryServiceStreamSecretsServer struct {
   357  	grpc.ServerStream
   358  }
   359  
   360  func (x *secretDiscoveryServiceStreamSecretsServer) Send(m *v2.DiscoveryResponse) error {
   361  	return x.ServerStream.SendMsg(m)
   362  }
   363  
   364  func (x *secretDiscoveryServiceStreamSecretsServer) Recv() (*v2.DiscoveryRequest, error) {
   365  	m := new(v2.DiscoveryRequest)
   366  	if err := x.ServerStream.RecvMsg(m); err != nil {
   367  		return nil, err
   368  	}
   369  	return m, nil
   370  }
   371  
   372  func _SecretDiscoveryService_FetchSecrets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   373  	in := new(v2.DiscoveryRequest)
   374  	if err := dec(in); err != nil {
   375  		return nil, err
   376  	}
   377  	if interceptor == nil {
   378  		return srv.(SecretDiscoveryServiceServer).FetchSecrets(ctx, in)
   379  	}
   380  	info := &grpc.UnaryServerInfo{
   381  		Server:     srv,
   382  		FullMethod: "/envoy.service.discovery.v2.SecretDiscoveryService/FetchSecrets",
   383  	}
   384  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   385  		return srv.(SecretDiscoveryServiceServer).FetchSecrets(ctx, req.(*v2.DiscoveryRequest))
   386  	}
   387  	return interceptor(ctx, in, info, handler)
   388  }
   389  
   390  var _SecretDiscoveryService_serviceDesc = grpc.ServiceDesc{
   391  	ServiceName: "envoy.service.discovery.v2.SecretDiscoveryService",
   392  	HandlerType: (*SecretDiscoveryServiceServer)(nil),
   393  	Methods: []grpc.MethodDesc{
   394  		{
   395  			MethodName: "FetchSecrets",
   396  			Handler:    _SecretDiscoveryService_FetchSecrets_Handler,
   397  		},
   398  	},
   399  	Streams: []grpc.StreamDesc{
   400  		{
   401  			StreamName:    "DeltaSecrets",
   402  			Handler:       _SecretDiscoveryService_DeltaSecrets_Handler,
   403  			ServerStreams: true,
   404  			ClientStreams: true,
   405  		},
   406  		{
   407  			StreamName:    "StreamSecrets",
   408  			Handler:       _SecretDiscoveryService_StreamSecrets_Handler,
   409  			ServerStreams: true,
   410  			ClientStreams: true,
   411  		},
   412  	},
   413  	Metadata: "envoy/service/discovery/v2/sds.proto",
   414  }
   415  

View as plain text