storage_v1

package
v1.42.0 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2023 License: Apache-2.0 Imports: 13 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStorage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStorage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStorage = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterArchiveSpanReaderPluginServer added in v1.20.0 

func RegisterArchiveSpanReaderPluginServer(s *grpc.Server, srv ArchiveSpanReaderPluginServer)

func RegisterArchiveSpanWriterPluginServer added in v1.20.0 

func RegisterArchiveSpanWriterPluginServer(s *grpc.Server, srv ArchiveSpanWriterPluginServer)

func RegisterDependenciesReaderPluginServer 

func RegisterDependenciesReaderPluginServer(s *grpc.Server, srv DependenciesReaderPluginServer)

func RegisterPluginCapabilitiesServer added in v1.20.0 

func RegisterPluginCapabilitiesServer(s *grpc.Server, srv PluginCapabilitiesServer)

func RegisterSpanReaderPluginServer 

func RegisterSpanReaderPluginServer(s *grpc.Server, srv SpanReaderPluginServer)

func RegisterSpanWriterPluginServer 

func RegisterSpanWriterPluginServer(s *grpc.Server, srv SpanWriterPluginServer)

func RegisterStreamingSpanWriterPluginServer added in v1.34.0 

func RegisterStreamingSpanWriterPluginServer(s *grpc.Server, srv StreamingSpanWriterPluginServer)

Types

type ArchiveSpanReaderPluginClient added in v1.20.0 

type ArchiveSpanReaderPluginClient interface {
	// spanstore/Reader
	GetArchiveTrace(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (ArchiveSpanReaderPlugin_GetArchiveTraceClient, error)
}

ArchiveSpanReaderPluginClient is the client API for ArchiveSpanReaderPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewArchiveSpanReaderPluginClient added in v1.20.0 

func NewArchiveSpanReaderPluginClient(cc *grpc.ClientConn) ArchiveSpanReaderPluginClient

type ArchiveSpanReaderPluginServer added in v1.20.0 

type ArchiveSpanReaderPluginServer interface {
	// spanstore/Reader
	GetArchiveTrace(*GetTraceRequest, ArchiveSpanReaderPlugin_GetArchiveTraceServer) error
}

ArchiveSpanReaderPluginServer is the server API for ArchiveSpanReaderPlugin service.

type ArchiveSpanReaderPlugin_GetArchiveTraceClient added in v1.20.0 

type ArchiveSpanReaderPlugin_GetArchiveTraceClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type ArchiveSpanReaderPlugin_GetArchiveTraceServer added in v1.20.0 

type ArchiveSpanReaderPlugin_GetArchiveTraceServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type ArchiveSpanWriterPluginClient added in v1.20.0 

type ArchiveSpanWriterPluginClient interface {
	// spanstore/Writer
	WriteArchiveSpan(ctx context.Context, in *WriteSpanRequest, opts ...grpc.CallOption) (*WriteSpanResponse, error)
}

ArchiveSpanWriterPluginClient is the client API for ArchiveSpanWriterPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewArchiveSpanWriterPluginClient added in v1.20.0 

func NewArchiveSpanWriterPluginClient(cc *grpc.ClientConn) ArchiveSpanWriterPluginClient

type ArchiveSpanWriterPluginServer added in v1.20.0 

type ArchiveSpanWriterPluginServer interface {
	// spanstore/Writer
	WriteArchiveSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)
}

ArchiveSpanWriterPluginServer is the server API for ArchiveSpanWriterPlugin service.

type CapabilitiesRequest added in v1.20.0 

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

empty; extensible in the future

func (*CapabilitiesRequest) Descriptor added in v1.20.0 

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

func (*CapabilitiesRequest) Marshal added in v1.20.0 

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

func (*CapabilitiesRequest) MarshalTo added in v1.20.0 

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

func (*CapabilitiesRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *CapabilitiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CapabilitiesRequest) ProtoMessage added in v1.20.0 

func (*CapabilitiesRequest) ProtoMessage()

func (*CapabilitiesRequest) Reset added in v1.20.0 

func (m *CapabilitiesRequest) Reset()

func (*CapabilitiesRequest) Size added in v1.20.0 

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

func (*CapabilitiesRequest) String added in v1.20.0 

func (m *CapabilitiesRequest) String() string

func (*CapabilitiesRequest) Unmarshal added in v1.20.0 

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

func (*CapabilitiesRequest) XXX_DiscardUnknown added in v1.20.0 

func (m *CapabilitiesRequest) XXX_DiscardUnknown()

func (*CapabilitiesRequest) XXX_Marshal added in v1.20.0 

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

func (*CapabilitiesRequest) XXX_Merge added in v1.20.0 

func (m *CapabilitiesRequest) XXX_Merge(src proto.Message)

func (*CapabilitiesRequest) XXX_Size added in v1.20.0 

func (m *CapabilitiesRequest) XXX_Size() int

func (*CapabilitiesRequest) XXX_Unmarshal added in v1.20.0 

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

type CapabilitiesResponse added in v1.20.0 

type CapabilitiesResponse struct {
	ArchiveSpanReader    bool     `protobuf:"varint,1,opt,name=archiveSpanReader,proto3" json:"archiveSpanReader,omitempty"`
	ArchiveSpanWriter    bool     `protobuf:"varint,2,opt,name=archiveSpanWriter,proto3" json:"archiveSpanWriter,omitempty"`
	StreamingSpanWriter  bool     `protobuf:"varint,3,opt,name=streamingSpanWriter,proto3" json:"streamingSpanWriter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CapabilitiesResponse) Descriptor added in v1.20.0 

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

func (*CapabilitiesResponse) GetArchiveSpanReader added in v1.20.0 

func (m *CapabilitiesResponse) GetArchiveSpanReader() bool

func (*CapabilitiesResponse) GetArchiveSpanWriter added in v1.20.0 

func (m *CapabilitiesResponse) GetArchiveSpanWriter() bool

func (*CapabilitiesResponse) GetStreamingSpanWriter added in v1.34.0 

func (m *CapabilitiesResponse) GetStreamingSpanWriter() bool

func (*CapabilitiesResponse) Marshal added in v1.20.0 

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

func (*CapabilitiesResponse) MarshalTo added in v1.20.0 

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

func (*CapabilitiesResponse) MarshalToSizedBuffer added in v1.24.0 

func (m *CapabilitiesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CapabilitiesResponse) ProtoMessage added in v1.20.0 

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) Reset added in v1.20.0 

func (m *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) Size added in v1.20.0 

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

func (*CapabilitiesResponse) String added in v1.20.0 

func (m *CapabilitiesResponse) String() string

func (*CapabilitiesResponse) Unmarshal added in v1.20.0 

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

func (*CapabilitiesResponse) XXX_DiscardUnknown added in v1.20.0 

func (m *CapabilitiesResponse) XXX_DiscardUnknown()

func (*CapabilitiesResponse) XXX_Marshal added in v1.20.0 

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

func (*CapabilitiesResponse) XXX_Merge added in v1.20.0 

func (m *CapabilitiesResponse) XXX_Merge(src proto.Message)

func (*CapabilitiesResponse) XXX_Size added in v1.20.0 

func (m *CapabilitiesResponse) XXX_Size() int

func (*CapabilitiesResponse) XXX_Unmarshal added in v1.20.0 

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

type CloseWriterRequest added in v1.27.0 

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

empty; extensible in the future

func (*CloseWriterRequest) Descriptor added in v1.27.0 

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

func (*CloseWriterRequest) Marshal added in v1.27.0 

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

func (*CloseWriterRequest) MarshalTo added in v1.27.0 

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

func (*CloseWriterRequest) MarshalToSizedBuffer added in v1.27.0 

func (m *CloseWriterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CloseWriterRequest) ProtoMessage added in v1.27.0 

func (*CloseWriterRequest) ProtoMessage()

func (*CloseWriterRequest) Reset added in v1.27.0 

func (m *CloseWriterRequest) Reset()

func (*CloseWriterRequest) Size added in v1.27.0 

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

func (*CloseWriterRequest) String added in v1.27.0 

func (m *CloseWriterRequest) String() string

func (*CloseWriterRequest) Unmarshal added in v1.27.0 

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

func (*CloseWriterRequest) XXX_DiscardUnknown added in v1.27.0 

func (m *CloseWriterRequest) XXX_DiscardUnknown()

func (*CloseWriterRequest) XXX_Marshal added in v1.27.0 

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

func (*CloseWriterRequest) XXX_Merge added in v1.27.0 

func (m *CloseWriterRequest) XXX_Merge(src proto.Message)

func (*CloseWriterRequest) XXX_Size added in v1.27.0 

func (m *CloseWriterRequest) XXX_Size() int

func (*CloseWriterRequest) XXX_Unmarshal added in v1.27.0 

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

type CloseWriterResponse added in v1.27.0 

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

empty; extensible in the future

func (*CloseWriterResponse) Descriptor added in v1.27.0 

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

func (*CloseWriterResponse) Marshal added in v1.27.0 

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

func (*CloseWriterResponse) MarshalTo added in v1.27.0 

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

func (*CloseWriterResponse) MarshalToSizedBuffer added in v1.27.0 

func (m *CloseWriterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CloseWriterResponse) ProtoMessage added in v1.27.0 

func (*CloseWriterResponse) ProtoMessage()

func (*CloseWriterResponse) Reset added in v1.27.0 

func (m *CloseWriterResponse) Reset()

func (*CloseWriterResponse) Size added in v1.27.0 

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

func (*CloseWriterResponse) String added in v1.27.0 

func (m *CloseWriterResponse) String() string

func (*CloseWriterResponse) Unmarshal added in v1.27.0 

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

func (*CloseWriterResponse) XXX_DiscardUnknown added in v1.27.0 

func (m *CloseWriterResponse) XXX_DiscardUnknown()

func (*CloseWriterResponse) XXX_Marshal added in v1.27.0 

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

func (*CloseWriterResponse) XXX_Merge added in v1.27.0 

func (m *CloseWriterResponse) XXX_Merge(src proto.Message)

func (*CloseWriterResponse) XXX_Size added in v1.27.0 

func (m *CloseWriterResponse) XXX_Size() int

func (*CloseWriterResponse) XXX_Unmarshal added in v1.27.0 

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

type DependenciesReaderPluginClient 

type DependenciesReaderPluginClient interface {
	// dependencystore/Reader
	GetDependencies(ctx context.Context, in *GetDependenciesRequest, opts ...grpc.CallOption) (*GetDependenciesResponse, error)
}

DependenciesReaderPluginClient is the client API for DependenciesReaderPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDependenciesReaderPluginClient 

func NewDependenciesReaderPluginClient(cc *grpc.ClientConn) DependenciesReaderPluginClient

type DependenciesReaderPluginServer 

type DependenciesReaderPluginServer interface {
	// dependencystore/Reader
	GetDependencies(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error)
}

DependenciesReaderPluginServer is the server API for DependenciesReaderPlugin service.

type FindTraceIDsRequest 

type FindTraceIDsRequest 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 (*FindTraceIDsRequest) Descriptor 

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

func (*FindTraceIDsRequest) GetQuery 

func (m *FindTraceIDsRequest) GetQuery() *TraceQueryParameters

func (*FindTraceIDsRequest) Marshal 

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

func (*FindTraceIDsRequest) MarshalTo 

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

func (*FindTraceIDsRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *FindTraceIDsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FindTraceIDsRequest) ProtoMessage 

func (*FindTraceIDsRequest) ProtoMessage()

func (*FindTraceIDsRequest) Reset 

func (m *FindTraceIDsRequest) Reset()

func (*FindTraceIDsRequest) Size 

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

func (*FindTraceIDsRequest) String 

func (m *FindTraceIDsRequest) String() string

func (*FindTraceIDsRequest) Unmarshal 

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

func (*FindTraceIDsRequest) XXX_DiscardUnknown 

func (m *FindTraceIDsRequest) XXX_DiscardUnknown()

func (*FindTraceIDsRequest) XXX_Marshal 

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

func (*FindTraceIDsRequest) XXX_Merge 

func (m *FindTraceIDsRequest) XXX_Merge(src proto.Message)

func (*FindTraceIDsRequest) XXX_Size 

func (m *FindTraceIDsRequest) XXX_Size() int

func (*FindTraceIDsRequest) XXX_Unmarshal 

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

type FindTraceIDsResponse 

type FindTraceIDsResponse struct {
	TraceIDs             []github_com_jaegertracing_jaeger_model.TraceID `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
	XXX_unrecognized     []byte                                          `json:"-"`
	XXX_sizecache        int32                                           `json:"-"`
}

func (*FindTraceIDsResponse) Descriptor 

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

func (*FindTraceIDsResponse) Marshal 

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

func (*FindTraceIDsResponse) MarshalTo 

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

func (*FindTraceIDsResponse) MarshalToSizedBuffer added in v1.24.0 

func (m *FindTraceIDsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FindTraceIDsResponse) ProtoMessage 

func (*FindTraceIDsResponse) ProtoMessage()

func (*FindTraceIDsResponse) Reset 

func (m *FindTraceIDsResponse) Reset()

func (*FindTraceIDsResponse) Size 

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

func (*FindTraceIDsResponse) String 

func (m *FindTraceIDsResponse) String() string

func (*FindTraceIDsResponse) Unmarshal 

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

func (*FindTraceIDsResponse) XXX_DiscardUnknown 

func (m *FindTraceIDsResponse) XXX_DiscardUnknown()

func (*FindTraceIDsResponse) XXX_Marshal 

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

func (*FindTraceIDsResponse) XXX_Merge 

func (m *FindTraceIDsResponse) XXX_Merge(src proto.Message)

func (*FindTraceIDsResponse) XXX_Size 

func (m *FindTraceIDsResponse) XXX_Size() int

func (*FindTraceIDsResponse) XXX_Unmarshal 

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

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

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

func (*FindTracesRequest) MarshalTo 

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

func (*FindTracesRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *FindTracesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FindTracesRequest) ProtoMessage 

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) Reset 

func (m *FindTracesRequest) Reset()

func (*FindTracesRequest) Size 

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

func (*FindTracesRequest) String 

func (m *FindTracesRequest) String() string

func (*FindTracesRequest) Unmarshal 

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

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            time.Time `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	EndTime              time.Time `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time"`
	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() time.Time

func (*GetDependenciesRequest) GetStartTime 

func (m *GetDependenciesRequest) GetStartTime() time.Time

func (*GetDependenciesRequest) Marshal 

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

func (*GetDependenciesRequest) MarshalTo 

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

func (*GetDependenciesRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *GetDependenciesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDependenciesRequest) ProtoMessage 

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) Reset 

func (m *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) Size 

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

func (*GetDependenciesRequest) String 

func (m *GetDependenciesRequest) String() string

func (*GetDependenciesRequest) Unmarshal 

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

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"`
	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) Marshal 

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

func (*GetDependenciesResponse) MarshalTo 

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

func (*GetDependenciesResponse) MarshalToSizedBuffer added in v1.24.0 

func (m *GetDependenciesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDependenciesResponse) ProtoMessage 

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) Reset 

func (m *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) Size 

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

func (*GetDependenciesResponse) String 

func (m *GetDependenciesResponse) String() string

func (*GetDependenciesResponse) Unmarshal 

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

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 added in v1.16.0 

func (m *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) Marshal 

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

func (*GetOperationsRequest) MarshalTo 

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

func (*GetOperationsRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *GetOperationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetOperationsRequest) ProtoMessage 

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) Reset 

func (m *GetOperationsRequest) Reset()

func (*GetOperationsRequest) Size 

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

func (*GetOperationsRequest) String 

func (m *GetOperationsRequest) String() string

func (*GetOperationsRequest) Unmarshal 

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

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 added in v1.16.0 

func (m *GetOperationsResponse) GetOperationNames() []string

func (*GetOperationsResponse) GetOperations 

func (m *GetOperationsResponse) GetOperations() []*Operation

func (*GetOperationsResponse) Marshal 

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

func (*GetOperationsResponse) MarshalTo 

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

func (*GetOperationsResponse) MarshalToSizedBuffer added in v1.24.0 

func (m *GetOperationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetOperationsResponse) ProtoMessage 

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) Reset 

func (m *GetOperationsResponse) Reset()

func (*GetOperationsResponse) Size 

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

func (*GetOperationsResponse) String 

func (m *GetOperationsResponse) String() string

func (*GetOperationsResponse) Unmarshal 

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

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

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

func (*GetServicesRequest) MarshalTo 

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

func (*GetServicesRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *GetServicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetServicesRequest) ProtoMessage 

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) Reset 

func (m *GetServicesRequest) Reset()

func (*GetServicesRequest) Size 

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

func (*GetServicesRequest) String 

func (m *GetServicesRequest) String() string

func (*GetServicesRequest) Unmarshal 

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

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

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

func (*GetServicesResponse) MarshalTo 

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

func (*GetServicesResponse) MarshalToSizedBuffer added in v1.24.0 

func (m *GetServicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetServicesResponse) ProtoMessage 

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) Reset 

func (m *GetServicesResponse) Reset()

func (*GetServicesResponse) Size 

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

func (*GetServicesResponse) String 

func (m *GetServicesResponse) String() string

func (*GetServicesResponse) Unmarshal 

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

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              github_com_jaegertracing_jaeger_model.TraceID `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*GetTraceRequest) Descriptor 

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

func (*GetTraceRequest) Marshal 

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

func (*GetTraceRequest) MarshalTo 

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

func (*GetTraceRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *GetTraceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTraceRequest) ProtoMessage 

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) Reset 

func (m *GetTraceRequest) Reset()

func (*GetTraceRequest) Size 

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

func (*GetTraceRequest) String 

func (m *GetTraceRequest) String() string

func (*GetTraceRequest) Unmarshal 

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

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 added in v1.16.0 

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 added in v1.16.0 

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

func (*Operation) GetName added in v1.16.0 

func (m *Operation) GetName() string

func (*Operation) GetSpanKind added in v1.16.0 

func (m *Operation) GetSpanKind() string

func (*Operation) Marshal added in v1.16.0 

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

func (*Operation) MarshalTo added in v1.16.0 

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

func (*Operation) MarshalToSizedBuffer added in v1.24.0 

func (m *Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operation) ProtoMessage added in v1.16.0 

func (*Operation) ProtoMessage()

func (*Operation) Reset added in v1.16.0 

func (m *Operation) Reset()

func (*Operation) Size added in v1.16.0 

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

func (*Operation) String added in v1.16.0 

func (m *Operation) String() string

func (*Operation) Unmarshal added in v1.16.0 

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

func (*Operation) XXX_DiscardUnknown added in v1.16.0 

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal added in v1.16.0 

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

func (*Operation) XXX_Merge added in v1.16.0 

func (m *Operation) XXX_Merge(src proto.Message)

func (*Operation) XXX_Size added in v1.16.0 

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal added in v1.16.0 

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

type PluginCapabilitiesClient added in v1.20.0 

type PluginCapabilitiesClient interface {
	Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
}

PluginCapabilitiesClient is the client API for PluginCapabilities service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPluginCapabilitiesClient added in v1.20.0 

func NewPluginCapabilitiesClient(cc *grpc.ClientConn) PluginCapabilitiesClient

type PluginCapabilitiesServer added in v1.20.0 

type PluginCapabilitiesServer interface {
	Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
}

PluginCapabilitiesServer is the server API for PluginCapabilities service.

type SpanReaderPluginClient 

type SpanReaderPluginClient interface {
	// spanstore/Reader
	GetTrace(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (SpanReaderPlugin_GetTraceClient, error)
	GetServices(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error)
	GetOperations(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error)
	FindTraces(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (SpanReaderPlugin_FindTracesClient, error)
	FindTraceIDs(ctx context.Context, in *FindTraceIDsRequest, opts ...grpc.CallOption) (*FindTraceIDsResponse, error)
}

SpanReaderPluginClient is the client API for SpanReaderPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSpanReaderPluginClient 

func NewSpanReaderPluginClient(cc *grpc.ClientConn) SpanReaderPluginClient

type SpanReaderPluginServer 

type SpanReaderPluginServer interface {
	// spanstore/Reader
	GetTrace(*GetTraceRequest, SpanReaderPlugin_GetTraceServer) error
	GetServices(context.Context, *GetServicesRequest) (*GetServicesResponse, error)
	GetOperations(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)
	FindTraces(*FindTracesRequest, SpanReaderPlugin_FindTracesServer) error
	FindTraceIDs(context.Context, *FindTraceIDsRequest) (*FindTraceIDsResponse, error)
}

SpanReaderPluginServer is the server API for SpanReaderPlugin service.

type SpanReaderPlugin_FindTracesClient 

type SpanReaderPlugin_FindTracesClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type SpanReaderPlugin_FindTracesServer 

type SpanReaderPlugin_FindTracesServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type SpanReaderPlugin_GetTraceClient 

type SpanReaderPlugin_GetTraceClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type SpanReaderPlugin_GetTraceServer 

type SpanReaderPlugin_GetTraceServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type SpanWriterPluginClient 

type SpanWriterPluginClient interface {
	// spanstore/Writer
	WriteSpan(ctx context.Context, in *WriteSpanRequest, opts ...grpc.CallOption) (*WriteSpanResponse, error)
	Close(ctx context.Context, in *CloseWriterRequest, opts ...grpc.CallOption) (*CloseWriterResponse, error)
}

SpanWriterPluginClient is the client API for SpanWriterPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSpanWriterPluginClient 

func NewSpanWriterPluginClient(cc *grpc.ClientConn) SpanWriterPluginClient

type SpanWriterPluginServer 

type SpanWriterPluginServer interface {
	// spanstore/Writer
	WriteSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)
	Close(context.Context, *CloseWriterRequest) (*CloseWriterResponse, error)
}

SpanWriterPluginServer is the server API for SpanWriterPlugin service.

type SpansResponseChunk 

type SpansResponseChunk struct {
	Spans                []model.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans"`
	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) Marshal 

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

func (*SpansResponseChunk) MarshalTo 

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

func (*SpansResponseChunk) MarshalToSizedBuffer added in v1.24.0 

func (m *SpansResponseChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SpansResponseChunk) ProtoMessage 

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) Reset 

func (m *SpansResponseChunk) Reset()

func (*SpansResponseChunk) Size 

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

func (*SpansResponseChunk) String 

func (m *SpansResponseChunk) String() string

func (*SpansResponseChunk) Unmarshal 

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

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 StreamingSpanWriterPluginClient added in v1.34.0 

type StreamingSpanWriterPluginClient interface {
	WriteSpanStream(ctx context.Context, opts ...grpc.CallOption) (StreamingSpanWriterPlugin_WriteSpanStreamClient, error)
}

StreamingSpanWriterPluginClient is the client API for StreamingSpanWriterPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStreamingSpanWriterPluginClient added in v1.34.0 

func NewStreamingSpanWriterPluginClient(cc *grpc.ClientConn) StreamingSpanWriterPluginClient

type StreamingSpanWriterPluginServer added in v1.34.0 

type StreamingSpanWriterPluginServer interface {
	WriteSpanStream(StreamingSpanWriterPlugin_WriteSpanStreamServer) error
}

StreamingSpanWriterPluginServer is the server API for StreamingSpanWriterPlugin service.

type StreamingSpanWriterPlugin_WriteSpanStreamClient added in v1.34.0 

type StreamingSpanWriterPlugin_WriteSpanStreamClient interface {
	Send(*WriteSpanRequest) error
	CloseAndRecv() (*WriteSpanResponse, error)
	grpc.ClientStream
}

type StreamingSpanWriterPlugin_WriteSpanStreamServer added in v1.34.0 

type StreamingSpanWriterPlugin_WriteSpanStreamServer interface {
	SendAndClose(*WriteSpanResponse) error
	Recv() (*WriteSpanRequest, error)
	grpc.ServerStream
}

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         time.Time         `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3,stdtime" json:"start_time_min"`
	StartTimeMax         time.Time         `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3,stdtime" json:"start_time_max"`
	DurationMin          time.Duration     `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3,stdduration" json:"duration_min"`
	DurationMax          time.Duration     `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3,stdduration" json:"duration_max"`
	NumTraces            int32             `protobuf:"varint,8,opt,name=num_traces,json=numTraces,proto3" json:"num_traces,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() time.Duration

func (*TraceQueryParameters) GetDurationMin 

func (m *TraceQueryParameters) GetDurationMin() time.Duration

func (*TraceQueryParameters) GetNumTraces 

func (m *TraceQueryParameters) GetNumTraces() int32

func (*TraceQueryParameters) GetOperationName 

func (m *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetServiceName 

func (m *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax 

func (m *TraceQueryParameters) GetStartTimeMax() time.Time

func (*TraceQueryParameters) GetStartTimeMin 

func (m *TraceQueryParameters) GetStartTimeMin() time.Time

func (*TraceQueryParameters) GetTags 

func (m *TraceQueryParameters) GetTags() map[string]string

func (*TraceQueryParameters) Marshal 

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

func (*TraceQueryParameters) MarshalTo 

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

func (*TraceQueryParameters) MarshalToSizedBuffer added in v1.24.0 

func (m *TraceQueryParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TraceQueryParameters) ProtoMessage 

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) Reset 

func (m *TraceQueryParameters) Reset()

func (*TraceQueryParameters) Size 

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

func (*TraceQueryParameters) String 

func (m *TraceQueryParameters) String() string

func (*TraceQueryParameters) Unmarshal 

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

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 UnimplementedArchiveSpanReaderPluginServer added in v1.24.0 

type UnimplementedArchiveSpanReaderPluginServer struct {
}

UnimplementedArchiveSpanReaderPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedArchiveSpanReaderPluginServer) GetArchiveTrace added in v1.24.0 

func (*UnimplementedArchiveSpanReaderPluginServer) GetArchiveTrace(req *GetTraceRequest, srv ArchiveSpanReaderPlugin_GetArchiveTraceServer) error

type UnimplementedArchiveSpanWriterPluginServer added in v1.24.0 

type UnimplementedArchiveSpanWriterPluginServer struct {
}

UnimplementedArchiveSpanWriterPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedArchiveSpanWriterPluginServer) WriteArchiveSpan added in v1.24.0 

func (*UnimplementedArchiveSpanWriterPluginServer) WriteArchiveSpan(ctx context.Context, req *WriteSpanRequest) (*WriteSpanResponse, error)

type UnimplementedDependenciesReaderPluginServer added in v1.24.0 

type UnimplementedDependenciesReaderPluginServer struct {
}

UnimplementedDependenciesReaderPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedDependenciesReaderPluginServer) GetDependencies added in v1.24.0 

func (*UnimplementedDependenciesReaderPluginServer) GetDependencies(ctx context.Context, req *GetDependenciesRequest) (*GetDependenciesResponse, error)

type UnimplementedPluginCapabilitiesServer added in v1.24.0 

type UnimplementedPluginCapabilitiesServer struct {
}

UnimplementedPluginCapabilitiesServer can be embedded to have forward compatible implementations.

func (*UnimplementedPluginCapabilitiesServer) Capabilities added in v1.24.0 

func (*UnimplementedPluginCapabilitiesServer) Capabilities(ctx context.Context, req *CapabilitiesRequest) (*CapabilitiesResponse, error)

type UnimplementedSpanReaderPluginServer added in v1.24.0 

type UnimplementedSpanReaderPluginServer struct {
}

UnimplementedSpanReaderPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedSpanReaderPluginServer) FindTraceIDs added in v1.24.0 

func (*UnimplementedSpanReaderPluginServer) FindTraceIDs(ctx context.Context, req *FindTraceIDsRequest) (*FindTraceIDsResponse, error)

func (*UnimplementedSpanReaderPluginServer) FindTraces added in v1.24.0 

func (*UnimplementedSpanReaderPluginServer) FindTraces(req *FindTracesRequest, srv SpanReaderPlugin_FindTracesServer) error

func (*UnimplementedSpanReaderPluginServer) GetOperations added in v1.24.0 

func (*UnimplementedSpanReaderPluginServer) GetOperations(ctx context.Context, req *GetOperationsRequest) (*GetOperationsResponse, error)

func (*UnimplementedSpanReaderPluginServer) GetServices added in v1.24.0 

func (*UnimplementedSpanReaderPluginServer) GetServices(ctx context.Context, req *GetServicesRequest) (*GetServicesResponse, error)

func (*UnimplementedSpanReaderPluginServer) GetTrace added in v1.24.0 

func (*UnimplementedSpanReaderPluginServer) GetTrace(req *GetTraceRequest, srv SpanReaderPlugin_GetTraceServer) error

type UnimplementedSpanWriterPluginServer added in v1.24.0 

type UnimplementedSpanWriterPluginServer struct {
}

UnimplementedSpanWriterPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedSpanWriterPluginServer) Close added in v1.27.0 

func (*UnimplementedSpanWriterPluginServer) Close(ctx context.Context, req *CloseWriterRequest) (*CloseWriterResponse, error)

func (*UnimplementedSpanWriterPluginServer) WriteSpan added in v1.24.0 

func (*UnimplementedSpanWriterPluginServer) WriteSpan(ctx context.Context, req *WriteSpanRequest) (*WriteSpanResponse, error)

type UnimplementedStreamingSpanWriterPluginServer added in v1.34.0 

type UnimplementedStreamingSpanWriterPluginServer struct {
}

UnimplementedStreamingSpanWriterPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamingSpanWriterPluginServer) WriteSpanStream added in v1.34.0 

func (*UnimplementedStreamingSpanWriterPluginServer) WriteSpanStream(srv StreamingSpanWriterPlugin_WriteSpanStreamServer) error

type WriteSpanRequest 

type WriteSpanRequest struct {
	Span                 *model.Span `protobuf:"bytes,1,opt,name=span,proto3" json:"span,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WriteSpanRequest) Descriptor 

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

func (*WriteSpanRequest) GetSpan 

func (m *WriteSpanRequest) GetSpan() *model.Span

func (*WriteSpanRequest) Marshal 

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

func (*WriteSpanRequest) MarshalTo 

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

func (*WriteSpanRequest) MarshalToSizedBuffer added in v1.24.0 

func (m *WriteSpanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteSpanRequest) ProtoMessage 

func (*WriteSpanRequest) ProtoMessage()

func (*WriteSpanRequest) Reset 

func (m *WriteSpanRequest) Reset()

func (*WriteSpanRequest) Size 

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

func (*WriteSpanRequest) String 

func (m *WriteSpanRequest) String() string

func (*WriteSpanRequest) Unmarshal 

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

func (*WriteSpanRequest) XXX_DiscardUnknown 

func (m *WriteSpanRequest) XXX_DiscardUnknown()

func (*WriteSpanRequest) XXX_Marshal 

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

func (*WriteSpanRequest) XXX_Merge 

func (m *WriteSpanRequest) XXX_Merge(src proto.Message)

func (*WriteSpanRequest) XXX_Size 

func (m *WriteSpanRequest) XXX_Size() int

func (*WriteSpanRequest) XXX_Unmarshal 

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

type WriteSpanResponse 

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

empty; extensible in the future

func (*WriteSpanResponse) Descriptor 

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

func (*WriteSpanResponse) Marshal 

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

func (*WriteSpanResponse) MarshalTo 

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

func (*WriteSpanResponse) MarshalToSizedBuffer added in v1.24.0 

func (m *WriteSpanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WriteSpanResponse) ProtoMessage 

func (*WriteSpanResponse) ProtoMessage()

func (*WriteSpanResponse) Reset 

func (m *WriteSpanResponse) Reset()

func (*WriteSpanResponse) Size 

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

func (*WriteSpanResponse) String 

func (m *WriteSpanResponse) String() string

func (*WriteSpanResponse) Unmarshal 

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

func (*WriteSpanResponse) XXX_DiscardUnknown 

func (m *WriteSpanResponse) XXX_DiscardUnknown()

func (*WriteSpanResponse) XXX_Marshal 

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

func (*WriteSpanResponse) XXX_Merge 

func (m *WriteSpanResponse) XXX_Merge(src proto.Message)

func (*WriteSpanResponse) XXX_Size 

func (m *WriteSpanResponse) XXX_Size() int

func (*WriteSpanResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.