v2

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 25, 2018 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTraceService = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTraceService   = fmt.Errorf("proto: integer overflow")
)

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" json:"identifier,omitempty"`
	// A list of Span entries
	Spans                []*trace.Span `protobuf:"bytes,2,rep,name=spans" json:"spans,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StreamTracesMessage) Descriptor

func (*StreamTracesMessage) Descriptor() ([]byte, []int)

func (*StreamTracesMessage) GetIdentifier

func (*StreamTracesMessage) GetSpans

func (m *StreamTracesMessage) GetSpans() []*trace.Span

func (*StreamTracesMessage) Marshal

func (m *StreamTracesMessage) Marshal() (dAtA []byte, err error)

func (*StreamTracesMessage) MarshalTo

func (m *StreamTracesMessage) MarshalTo(dAtA []byte) (int, error)

func (*StreamTracesMessage) ProtoMessage

func (*StreamTracesMessage) ProtoMessage()

func (*StreamTracesMessage) Reset

func (m *StreamTracesMessage) Reset()

func (*StreamTracesMessage) Size

func (m *StreamTracesMessage) Size() (n int)

func (*StreamTracesMessage) String

func (m *StreamTracesMessage) String() string

func (*StreamTracesMessage) Unmarshal

func (m *StreamTracesMessage) Unmarshal(dAtA []byte) error

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, an error is returned.

func (*StreamTracesMessage) XXX_DiscardUnknown

func (m *StreamTracesMessage) XXX_DiscardUnknown()

func (*StreamTracesMessage) XXX_Marshal

func (m *StreamTracesMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTracesMessage) XXX_Merge

func (dst *StreamTracesMessage) XXX_Merge(src proto.Message)

func (*StreamTracesMessage) XXX_Size

func (m *StreamTracesMessage) XXX_Size() int

func (*StreamTracesMessage) XXX_Unmarshal

func (m *StreamTracesMessage) XXX_Unmarshal(b []byte) error

type StreamTracesMessageValidationError

type StreamTracesMessageValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamTracesMessageValidationError is the validation error returned by StreamTracesMessage.Validate if the designated constraints aren't met.

func (StreamTracesMessageValidationError) Error

Error satisfies the builtin error interface

type StreamTracesMessage_Identifier

type StreamTracesMessage_Identifier struct {
	// The node sending the access log messages over the stream.
	Node                 *core.Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*StreamTracesMessage_Identifier) Descriptor

func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int)

func (*StreamTracesMessage_Identifier) GetNode

func (*StreamTracesMessage_Identifier) Marshal

func (m *StreamTracesMessage_Identifier) Marshal() (dAtA []byte, err error)

func (*StreamTracesMessage_Identifier) MarshalTo

func (m *StreamTracesMessage_Identifier) MarshalTo(dAtA []byte) (int, error)

func (*StreamTracesMessage_Identifier) ProtoMessage

func (*StreamTracesMessage_Identifier) ProtoMessage()

func (*StreamTracesMessage_Identifier) Reset

func (m *StreamTracesMessage_Identifier) Reset()

func (*StreamTracesMessage_Identifier) Size

func (m *StreamTracesMessage_Identifier) Size() (n int)

func (*StreamTracesMessage_Identifier) String

func (*StreamTracesMessage_Identifier) Unmarshal

func (m *StreamTracesMessage_Identifier) Unmarshal(dAtA []byte) error

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, an error is returned.

func (*StreamTracesMessage_Identifier) XXX_DiscardUnknown

func (m *StreamTracesMessage_Identifier) XXX_DiscardUnknown()

func (*StreamTracesMessage_Identifier) XXX_Marshal

func (m *StreamTracesMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTracesMessage_Identifier) XXX_Merge

func (dst *StreamTracesMessage_Identifier) XXX_Merge(src proto.Message)

func (*StreamTracesMessage_Identifier) XXX_Size

func (m *StreamTracesMessage_Identifier) XXX_Size() int

func (*StreamTracesMessage_Identifier) XXX_Unmarshal

func (m *StreamTracesMessage_Identifier) XXX_Unmarshal(b []byte) error

type StreamTracesMessage_IdentifierValidationError

type StreamTracesMessage_IdentifierValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamTracesMessage_IdentifierValidationError is the validation error returned by StreamTracesMessage_Identifier.Validate if the designated constraints aren't met.

func (StreamTracesMessage_IdentifierValidationError) Error

Error satisfies the builtin error interface

type StreamTracesResponse

type StreamTracesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamTracesResponse) Descriptor

func (*StreamTracesResponse) Descriptor() ([]byte, []int)

func (*StreamTracesResponse) Marshal

func (m *StreamTracesResponse) Marshal() (dAtA []byte, err error)

func (*StreamTracesResponse) MarshalTo

func (m *StreamTracesResponse) MarshalTo(dAtA []byte) (int, error)

func (*StreamTracesResponse) ProtoMessage

func (*StreamTracesResponse) ProtoMessage()

func (*StreamTracesResponse) Reset

func (m *StreamTracesResponse) Reset()

func (*StreamTracesResponse) Size

func (m *StreamTracesResponse) Size() (n int)

func (*StreamTracesResponse) String

func (m *StreamTracesResponse) String() string

func (*StreamTracesResponse) Unmarshal

func (m *StreamTracesResponse) Unmarshal(dAtA []byte) error

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, an error is returned.

func (*StreamTracesResponse) XXX_DiscardUnknown

func (m *StreamTracesResponse) XXX_DiscardUnknown()

func (*StreamTracesResponse) XXX_Marshal

func (m *StreamTracesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTracesResponse) XXX_Merge

func (dst *StreamTracesResponse) XXX_Merge(src proto.Message)

func (*StreamTracesResponse) XXX_Size

func (m *StreamTracesResponse) XXX_Size() int

func (*StreamTracesResponse) XXX_Unmarshal

func (m *StreamTracesResponse) XXX_Unmarshal(b []byte) error

type StreamTracesResponseValidationError

type StreamTracesResponseValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamTracesResponseValidationError is the validation error returned by StreamTracesResponse.Validate if the designated constraints aren't met.

func (StreamTracesResponseValidationError) Error

Error satisfies the builtin error interface

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)
}

func NewTraceServiceClient

func NewTraceServiceClient(cc *grpc.ClientConn) 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
}

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL