trace_service.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/trace/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/trace/v3/trace_service.proto
     6  
     7  package envoy_service_trace_v3
     8  
     9  import (
    10  	context "context"
    11  	v1 "github.com/census-instrumentation/opencensus-proto/gen-go/trace/v1"
    12  	_ "github.com/cncf/udpa/go/udpa/annotations"
    13  	v3 "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v3"
    14  	_ "github.com/envoyproxy/protoc-gen-validate/validate"
    15  	proto "github.com/golang/protobuf/proto"
    16  	_ "google.golang.org/genproto/googleapis/api/annotations"
    17  	grpc "google.golang.org/grpc"
    18  	codes "google.golang.org/grpc/codes"
    19  	status "google.golang.org/grpc/status"
    20  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    21  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    22  	reflect "reflect"
    23  	sync "sync"
    24  )
    25  
    26  const (
    27  	// Verify that this generated code is sufficiently up-to-date.
    28  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    29  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    30  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    31  )
    32  
    33  // This is a compile-time assertion that a sufficiently up-to-date version
    34  // of the legacy proto package is being used.
    35  const _ = proto.ProtoPackageIsVersion4
    36  
    37  type StreamTracesResponse struct {
    38  	state         protoimpl.MessageState
    39  	sizeCache     protoimpl.SizeCache
    40  	unknownFields protoimpl.UnknownFields
    41  }
    42  
    43  func (x *StreamTracesResponse) Reset() {
    44  	*x = StreamTracesResponse{}
    45  	if protoimpl.UnsafeEnabled {
    46  		mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[0]
    47  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    48  		ms.StoreMessageInfo(mi)
    49  	}
    50  }
    51  
    52  func (x *StreamTracesResponse) String() string {
    53  	return protoimpl.X.MessageStringOf(x)
    54  }
    55  
    56  func (*StreamTracesResponse) ProtoMessage() {}
    57  
    58  func (x *StreamTracesResponse) ProtoReflect() protoreflect.Message {
    59  	mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[0]
    60  	if protoimpl.UnsafeEnabled && x != nil {
    61  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    62  		if ms.LoadMessageInfo() == nil {
    63  			ms.StoreMessageInfo(mi)
    64  		}
    65  		return ms
    66  	}
    67  	return mi.MessageOf(x)
    68  }
    69  
    70  // Deprecated: Use StreamTracesResponse.ProtoReflect.Descriptor instead.
    71  func (*StreamTracesResponse) Descriptor() ([]byte, []int) {
    72  	return file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP(), []int{0}
    73  }
    74  
    75  type StreamTracesMessage struct {
    76  	state         protoimpl.MessageState
    77  	sizeCache     protoimpl.SizeCache
    78  	unknownFields protoimpl.UnknownFields
    79  
    80  	// Identifier data effectively is a structured metadata.
    81  	// As a performance optimization this will only be sent in the first message
    82  	// on the stream.
    83  	Identifier *StreamTracesMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
    84  	// A list of Span entries
    85  	Spans []*v1.Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
    86  }
    87  
    88  func (x *StreamTracesMessage) Reset() {
    89  	*x = StreamTracesMessage{}
    90  	if protoimpl.UnsafeEnabled {
    91  		mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[1]
    92  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    93  		ms.StoreMessageInfo(mi)
    94  	}
    95  }
    96  
    97  func (x *StreamTracesMessage) String() string {
    98  	return protoimpl.X.MessageStringOf(x)
    99  }
   100  
   101  func (*StreamTracesMessage) ProtoMessage() {}
   102  
   103  func (x *StreamTracesMessage) ProtoReflect() protoreflect.Message {
   104  	mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[1]
   105  	if protoimpl.UnsafeEnabled && x != nil {
   106  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   107  		if ms.LoadMessageInfo() == nil {
   108  			ms.StoreMessageInfo(mi)
   109  		}
   110  		return ms
   111  	}
   112  	return mi.MessageOf(x)
   113  }
   114  
   115  // Deprecated: Use StreamTracesMessage.ProtoReflect.Descriptor instead.
   116  func (*StreamTracesMessage) Descriptor() ([]byte, []int) {
   117  	return file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP(), []int{1}
   118  }
   119  
   120  func (x *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier {
   121  	if x != nil {
   122  		return x.Identifier
   123  	}
   124  	return nil
   125  }
   126  
   127  func (x *StreamTracesMessage) GetSpans() []*v1.Span {
   128  	if x != nil {
   129  		return x.Spans
   130  	}
   131  	return nil
   132  }
   133  
   134  type StreamTracesMessage_Identifier struct {
   135  	state         protoimpl.MessageState
   136  	sizeCache     protoimpl.SizeCache
   137  	unknownFields protoimpl.UnknownFields
   138  
   139  	// The node sending the access log messages over the stream.
   140  	Node *v3.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
   141  }
   142  
   143  func (x *StreamTracesMessage_Identifier) Reset() {
   144  	*x = StreamTracesMessage_Identifier{}
   145  	if protoimpl.UnsafeEnabled {
   146  		mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[2]
   147  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   148  		ms.StoreMessageInfo(mi)
   149  	}
   150  }
   151  
   152  func (x *StreamTracesMessage_Identifier) String() string {
   153  	return protoimpl.X.MessageStringOf(x)
   154  }
   155  
   156  func (*StreamTracesMessage_Identifier) ProtoMessage() {}
   157  
   158  func (x *StreamTracesMessage_Identifier) ProtoReflect() protoreflect.Message {
   159  	mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[2]
   160  	if protoimpl.UnsafeEnabled && x != nil {
   161  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   162  		if ms.LoadMessageInfo() == nil {
   163  			ms.StoreMessageInfo(mi)
   164  		}
   165  		return ms
   166  	}
   167  	return mi.MessageOf(x)
   168  }
   169  
   170  // Deprecated: Use StreamTracesMessage_Identifier.ProtoReflect.Descriptor instead.
   171  func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int) {
   172  	return file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP(), []int{1, 0}
   173  }
   174  
   175  func (x *StreamTracesMessage_Identifier) GetNode() *v3.Node {
   176  	if x != nil {
   177  		return x.Node
   178  	}
   179  	return nil
   180  }
   181  
   182  var File_envoy_service_trace_v3_trace_service_proto protoreflect.FileDescriptor
   183  
   184  var file_envoy_service_trace_v3_trace_service_proto_rawDesc = []byte{
   185  	0x0a, 0x2a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   186  	0x74, 0x72, 0x61, 0x63, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x73,
   187  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x16, 0x65, 0x6e,
   188  	0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63,
   189  	0x65, 0x2e, 0x76, 0x33, 0x1a, 0x1f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66,
   190  	0x69, 0x67, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e,
   191  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70,
   192  	0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72,
   193  	0x6f, 0x74, 0x6f, 0x1a, 0x25, 0x6f, 0x70, 0x65, 0x6e, 0x63, 0x65, 0x6e, 0x73, 0x75, 0x73, 0x2f,
   194  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x74,
   195  	0x72, 0x61, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61,
   196  	0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61,
   197  	0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f,
   198  	0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73,
   199  	0x69, 0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76, 0x61,
   200  	0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2e,
   201  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x4a, 0x0a, 0x14, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54,
   202  	0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x3a, 0x32, 0x9a,
   203  	0xc5, 0x88, 0x1e, 0x2d, 0x0a, 0x2b, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
   204  	0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x74, 0x72,
   205  	0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
   206  	0x65, 0x22, 0xde, 0x02, 0x0a, 0x13, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63,
   207  	0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x56, 0x0a, 0x0a, 0x69, 0x64, 0x65,
   208  	0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e,
   209  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72,
   210  	0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61,
   211  	0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74,
   212  	0x69, 0x66, 0x69, 0x65, 0x72, 0x52, 0x0a, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65,
   213  	0x72, 0x12, 0x35, 0x0a, 0x05, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b,
   214  	0x32, 0x1f, 0x2e, 0x6f, 0x70, 0x65, 0x6e, 0x63, 0x65, 0x6e, 0x73, 0x75, 0x73, 0x2e, 0x70, 0x72,
   215  	0x6f, 0x74, 0x6f, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61,
   216  	0x6e, 0x52, 0x05, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x1a, 0x84, 0x01, 0x0a, 0x0a, 0x49, 0x64, 0x65,
   217  	0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18,
   218  	0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f,
   219  	0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x4e, 0x6f, 0x64,
   220  	0x65, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x8a, 0x01, 0x02, 0x10, 0x01, 0x52, 0x04, 0x6e, 0x6f, 0x64,
   221  	0x65, 0x3a, 0x3c, 0x9a, 0xc5, 0x88, 0x1e, 0x37, 0x0a, 0x35, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   222  	0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x32,
   223  	0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73,
   224  	0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x3a,
   225  	0x31, 0x9a, 0xc5, 0x88, 0x1e, 0x2c, 0x0a, 0x2a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
   226  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x53,
   227  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61,
   228  	0x67, 0x65, 0x32, 0x7d, 0x0a, 0x0c, 0x54, 0x72, 0x61, 0x63, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69,
   229  	0x63, 0x65, 0x12, 0x6d, 0x0a, 0x0c, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63,
   230  	0x65, 0x73, 0x12, 0x2b, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
   231  	0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65,
   232  	0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x1a,
   233  	0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
   234  	0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54,
   235  	0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28,
   236  	0x01, 0x42, 0x46, 0x0a, 0x24, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f,
   237  	0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   238  	0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x42, 0x11, 0x54, 0x72, 0x61, 0x63, 0x65,
   239  	0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01,
   240  	0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x02, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
   241  	0x33,
   242  }
   243  
   244  var (
   245  	file_envoy_service_trace_v3_trace_service_proto_rawDescOnce sync.Once
   246  	file_envoy_service_trace_v3_trace_service_proto_rawDescData = file_envoy_service_trace_v3_trace_service_proto_rawDesc
   247  )
   248  
   249  func file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP() []byte {
   250  	file_envoy_service_trace_v3_trace_service_proto_rawDescOnce.Do(func() {
   251  		file_envoy_service_trace_v3_trace_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_trace_v3_trace_service_proto_rawDescData)
   252  	})
   253  	return file_envoy_service_trace_v3_trace_service_proto_rawDescData
   254  }
   255  
   256  var file_envoy_service_trace_v3_trace_service_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
   257  var file_envoy_service_trace_v3_trace_service_proto_goTypes = []interface{}{
   258  	(*StreamTracesResponse)(nil),           // 0: envoy.service.trace.v3.StreamTracesResponse
   259  	(*StreamTracesMessage)(nil),            // 1: envoy.service.trace.v3.StreamTracesMessage
   260  	(*StreamTracesMessage_Identifier)(nil), // 2: envoy.service.trace.v3.StreamTracesMessage.Identifier
   261  	(*v1.Span)(nil),                        // 3: opencensus.proto.trace.v1.Span
   262  	(*v3.Node)(nil),                        // 4: envoy.config.core.v3.Node
   263  }
   264  var file_envoy_service_trace_v3_trace_service_proto_depIdxs = []int32{
   265  	2, // 0: envoy.service.trace.v3.StreamTracesMessage.identifier:type_name -> envoy.service.trace.v3.StreamTracesMessage.Identifier
   266  	3, // 1: envoy.service.trace.v3.StreamTracesMessage.spans:type_name -> opencensus.proto.trace.v1.Span
   267  	4, // 2: envoy.service.trace.v3.StreamTracesMessage.Identifier.node:type_name -> envoy.config.core.v3.Node
   268  	1, // 3: envoy.service.trace.v3.TraceService.StreamTraces:input_type -> envoy.service.trace.v3.StreamTracesMessage
   269  	0, // 4: envoy.service.trace.v3.TraceService.StreamTraces:output_type -> envoy.service.trace.v3.StreamTracesResponse
   270  	4, // [4:5] is the sub-list for method output_type
   271  	3, // [3:4] is the sub-list for method input_type
   272  	3, // [3:3] is the sub-list for extension type_name
   273  	3, // [3:3] is the sub-list for extension extendee
   274  	0, // [0:3] is the sub-list for field type_name
   275  }
   276  
   277  func init() { file_envoy_service_trace_v3_trace_service_proto_init() }
   278  func file_envoy_service_trace_v3_trace_service_proto_init() {
   279  	if File_envoy_service_trace_v3_trace_service_proto != nil {
   280  		return
   281  	}
   282  	if !protoimpl.UnsafeEnabled {
   283  		file_envoy_service_trace_v3_trace_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   284  			switch v := v.(*StreamTracesResponse); i {
   285  			case 0:
   286  				return &v.state
   287  			case 1:
   288  				return &v.sizeCache
   289  			case 2:
   290  				return &v.unknownFields
   291  			default:
   292  				return nil
   293  			}
   294  		}
   295  		file_envoy_service_trace_v3_trace_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   296  			switch v := v.(*StreamTracesMessage); i {
   297  			case 0:
   298  				return &v.state
   299  			case 1:
   300  				return &v.sizeCache
   301  			case 2:
   302  				return &v.unknownFields
   303  			default:
   304  				return nil
   305  			}
   306  		}
   307  		file_envoy_service_trace_v3_trace_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   308  			switch v := v.(*StreamTracesMessage_Identifier); i {
   309  			case 0:
   310  				return &v.state
   311  			case 1:
   312  				return &v.sizeCache
   313  			case 2:
   314  				return &v.unknownFields
   315  			default:
   316  				return nil
   317  			}
   318  		}
   319  	}
   320  	type x struct{}
   321  	out := protoimpl.TypeBuilder{
   322  		File: protoimpl.DescBuilder{
   323  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   324  			RawDescriptor: file_envoy_service_trace_v3_trace_service_proto_rawDesc,
   325  			NumEnums:      0,
   326  			NumMessages:   3,
   327  			NumExtensions: 0,
   328  			NumServices:   1,
   329  		},
   330  		GoTypes:           file_envoy_service_trace_v3_trace_service_proto_goTypes,
   331  		DependencyIndexes: file_envoy_service_trace_v3_trace_service_proto_depIdxs,
   332  		MessageInfos:      file_envoy_service_trace_v3_trace_service_proto_msgTypes,
   333  	}.Build()
   334  	File_envoy_service_trace_v3_trace_service_proto = out.File
   335  	file_envoy_service_trace_v3_trace_service_proto_rawDesc = nil
   336  	file_envoy_service_trace_v3_trace_service_proto_goTypes = nil
   337  	file_envoy_service_trace_v3_trace_service_proto_depIdxs = nil
   338  }
   339  
   340  // Reference imports to suppress errors if they are not otherwise used.
   341  var _ context.Context
   342  var _ grpc.ClientConnInterface
   343  
   344  // This is a compile-time assertion to ensure that this generated file
   345  // is compatible with the grpc package it is being compiled against.
   346  const _ = grpc.SupportPackageIsVersion6
   347  
   348  // TraceServiceClient is the client API for TraceService service.
   349  //
   350  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   351  type TraceServiceClient interface {
   352  	// Envoy will connect and send StreamTracesMessage messages forever. It does
   353  	// not expect any response to be sent as nothing would be done in the case
   354  	// of failure.
   355  	StreamTraces(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error)
   356  }
   357  
   358  type traceServiceClient struct {
   359  	cc grpc.ClientConnInterface
   360  }
   361  
   362  func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient {
   363  	return &traceServiceClient{cc}
   364  }
   365  
   366  func (c *traceServiceClient) StreamTraces(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error) {
   367  	stream, err := c.cc.NewStream(ctx, &_TraceService_serviceDesc.Streams[0], "/envoy.service.trace.v3.TraceService/StreamTraces", opts...)
   368  	if err != nil {
   369  		return nil, err
   370  	}
   371  	x := &traceServiceStreamTracesClient{stream}
   372  	return x, nil
   373  }
   374  
   375  type TraceService_StreamTracesClient interface {
   376  	Send(*StreamTracesMessage) error
   377  	CloseAndRecv() (*StreamTracesResponse, error)
   378  	grpc.ClientStream
   379  }
   380  
   381  type traceServiceStreamTracesClient struct {
   382  	grpc.ClientStream
   383  }
   384  
   385  func (x *traceServiceStreamTracesClient) Send(m *StreamTracesMessage) error {
   386  	return x.ClientStream.SendMsg(m)
   387  }
   388  
   389  func (x *traceServiceStreamTracesClient) CloseAndRecv() (*StreamTracesResponse, error) {
   390  	if err := x.ClientStream.CloseSend(); err != nil {
   391  		return nil, err
   392  	}
   393  	m := new(StreamTracesResponse)
   394  	if err := x.ClientStream.RecvMsg(m); err != nil {
   395  		return nil, err
   396  	}
   397  	return m, nil
   398  }
   399  
   400  // TraceServiceServer is the server API for TraceService service.
   401  type TraceServiceServer interface {
   402  	// Envoy will connect and send StreamTracesMessage messages forever. It does
   403  	// not expect any response to be sent as nothing would be done in the case
   404  	// of failure.
   405  	StreamTraces(TraceService_StreamTracesServer) error
   406  }
   407  
   408  // UnimplementedTraceServiceServer can be embedded to have forward compatible implementations.
   409  type UnimplementedTraceServiceServer struct {
   410  }
   411  
   412  func (*UnimplementedTraceServiceServer) StreamTraces(TraceService_StreamTracesServer) error {
   413  	return status.Errorf(codes.Unimplemented, "method StreamTraces not implemented")
   414  }
   415  
   416  func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
   417  	s.RegisterService(&_TraceService_serviceDesc, srv)
   418  }
   419  
   420  func _TraceService_StreamTraces_Handler(srv interface{}, stream grpc.ServerStream) error {
   421  	return srv.(TraceServiceServer).StreamTraces(&traceServiceStreamTracesServer{stream})
   422  }
   423  
   424  type TraceService_StreamTracesServer interface {
   425  	SendAndClose(*StreamTracesResponse) error
   426  	Recv() (*StreamTracesMessage, error)
   427  	grpc.ServerStream
   428  }
   429  
   430  type traceServiceStreamTracesServer struct {
   431  	grpc.ServerStream
   432  }
   433  
   434  func (x *traceServiceStreamTracesServer) SendAndClose(m *StreamTracesResponse) error {
   435  	return x.ServerStream.SendMsg(m)
   436  }
   437  
   438  func (x *traceServiceStreamTracesServer) Recv() (*StreamTracesMessage, error) {
   439  	m := new(StreamTracesMessage)
   440  	if err := x.ServerStream.RecvMsg(m); err != nil {
   441  		return nil, err
   442  	}
   443  	return m, nil
   444  }
   445  
   446  var _TraceService_serviceDesc = grpc.ServiceDesc{
   447  	ServiceName: "envoy.service.trace.v3.TraceService",
   448  	HandlerType: (*TraceServiceServer)(nil),
   449  	Methods:     []grpc.MethodDesc{},
   450  	Streams: []grpc.StreamDesc{
   451  		{
   452  			StreamName:    "StreamTraces",
   453  			Handler:       _TraceService_StreamTraces_Handler,
   454  			ClientStreams: true,
   455  		},
   456  	},
   457  	Metadata: "envoy/service/trace/v3/trace_service.proto",
   458  }
   459
View as plain text