Documentation ¶
Index ¶
- func RegisterCollectorServiceServer(s *grpc.Server, srv CollectorServiceServer)
- func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer)
- type ArchiveTraceRequest
- func (*ArchiveTraceRequest) Descriptor() ([]byte, []int)
- func (m *ArchiveTraceRequest) GetTraceId() []byte
- func (*ArchiveTraceRequest) ProtoMessage()
- func (m *ArchiveTraceRequest) Reset()
- func (m *ArchiveTraceRequest) String() string
- func (m *ArchiveTraceRequest) XXX_DiscardUnknown()
- func (m *ArchiveTraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArchiveTraceRequest) XXX_Merge(src proto.Message)
- func (m *ArchiveTraceRequest) XXX_Size() int
- func (m *ArchiveTraceRequest) XXX_Unmarshal(b []byte) error
- type ArchiveTraceResponse
- func (*ArchiveTraceResponse) Descriptor() ([]byte, []int)
- func (*ArchiveTraceResponse) ProtoMessage()
- func (m *ArchiveTraceResponse) Reset()
- func (m *ArchiveTraceResponse) String() string
- func (m *ArchiveTraceResponse) XXX_DiscardUnknown()
- func (m *ArchiveTraceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ArchiveTraceResponse) XXX_Merge(src proto.Message)
- func (m *ArchiveTraceResponse) XXX_Size() int
- func (m *ArchiveTraceResponse) XXX_Unmarshal(b []byte) error
- type CollectorServiceClient
- type CollectorServiceServer
- type FindTracesRequest
- func (*FindTracesRequest) Descriptor() ([]byte, []int)
- func (m *FindTracesRequest) GetQuery() *TraceQueryParameters
- func (*FindTracesRequest) ProtoMessage()
- func (m *FindTracesRequest) Reset()
- func (m *FindTracesRequest) String() string
- func (m *FindTracesRequest) XXX_DiscardUnknown()
- func (m *FindTracesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FindTracesRequest) XXX_Merge(src proto.Message)
- func (m *FindTracesRequest) XXX_Size() int
- func (m *FindTracesRequest) XXX_Unmarshal(b []byte) error
- type GetDependenciesRequest
- func (*GetDependenciesRequest) Descriptor() ([]byte, []int)
- func (m *GetDependenciesRequest) GetEndTime() *timestamp.Timestamp
- func (m *GetDependenciesRequest) GetStartTime() *timestamp.Timestamp
- func (*GetDependenciesRequest) ProtoMessage()
- func (m *GetDependenciesRequest) Reset()
- func (m *GetDependenciesRequest) String() string
- func (m *GetDependenciesRequest) XXX_DiscardUnknown()
- func (m *GetDependenciesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDependenciesRequest) XXX_Merge(src proto.Message)
- func (m *GetDependenciesRequest) XXX_Size() int
- func (m *GetDependenciesRequest) XXX_Unmarshal(b []byte) error
- type GetDependenciesResponse
- func (*GetDependenciesResponse) Descriptor() ([]byte, []int)
- func (m *GetDependenciesResponse) GetDependencies() []*model.DependencyLink
- func (*GetDependenciesResponse) ProtoMessage()
- func (m *GetDependenciesResponse) Reset()
- func (m *GetDependenciesResponse) String() string
- func (m *GetDependenciesResponse) XXX_DiscardUnknown()
- func (m *GetDependenciesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDependenciesResponse) XXX_Merge(src proto.Message)
- func (m *GetDependenciesResponse) XXX_Size() int
- func (m *GetDependenciesResponse) XXX_Unmarshal(b []byte) error
- type GetOperationsRequest
- func (*GetOperationsRequest) Descriptor() ([]byte, []int)
- func (m *GetOperationsRequest) GetService() string
- func (m *GetOperationsRequest) GetSpanKind() string
- func (*GetOperationsRequest) ProtoMessage()
- func (m *GetOperationsRequest) Reset()
- func (m *GetOperationsRequest) String() string
- func (m *GetOperationsRequest) XXX_DiscardUnknown()
- func (m *GetOperationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetOperationsRequest) XXX_Merge(src proto.Message)
- func (m *GetOperationsRequest) XXX_Size() int
- func (m *GetOperationsRequest) XXX_Unmarshal(b []byte) error
- type GetOperationsResponse
- func (*GetOperationsResponse) Descriptor() ([]byte, []int)
- func (m *GetOperationsResponse) GetOperationNames() []string
- func (m *GetOperationsResponse) GetOperations() []*Operation
- func (*GetOperationsResponse) ProtoMessage()
- func (m *GetOperationsResponse) Reset()
- func (m *GetOperationsResponse) String() string
- func (m *GetOperationsResponse) XXX_DiscardUnknown()
- func (m *GetOperationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetOperationsResponse) XXX_Merge(src proto.Message)
- func (m *GetOperationsResponse) XXX_Size() int
- func (m *GetOperationsResponse) XXX_Unmarshal(b []byte) error
- type GetServicesRequest
- func (*GetServicesRequest) Descriptor() ([]byte, []int)
- func (*GetServicesRequest) ProtoMessage()
- func (m *GetServicesRequest) Reset()
- func (m *GetServicesRequest) String() string
- func (m *GetServicesRequest) XXX_DiscardUnknown()
- func (m *GetServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetServicesRequest) XXX_Merge(src proto.Message)
- func (m *GetServicesRequest) XXX_Size() int
- func (m *GetServicesRequest) XXX_Unmarshal(b []byte) error
- type GetServicesResponse
- func (*GetServicesResponse) Descriptor() ([]byte, []int)
- func (m *GetServicesResponse) GetServices() []string
- func (*GetServicesResponse) ProtoMessage()
- func (m *GetServicesResponse) Reset()
- func (m *GetServicesResponse) String() string
- func (m *GetServicesResponse) XXX_DiscardUnknown()
- func (m *GetServicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetServicesResponse) XXX_Merge(src proto.Message)
- func (m *GetServicesResponse) XXX_Size() int
- func (m *GetServicesResponse) XXX_Unmarshal(b []byte) error
- type GetTraceRequest
- func (*GetTraceRequest) Descriptor() ([]byte, []int)
- func (m *GetTraceRequest) GetTraceId() []byte
- func (*GetTraceRequest) ProtoMessage()
- func (m *GetTraceRequest) Reset()
- func (m *GetTraceRequest) String() string
- func (m *GetTraceRequest) XXX_DiscardUnknown()
- func (m *GetTraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTraceRequest) XXX_Merge(src proto.Message)
- func (m *GetTraceRequest) XXX_Size() int
- func (m *GetTraceRequest) XXX_Unmarshal(b []byte) error
- type Operation
- func (*Operation) Descriptor() ([]byte, []int)
- func (m *Operation) GetName() string
- func (m *Operation) GetSpanKind() string
- func (*Operation) ProtoMessage()
- func (m *Operation) Reset()
- func (m *Operation) String() string
- func (m *Operation) XXX_DiscardUnknown()
- func (m *Operation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Operation) XXX_Merge(src proto.Message)
- func (m *Operation) XXX_Size() int
- func (m *Operation) XXX_Unmarshal(b []byte) error
- type PostSpansRequest
- func (*PostSpansRequest) Descriptor() ([]byte, []int)
- func (m *PostSpansRequest) GetBatch() *model.Batch
- func (*PostSpansRequest) ProtoMessage()
- func (m *PostSpansRequest) Reset()
- func (m *PostSpansRequest) String() string
- func (m *PostSpansRequest) XXX_DiscardUnknown()
- func (m *PostSpansRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PostSpansRequest) XXX_Merge(src proto.Message)
- func (m *PostSpansRequest) XXX_Size() int
- func (m *PostSpansRequest) XXX_Unmarshal(b []byte) error
- type PostSpansResponse
- func (*PostSpansResponse) Descriptor() ([]byte, []int)
- func (*PostSpansResponse) ProtoMessage()
- func (m *PostSpansResponse) Reset()
- func (m *PostSpansResponse) String() string
- func (m *PostSpansResponse) XXX_DiscardUnknown()
- func (m *PostSpansResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PostSpansResponse) XXX_Merge(src proto.Message)
- func (m *PostSpansResponse) XXX_Size() int
- func (m *PostSpansResponse) XXX_Unmarshal(b []byte) error
- type QueryServiceClient
- type QueryServiceServer
- type QueryService_FindTracesClient
- type QueryService_FindTracesServer
- type QueryService_GetTraceClient
- type QueryService_GetTraceServer
- type SpansResponseChunk
- func (*SpansResponseChunk) Descriptor() ([]byte, []int)
- func (m *SpansResponseChunk) GetSpans() []*model.Span
- func (*SpansResponseChunk) ProtoMessage()
- func (m *SpansResponseChunk) Reset()
- func (m *SpansResponseChunk) String() string
- func (m *SpansResponseChunk) XXX_DiscardUnknown()
- func (m *SpansResponseChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SpansResponseChunk) XXX_Merge(src proto.Message)
- func (m *SpansResponseChunk) XXX_Size() int
- func (m *SpansResponseChunk) XXX_Unmarshal(b []byte) error
- type TraceQueryParameters
- func (*TraceQueryParameters) Descriptor() ([]byte, []int)
- func (m *TraceQueryParameters) GetDurationMax() *duration.Duration
- func (m *TraceQueryParameters) GetDurationMin() *duration.Duration
- func (m *TraceQueryParameters) GetOperationName() string
- func (m *TraceQueryParameters) GetSearchDepth() int32
- func (m *TraceQueryParameters) GetServiceName() string
- func (m *TraceQueryParameters) GetStartTimeMax() *timestamp.Timestamp
- func (m *TraceQueryParameters) GetStartTimeMin() *timestamp.Timestamp
- func (m *TraceQueryParameters) GetTags() map[string]string
- func (*TraceQueryParameters) ProtoMessage()
- func (m *TraceQueryParameters) Reset()
- func (m *TraceQueryParameters) String() string
- func (m *TraceQueryParameters) XXX_DiscardUnknown()
- func (m *TraceQueryParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TraceQueryParameters) XXX_Merge(src proto.Message)
- func (m *TraceQueryParameters) XXX_Size() int
- func (m *TraceQueryParameters) XXX_Unmarshal(b []byte) error
- type UnimplementedCollectorServiceServer
- type UnimplementedQueryServiceServer
- func (*UnimplementedQueryServiceServer) ArchiveTrace(ctx context.Context, req *ArchiveTraceRequest) (*ArchiveTraceResponse, error)
- func (*UnimplementedQueryServiceServer) FindTraces(req *FindTracesRequest, srv QueryService_FindTracesServer) error
- func (*UnimplementedQueryServiceServer) GetDependencies(ctx context.Context, req *GetDependenciesRequest) (*GetDependenciesResponse, error)
- func (*UnimplementedQueryServiceServer) GetOperations(ctx context.Context, req *GetOperationsRequest) (*GetOperationsResponse, error)
- func (*UnimplementedQueryServiceServer) GetServices(ctx context.Context, req *GetServicesRequest) (*GetServicesResponse, error)
- func (*UnimplementedQueryServiceServer) GetTrace(req *GetTraceRequest, srv QueryService_GetTraceServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCollectorServiceServer ¶
func RegisterCollectorServiceServer(s *grpc.Server, srv CollectorServiceServer)
func RegisterQueryServiceServer ¶
func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer)
Types ¶
type ArchiveTraceRequest ¶
type ArchiveTraceRequest struct { TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ArchiveTraceRequest) Descriptor ¶
func (*ArchiveTraceRequest) Descriptor() ([]byte, []int)
func (*ArchiveTraceRequest) GetTraceId ¶
func (m *ArchiveTraceRequest) GetTraceId() []byte
func (*ArchiveTraceRequest) ProtoMessage ¶
func (*ArchiveTraceRequest) ProtoMessage()
func (*ArchiveTraceRequest) Reset ¶
func (m *ArchiveTraceRequest) Reset()
func (*ArchiveTraceRequest) String ¶
func (m *ArchiveTraceRequest) String() string
func (*ArchiveTraceRequest) XXX_DiscardUnknown ¶
func (m *ArchiveTraceRequest) XXX_DiscardUnknown()
func (*ArchiveTraceRequest) XXX_Marshal ¶
func (m *ArchiveTraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArchiveTraceRequest) XXX_Merge ¶
func (m *ArchiveTraceRequest) XXX_Merge(src proto.Message)
func (*ArchiveTraceRequest) XXX_Size ¶
func (m *ArchiveTraceRequest) XXX_Size() int
func (*ArchiveTraceRequest) XXX_Unmarshal ¶
func (m *ArchiveTraceRequest) XXX_Unmarshal(b []byte) error
type ArchiveTraceResponse ¶
type ArchiveTraceResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ArchiveTraceResponse) Descriptor ¶
func (*ArchiveTraceResponse) Descriptor() ([]byte, []int)
func (*ArchiveTraceResponse) ProtoMessage ¶
func (*ArchiveTraceResponse) ProtoMessage()
func (*ArchiveTraceResponse) Reset ¶
func (m *ArchiveTraceResponse) Reset()
func (*ArchiveTraceResponse) String ¶
func (m *ArchiveTraceResponse) String() string
func (*ArchiveTraceResponse) XXX_DiscardUnknown ¶
func (m *ArchiveTraceResponse) XXX_DiscardUnknown()
func (*ArchiveTraceResponse) XXX_Marshal ¶
func (m *ArchiveTraceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ArchiveTraceResponse) XXX_Merge ¶
func (m *ArchiveTraceResponse) XXX_Merge(src proto.Message)
func (*ArchiveTraceResponse) XXX_Size ¶
func (m *ArchiveTraceResponse) XXX_Size() int
func (*ArchiveTraceResponse) XXX_Unmarshal ¶
func (m *ArchiveTraceResponse) XXX_Unmarshal(b []byte) error
type CollectorServiceClient ¶
type CollectorServiceClient interface {
PostSpans(ctx context.Context, in *PostSpansRequest, opts ...grpc.CallOption) (*PostSpansResponse, error)
}
CollectorServiceClient is the client API for CollectorService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCollectorServiceClient ¶
func NewCollectorServiceClient(cc *grpc.ClientConn) CollectorServiceClient
type CollectorServiceServer ¶
type CollectorServiceServer interface {
PostSpans(context.Context, *PostSpansRequest) (*PostSpansResponse, error)
}
CollectorServiceServer is the server API for CollectorService service.
type FindTracesRequest ¶
type FindTracesRequest struct { Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FindTracesRequest) Descriptor ¶
func (*FindTracesRequest) Descriptor() ([]byte, []int)
func (*FindTracesRequest) GetQuery ¶
func (m *FindTracesRequest) GetQuery() *TraceQueryParameters
func (*FindTracesRequest) ProtoMessage ¶
func (*FindTracesRequest) ProtoMessage()
func (*FindTracesRequest) Reset ¶
func (m *FindTracesRequest) Reset()
func (*FindTracesRequest) String ¶
func (m *FindTracesRequest) String() string
func (*FindTracesRequest) XXX_DiscardUnknown ¶
func (m *FindTracesRequest) XXX_DiscardUnknown()
func (*FindTracesRequest) XXX_Marshal ¶
func (m *FindTracesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FindTracesRequest) XXX_Merge ¶
func (m *FindTracesRequest) XXX_Merge(src proto.Message)
func (*FindTracesRequest) XXX_Size ¶
func (m *FindTracesRequest) XXX_Size() int
func (*FindTracesRequest) XXX_Unmarshal ¶
func (m *FindTracesRequest) XXX_Unmarshal(b []byte) error
type GetDependenciesRequest ¶
type GetDependenciesRequest struct { StartTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetDependenciesRequest) Descriptor ¶
func (*GetDependenciesRequest) Descriptor() ([]byte, []int)
func (*GetDependenciesRequest) GetEndTime ¶
func (m *GetDependenciesRequest) GetEndTime() *timestamp.Timestamp
func (*GetDependenciesRequest) GetStartTime ¶
func (m *GetDependenciesRequest) GetStartTime() *timestamp.Timestamp
func (*GetDependenciesRequest) ProtoMessage ¶
func (*GetDependenciesRequest) ProtoMessage()
func (*GetDependenciesRequest) Reset ¶
func (m *GetDependenciesRequest) Reset()
func (*GetDependenciesRequest) String ¶
func (m *GetDependenciesRequest) String() string
func (*GetDependenciesRequest) XXX_DiscardUnknown ¶
func (m *GetDependenciesRequest) XXX_DiscardUnknown()
func (*GetDependenciesRequest) XXX_Marshal ¶
func (m *GetDependenciesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDependenciesRequest) XXX_Merge ¶
func (m *GetDependenciesRequest) XXX_Merge(src proto.Message)
func (*GetDependenciesRequest) XXX_Size ¶
func (m *GetDependenciesRequest) XXX_Size() int
func (*GetDependenciesRequest) XXX_Unmarshal ¶
func (m *GetDependenciesRequest) XXX_Unmarshal(b []byte) error
type GetDependenciesResponse ¶
type GetDependenciesResponse struct { Dependencies []*model.DependencyLink `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetDependenciesResponse) Descriptor ¶
func (*GetDependenciesResponse) Descriptor() ([]byte, []int)
func (*GetDependenciesResponse) GetDependencies ¶
func (m *GetDependenciesResponse) GetDependencies() []*model.DependencyLink
func (*GetDependenciesResponse) ProtoMessage ¶
func (*GetDependenciesResponse) ProtoMessage()
func (*GetDependenciesResponse) Reset ¶
func (m *GetDependenciesResponse) Reset()
func (*GetDependenciesResponse) String ¶
func (m *GetDependenciesResponse) String() string
func (*GetDependenciesResponse) XXX_DiscardUnknown ¶
func (m *GetDependenciesResponse) XXX_DiscardUnknown()
func (*GetDependenciesResponse) XXX_Marshal ¶
func (m *GetDependenciesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDependenciesResponse) XXX_Merge ¶
func (m *GetDependenciesResponse) XXX_Merge(src proto.Message)
func (*GetDependenciesResponse) XXX_Size ¶
func (m *GetDependenciesResponse) XXX_Size() int
func (*GetDependenciesResponse) XXX_Unmarshal ¶
func (m *GetDependenciesResponse) XXX_Unmarshal(b []byte) error
type GetOperationsRequest ¶
type GetOperationsRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` SpanKind string `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetOperationsRequest) Descriptor ¶
func (*GetOperationsRequest) Descriptor() ([]byte, []int)
func (*GetOperationsRequest) GetService ¶
func (m *GetOperationsRequest) GetService() string
func (*GetOperationsRequest) GetSpanKind ¶
func (m *GetOperationsRequest) GetSpanKind() string
func (*GetOperationsRequest) ProtoMessage ¶
func (*GetOperationsRequest) ProtoMessage()
func (*GetOperationsRequest) Reset ¶
func (m *GetOperationsRequest) Reset()
func (*GetOperationsRequest) String ¶
func (m *GetOperationsRequest) String() string
func (*GetOperationsRequest) XXX_DiscardUnknown ¶
func (m *GetOperationsRequest) XXX_DiscardUnknown()
func (*GetOperationsRequest) XXX_Marshal ¶
func (m *GetOperationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetOperationsRequest) XXX_Merge ¶
func (m *GetOperationsRequest) XXX_Merge(src proto.Message)
func (*GetOperationsRequest) XXX_Size ¶
func (m *GetOperationsRequest) XXX_Size() int
func (*GetOperationsRequest) XXX_Unmarshal ¶
func (m *GetOperationsRequest) XXX_Unmarshal(b []byte) error
type GetOperationsResponse ¶
type GetOperationsResponse struct { OperationNames []string `protobuf:"bytes,1,rep,name=operationNames,proto3" json:"operationNames,omitempty"` Operations []*Operation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetOperationsResponse) Descriptor ¶
func (*GetOperationsResponse) Descriptor() ([]byte, []int)
func (*GetOperationsResponse) GetOperationNames ¶
func (m *GetOperationsResponse) GetOperationNames() []string
func (*GetOperationsResponse) GetOperations ¶
func (m *GetOperationsResponse) GetOperations() []*Operation
func (*GetOperationsResponse) ProtoMessage ¶
func (*GetOperationsResponse) ProtoMessage()
func (*GetOperationsResponse) Reset ¶
func (m *GetOperationsResponse) Reset()
func (*GetOperationsResponse) String ¶
func (m *GetOperationsResponse) String() string
func (*GetOperationsResponse) XXX_DiscardUnknown ¶
func (m *GetOperationsResponse) XXX_DiscardUnknown()
func (*GetOperationsResponse) XXX_Marshal ¶
func (m *GetOperationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetOperationsResponse) XXX_Merge ¶
func (m *GetOperationsResponse) XXX_Merge(src proto.Message)
func (*GetOperationsResponse) XXX_Size ¶
func (m *GetOperationsResponse) XXX_Size() int
func (*GetOperationsResponse) XXX_Unmarshal ¶
func (m *GetOperationsResponse) XXX_Unmarshal(b []byte) error
type GetServicesRequest ¶
type GetServicesRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetServicesRequest) Descriptor ¶
func (*GetServicesRequest) Descriptor() ([]byte, []int)
func (*GetServicesRequest) ProtoMessage ¶
func (*GetServicesRequest) ProtoMessage()
func (*GetServicesRequest) Reset ¶
func (m *GetServicesRequest) Reset()
func (*GetServicesRequest) String ¶
func (m *GetServicesRequest) String() string
func (*GetServicesRequest) XXX_DiscardUnknown ¶
func (m *GetServicesRequest) XXX_DiscardUnknown()
func (*GetServicesRequest) XXX_Marshal ¶
func (m *GetServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetServicesRequest) XXX_Merge ¶
func (m *GetServicesRequest) XXX_Merge(src proto.Message)
func (*GetServicesRequest) XXX_Size ¶
func (m *GetServicesRequest) XXX_Size() int
func (*GetServicesRequest) XXX_Unmarshal ¶
func (m *GetServicesRequest) XXX_Unmarshal(b []byte) error
type GetServicesResponse ¶
type GetServicesResponse struct { Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetServicesResponse) Descriptor ¶
func (*GetServicesResponse) Descriptor() ([]byte, []int)
func (*GetServicesResponse) GetServices ¶
func (m *GetServicesResponse) GetServices() []string
func (*GetServicesResponse) ProtoMessage ¶
func (*GetServicesResponse) ProtoMessage()
func (*GetServicesResponse) Reset ¶
func (m *GetServicesResponse) Reset()
func (*GetServicesResponse) String ¶
func (m *GetServicesResponse) String() string
func (*GetServicesResponse) XXX_DiscardUnknown ¶
func (m *GetServicesResponse) XXX_DiscardUnknown()
func (*GetServicesResponse) XXX_Marshal ¶
func (m *GetServicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetServicesResponse) XXX_Merge ¶
func (m *GetServicesResponse) XXX_Merge(src proto.Message)
func (*GetServicesResponse) XXX_Size ¶
func (m *GetServicesResponse) XXX_Size() int
func (*GetServicesResponse) XXX_Unmarshal ¶
func (m *GetServicesResponse) XXX_Unmarshal(b []byte) error
type GetTraceRequest ¶
type GetTraceRequest struct { TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTraceRequest) Descriptor ¶
func (*GetTraceRequest) Descriptor() ([]byte, []int)
func (*GetTraceRequest) GetTraceId ¶
func (m *GetTraceRequest) GetTraceId() []byte
func (*GetTraceRequest) ProtoMessage ¶
func (*GetTraceRequest) ProtoMessage()
func (*GetTraceRequest) Reset ¶
func (m *GetTraceRequest) Reset()
func (*GetTraceRequest) String ¶
func (m *GetTraceRequest) String() string
func (*GetTraceRequest) XXX_DiscardUnknown ¶
func (m *GetTraceRequest) XXX_DiscardUnknown()
func (*GetTraceRequest) XXX_Marshal ¶
func (m *GetTraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTraceRequest) XXX_Merge ¶
func (m *GetTraceRequest) XXX_Merge(src proto.Message)
func (*GetTraceRequest) XXX_Size ¶
func (m *GetTraceRequest) XXX_Size() int
func (*GetTraceRequest) XXX_Unmarshal ¶
func (m *GetTraceRequest) XXX_Unmarshal(b []byte) error
type Operation ¶
type Operation struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` SpanKind string `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Operation) Descriptor ¶
func (*Operation) GetSpanKind ¶
func (*Operation) ProtoMessage ¶
func (*Operation) ProtoMessage()
func (*Operation) XXX_DiscardUnknown ¶
func (m *Operation) XXX_DiscardUnknown()
func (*Operation) XXX_Marshal ¶
func (*Operation) XXX_Unmarshal ¶
type PostSpansRequest ¶
type PostSpansRequest struct { Batch *model.Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PostSpansRequest) Descriptor ¶
func (*PostSpansRequest) Descriptor() ([]byte, []int)
func (*PostSpansRequest) GetBatch ¶
func (m *PostSpansRequest) GetBatch() *model.Batch
func (*PostSpansRequest) ProtoMessage ¶
func (*PostSpansRequest) ProtoMessage()
func (*PostSpansRequest) Reset ¶
func (m *PostSpansRequest) Reset()
func (*PostSpansRequest) String ¶
func (m *PostSpansRequest) String() string
func (*PostSpansRequest) XXX_DiscardUnknown ¶
func (m *PostSpansRequest) XXX_DiscardUnknown()
func (*PostSpansRequest) XXX_Marshal ¶
func (m *PostSpansRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PostSpansRequest) XXX_Merge ¶
func (m *PostSpansRequest) XXX_Merge(src proto.Message)
func (*PostSpansRequest) XXX_Size ¶
func (m *PostSpansRequest) XXX_Size() int
func (*PostSpansRequest) XXX_Unmarshal ¶
func (m *PostSpansRequest) XXX_Unmarshal(b []byte) error
type PostSpansResponse ¶
type PostSpansResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PostSpansResponse) Descriptor ¶
func (*PostSpansResponse) Descriptor() ([]byte, []int)
func (*PostSpansResponse) ProtoMessage ¶
func (*PostSpansResponse) ProtoMessage()
func (*PostSpansResponse) Reset ¶
func (m *PostSpansResponse) Reset()
func (*PostSpansResponse) String ¶
func (m *PostSpansResponse) String() string
func (*PostSpansResponse) XXX_DiscardUnknown ¶
func (m *PostSpansResponse) XXX_DiscardUnknown()
func (*PostSpansResponse) XXX_Marshal ¶
func (m *PostSpansResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PostSpansResponse) XXX_Merge ¶
func (m *PostSpansResponse) XXX_Merge(src proto.Message)
func (*PostSpansResponse) XXX_Size ¶
func (m *PostSpansResponse) XXX_Size() int
func (*PostSpansResponse) XXX_Unmarshal ¶
func (m *PostSpansResponse) XXX_Unmarshal(b []byte) error
type QueryServiceClient ¶
type QueryServiceClient interface { GetTrace(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (QueryService_GetTraceClient, error) ArchiveTrace(ctx context.Context, in *ArchiveTraceRequest, opts ...grpc.CallOption) (*ArchiveTraceResponse, error) FindTraces(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (QueryService_FindTracesClient, error) GetServices(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error) GetOperations(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error) GetDependencies(ctx context.Context, in *GetDependenciesRequest, opts ...grpc.CallOption) (*GetDependenciesResponse, error) }
QueryServiceClient is the client API for QueryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryServiceClient ¶
func NewQueryServiceClient(cc *grpc.ClientConn) QueryServiceClient
type QueryServiceServer ¶
type QueryServiceServer interface { GetTrace(*GetTraceRequest, QueryService_GetTraceServer) error ArchiveTrace(context.Context, *ArchiveTraceRequest) (*ArchiveTraceResponse, error) FindTraces(*FindTracesRequest, QueryService_FindTracesServer) error GetServices(context.Context, *GetServicesRequest) (*GetServicesResponse, error) GetOperations(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error) GetDependencies(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error) }
QueryServiceServer is the server API for QueryService service.
type QueryService_FindTracesClient ¶
type QueryService_FindTracesClient interface { Recv() (*SpansResponseChunk, error) grpc.ClientStream }
type QueryService_FindTracesServer ¶
type QueryService_FindTracesServer interface { Send(*SpansResponseChunk) error grpc.ServerStream }
type QueryService_GetTraceClient ¶
type QueryService_GetTraceClient interface { Recv() (*SpansResponseChunk, error) grpc.ClientStream }
type QueryService_GetTraceServer ¶
type QueryService_GetTraceServer interface { Send(*SpansResponseChunk) error grpc.ServerStream }
type SpansResponseChunk ¶
type SpansResponseChunk struct { Spans []*model.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SpansResponseChunk) Descriptor ¶
func (*SpansResponseChunk) Descriptor() ([]byte, []int)
func (*SpansResponseChunk) GetSpans ¶
func (m *SpansResponseChunk) GetSpans() []*model.Span
func (*SpansResponseChunk) ProtoMessage ¶
func (*SpansResponseChunk) ProtoMessage()
func (*SpansResponseChunk) Reset ¶
func (m *SpansResponseChunk) Reset()
func (*SpansResponseChunk) String ¶
func (m *SpansResponseChunk) String() string
func (*SpansResponseChunk) XXX_DiscardUnknown ¶
func (m *SpansResponseChunk) XXX_DiscardUnknown()
func (*SpansResponseChunk) XXX_Marshal ¶
func (m *SpansResponseChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SpansResponseChunk) XXX_Merge ¶
func (m *SpansResponseChunk) XXX_Merge(src proto.Message)
func (*SpansResponseChunk) XXX_Size ¶
func (m *SpansResponseChunk) XXX_Size() int
func (*SpansResponseChunk) XXX_Unmarshal ¶
func (m *SpansResponseChunk) XXX_Unmarshal(b []byte) error
type TraceQueryParameters ¶
type TraceQueryParameters struct { ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` OperationName string `protobuf:"bytes,2,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ StartTimeMin *timestamp.Timestamp `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3" json:"start_time_min,omitempty"` StartTimeMax *timestamp.Timestamp `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3" json:"start_time_max,omitempty"` DurationMin *duration.Duration `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3" json:"duration_min,omitempty"` DurationMax *duration.Duration `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3" json:"duration_max,omitempty"` SearchDepth int32 `protobuf:"varint,8,opt,name=search_depth,json=searchDepth,proto3" json:"search_depth,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TraceQueryParameters) Descriptor ¶
func (*TraceQueryParameters) Descriptor() ([]byte, []int)
func (*TraceQueryParameters) GetDurationMax ¶
func (m *TraceQueryParameters) GetDurationMax() *duration.Duration
func (*TraceQueryParameters) GetDurationMin ¶
func (m *TraceQueryParameters) GetDurationMin() *duration.Duration
func (*TraceQueryParameters) GetOperationName ¶
func (m *TraceQueryParameters) GetOperationName() string
func (*TraceQueryParameters) GetSearchDepth ¶
func (m *TraceQueryParameters) GetSearchDepth() int32
func (*TraceQueryParameters) GetServiceName ¶
func (m *TraceQueryParameters) GetServiceName() string
func (*TraceQueryParameters) GetStartTimeMax ¶
func (m *TraceQueryParameters) GetStartTimeMax() *timestamp.Timestamp
func (*TraceQueryParameters) GetStartTimeMin ¶
func (m *TraceQueryParameters) GetStartTimeMin() *timestamp.Timestamp
func (*TraceQueryParameters) GetTags ¶
func (m *TraceQueryParameters) GetTags() map[string]string
func (*TraceQueryParameters) ProtoMessage ¶
func (*TraceQueryParameters) ProtoMessage()
func (*TraceQueryParameters) Reset ¶
func (m *TraceQueryParameters) Reset()
func (*TraceQueryParameters) String ¶
func (m *TraceQueryParameters) String() string
func (*TraceQueryParameters) XXX_DiscardUnknown ¶
func (m *TraceQueryParameters) XXX_DiscardUnknown()
func (*TraceQueryParameters) XXX_Marshal ¶
func (m *TraceQueryParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TraceQueryParameters) XXX_Merge ¶
func (m *TraceQueryParameters) XXX_Merge(src proto.Message)
func (*TraceQueryParameters) XXX_Size ¶
func (m *TraceQueryParameters) XXX_Size() int
func (*TraceQueryParameters) XXX_Unmarshal ¶
func (m *TraceQueryParameters) XXX_Unmarshal(b []byte) error
type UnimplementedCollectorServiceServer ¶
type UnimplementedCollectorServiceServer struct { }
UnimplementedCollectorServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedCollectorServiceServer) PostSpans ¶
func (*UnimplementedCollectorServiceServer) PostSpans(ctx context.Context, req *PostSpansRequest) (*PostSpansResponse, error)
type UnimplementedQueryServiceServer ¶
type UnimplementedQueryServiceServer struct { }
UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServiceServer) ArchiveTrace ¶
func (*UnimplementedQueryServiceServer) ArchiveTrace(ctx context.Context, req *ArchiveTraceRequest) (*ArchiveTraceResponse, error)
func (*UnimplementedQueryServiceServer) FindTraces ¶
func (*UnimplementedQueryServiceServer) FindTraces(req *FindTracesRequest, srv QueryService_FindTracesServer) error
func (*UnimplementedQueryServiceServer) GetDependencies ¶
func (*UnimplementedQueryServiceServer) GetDependencies(ctx context.Context, req *GetDependenciesRequest) (*GetDependenciesResponse, error)
func (*UnimplementedQueryServiceServer) GetOperations ¶
func (*UnimplementedQueryServiceServer) GetOperations(ctx context.Context, req *GetOperationsRequest) (*GetOperationsResponse, error)
func (*UnimplementedQueryServiceServer) GetServices ¶
func (*UnimplementedQueryServiceServer) GetServices(ctx context.Context, req *GetServicesRequest) (*GetServicesResponse, error)
func (*UnimplementedQueryServiceServer) GetTrace ¶
func (*UnimplementedQueryServiceServer) GetTrace(req *GetTraceRequest, srv QueryService_GetTraceServer) error