Source file src/github.com/datawire/ambassador/v2/pkg/api/envoy/service/tap/v4alpha/tap.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/tap/v4alpha

     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/tap/v4alpha/tap.proto
     6  
     7  package envoy_service_tap_v4alpha
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/udpa/go/udpa/annotations"
    12  	v4alpha "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v4alpha"
    13  	v3 "github.com/datawire/ambassador/v2/pkg/api/envoy/data/tap/v3"
    14  	_ "github.com/envoyproxy/protoc-gen-validate/validate"
    15  	proto "github.com/golang/protobuf/proto"
    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:] Stream message for the Tap API. Envoy will open a stream to the server
    37  // and stream taps without ever expecting a response.
    38  type StreamTapsRequest struct {
    39  	state         protoimpl.MessageState
    40  	sizeCache     protoimpl.SizeCache
    41  	unknownFields protoimpl.UnknownFields
    42  
    43  	// Identifier data effectively is a structured metadata. As a performance optimization this will
    44  	// only be sent in the first message on the stream.
    45  	Identifier *StreamTapsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
    46  	// The trace id. this can be used to merge together a streaming trace. Note that the trace_id
    47  	// is not guaranteed to be spatially or temporally unique.
    48  	TraceId uint64 `protobuf:"varint,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
    49  	// The trace data.
    50  	Trace *v3.TraceWrapper `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"`
    51  }
    52  
    53  func (x *StreamTapsRequest) Reset() {
    54  	*x = StreamTapsRequest{}
    55  	if protoimpl.UnsafeEnabled {
    56  		mi := &file_envoy_service_tap_v4alpha_tap_proto_msgTypes[0]
    57  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    58  		ms.StoreMessageInfo(mi)
    59  	}
    60  }
    61  
    62  func (x *StreamTapsRequest) String() string {
    63  	return protoimpl.X.MessageStringOf(x)
    64  }
    65  
    66  func (*StreamTapsRequest) ProtoMessage() {}
    67  
    68  func (x *StreamTapsRequest) ProtoReflect() protoreflect.Message {
    69  	mi := &file_envoy_service_tap_v4alpha_tap_proto_msgTypes[0]
    70  	if protoimpl.UnsafeEnabled && x != nil {
    71  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    72  		if ms.LoadMessageInfo() == nil {
    73  			ms.StoreMessageInfo(mi)
    74  		}
    75  		return ms
    76  	}
    77  	return mi.MessageOf(x)
    78  }
    79  
    80  // Deprecated: Use StreamTapsRequest.ProtoReflect.Descriptor instead.
    81  func (*StreamTapsRequest) Descriptor() ([]byte, []int) {
    82  	return file_envoy_service_tap_v4alpha_tap_proto_rawDescGZIP(), []int{0}
    83  }
    84  
    85  func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier {
    86  	if x != nil {
    87  		return x.Identifier
    88  	}
    89  	return nil
    90  }
    91  
    92  func (x *StreamTapsRequest) GetTraceId() uint64 {
    93  	if x != nil {
    94  		return x.TraceId
    95  	}
    96  	return 0
    97  }
    98  
    99  func (x *StreamTapsRequest) GetTrace() *v3.TraceWrapper {
   100  	if x != nil {
   101  		return x.Trace
   102  	}
   103  	return nil
   104  }
   105  
   106  // [#not-implemented-hide:]
   107  type StreamTapsResponse struct {
   108  	state         protoimpl.MessageState
   109  	sizeCache     protoimpl.SizeCache
   110  	unknownFields protoimpl.UnknownFields
   111  }
   112  
   113  func (x *StreamTapsResponse) Reset() {
   114  	*x = StreamTapsResponse{}
   115  	if protoimpl.UnsafeEnabled {
   116  		mi := &file_envoy_service_tap_v4alpha_tap_proto_msgTypes[1]
   117  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   118  		ms.StoreMessageInfo(mi)
   119  	}
   120  }
   121  
   122  func (x *StreamTapsResponse) String() string {
   123  	return protoimpl.X.MessageStringOf(x)
   124  }
   125  
   126  func (*StreamTapsResponse) ProtoMessage() {}
   127  
   128  func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message {
   129  	mi := &file_envoy_service_tap_v4alpha_tap_proto_msgTypes[1]
   130  	if protoimpl.UnsafeEnabled && x != nil {
   131  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   132  		if ms.LoadMessageInfo() == nil {
   133  			ms.StoreMessageInfo(mi)
   134  		}
   135  		return ms
   136  	}
   137  	return mi.MessageOf(x)
   138  }
   139  
   140  // Deprecated: Use StreamTapsResponse.ProtoReflect.Descriptor instead.
   141  func (*StreamTapsResponse) Descriptor() ([]byte, []int) {
   142  	return file_envoy_service_tap_v4alpha_tap_proto_rawDescGZIP(), []int{1}
   143  }
   144  
   145  type StreamTapsRequest_Identifier struct {
   146  	state         protoimpl.MessageState
   147  	sizeCache     protoimpl.SizeCache
   148  	unknownFields protoimpl.UnknownFields
   149  
   150  	// The node sending taps over the stream.
   151  	Node *v4alpha.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
   152  	// The opaque identifier that was set in the :ref:`output config
   153  	// <envoy_api_field_config.tap.v4alpha.StreamingGrpcSink.tap_id>`.
   154  	TapId string `protobuf:"bytes,2,opt,name=tap_id,json=tapId,proto3" json:"tap_id,omitempty"`
   155  }
   156  
   157  func (x *StreamTapsRequest_Identifier) Reset() {
   158  	*x = StreamTapsRequest_Identifier{}
   159  	if protoimpl.UnsafeEnabled {
   160  		mi := &file_envoy_service_tap_v4alpha_tap_proto_msgTypes[2]
   161  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   162  		ms.StoreMessageInfo(mi)
   163  	}
   164  }
   165  
   166  func (x *StreamTapsRequest_Identifier) String() string {
   167  	return protoimpl.X.MessageStringOf(x)
   168  }
   169  
   170  func (*StreamTapsRequest_Identifier) ProtoMessage() {}
   171  
   172  func (x *StreamTapsRequest_Identifier) ProtoReflect() protoreflect.Message {
   173  	mi := &file_envoy_service_tap_v4alpha_tap_proto_msgTypes[2]
   174  	if protoimpl.UnsafeEnabled && x != nil {
   175  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   176  		if ms.LoadMessageInfo() == nil {
   177  			ms.StoreMessageInfo(mi)
   178  		}
   179  		return ms
   180  	}
   181  	return mi.MessageOf(x)
   182  }
   183  
   184  // Deprecated: Use StreamTapsRequest_Identifier.ProtoReflect.Descriptor instead.
   185  func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int) {
   186  	return file_envoy_service_tap_v4alpha_tap_proto_rawDescGZIP(), []int{0, 0}
   187  }
   188  
   189  func (x *StreamTapsRequest_Identifier) GetNode() *v4alpha.Node {
   190  	if x != nil {
   191  		return x.Node
   192  	}
   193  	return nil
   194  }
   195  
   196  func (x *StreamTapsRequest_Identifier) GetTapId() string {
   197  	if x != nil {
   198  		return x.TapId
   199  	}
   200  	return ""
   201  }
   202  
   203  var File_envoy_service_tap_v4alpha_tap_proto protoreflect.FileDescriptor
   204  
   205  var file_envoy_service_tap_v4alpha_tap_proto_rawDesc = []byte{
   206  	0x0a, 0x23, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   207  	0x74, 0x61, 0x70, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x74, 0x61, 0x70, 0x2e,
   208  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x19, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
   209  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61,
   210  	0x1a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2f, 0x63,
   211  	0x6f, 0x72, 0x65, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x62, 0x61, 0x73, 0x65,
   212  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x64, 0x61,
   213  	0x74, 0x61, 0x2f, 0x74, 0x61, 0x70, 0x2f, 0x76, 0x33, 0x2f, 0x77, 0x72, 0x61, 0x70, 0x70, 0x65,
   214  	0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e,
   215  	0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
   216  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e,
   217  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
   218  	0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76, 0x61, 0x6c, 0x69, 0x64,
   219  	0x61, 0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f,
   220  	0x74, 0x6f, 0x22, 0x8c, 0x03, 0x0a, 0x11, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x61, 0x70,
   221  	0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x57, 0x0a, 0x0a, 0x69, 0x64, 0x65, 0x6e,
   222  	0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x65,
   223  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x61, 0x70,
   224  	0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54,
   225  	0x61, 0x70, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74,
   226  	0x69, 0x66, 0x69, 0x65, 0x72, 0x52, 0x0a, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65,
   227  	0x72, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20,
   228  	0x01, 0x28, 0x04, 0x52, 0x07, 0x74, 0x72, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x35, 0x0a, 0x05,
   229  	0x74, 0x72, 0x61, 0x63, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x65, 0x6e,
   230  	0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x33, 0x2e,
   231  	0x54, 0x72, 0x61, 0x63, 0x65, 0x57, 0x72, 0x61, 0x70, 0x70, 0x65, 0x72, 0x52, 0x05, 0x74, 0x72,
   232  	0x61, 0x63, 0x65, 0x1a, 0x9c, 0x01, 0x0a, 0x0a, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69,
   233  	0x65, 0x72, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
   234  	0x32, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e,
   235  	0x63, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4e, 0x6f, 0x64,
   236  	0x65, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x8a, 0x01, 0x02, 0x10, 0x01, 0x52, 0x04, 0x6e, 0x6f, 0x64,
   237  	0x65, 0x12, 0x15, 0x0a, 0x06, 0x74, 0x61, 0x70, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
   238  	0x09, 0x52, 0x05, 0x74, 0x61, 0x70, 0x49, 0x64, 0x3a, 0x38, 0x9a, 0xc5, 0x88, 0x1e, 0x33, 0x0a,
   239  	0x31, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74,
   240  	0x61, 0x70, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x61, 0x70, 0x73,
   241  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69,
   242  	0x65, 0x72, 0x3a, 0x2d, 0x9a, 0xc5, 0x88, 0x1e, 0x28, 0x0a, 0x26, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   243  	0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x33, 0x2e,
   244  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x61, 0x70, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
   245  	0x74, 0x22, 0x44, 0x0a, 0x12, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x61, 0x70, 0x73, 0x52,
   246  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x3a, 0x2e, 0x9a, 0xc5, 0x88, 0x1e, 0x29, 0x0a, 0x27,
   247  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x61,
   248  	0x70, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x61, 0x70, 0x73, 0x52,
   249  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0x7f, 0x0a, 0x0e, 0x54, 0x61, 0x70, 0x53, 0x69,
   250  	0x6e, 0x6b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x6d, 0x0a, 0x0a, 0x53, 0x74, 0x72,
   251  	0x65, 0x61, 0x6d, 0x54, 0x61, 0x70, 0x73, 0x12, 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   252  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x34, 0x61, 0x6c,
   253  	0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x61, 0x70, 0x73, 0x52, 0x65,
   254  	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
   255  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68,
   256  	0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x61, 0x70, 0x73, 0x52, 0x65, 0x73, 0x70,
   257  	0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x42, 0x40, 0x0a, 0x27, 0x69, 0x6f, 0x2e, 0x65,
   258  	0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   259  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x34, 0x61, 0x6c,
   260  	0x70, 0x68, 0x61, 0x42, 0x08, 0x54, 0x61, 0x70, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88,
   261  	0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x03, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
   262  	0x6f, 0x33,
   263  }
   264  
   265  var (
   266  	file_envoy_service_tap_v4alpha_tap_proto_rawDescOnce sync.Once
   267  	file_envoy_service_tap_v4alpha_tap_proto_rawDescData = file_envoy_service_tap_v4alpha_tap_proto_rawDesc
   268  )
   269  
   270  func file_envoy_service_tap_v4alpha_tap_proto_rawDescGZIP() []byte {
   271  	file_envoy_service_tap_v4alpha_tap_proto_rawDescOnce.Do(func() {
   272  		file_envoy_service_tap_v4alpha_tap_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_tap_v4alpha_tap_proto_rawDescData)
   273  	})
   274  	return file_envoy_service_tap_v4alpha_tap_proto_rawDescData
   275  }
   276  
   277  var file_envoy_service_tap_v4alpha_tap_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
   278  var file_envoy_service_tap_v4alpha_tap_proto_goTypes = []interface{}{
   279  	(*StreamTapsRequest)(nil),            // 0: envoy.service.tap.v4alpha.StreamTapsRequest
   280  	(*StreamTapsResponse)(nil),           // 1: envoy.service.tap.v4alpha.StreamTapsResponse
   281  	(*StreamTapsRequest_Identifier)(nil), // 2: envoy.service.tap.v4alpha.StreamTapsRequest.Identifier
   282  	(*v3.TraceWrapper)(nil),              // 3: envoy.data.tap.v3.TraceWrapper
   283  	(*v4alpha.Node)(nil),                 // 4: envoy.config.core.v4alpha.Node
   284  }
   285  var file_envoy_service_tap_v4alpha_tap_proto_depIdxs = []int32{
   286  	2, // 0: envoy.service.tap.v4alpha.StreamTapsRequest.identifier:type_name -> envoy.service.tap.v4alpha.StreamTapsRequest.Identifier
   287  	3, // 1: envoy.service.tap.v4alpha.StreamTapsRequest.trace:type_name -> envoy.data.tap.v3.TraceWrapper
   288  	4, // 2: envoy.service.tap.v4alpha.StreamTapsRequest.Identifier.node:type_name -> envoy.config.core.v4alpha.Node
   289  	0, // 3: envoy.service.tap.v4alpha.TapSinkService.StreamTaps:input_type -> envoy.service.tap.v4alpha.StreamTapsRequest
   290  	1, // 4: envoy.service.tap.v4alpha.TapSinkService.StreamTaps:output_type -> envoy.service.tap.v4alpha.StreamTapsResponse
   291  	4, // [4:5] is the sub-list for method output_type
   292  	3, // [3:4] is the sub-list for method input_type
   293  	3, // [3:3] is the sub-list for extension type_name
   294  	3, // [3:3] is the sub-list for extension extendee
   295  	0, // [0:3] is the sub-list for field type_name
   296  }
   297  
   298  func init() { file_envoy_service_tap_v4alpha_tap_proto_init() }
   299  func file_envoy_service_tap_v4alpha_tap_proto_init() {
   300  	if File_envoy_service_tap_v4alpha_tap_proto != nil {
   301  		return
   302  	}
   303  	if !protoimpl.UnsafeEnabled {
   304  		file_envoy_service_tap_v4alpha_tap_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   305  			switch v := v.(*StreamTapsRequest); i {
   306  			case 0:
   307  				return &v.state
   308  			case 1:
   309  				return &v.sizeCache
   310  			case 2:
   311  				return &v.unknownFields
   312  			default:
   313  				return nil
   314  			}
   315  		}
   316  		file_envoy_service_tap_v4alpha_tap_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   317  			switch v := v.(*StreamTapsResponse); i {
   318  			case 0:
   319  				return &v.state
   320  			case 1:
   321  				return &v.sizeCache
   322  			case 2:
   323  				return &v.unknownFields
   324  			default:
   325  				return nil
   326  			}
   327  		}
   328  		file_envoy_service_tap_v4alpha_tap_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   329  			switch v := v.(*StreamTapsRequest_Identifier); i {
   330  			case 0:
   331  				return &v.state
   332  			case 1:
   333  				return &v.sizeCache
   334  			case 2:
   335  				return &v.unknownFields
   336  			default:
   337  				return nil
   338  			}
   339  		}
   340  	}
   341  	type x struct{}
   342  	out := protoimpl.TypeBuilder{
   343  		File: protoimpl.DescBuilder{
   344  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   345  			RawDescriptor: file_envoy_service_tap_v4alpha_tap_proto_rawDesc,
   346  			NumEnums:      0,
   347  			NumMessages:   3,
   348  			NumExtensions: 0,
   349  			NumServices:   1,
   350  		},
   351  		GoTypes:           file_envoy_service_tap_v4alpha_tap_proto_goTypes,
   352  		DependencyIndexes: file_envoy_service_tap_v4alpha_tap_proto_depIdxs,
   353  		MessageInfos:      file_envoy_service_tap_v4alpha_tap_proto_msgTypes,
   354  	}.Build()
   355  	File_envoy_service_tap_v4alpha_tap_proto = out.File
   356  	file_envoy_service_tap_v4alpha_tap_proto_rawDesc = nil
   357  	file_envoy_service_tap_v4alpha_tap_proto_goTypes = nil
   358  	file_envoy_service_tap_v4alpha_tap_proto_depIdxs = nil
   359  }
   360  
   361  // Reference imports to suppress errors if they are not otherwise used.
   362  var _ context.Context
   363  var _ grpc.ClientConnInterface
   364  
   365  // This is a compile-time assertion to ensure that this generated file
   366  // is compatible with the grpc package it is being compiled against.
   367  const _ = grpc.SupportPackageIsVersion6
   368  
   369  // TapSinkServiceClient is the client API for TapSinkService service.
   370  //
   371  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   372  type TapSinkServiceClient interface {
   373  	// Envoy will connect and send StreamTapsRequest messages forever. It does not expect any
   374  	// response to be sent as nothing would be done in the case of failure. The server should
   375  	// disconnect if it expects Envoy to reconnect.
   376  	StreamTaps(ctx context.Context, opts ...grpc.CallOption) (TapSinkService_StreamTapsClient, error)
   377  }
   378  
   379  type tapSinkServiceClient struct {
   380  	cc grpc.ClientConnInterface
   381  }
   382  
   383  func NewTapSinkServiceClient(cc grpc.ClientConnInterface) TapSinkServiceClient {
   384  	return &tapSinkServiceClient{cc}
   385  }
   386  
   387  func (c *tapSinkServiceClient) StreamTaps(ctx context.Context, opts ...grpc.CallOption) (TapSinkService_StreamTapsClient, error) {
   388  	stream, err := c.cc.NewStream(ctx, &_TapSinkService_serviceDesc.Streams[0], "/envoy.service.tap.v4alpha.TapSinkService/StreamTaps", opts...)
   389  	if err != nil {
   390  		return nil, err
   391  	}
   392  	x := &tapSinkServiceStreamTapsClient{stream}
   393  	return x, nil
   394  }
   395  
   396  type TapSinkService_StreamTapsClient interface {
   397  	Send(*StreamTapsRequest) error
   398  	CloseAndRecv() (*StreamTapsResponse, error)
   399  	grpc.ClientStream
   400  }
   401  
   402  type tapSinkServiceStreamTapsClient struct {
   403  	grpc.ClientStream
   404  }
   405  
   406  func (x *tapSinkServiceStreamTapsClient) Send(m *StreamTapsRequest) error {
   407  	return x.ClientStream.SendMsg(m)
   408  }
   409  
   410  func (x *tapSinkServiceStreamTapsClient) CloseAndRecv() (*StreamTapsResponse, error) {
   411  	if err := x.ClientStream.CloseSend(); err != nil {
   412  		return nil, err
   413  	}
   414  	m := new(StreamTapsResponse)
   415  	if err := x.ClientStream.RecvMsg(m); err != nil {
   416  		return nil, err
   417  	}
   418  	return m, nil
   419  }
   420  
   421  // TapSinkServiceServer is the server API for TapSinkService service.
   422  type TapSinkServiceServer interface {
   423  	// Envoy will connect and send StreamTapsRequest messages forever. It does not expect any
   424  	// response to be sent as nothing would be done in the case of failure. The server should
   425  	// disconnect if it expects Envoy to reconnect.
   426  	StreamTaps(TapSinkService_StreamTapsServer) error
   427  }
   428  
   429  // UnimplementedTapSinkServiceServer can be embedded to have forward compatible implementations.
   430  type UnimplementedTapSinkServiceServer struct {
   431  }
   432  
   433  func (*UnimplementedTapSinkServiceServer) StreamTaps(TapSinkService_StreamTapsServer) error {
   434  	return status.Errorf(codes.Unimplemented, "method StreamTaps not implemented")
   435  }
   436  
   437  func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer) {
   438  	s.RegisterService(&_TapSinkService_serviceDesc, srv)
   439  }
   440  
   441  func _TapSinkService_StreamTaps_Handler(srv interface{}, stream grpc.ServerStream) error {
   442  	return srv.(TapSinkServiceServer).StreamTaps(&tapSinkServiceStreamTapsServer{stream})
   443  }
   444  
   445  type TapSinkService_StreamTapsServer interface {
   446  	SendAndClose(*StreamTapsResponse) error
   447  	Recv() (*StreamTapsRequest, error)
   448  	grpc.ServerStream
   449  }
   450  
   451  type tapSinkServiceStreamTapsServer struct {
   452  	grpc.ServerStream
   453  }
   454  
   455  func (x *tapSinkServiceStreamTapsServer) SendAndClose(m *StreamTapsResponse) error {
   456  	return x.ServerStream.SendMsg(m)
   457  }
   458  
   459  func (x *tapSinkServiceStreamTapsServer) Recv() (*StreamTapsRequest, error) {
   460  	m := new(StreamTapsRequest)
   461  	if err := x.ServerStream.RecvMsg(m); err != nil {
   462  		return nil, err
   463  	}
   464  	return m, nil
   465  }
   466  
   467  var _TapSinkService_serviceDesc = grpc.ServiceDesc{
   468  	ServiceName: "envoy.service.tap.v4alpha.TapSinkService",
   469  	HandlerType: (*TapSinkServiceServer)(nil),
   470  	Methods:     []grpc.MethodDesc{},
   471  	Streams: []grpc.StreamDesc{
   472  		{
   473  			StreamName:    "StreamTaps",
   474  			Handler:       _TapSinkService_StreamTaps_Handler,
   475  			ClientStreams: true,
   476  		},
   477  	},
   478  	Metadata: "envoy/service/tap/v4alpha/tap.proto",
   479  }
   480  

View as plain text