trace_service.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/trace/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/trace/v4alpha/trace_service.proto
     6  
     7  package envoy_service_trace_v4alpha
     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  	v4alpha "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v4alpha"
    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_v4alpha_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_v4alpha_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_v4alpha_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_v4alpha_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_v4alpha_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_v4alpha_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 *v4alpha.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_v4alpha_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_v4alpha_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_v4alpha_trace_service_proto_rawDescGZIP(), []int{1, 0}
   173  }
   174  
   175  func (x *StreamTracesMessage_Identifier) GetNode() *v4alpha.Node {
   176  	if x != nil {
   177  		return x.Node
   178  	}
   179  	return nil
   180  }
   181  
   182  var File_envoy_service_trace_v4alpha_trace_service_proto protoreflect.FileDescriptor
   183  
   184  var file_envoy_service_trace_v4alpha_trace_service_proto_rawDesc = []byte{
   185  	0x0a, 0x2f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   186  	0x74, 0x72, 0x61, 0x63, 0x65, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x74, 0x72,
   187  	0x61, 0x63, 0x65, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
   188  	0x6f, 0x12, 0x1b, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   189  	0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x1a, 0x24,
   190  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2f, 0x63, 0x6f, 0x72,
   191  	0x65, 0x2f, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e, 0x70,
   192  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69,
   193  	0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f,
   194  	0x74, 0x6f, 0x1a, 0x25, 0x6f, 0x70, 0x65, 0x6e, 0x63, 0x65, 0x6e, 0x73, 0x75, 0x73, 0x2f, 0x70,
   195  	0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x74, 0x72,
   196  	0x61, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f,
   197  	0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74,
   198  	0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61,
   199  	0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73, 0x69,
   200  	0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76, 0x61, 0x6c,
   201  	0x69, 0x64, 0x61, 0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2e, 0x70,
   202  	0x72, 0x6f, 0x74, 0x6f, 0x22, 0x4a, 0x0a, 0x14, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72,
   203  	0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x3a, 0x32, 0x9a, 0xc5,
   204  	0x88, 0x1e, 0x2d, 0x0a, 0x2b, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
   205  	0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65,
   206  	0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
   207  	0x22, 0xe8, 0x02, 0x0a, 0x13, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65,
   208  	0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x5b, 0x0a, 0x0a, 0x69, 0x64, 0x65, 0x6e,
   209  	0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x65,
   210  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61,
   211  	0x63, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61,
   212  	0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x49,
   213  	0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x52, 0x0a, 0x69, 0x64, 0x65, 0x6e, 0x74,
   214  	0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x35, 0x0a, 0x05, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x18, 0x02,
   215  	0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x6f, 0x70, 0x65, 0x6e, 0x63, 0x65, 0x6e, 0x73, 0x75,
   216  	0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x31,
   217  	0x2e, 0x53, 0x70, 0x61, 0x6e, 0x52, 0x05, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x1a, 0x89, 0x01, 0x0a,
   218  	0x0a, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x3d, 0x0a, 0x04, 0x6e,
   219  	0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f,
   220  	0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x34,
   221  	0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x8a,
   222  	0x01, 0x02, 0x10, 0x01, 0x52, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x3a, 0x3c, 0x9a, 0xc5, 0x88, 0x1e,
   223  	0x37, 0x0a, 0x35, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   224  	0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
   225  	0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64,
   226  	0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x3a, 0x31, 0x9a, 0xc5, 0x88, 0x1e, 0x2c, 0x0a,
   227  	0x2a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74,
   228  	0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72,
   229  	0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x32, 0x87, 0x01, 0x0a, 0x0c,
   230  	0x54, 0x72, 0x61, 0x63, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x77, 0x0a, 0x0c,
   231  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x12, 0x30, 0x2e, 0x65,
   232  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61,
   233  	0x63, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61,
   234  	0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x1a, 0x31,
   235  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74,
   236  	0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x72,
   237  	0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
   238  	0x65, 0x22, 0x00, 0x28, 0x01, 0x42, 0x4b, 0x0a, 0x29, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f,
   239  	0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
   240  	0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70,
   241  	0x68, 0x61, 0x42, 0x11, 0x54, 0x72, 0x61, 0x63, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   242  	0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02,
   243  	0x10, 0x03, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   244  }
   245  
   246  var (
   247  	file_envoy_service_trace_v4alpha_trace_service_proto_rawDescOnce sync.Once
   248  	file_envoy_service_trace_v4alpha_trace_service_proto_rawDescData = file_envoy_service_trace_v4alpha_trace_service_proto_rawDesc
   249  )
   250  
   251  func file_envoy_service_trace_v4alpha_trace_service_proto_rawDescGZIP() []byte {
   252  	file_envoy_service_trace_v4alpha_trace_service_proto_rawDescOnce.Do(func() {
   253  		file_envoy_service_trace_v4alpha_trace_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_trace_v4alpha_trace_service_proto_rawDescData)
   254  	})
   255  	return file_envoy_service_trace_v4alpha_trace_service_proto_rawDescData
   256  }
   257  
   258  var file_envoy_service_trace_v4alpha_trace_service_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
   259  var file_envoy_service_trace_v4alpha_trace_service_proto_goTypes = []interface{}{
   260  	(*StreamTracesResponse)(nil),           // 0: envoy.service.trace.v4alpha.StreamTracesResponse
   261  	(*StreamTracesMessage)(nil),            // 1: envoy.service.trace.v4alpha.StreamTracesMessage
   262  	(*StreamTracesMessage_Identifier)(nil), // 2: envoy.service.trace.v4alpha.StreamTracesMessage.Identifier
   263  	(*v1.Span)(nil),                        // 3: opencensus.proto.trace.v1.Span
   264  	(*v4alpha.Node)(nil),                   // 4: envoy.config.core.v4alpha.Node
   265  }
   266  var file_envoy_service_trace_v4alpha_trace_service_proto_depIdxs = []int32{
   267  	2, // 0: envoy.service.trace.v4alpha.StreamTracesMessage.identifier:type_name -> envoy.service.trace.v4alpha.StreamTracesMessage.Identifier
   268  	3, // 1: envoy.service.trace.v4alpha.StreamTracesMessage.spans:type_name -> opencensus.proto.trace.v1.Span
   269  	4, // 2: envoy.service.trace.v4alpha.StreamTracesMessage.Identifier.node:type_name -> envoy.config.core.v4alpha.Node
   270  	1, // 3: envoy.service.trace.v4alpha.TraceService.StreamTraces:input_type -> envoy.service.trace.v4alpha.StreamTracesMessage
   271  	0, // 4: envoy.service.trace.v4alpha.TraceService.StreamTraces:output_type -> envoy.service.trace.v4alpha.StreamTracesResponse
   272  	4, // [4:5] is the sub-list for method output_type
   273  	3, // [3:4] is the sub-list for method input_type
   274  	3, // [3:3] is the sub-list for extension type_name
   275  	3, // [3:3] is the sub-list for extension extendee
   276  	0, // [0:3] is the sub-list for field type_name
   277  }
   278  
   279  func init() { file_envoy_service_trace_v4alpha_trace_service_proto_init() }
   280  func file_envoy_service_trace_v4alpha_trace_service_proto_init() {
   281  	if File_envoy_service_trace_v4alpha_trace_service_proto != nil {
   282  		return
   283  	}
   284  	if !protoimpl.UnsafeEnabled {
   285  		file_envoy_service_trace_v4alpha_trace_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   286  			switch v := v.(*StreamTracesResponse); i {
   287  			case 0:
   288  				return &v.state
   289  			case 1:
   290  				return &v.sizeCache
   291  			case 2:
   292  				return &v.unknownFields
   293  			default:
   294  				return nil
   295  			}
   296  		}
   297  		file_envoy_service_trace_v4alpha_trace_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   298  			switch v := v.(*StreamTracesMessage); i {
   299  			case 0:
   300  				return &v.state
   301  			case 1:
   302  				return &v.sizeCache
   303  			case 2:
   304  				return &v.unknownFields
   305  			default:
   306  				return nil
   307  			}
   308  		}
   309  		file_envoy_service_trace_v4alpha_trace_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   310  			switch v := v.(*StreamTracesMessage_Identifier); i {
   311  			case 0:
   312  				return &v.state
   313  			case 1:
   314  				return &v.sizeCache
   315  			case 2:
   316  				return &v.unknownFields
   317  			default:
   318  				return nil
   319  			}
   320  		}
   321  	}
   322  	type x struct{}
   323  	out := protoimpl.TypeBuilder{
   324  		File: protoimpl.DescBuilder{
   325  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   326  			RawDescriptor: file_envoy_service_trace_v4alpha_trace_service_proto_rawDesc,
   327  			NumEnums:      0,
   328  			NumMessages:   3,
   329  			NumExtensions: 0,
   330  			NumServices:   1,
   331  		},
   332  		GoTypes:           file_envoy_service_trace_v4alpha_trace_service_proto_goTypes,
   333  		DependencyIndexes: file_envoy_service_trace_v4alpha_trace_service_proto_depIdxs,
   334  		MessageInfos:      file_envoy_service_trace_v4alpha_trace_service_proto_msgTypes,
   335  	}.Build()
   336  	File_envoy_service_trace_v4alpha_trace_service_proto = out.File
   337  	file_envoy_service_trace_v4alpha_trace_service_proto_rawDesc = nil
   338  	file_envoy_service_trace_v4alpha_trace_service_proto_goTypes = nil
   339  	file_envoy_service_trace_v4alpha_trace_service_proto_depIdxs = nil
   340  }
   341  
   342  // Reference imports to suppress errors if they are not otherwise used.
   343  var _ context.Context
   344  var _ grpc.ClientConnInterface
   345  
   346  // This is a compile-time assertion to ensure that this generated file
   347  // is compatible with the grpc package it is being compiled against.
   348  const _ = grpc.SupportPackageIsVersion6
   349  
   350  // TraceServiceClient is the client API for TraceService service.
   351  //
   352  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   353  type TraceServiceClient interface {
   354  	// Envoy will connect and send StreamTracesMessage messages forever. It does
   355  	// not expect any response to be sent as nothing would be done in the case
   356  	// of failure.
   357  	StreamTraces(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error)
   358  }
   359  
   360  type traceServiceClient struct {
   361  	cc grpc.ClientConnInterface
   362  }
   363  
   364  func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient {
   365  	return &traceServiceClient{cc}
   366  }
   367  
   368  func (c *traceServiceClient) StreamTraces(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error) {
   369  	stream, err := c.cc.NewStream(ctx, &_TraceService_serviceDesc.Streams[0], "/envoy.service.trace.v4alpha.TraceService/StreamTraces", opts...)
   370  	if err != nil {
   371  		return nil, err
   372  	}
   373  	x := &traceServiceStreamTracesClient{stream}
   374  	return x, nil
   375  }
   376  
   377  type TraceService_StreamTracesClient interface {
   378  	Send(*StreamTracesMessage) error
   379  	CloseAndRecv() (*StreamTracesResponse, error)
   380  	grpc.ClientStream
   381  }
   382  
   383  type traceServiceStreamTracesClient struct {
   384  	grpc.ClientStream
   385  }
   386  
   387  func (x *traceServiceStreamTracesClient) Send(m *StreamTracesMessage) error {
   388  	return x.ClientStream.SendMsg(m)
   389  }
   390  
   391  func (x *traceServiceStreamTracesClient) CloseAndRecv() (*StreamTracesResponse, error) {
   392  	if err := x.ClientStream.CloseSend(); err != nil {
   393  		return nil, err
   394  	}
   395  	m := new(StreamTracesResponse)
   396  	if err := x.ClientStream.RecvMsg(m); err != nil {
   397  		return nil, err
   398  	}
   399  	return m, nil
   400  }
   401  
   402  // TraceServiceServer is the server API for TraceService service.
   403  type TraceServiceServer interface {
   404  	// Envoy will connect and send StreamTracesMessage messages forever. It does
   405  	// not expect any response to be sent as nothing would be done in the case
   406  	// of failure.
   407  	StreamTraces(TraceService_StreamTracesServer) error
   408  }
   409  
   410  // UnimplementedTraceServiceServer can be embedded to have forward compatible implementations.
   411  type UnimplementedTraceServiceServer struct {
   412  }
   413  
   414  func (*UnimplementedTraceServiceServer) StreamTraces(TraceService_StreamTracesServer) error {
   415  	return status.Errorf(codes.Unimplemented, "method StreamTraces not implemented")
   416  }
   417  
   418  func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
   419  	s.RegisterService(&_TraceService_serviceDesc, srv)
   420  }
   421  
   422  func _TraceService_StreamTraces_Handler(srv interface{}, stream grpc.ServerStream) error {
   423  	return srv.(TraceServiceServer).StreamTraces(&traceServiceStreamTracesServer{stream})
   424  }
   425  
   426  type TraceService_StreamTracesServer interface {
   427  	SendAndClose(*StreamTracesResponse) error
   428  	Recv() (*StreamTracesMessage, error)
   429  	grpc.ServerStream
   430  }
   431  
   432  type traceServiceStreamTracesServer struct {
   433  	grpc.ServerStream
   434  }
   435  
   436  func (x *traceServiceStreamTracesServer) SendAndClose(m *StreamTracesResponse) error {
   437  	return x.ServerStream.SendMsg(m)
   438  }
   439  
   440  func (x *traceServiceStreamTracesServer) Recv() (*StreamTracesMessage, error) {
   441  	m := new(StreamTracesMessage)
   442  	if err := x.ServerStream.RecvMsg(m); err != nil {
   443  		return nil, err
   444  	}
   445  	return m, nil
   446  }
   447  
   448  var _TraceService_serviceDesc = grpc.ServiceDesc{
   449  	ServiceName: "envoy.service.trace.v4alpha.TraceService",
   450  	HandlerType: (*TraceServiceServer)(nil),
   451  	Methods:     []grpc.MethodDesc{},
   452  	Streams: []grpc.StreamDesc{
   453  		{
   454  			StreamName:    "StreamTraces",
   455  			Handler:       _TraceService_StreamTraces_Handler,
   456  			ClientStreams: true,
   457  		},
   458  	},
   459  	Metadata: "envoy/service/trace/v4alpha/trace_service.proto",
   460  }
   461
View as plain text