Documentation ¶
Index ¶
- Variables
- func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer)
- type StreamTracesMessage
- func (*StreamTracesMessage) Descriptor() ([]byte, []int)deprecated
- func (x *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier
- func (x *StreamTracesMessage) GetSpans() []*v1.Span
- func (*StreamTracesMessage) ProtoMessage()
- func (x *StreamTracesMessage) ProtoReflect() protoreflect.Message
- func (x *StreamTracesMessage) Reset()
- func (x *StreamTracesMessage) String() string
- func (m *StreamTracesMessage) Validate() error
- func (m *StreamTracesMessage) ValidateAll() error
- type StreamTracesMessageMultiError
- type StreamTracesMessageValidationError
- func (e StreamTracesMessageValidationError) Cause() error
- func (e StreamTracesMessageValidationError) Error() string
- func (e StreamTracesMessageValidationError) ErrorName() string
- func (e StreamTracesMessageValidationError) Field() string
- func (e StreamTracesMessageValidationError) Key() bool
- func (e StreamTracesMessageValidationError) Reason() string
- type StreamTracesMessage_Identifier
- func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int)deprecated
- func (x *StreamTracesMessage_Identifier) GetNode() *v3.Node
- func (*StreamTracesMessage_Identifier) ProtoMessage()
- func (x *StreamTracesMessage_Identifier) ProtoReflect() protoreflect.Message
- func (x *StreamTracesMessage_Identifier) Reset()
- func (x *StreamTracesMessage_Identifier) String() string
- func (m *StreamTracesMessage_Identifier) Validate() error
- func (m *StreamTracesMessage_Identifier) ValidateAll() error
- type StreamTracesMessage_IdentifierMultiError
- type StreamTracesMessage_IdentifierValidationError
- func (e StreamTracesMessage_IdentifierValidationError) Cause() error
- func (e StreamTracesMessage_IdentifierValidationError) Error() string
- func (e StreamTracesMessage_IdentifierValidationError) ErrorName() string
- func (e StreamTracesMessage_IdentifierValidationError) Field() string
- func (e StreamTracesMessage_IdentifierValidationError) Key() bool
- func (e StreamTracesMessage_IdentifierValidationError) Reason() string
- type StreamTracesResponse
- func (*StreamTracesResponse) Descriptor() ([]byte, []int)deprecated
- func (*StreamTracesResponse) ProtoMessage()
- func (x *StreamTracesResponse) ProtoReflect() protoreflect.Message
- func (x *StreamTracesResponse) Reset()
- func (x *StreamTracesResponse) String() string
- func (m *StreamTracesResponse) Validate() error
- func (m *StreamTracesResponse) ValidateAll() error
- type StreamTracesResponseMultiError
- type StreamTracesResponseValidationError
- func (e StreamTracesResponseValidationError) Cause() error
- func (e StreamTracesResponseValidationError) Error() string
- func (e StreamTracesResponseValidationError) ErrorName() string
- func (e StreamTracesResponseValidationError) Field() string
- func (e StreamTracesResponseValidationError) Key() bool
- func (e StreamTracesResponseValidationError) Reason() string
- type TraceServiceClient
- type TraceServiceServer
- type TraceService_StreamTracesClient
- type TraceService_StreamTracesServer
- type UnimplementedTraceServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_envoy_service_trace_v3_trace_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterTraceServiceServer ¶
func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer)
Types ¶
type StreamTracesMessage ¶
type StreamTracesMessage struct { // Identifier data effectively is a structured metadata. // As a performance optimization this will only be sent in the first message // on the stream. Identifier *StreamTracesMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` // A list of Span entries Spans []*v1.Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"` // contains filtered or unexported fields }
func (*StreamTracesMessage) Descriptor
deprecated
func (*StreamTracesMessage) Descriptor() ([]byte, []int)
Deprecated: Use StreamTracesMessage.ProtoReflect.Descriptor instead.
func (*StreamTracesMessage) GetIdentifier ¶
func (x *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier
func (*StreamTracesMessage) GetSpans ¶
func (x *StreamTracesMessage) GetSpans() []*v1.Span
func (*StreamTracesMessage) ProtoMessage ¶
func (*StreamTracesMessage) ProtoMessage()
func (*StreamTracesMessage) ProtoReflect ¶
func (x *StreamTracesMessage) ProtoReflect() protoreflect.Message
func (*StreamTracesMessage) Reset ¶
func (x *StreamTracesMessage) Reset()
func (*StreamTracesMessage) String ¶
func (x *StreamTracesMessage) String() string
func (*StreamTracesMessage) Validate ¶
func (m *StreamTracesMessage) Validate() error
Validate checks the field values on StreamTracesMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamTracesMessage) ValidateAll ¶
func (m *StreamTracesMessage) ValidateAll() error
ValidateAll checks the field values on StreamTracesMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamTracesMessageMultiError, or nil if none found.
type StreamTracesMessageMultiError ¶
type StreamTracesMessageMultiError []error
StreamTracesMessageMultiError is an error wrapping multiple validation errors returned by StreamTracesMessage.ValidateAll() if the designated constraints aren't met.
func (StreamTracesMessageMultiError) AllErrors ¶
func (m StreamTracesMessageMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamTracesMessageMultiError) Error ¶
func (m StreamTracesMessageMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamTracesMessageValidationError ¶
type StreamTracesMessageValidationError struct {
// contains filtered or unexported fields
}
StreamTracesMessageValidationError is the validation error returned by StreamTracesMessage.Validate if the designated constraints aren't met.
func (StreamTracesMessageValidationError) Cause ¶
func (e StreamTracesMessageValidationError) Cause() error
Cause function returns cause value.
func (StreamTracesMessageValidationError) Error ¶
func (e StreamTracesMessageValidationError) Error() string
Error satisfies the builtin error interface
func (StreamTracesMessageValidationError) ErrorName ¶
func (e StreamTracesMessageValidationError) ErrorName() string
ErrorName returns error name.
func (StreamTracesMessageValidationError) Field ¶
func (e StreamTracesMessageValidationError) Field() string
Field function returns field value.
func (StreamTracesMessageValidationError) Key ¶
func (e StreamTracesMessageValidationError) Key() bool
Key function returns key value.
func (StreamTracesMessageValidationError) Reason ¶
func (e StreamTracesMessageValidationError) Reason() string
Reason function returns reason value.
type StreamTracesMessage_Identifier ¶
type StreamTracesMessage_Identifier struct { // The node sending the access log messages over the stream. Node *v3.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // contains filtered or unexported fields }
func (*StreamTracesMessage_Identifier) Descriptor
deprecated
func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int)
Deprecated: Use StreamTracesMessage_Identifier.ProtoReflect.Descriptor instead.
func (*StreamTracesMessage_Identifier) GetNode ¶
func (x *StreamTracesMessage_Identifier) GetNode() *v3.Node
func (*StreamTracesMessage_Identifier) ProtoMessage ¶
func (*StreamTracesMessage_Identifier) ProtoMessage()
func (*StreamTracesMessage_Identifier) ProtoReflect ¶
func (x *StreamTracesMessage_Identifier) ProtoReflect() protoreflect.Message
func (*StreamTracesMessage_Identifier) Reset ¶
func (x *StreamTracesMessage_Identifier) Reset()
func (*StreamTracesMessage_Identifier) String ¶
func (x *StreamTracesMessage_Identifier) String() string
func (*StreamTracesMessage_Identifier) Validate ¶
func (m *StreamTracesMessage_Identifier) Validate() error
Validate checks the field values on StreamTracesMessage_Identifier with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamTracesMessage_Identifier) ValidateAll ¶
func (m *StreamTracesMessage_Identifier) ValidateAll() error
ValidateAll checks the field values on StreamTracesMessage_Identifier with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamTracesMessage_IdentifierMultiError, or nil if none found.
type StreamTracesMessage_IdentifierMultiError ¶
type StreamTracesMessage_IdentifierMultiError []error
StreamTracesMessage_IdentifierMultiError is an error wrapping multiple validation errors returned by StreamTracesMessage_Identifier.ValidateAll() if the designated constraints aren't met.
func (StreamTracesMessage_IdentifierMultiError) AllErrors ¶
func (m StreamTracesMessage_IdentifierMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamTracesMessage_IdentifierMultiError) Error ¶
func (m StreamTracesMessage_IdentifierMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamTracesMessage_IdentifierValidationError ¶
type StreamTracesMessage_IdentifierValidationError struct {
// contains filtered or unexported fields
}
StreamTracesMessage_IdentifierValidationError is the validation error returned by StreamTracesMessage_Identifier.Validate if the designated constraints aren't met.
func (StreamTracesMessage_IdentifierValidationError) Cause ¶
func (e StreamTracesMessage_IdentifierValidationError) Cause() error
Cause function returns cause value.
func (StreamTracesMessage_IdentifierValidationError) Error ¶
func (e StreamTracesMessage_IdentifierValidationError) Error() string
Error satisfies the builtin error interface
func (StreamTracesMessage_IdentifierValidationError) ErrorName ¶
func (e StreamTracesMessage_IdentifierValidationError) ErrorName() string
ErrorName returns error name.
func (StreamTracesMessage_IdentifierValidationError) Field ¶
func (e StreamTracesMessage_IdentifierValidationError) Field() string
Field function returns field value.
func (StreamTracesMessage_IdentifierValidationError) Key ¶
func (e StreamTracesMessage_IdentifierValidationError) Key() bool
Key function returns key value.
func (StreamTracesMessage_IdentifierValidationError) Reason ¶
func (e StreamTracesMessage_IdentifierValidationError) Reason() string
Reason function returns reason value.
type StreamTracesResponse ¶
type StreamTracesResponse struct {
// contains filtered or unexported fields
}
func (*StreamTracesResponse) Descriptor
deprecated
func (*StreamTracesResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamTracesResponse.ProtoReflect.Descriptor instead.
func (*StreamTracesResponse) ProtoMessage ¶
func (*StreamTracesResponse) ProtoMessage()
func (*StreamTracesResponse) ProtoReflect ¶
func (x *StreamTracesResponse) ProtoReflect() protoreflect.Message
func (*StreamTracesResponse) Reset ¶
func (x *StreamTracesResponse) Reset()
func (*StreamTracesResponse) String ¶
func (x *StreamTracesResponse) String() string
func (*StreamTracesResponse) Validate ¶
func (m *StreamTracesResponse) Validate() error
Validate checks the field values on StreamTracesResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamTracesResponse) ValidateAll ¶
func (m *StreamTracesResponse) ValidateAll() error
ValidateAll checks the field values on StreamTracesResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamTracesResponseMultiError, or nil if none found.
type StreamTracesResponseMultiError ¶
type StreamTracesResponseMultiError []error
StreamTracesResponseMultiError is an error wrapping multiple validation errors returned by StreamTracesResponse.ValidateAll() if the designated constraints aren't met.
func (StreamTracesResponseMultiError) AllErrors ¶
func (m StreamTracesResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamTracesResponseMultiError) Error ¶
func (m StreamTracesResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamTracesResponseValidationError ¶
type StreamTracesResponseValidationError struct {
// contains filtered or unexported fields
}
StreamTracesResponseValidationError is the validation error returned by StreamTracesResponse.Validate if the designated constraints aren't met.
func (StreamTracesResponseValidationError) Cause ¶
func (e StreamTracesResponseValidationError) Cause() error
Cause function returns cause value.
func (StreamTracesResponseValidationError) Error ¶
func (e StreamTracesResponseValidationError) Error() string
Error satisfies the builtin error interface
func (StreamTracesResponseValidationError) ErrorName ¶
func (e StreamTracesResponseValidationError) ErrorName() string
ErrorName returns error name.
func (StreamTracesResponseValidationError) Field ¶
func (e StreamTracesResponseValidationError) Field() string
Field function returns field value.
func (StreamTracesResponseValidationError) Key ¶
func (e StreamTracesResponseValidationError) Key() bool
Key function returns key value.
func (StreamTracesResponseValidationError) Reason ¶
func (e StreamTracesResponseValidationError) Reason() string
Reason function returns reason value.
type TraceServiceClient ¶
type TraceServiceClient interface { // Envoy will connect and send StreamTracesMessage messages forever. It does // not expect any response to be sent as nothing would be done in the case // of failure. StreamTraces(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error) }
TraceServiceClient is the client API for TraceService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTraceServiceClient ¶
func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient
type TraceServiceServer ¶
type TraceServiceServer interface { // Envoy will connect and send StreamTracesMessage messages forever. It does // not expect any response to be sent as nothing would be done in the case // of failure. StreamTraces(TraceService_StreamTracesServer) error }
TraceServiceServer is the server API for TraceService service.
type TraceService_StreamTracesClient ¶
type TraceService_StreamTracesClient interface { Send(*StreamTracesMessage) error CloseAndRecv() (*StreamTracesResponse, error) grpc.ClientStream }
type TraceService_StreamTracesServer ¶
type TraceService_StreamTracesServer interface { SendAndClose(*StreamTracesResponse) error Recv() (*StreamTracesMessage, error) grpc.ServerStream }
type UnimplementedTraceServiceServer ¶
type UnimplementedTraceServiceServer struct { }
UnimplementedTraceServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTraceServiceServer) StreamTraces ¶
func (*UnimplementedTraceServiceServer) StreamTraces(TraceService_StreamTracesServer) error