envoy_service_trace_v3alpha

Documentation

Index

• func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer)
• type StreamTracesMessage
  • func (*StreamTracesMessage) Descriptor() ([]byte, []int)
  • func (m *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier
  • func (m *StreamTracesMessage) GetSpans() []*v1.Span
  • func (*StreamTracesMessage) ProtoMessage()
  • func (m *StreamTracesMessage) Reset()
  • func (m *StreamTracesMessage) String() string
  • func (m *StreamTracesMessage) XXX_DiscardUnknown()
  • func (m *StreamTracesMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamTracesMessage) XXX_Merge(src proto.Message)
  • func (m *StreamTracesMessage) XXX_Size() int
  • func (m *StreamTracesMessage) XXX_Unmarshal(b []byte) error
• type StreamTracesMessage_Identifier
  • func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int)
  • func (m *StreamTracesMessage_Identifier) GetNode() *core.Node
  • func (*StreamTracesMessage_Identifier) ProtoMessage()
  • func (m *StreamTracesMessage_Identifier) Reset()
  • func (m *StreamTracesMessage_Identifier) String() string
  • func (m *StreamTracesMessage_Identifier) XXX_DiscardUnknown()
  • func (m *StreamTracesMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamTracesMessage_Identifier) XXX_Merge(src proto.Message)
  • func (m *StreamTracesMessage_Identifier) XXX_Size() int
  • func (m *StreamTracesMessage_Identifier) XXX_Unmarshal(b []byte) error
• type StreamTracesResponse
  • func (*StreamTracesResponse) Descriptor() ([]byte, []int)
  • func (*StreamTracesResponse) ProtoMessage()
  • func (m *StreamTracesResponse) Reset()
  • func (m *StreamTracesResponse) String() string
  • func (m *StreamTracesResponse) XXX_DiscardUnknown()
  • func (m *StreamTracesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamTracesResponse) XXX_Merge(src proto.Message)
  • func (m *StreamTracesResponse) XXX_Size() int
  • func (m *StreamTracesResponse) XXX_Unmarshal(b []byte) error
• type TraceServiceClient
  • func NewTraceServiceClient(cc *grpc.ClientConn) TraceServiceClient
• type TraceServiceServer
• type TraceService_StreamTracesClient
• type TraceService_StreamTracesServer

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*StreamTracesMessage) Descriptor

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

func (*StreamTracesMessage) GetIdentifier

func (m *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier

func (*StreamTracesMessage) GetSpans

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

func (*StreamTracesMessage) ProtoMessage

func (*StreamTracesMessage) ProtoMessage()

func (*StreamTracesMessage) Reset

func (m *StreamTracesMessage) Reset()

func (*StreamTracesMessage) String

func (m *StreamTracesMessage) String() string

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 (m *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 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,proto3" 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 (m *StreamTracesMessage_Identifier) GetNode() *core.Node

func (*StreamTracesMessage_Identifier) ProtoMessage

func (*StreamTracesMessage_Identifier) ProtoMessage()

func (*StreamTracesMessage_Identifier) Reset

func (m *StreamTracesMessage_Identifier) Reset()

func (*StreamTracesMessage_Identifier) String

func (m *StreamTracesMessage_Identifier) String() string

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 (m *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 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) ProtoMessage

func (*StreamTracesResponse) ProtoMessage()

func (*StreamTracesResponse) Reset

func (m *StreamTracesResponse) Reset()

func (*StreamTracesResponse) String

func (m *StreamTracesResponse) String() string

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 (m *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 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.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
}

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
}