sds.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/secret/v3

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