Versions in this module Expand all Collapse all v1 v1.12.0 May 16, 2019 Changes in this version + var ErrIntOverflowStorage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthStorage = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterDependenciesReaderPluginServer(s *grpc.Server, srv DependenciesReaderPluginServer) + func RegisterSpanReaderPluginServer(s *grpc.Server, srv SpanReaderPluginServer) + func RegisterSpanWriterPluginServer(s *grpc.Server, srv SpanWriterPluginServer) + type DependenciesReaderPluginClient interface + GetDependencies func(ctx context.Context, in *GetDependenciesRequest, opts ...grpc.CallOption) (*GetDependenciesResponse, error) + func NewDependenciesReaderPluginClient(cc *grpc.ClientConn) DependenciesReaderPluginClient + type DependenciesReaderPluginServer interface + GetDependencies func(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error) + type FindTraceIDsRequest struct + Query *TraceQueryParameters + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindTraceIDsRequest) Descriptor() ([]byte, []int) + func (*FindTraceIDsRequest) ProtoMessage() + func (m *FindTraceIDsRequest) GetQuery() *TraceQueryParameters + func (m *FindTraceIDsRequest) Marshal() (dAtA []byte, err error) + func (m *FindTraceIDsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FindTraceIDsRequest) Reset() + func (m *FindTraceIDsRequest) Size() (n int) + func (m *FindTraceIDsRequest) String() string + func (m *FindTraceIDsRequest) Unmarshal(dAtA []byte) error + func (m *FindTraceIDsRequest) XXX_DiscardUnknown() + func (m *FindTraceIDsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FindTraceIDsRequest) XXX_Merge(src proto.Message) + func (m *FindTraceIDsRequest) XXX_Size() int + func (m *FindTraceIDsRequest) XXX_Unmarshal(b []byte) error + type FindTraceIDsResponse struct + TraceIDs []github_com_jaegertracing_jaeger_model.TraceID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindTraceIDsResponse) Descriptor() ([]byte, []int) + func (*FindTraceIDsResponse) ProtoMessage() + func (m *FindTraceIDsResponse) Marshal() (dAtA []byte, err error) + func (m *FindTraceIDsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *FindTraceIDsResponse) Reset() + func (m *FindTraceIDsResponse) Size() (n int) + func (m *FindTraceIDsResponse) String() string + func (m *FindTraceIDsResponse) Unmarshal(dAtA []byte) error + func (m *FindTraceIDsResponse) XXX_DiscardUnknown() + func (m *FindTraceIDsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FindTraceIDsResponse) XXX_Merge(src proto.Message) + func (m *FindTraceIDsResponse) XXX_Size() int + func (m *FindTraceIDsResponse) XXX_Unmarshal(b []byte) error + type FindTracesRequest struct + Query *TraceQueryParameters + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindTracesRequest) Descriptor() ([]byte, []int) + func (*FindTracesRequest) ProtoMessage() + func (m *FindTracesRequest) GetQuery() *TraceQueryParameters + func (m *FindTracesRequest) Marshal() (dAtA []byte, err error) + func (m *FindTracesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FindTracesRequest) Reset() + func (m *FindTracesRequest) Size() (n int) + func (m *FindTracesRequest) String() string + func (m *FindTracesRequest) Unmarshal(dAtA []byte) error + 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 struct + EndTime time.Time + StartTime time.Time + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDependenciesRequest) Descriptor() ([]byte, []int) + func (*GetDependenciesRequest) ProtoMessage() + func (m *GetDependenciesRequest) GetEndTime() time.Time + func (m *GetDependenciesRequest) GetStartTime() time.Time + func (m *GetDependenciesRequest) Marshal() (dAtA []byte, err error) + func (m *GetDependenciesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetDependenciesRequest) Reset() + func (m *GetDependenciesRequest) Size() (n int) + func (m *GetDependenciesRequest) String() string + func (m *GetDependenciesRequest) Unmarshal(dAtA []byte) error + 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 struct + Dependencies []model.DependencyLink + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDependenciesResponse) Descriptor() ([]byte, []int) + func (*GetDependenciesResponse) ProtoMessage() + func (m *GetDependenciesResponse) GetDependencies() []model.DependencyLink + func (m *GetDependenciesResponse) Marshal() (dAtA []byte, err error) + func (m *GetDependenciesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetDependenciesResponse) Reset() + func (m *GetDependenciesResponse) Size() (n int) + func (m *GetDependenciesResponse) String() string + func (m *GetDependenciesResponse) Unmarshal(dAtA []byte) error + 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 struct + Service string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetOperationsRequest) Descriptor() ([]byte, []int) + func (*GetOperationsRequest) ProtoMessage() + func (m *GetOperationsRequest) GetService() string + func (m *GetOperationsRequest) Marshal() (dAtA []byte, err error) + func (m *GetOperationsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetOperationsRequest) Reset() + func (m *GetOperationsRequest) Size() (n int) + func (m *GetOperationsRequest) String() string + func (m *GetOperationsRequest) Unmarshal(dAtA []byte) error + 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 struct + Operations []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetOperationsResponse) Descriptor() ([]byte, []int) + func (*GetOperationsResponse) ProtoMessage() + func (m *GetOperationsResponse) GetOperations() []string + func (m *GetOperationsResponse) Marshal() (dAtA []byte, err error) + func (m *GetOperationsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetOperationsResponse) Reset() + func (m *GetOperationsResponse) Size() (n int) + func (m *GetOperationsResponse) String() string + func (m *GetOperationsResponse) Unmarshal(dAtA []byte) error + 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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetServicesRequest) Descriptor() ([]byte, []int) + func (*GetServicesRequest) ProtoMessage() + func (m *GetServicesRequest) Marshal() (dAtA []byte, err error) + func (m *GetServicesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetServicesRequest) Reset() + func (m *GetServicesRequest) Size() (n int) + func (m *GetServicesRequest) String() string + func (m *GetServicesRequest) Unmarshal(dAtA []byte) error + 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 struct + Services []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetServicesResponse) Descriptor() ([]byte, []int) + func (*GetServicesResponse) ProtoMessage() + func (m *GetServicesResponse) GetServices() []string + func (m *GetServicesResponse) Marshal() (dAtA []byte, err error) + func (m *GetServicesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetServicesResponse) Reset() + func (m *GetServicesResponse) Size() (n int) + func (m *GetServicesResponse) String() string + func (m *GetServicesResponse) Unmarshal(dAtA []byte) error + 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 struct + TraceID github_com_jaegertracing_jaeger_model.TraceID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetTraceRequest) Descriptor() ([]byte, []int) + func (*GetTraceRequest) ProtoMessage() + func (m *GetTraceRequest) Marshal() (dAtA []byte, err error) + func (m *GetTraceRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetTraceRequest) Reset() + func (m *GetTraceRequest) Size() (n int) + func (m *GetTraceRequest) String() string + func (m *GetTraceRequest) Unmarshal(dAtA []byte) error + 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 SpanReaderPluginClient interface + FindTraceIDs func(ctx context.Context, in *FindTraceIDsRequest, opts ...grpc.CallOption) (*FindTraceIDsResponse, error) + FindTraces func(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (SpanReaderPlugin_FindTracesClient, error) + GetOperations func(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error) + GetServices func(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error) + GetTrace func(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (SpanReaderPlugin_GetTraceClient, error) + func NewSpanReaderPluginClient(cc *grpc.ClientConn) SpanReaderPluginClient + type SpanReaderPluginServer interface + FindTraceIDs func(context.Context, *FindTraceIDsRequest) (*FindTraceIDsResponse, error) + FindTraces func(*FindTracesRequest, SpanReaderPlugin_FindTracesServer) error + GetOperations func(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error) + GetServices func(context.Context, *GetServicesRequest) (*GetServicesResponse, error) + GetTrace func(*GetTraceRequest, SpanReaderPlugin_GetTraceServer) error + type SpanReaderPlugin_FindTracesClient interface + Recv func() (*SpansResponseChunk, error) + type SpanReaderPlugin_FindTracesServer interface + Send func(*SpansResponseChunk) error + type SpanReaderPlugin_GetTraceClient interface + Recv func() (*SpansResponseChunk, error) + type SpanReaderPlugin_GetTraceServer interface + Send func(*SpansResponseChunk) error + type SpanWriterPluginClient interface + WriteSpan func(ctx context.Context, in *WriteSpanRequest, opts ...grpc.CallOption) (*WriteSpanResponse, error) + func NewSpanWriterPluginClient(cc *grpc.ClientConn) SpanWriterPluginClient + type SpanWriterPluginServer interface + WriteSpan func(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error) + type SpansResponseChunk struct + Spans []model.Span + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SpansResponseChunk) Descriptor() ([]byte, []int) + func (*SpansResponseChunk) ProtoMessage() + func (m *SpansResponseChunk) GetSpans() []model.Span + func (m *SpansResponseChunk) Marshal() (dAtA []byte, err error) + func (m *SpansResponseChunk) MarshalTo(dAtA []byte) (int, error) + func (m *SpansResponseChunk) Reset() + func (m *SpansResponseChunk) Size() (n int) + func (m *SpansResponseChunk) String() string + func (m *SpansResponseChunk) Unmarshal(dAtA []byte) error + 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 struct + DurationMax time.Duration + DurationMin time.Duration + NumTraces int32 + OperationName string + ServiceName string + StartTimeMax time.Time + StartTimeMin time.Time + Tags map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TraceQueryParameters) Descriptor() ([]byte, []int) + func (*TraceQueryParameters) ProtoMessage() + func (m *TraceQueryParameters) GetDurationMax() time.Duration + func (m *TraceQueryParameters) GetDurationMin() time.Duration + func (m *TraceQueryParameters) GetNumTraces() int32 + func (m *TraceQueryParameters) GetOperationName() string + func (m *TraceQueryParameters) GetServiceName() string + func (m *TraceQueryParameters) GetStartTimeMax() time.Time + func (m *TraceQueryParameters) GetStartTimeMin() time.Time + func (m *TraceQueryParameters) GetTags() map[string]string + func (m *TraceQueryParameters) Marshal() (dAtA []byte, err error) + func (m *TraceQueryParameters) MarshalTo(dAtA []byte) (int, error) + func (m *TraceQueryParameters) Reset() + func (m *TraceQueryParameters) Size() (n int) + func (m *TraceQueryParameters) String() string + func (m *TraceQueryParameters) Unmarshal(dAtA []byte) error + 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 WriteSpanRequest struct + Span *model.Span + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteSpanRequest) Descriptor() ([]byte, []int) + func (*WriteSpanRequest) ProtoMessage() + func (m *WriteSpanRequest) GetSpan() *model.Span + func (m *WriteSpanRequest) Marshal() (dAtA []byte, err error) + func (m *WriteSpanRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WriteSpanRequest) Reset() + func (m *WriteSpanRequest) Size() (n int) + func (m *WriteSpanRequest) String() string + func (m *WriteSpanRequest) Unmarshal(dAtA []byte) error + func (m *WriteSpanRequest) XXX_DiscardUnknown() + func (m *WriteSpanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteSpanRequest) XXX_Merge(src proto.Message) + func (m *WriteSpanRequest) XXX_Size() int + func (m *WriteSpanRequest) XXX_Unmarshal(b []byte) error + type WriteSpanResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteSpanResponse) Descriptor() ([]byte, []int) + func (*WriteSpanResponse) ProtoMessage() + func (m *WriteSpanResponse) Marshal() (dAtA []byte, err error) + func (m *WriteSpanResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WriteSpanResponse) Reset() + func (m *WriteSpanResponse) Size() (n int) + func (m *WriteSpanResponse) String() string + func (m *WriteSpanResponse) Unmarshal(dAtA []byte) error + func (m *WriteSpanResponse) XXX_DiscardUnknown() + func (m *WriteSpanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteSpanResponse) XXX_Merge(src proto.Message) + func (m *WriteSpanResponse) XXX_Size() int + func (m *WriteSpanResponse) XXX_Unmarshal(b []byte) error
Go to main page