Documentation
¶
Index ¶
- Variables
- func NewTraceEndpoints() []*api.Endpoint
- func RegisterTraceHandler(s server.Server, hdlr TraceHandler, opts ...server.HandlerOption) error
- type Node
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadRequest) GetLimit() int64
- func (x *ReadRequest) GetPast() bool
- func (x *ReadRequest) GetService() *Service
- func (*ReadRequest) ProtoMessage()
- func (x *ReadRequest) ProtoReflect() protoreflect.Message
- func (x *ReadRequest) Reset()
- func (x *ReadRequest) String() string
- type ReadResponse
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetName() string
- func (x *Service) GetNode() *Node
- func (x *Service) GetVersion() string
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type Snapshot
- type Span
- func (*Span) Descriptor() ([]byte, []int)deprecated
- func (x *Span) GetDuration() uint64
- func (x *Span) GetId() string
- func (x *Span) GetMetadata() map[string]string
- func (x *Span) GetName() string
- func (x *Span) GetParent() string
- func (x *Span) GetStarted() uint64
- func (x *Span) GetTrace() string
- func (x *Span) GetType() SpanType
- func (*Span) ProtoMessage()
- func (x *Span) ProtoReflect() protoreflect.Message
- func (x *Span) Reset()
- func (x *Span) String() string
- type SpanType
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest) GetNamespace() string
- func (x *StreamRequest) GetService() *Service
- func (*StreamRequest) ProtoMessage()
- func (x *StreamRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRequest) Reset()
- func (x *StreamRequest) String() string
- type StreamResponse
- type TraceHandler
- type TraceService
- type Trace_StreamService
- type Trace_StreamStream
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRequest) GetService() *Service
- func (x *WriteRequest) GetStats() *Snapshot
- func (*WriteRequest) ProtoMessage()
- func (x *WriteRequest) ProtoReflect() protoreflect.Message
- func (x *WriteRequest) Reset()
- func (x *WriteRequest) String() string
- type WriteResponse
Constants ¶
This section is empty.
Variables ¶
var ( SpanType_name = map[int32]string{ 0: "INBOUND", 1: "OUTBOUND", } SpanType_value = map[string]int32{ "INBOUND": 0, "OUTBOUND": 1, } )
Enum value maps for SpanType.
var File_service_debug_trace_proto_trace_proto protoreflect.FileDescriptor
Functions ¶
func NewTraceEndpoints ¶
NewTraceEndpoints API Endpoints for Trace service
func RegisterTraceHandler ¶
func RegisterTraceHandler(s server.Server, hdlr TraceHandler, opts ...server.HandlerOption) error
Types ¶
type Node ¶
type Node struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
// contains filtered or unexported fields
}
Node describes a single instance of a service.
func (*Node) Descriptor
deprecated
func (*Node) GetAddress ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type ReadRequest ¶
type ReadRequest struct {
// If set, only return services matching the filter
Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
// If false, only the current snapshots will be returned.
// If true, all historical snapshots in memory will be returned.
Past bool `protobuf:"varint,2,opt,name=past,proto3" json:"past,omitempty"`
// Number of traces to return
Limit int64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
// contains filtered or unexported fields
}
func (*ReadRequest) Descriptor
deprecated
func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetLimit ¶
func (x *ReadRequest) GetLimit() int64
func (*ReadRequest) GetPast ¶
func (x *ReadRequest) GetPast() bool
func (*ReadRequest) GetService ¶
func (x *ReadRequest) GetService() *Service
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (x *ReadRequest) String() string
type ReadResponse ¶
type ReadResponse struct {
Spans []*Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
// contains filtered or unexported fields
}
func (*ReadResponse) Descriptor
deprecated
func (*ReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.
func (*ReadResponse) GetSpans ¶
func (x *ReadResponse) GetSpans() []*Span
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) ProtoReflect ¶
func (x *ReadResponse) ProtoReflect() protoreflect.Message
func (*ReadResponse) Reset ¶
func (x *ReadResponse) Reset()
func (*ReadResponse) String ¶
func (x *ReadResponse) String() string
type Service ¶
type Service struct {
// Service name, e.g. go.micro.service.greeter
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
Node *Node `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
// contains filtered or unexported fields
}
Service describes a service running in the micro network.
func (*Service) Descriptor
deprecated
func (*Service) GetVersion ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type Snapshot ¶
type Snapshot struct {
// Source of the service where the snapshot was collected from
Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
// Trace spans
Spans []*Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
// contains filtered or unexported fields
}
Snapshot is a snapshot of Trace.Read from a particular service when called.
func (*Snapshot) Descriptor
deprecated
func (*Snapshot) GetService ¶
func (*Snapshot) ProtoMessage ¶
func (*Snapshot) ProtoMessage()
func (*Snapshot) ProtoReflect ¶
func (x *Snapshot) ProtoReflect() protoreflect.Message
type Span ¶
type Span struct {
// the trace id
Trace string `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"`
// id of the span
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
// parent span
Parent string `protobuf:"bytes,3,opt,name=parent,proto3" json:"parent,omitempty"`
// name of the resource
Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
// time of start in nanoseconds
Started uint64 `protobuf:"varint,5,opt,name=started,proto3" json:"started,omitempty"`
// duration of the execution in nanoseconds
Duration uint64 `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"`
// associated metadata
Metadata map[string]string `` /* 157-byte string literal not displayed */
Type SpanType `protobuf:"varint,8,opt,name=type,proto3,enum=go.micro.debug.trace.SpanType" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*Span) Descriptor
deprecated
func (*Span) GetDuration ¶
func (*Span) GetMetadata ¶
func (*Span) GetStarted ¶
func (*Span) ProtoMessage ¶
func (*Span) ProtoMessage()
func (*Span) ProtoReflect ¶
func (x *Span) ProtoReflect() protoreflect.Message
type SpanType ¶
type SpanType int32
func (SpanType) Descriptor ¶
func (SpanType) Descriptor() protoreflect.EnumDescriptor
func (SpanType) EnumDescriptor
deprecated
func (SpanType) Number ¶
func (x SpanType) Number() protoreflect.EnumNumber
func (SpanType) Type ¶
func (SpanType) Type() protoreflect.EnumType
type StreamRequest ¶
type StreamRequest struct {
// If set, only return services matching the filter
Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
// If set, only return services matching the namespace
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*StreamRequest) Descriptor
deprecated
func (*StreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.
func (*StreamRequest) GetNamespace ¶
func (x *StreamRequest) GetNamespace() string
func (*StreamRequest) GetService ¶
func (x *StreamRequest) GetService() *Service
func (*StreamRequest) ProtoMessage ¶
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) ProtoReflect ¶
func (x *StreamRequest) ProtoReflect() protoreflect.Message
func (*StreamRequest) Reset ¶
func (x *StreamRequest) Reset()
func (*StreamRequest) String ¶
func (x *StreamRequest) String() string
type StreamResponse ¶
type StreamResponse struct {
Stats []*Snapshot `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
func (*StreamResponse) Descriptor
deprecated
func (*StreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.
func (*StreamResponse) GetStats ¶
func (x *StreamResponse) GetStats() []*Snapshot
func (*StreamResponse) ProtoMessage ¶
func (*StreamResponse) ProtoMessage()
func (*StreamResponse) ProtoReflect ¶
func (x *StreamResponse) ProtoReflect() protoreflect.Message
func (*StreamResponse) Reset ¶
func (x *StreamResponse) Reset()
func (*StreamResponse) String ¶
func (x *StreamResponse) String() string
type TraceHandler ¶
type TraceHandler interface {
Read(context.Context, *ReadRequest, *ReadResponse) error
Write(context.Context, *WriteRequest, *WriteResponse) error
Stream(context.Context, *StreamRequest, Trace_StreamStream) error
}
TraceHandler is the server API for Trace service.
type TraceService ¶
type TraceService interface {
Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
Write(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error)
Stream(ctx context.Context, in *StreamRequest, opts ...client.CallOption) (Trace_StreamService, error)
}
TraceService is the client API for Trace service.
func NewTraceService ¶
func NewTraceService(name string, c client.Client) TraceService
type Trace_StreamService ¶
type Trace_StreamStream ¶
type WriteRequest ¶
type WriteRequest struct {
// If set, only return services matching the filter
Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
// snapshot to write
Stats *Snapshot `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
// contains filtered or unexported fields
}
func (*WriteRequest) Descriptor
deprecated
func (*WriteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.
func (*WriteRequest) GetService ¶
func (x *WriteRequest) GetService() *Service
func (*WriteRequest) GetStats ¶
func (x *WriteRequest) GetStats() *Snapshot
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) ProtoReflect ¶
func (x *WriteRequest) ProtoReflect() protoreflect.Message
func (*WriteRequest) Reset ¶
func (x *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (x *WriteRequest) String() string
type WriteResponse ¶
type WriteResponse struct {
// contains filtered or unexported fields
}
func (*WriteResponse) Descriptor
deprecated
func (*WriteResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.
func (*WriteResponse) ProtoMessage ¶
func (*WriteResponse) ProtoMessage()
func (*WriteResponse) ProtoReflect ¶
func (x *WriteResponse) ProtoReflect() protoreflect.Message
func (*WriteResponse) Reset ¶
func (x *WriteResponse) Reset()
func (*WriteResponse) String ¶
func (x *WriteResponse) String() string