v1

package
v0.0.0-...-87a0483 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ArchiveSpanReaderPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.storage.v1.ArchiveSpanReaderPlugin",
	HandlerType: (*ArchiveSpanReaderPluginServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetArchiveTrace",
			Handler:       _ArchiveSpanReaderPlugin_GetArchiveTrace_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "jaeger/storage/v1/storage.proto",
}

ArchiveSpanReaderPlugin_ServiceDesc is the grpc.ServiceDesc for ArchiveSpanReaderPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var ArchiveSpanWriterPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.storage.v1.ArchiveSpanWriterPlugin",
	HandlerType: (*ArchiveSpanWriterPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WriteArchiveSpan",
			Handler:    _ArchiveSpanWriterPlugin_WriteArchiveSpan_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jaeger/storage/v1/storage.proto",
}

ArchiveSpanWriterPlugin_ServiceDesc is the grpc.ServiceDesc for ArchiveSpanWriterPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var DependenciesReaderPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.storage.v1.DependenciesReaderPlugin",
	HandlerType: (*DependenciesReaderPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDependencies",
			Handler:    _DependenciesReaderPlugin_GetDependencies_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jaeger/storage/v1/storage.proto",
}

DependenciesReaderPlugin_ServiceDesc is the grpc.ServiceDesc for DependenciesReaderPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_jaeger_storage_v1_storage_proto protoreflect.FileDescriptor
View Source
var PluginCapabilities_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.storage.v1.PluginCapabilities",
	HandlerType: (*PluginCapabilitiesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Capabilities",
			Handler:    _PluginCapabilities_Capabilities_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jaeger/storage/v1/storage.proto",
}

PluginCapabilities_ServiceDesc is the grpc.ServiceDesc for PluginCapabilities service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var SpanReaderPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.storage.v1.SpanReaderPlugin",
	HandlerType: (*SpanReaderPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetServices",
			Handler:    _SpanReaderPlugin_GetServices_Handler,
		},
		{
			MethodName: "GetOperations",
			Handler:    _SpanReaderPlugin_GetOperations_Handler,
		},
		{
			MethodName: "FindTraceIDs",
			Handler:    _SpanReaderPlugin_FindTraceIDs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetTrace",
			Handler:       _SpanReaderPlugin_GetTrace_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "FindTraces",
			Handler:       _SpanReaderPlugin_FindTraces_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "jaeger/storage/v1/storage.proto",
}

SpanReaderPlugin_ServiceDesc is the grpc.ServiceDesc for SpanReaderPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var SpanWriterPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.storage.v1.SpanWriterPlugin",
	HandlerType: (*SpanWriterPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WriteSpan",
			Handler:    _SpanWriterPlugin_WriteSpan_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _SpanWriterPlugin_Close_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "jaeger/storage/v1/storage.proto",
}

SpanWriterPlugin_ServiceDesc is the grpc.ServiceDesc for SpanWriterPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var StreamingSpanWriterPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "jaeger.storage.v1.StreamingSpanWriterPlugin",
	HandlerType: (*StreamingSpanWriterPluginServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WriteSpanStream",
			Handler:       _StreamingSpanWriterPlugin_WriteSpanStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "jaeger/storage/v1/storage.proto",
}

StreamingSpanWriterPlugin_ServiceDesc is the grpc.ServiceDesc for StreamingSpanWriterPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterArchiveSpanReaderPluginServer

func RegisterArchiveSpanReaderPluginServer(s grpc.ServiceRegistrar, srv ArchiveSpanReaderPluginServer)

func RegisterArchiveSpanWriterPluginServer

func RegisterArchiveSpanWriterPluginServer(s grpc.ServiceRegistrar, srv ArchiveSpanWriterPluginServer)

func RegisterDependenciesReaderPluginServer

func RegisterDependenciesReaderPluginServer(s grpc.ServiceRegistrar, srv DependenciesReaderPluginServer)

func RegisterPluginCapabilitiesServer

func RegisterPluginCapabilitiesServer(s grpc.ServiceRegistrar, srv PluginCapabilitiesServer)

func RegisterSpanReaderPluginServer

func RegisterSpanReaderPluginServer(s grpc.ServiceRegistrar, srv SpanReaderPluginServer)

func RegisterSpanWriterPluginServer

func RegisterSpanWriterPluginServer(s grpc.ServiceRegistrar, srv SpanWriterPluginServer)

func RegisterStreamingSpanWriterPluginServer

func RegisterStreamingSpanWriterPluginServer(s grpc.ServiceRegistrar, srv StreamingSpanWriterPluginServer)

Types

type ArchiveSpanReaderPluginClient

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ArchiveSpanReaderPluginServer

type ArchiveSpanReaderPluginServer interface {
	// spanstore/Reader
	GetArchiveTrace(*GetTraceRequest, ArchiveSpanReaderPlugin_GetArchiveTraceServer) error
	// contains filtered or unexported methods
}

ArchiveSpanReaderPluginServer is the server API for ArchiveSpanReaderPlugin service. All implementations must embed UnimplementedArchiveSpanReaderPluginServer for forward compatibility

type ArchiveSpanReaderPlugin_GetArchiveTraceClient

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

type ArchiveSpanReaderPlugin_GetArchiveTraceServer

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

type ArchiveSpanWriterPluginClient

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ArchiveSpanWriterPluginServer

type ArchiveSpanWriterPluginServer interface {
	// spanstore/Writer
	WriteArchiveSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)
	// contains filtered or unexported methods
}

ArchiveSpanWriterPluginServer is the server API for ArchiveSpanWriterPlugin service. All implementations must embed UnimplementedArchiveSpanWriterPluginServer for forward compatibility

type CapabilitiesRequest

type CapabilitiesRequest struct {
	// contains filtered or unexported fields
}

empty; extensible in the future

func (*CapabilitiesRequest) Descriptor deprecated

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

Deprecated: Use CapabilitiesRequest.ProtoReflect.Descriptor instead.

func (*CapabilitiesRequest) ProtoMessage

func (*CapabilitiesRequest) ProtoMessage()

func (*CapabilitiesRequest) ProtoReflect

func (x *CapabilitiesRequest) ProtoReflect() protoreflect.Message

func (*CapabilitiesRequest) Reset

func (x *CapabilitiesRequest) Reset()

func (*CapabilitiesRequest) String

func (x *CapabilitiesRequest) String() string

type CapabilitiesResponse

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"`
	// contains filtered or unexported fields
}

func (*CapabilitiesResponse) Descriptor deprecated

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

Deprecated: Use CapabilitiesResponse.ProtoReflect.Descriptor instead.

func (*CapabilitiesResponse) GetArchiveSpanReader

func (x *CapabilitiesResponse) GetArchiveSpanReader() bool

func (*CapabilitiesResponse) GetArchiveSpanWriter

func (x *CapabilitiesResponse) GetArchiveSpanWriter() bool

func (*CapabilitiesResponse) GetStreamingSpanWriter

func (x *CapabilitiesResponse) GetStreamingSpanWriter() bool

func (*CapabilitiesResponse) ProtoMessage

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) ProtoReflect

func (x *CapabilitiesResponse) ProtoReflect() protoreflect.Message

func (*CapabilitiesResponse) Reset

func (x *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) String

func (x *CapabilitiesResponse) String() string

type CloseWriterRequest

type CloseWriterRequest struct {
	// contains filtered or unexported fields
}

empty; extensible in the future

func (*CloseWriterRequest) Descriptor deprecated

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

Deprecated: Use CloseWriterRequest.ProtoReflect.Descriptor instead.

func (*CloseWriterRequest) ProtoMessage

func (*CloseWriterRequest) ProtoMessage()

func (*CloseWriterRequest) ProtoReflect

func (x *CloseWriterRequest) ProtoReflect() protoreflect.Message

func (*CloseWriterRequest) Reset

func (x *CloseWriterRequest) Reset()

func (*CloseWriterRequest) String

func (x *CloseWriterRequest) String() string

type CloseWriterResponse

type CloseWriterResponse struct {
	// contains filtered or unexported fields
}

empty; extensible in the future

func (*CloseWriterResponse) Descriptor deprecated

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

Deprecated: Use CloseWriterResponse.ProtoReflect.Descriptor instead.

func (*CloseWriterResponse) ProtoMessage

func (*CloseWriterResponse) ProtoMessage()

func (*CloseWriterResponse) ProtoReflect

func (x *CloseWriterResponse) ProtoReflect() protoreflect.Message

func (*CloseWriterResponse) Reset

func (x *CloseWriterResponse) Reset()

func (*CloseWriterResponse) String

func (x *CloseWriterResponse) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type DependenciesReaderPluginServer

type DependenciesReaderPluginServer interface {
	// dependencystore/Reader
	GetDependencies(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error)
	// contains filtered or unexported methods
}

DependenciesReaderPluginServer is the server API for DependenciesReaderPlugin service. All implementations must embed UnimplementedDependenciesReaderPluginServer for forward compatibility

type FindTraceIDsRequest

type FindTraceIDsRequest struct {
	Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*FindTraceIDsRequest) Descriptor deprecated

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

Deprecated: Use FindTraceIDsRequest.ProtoReflect.Descriptor instead.

func (*FindTraceIDsRequest) GetQuery

func (*FindTraceIDsRequest) ProtoMessage

func (*FindTraceIDsRequest) ProtoMessage()

func (*FindTraceIDsRequest) ProtoReflect

func (x *FindTraceIDsRequest) ProtoReflect() protoreflect.Message

func (*FindTraceIDsRequest) Reset

func (x *FindTraceIDsRequest) Reset()

func (*FindTraceIDsRequest) String

func (x *FindTraceIDsRequest) String() string

type FindTraceIDsResponse

type FindTraceIDsResponse struct {
	TraceIds [][]byte `protobuf:"bytes,1,rep,name=trace_ids,json=traceIds,proto3" json:"trace_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*FindTraceIDsResponse) Descriptor deprecated

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

Deprecated: Use FindTraceIDsResponse.ProtoReflect.Descriptor instead.

func (*FindTraceIDsResponse) GetTraceIds

func (x *FindTraceIDsResponse) GetTraceIds() [][]byte

func (*FindTraceIDsResponse) ProtoMessage

func (*FindTraceIDsResponse) ProtoMessage()

func (*FindTraceIDsResponse) ProtoReflect

func (x *FindTraceIDsResponse) ProtoReflect() protoreflect.Message

func (*FindTraceIDsResponse) Reset

func (x *FindTraceIDsResponse) Reset()

func (*FindTraceIDsResponse) String

func (x *FindTraceIDsResponse) String() string

type FindTracesRequest

type FindTracesRequest struct {
	Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*FindTracesRequest) Descriptor deprecated

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

Deprecated: Use FindTracesRequest.ProtoReflect.Descriptor instead.

func (*FindTracesRequest) GetQuery

func (x *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) ProtoMessage

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) ProtoReflect

func (x *FindTracesRequest) ProtoReflect() protoreflect.Message

func (*FindTracesRequest) Reset

func (x *FindTracesRequest) Reset()

func (*FindTracesRequest) String

func (x *FindTracesRequest) String() string

type GetDependenciesRequest

type GetDependenciesRequest struct {
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDependenciesRequest) Descriptor deprecated

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

Deprecated: Use GetDependenciesRequest.ProtoReflect.Descriptor instead.

func (*GetDependenciesRequest) GetEndTime

func (x *GetDependenciesRequest) GetEndTime() *timestamppb.Timestamp

func (*GetDependenciesRequest) GetStartTime

func (x *GetDependenciesRequest) GetStartTime() *timestamppb.Timestamp

func (*GetDependenciesRequest) ProtoMessage

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) ProtoReflect

func (x *GetDependenciesRequest) ProtoReflect() protoreflect.Message

func (*GetDependenciesRequest) Reset

func (x *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) String

func (x *GetDependenciesRequest) String() string

type GetDependenciesResponse

type GetDependenciesResponse struct {
	Dependencies []*v2.DependencyLink `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDependenciesResponse) Descriptor deprecated

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

Deprecated: Use GetDependenciesResponse.ProtoReflect.Descriptor instead.

func (*GetDependenciesResponse) GetDependencies

func (x *GetDependenciesResponse) GetDependencies() []*v2.DependencyLink

func (*GetDependenciesResponse) ProtoMessage

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) ProtoReflect

func (x *GetDependenciesResponse) ProtoReflect() protoreflect.Message

func (*GetDependenciesResponse) Reset

func (x *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) String

func (x *GetDependenciesResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetOperationsRequest) Descriptor deprecated

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

Deprecated: Use GetOperationsRequest.ProtoReflect.Descriptor instead.

func (*GetOperationsRequest) GetService

func (x *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind

func (x *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) ProtoMessage

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) ProtoReflect

func (x *GetOperationsRequest) ProtoReflect() protoreflect.Message

func (*GetOperationsRequest) Reset

func (x *GetOperationsRequest) Reset()

func (*GetOperationsRequest) String

func (x *GetOperationsRequest) String() string

type GetOperationsResponse

type GetOperationsResponse struct {
	OperationNames []string     `protobuf:"bytes,1,rep,name=operationNames,proto3" json:"operationNames,omitempty"` // deprecated
	Operations     []*Operation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationsResponse) Descriptor deprecated

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

Deprecated: Use GetOperationsResponse.ProtoReflect.Descriptor instead.

func (*GetOperationsResponse) GetOperationNames

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

func (*GetOperationsResponse) GetOperations

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

func (*GetOperationsResponse) ProtoMessage

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) ProtoReflect

func (x *GetOperationsResponse) ProtoReflect() protoreflect.Message

func (*GetOperationsResponse) Reset

func (x *GetOperationsResponse) Reset()

func (*GetOperationsResponse) String

func (x *GetOperationsResponse) String() string

type GetServicesRequest

type GetServicesRequest struct {
	// contains filtered or unexported fields
}

func (*GetServicesRequest) Descriptor deprecated

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

Deprecated: Use GetServicesRequest.ProtoReflect.Descriptor instead.

func (*GetServicesRequest) ProtoMessage

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) ProtoReflect

func (x *GetServicesRequest) ProtoReflect() protoreflect.Message

func (*GetServicesRequest) Reset

func (x *GetServicesRequest) Reset()

func (*GetServicesRequest) String

func (x *GetServicesRequest) String() string

type GetServicesResponse

type GetServicesResponse struct {
	Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServicesResponse) Descriptor deprecated

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

Deprecated: Use GetServicesResponse.ProtoReflect.Descriptor instead.

func (*GetServicesResponse) GetServices

func (x *GetServicesResponse) GetServices() []string

func (*GetServicesResponse) ProtoMessage

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) ProtoReflect

func (x *GetServicesResponse) ProtoReflect() protoreflect.Message

func (*GetServicesResponse) Reset

func (x *GetServicesResponse) Reset()

func (*GetServicesResponse) String

func (x *GetServicesResponse) String() string

type GetTraceRequest

type GetTraceRequest struct {
	TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTraceRequest) Descriptor deprecated

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

Deprecated: Use GetTraceRequest.ProtoReflect.Descriptor instead.

func (*GetTraceRequest) GetTraceId

func (x *GetTraceRequest) GetTraceId() []byte

func (*GetTraceRequest) ProtoMessage

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) ProtoReflect

func (x *GetTraceRequest) ProtoReflect() protoreflect.Message

func (*GetTraceRequest) Reset

func (x *GetTraceRequest) Reset()

func (*GetTraceRequest) String

func (x *GetTraceRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*Operation) Descriptor deprecated

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

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetName

func (x *Operation) GetName() string

func (*Operation) GetSpanKind

func (x *Operation) GetSpanKind() string

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect

func (x *Operation) ProtoReflect() protoreflect.Message

func (*Operation) Reset

func (x *Operation) Reset()

func (*Operation) String

func (x *Operation) String() string

type PluginCapabilitiesClient

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type PluginCapabilitiesServer

type PluginCapabilitiesServer interface {
	Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
	// contains filtered or unexported methods
}

PluginCapabilitiesServer is the server API for PluginCapabilities service. All implementations must embed UnimplementedPluginCapabilitiesServer for forward compatibility

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

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)
	// contains filtered or unexported methods
}

SpanReaderPluginServer is the server API for SpanReaderPlugin service. All implementations must embed UnimplementedSpanReaderPluginServer for forward compatibility

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type SpanWriterPluginServer

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

SpanWriterPluginServer is the server API for SpanWriterPlugin service. All implementations must embed UnimplementedSpanWriterPluginServer for forward compatibility

type SpansResponseChunk

type SpansResponseChunk struct {
	Spans []*v2.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"`
	// contains filtered or unexported fields
}

func (*SpansResponseChunk) Descriptor deprecated

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

Deprecated: Use SpansResponseChunk.ProtoReflect.Descriptor instead.

func (*SpansResponseChunk) GetSpans

func (x *SpansResponseChunk) GetSpans() []*v2.Span

func (*SpansResponseChunk) ProtoMessage

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) ProtoReflect

func (x *SpansResponseChunk) ProtoReflect() protoreflect.Message

func (*SpansResponseChunk) Reset

func (x *SpansResponseChunk) Reset()

func (*SpansResponseChunk) String

func (x *SpansResponseChunk) String() string

type StreamingSpanWriterPluginClient

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type StreamingSpanWriterPluginServer

type StreamingSpanWriterPluginServer interface {
	WriteSpanStream(StreamingSpanWriterPlugin_WriteSpanStreamServer) error
	// contains filtered or unexported methods
}

StreamingSpanWriterPluginServer is the server API for StreamingSpanWriterPlugin service. All implementations must embed UnimplementedStreamingSpanWriterPluginServer for forward compatibility

type StreamingSpanWriterPlugin_WriteSpanStreamClient

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

type StreamingSpanWriterPlugin_WriteSpanStreamServer

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  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3" json:"start_time_min,omitempty"`
	StartTimeMax  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3" json:"start_time_max,omitempty"`
	DurationMin   *durationpb.Duration   `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3" json:"duration_min,omitempty"`
	DurationMax   *durationpb.Duration   `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3" json:"duration_max,omitempty"`
	NumTraces     int32                  `protobuf:"varint,8,opt,name=num_traces,json=numTraces,proto3" json:"num_traces,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceQueryParameters) Descriptor deprecated

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

Deprecated: Use TraceQueryParameters.ProtoReflect.Descriptor instead.

func (*TraceQueryParameters) GetDurationMax

func (x *TraceQueryParameters) GetDurationMax() *durationpb.Duration

func (*TraceQueryParameters) GetDurationMin

func (x *TraceQueryParameters) GetDurationMin() *durationpb.Duration

func (*TraceQueryParameters) GetNumTraces

func (x *TraceQueryParameters) GetNumTraces() int32

func (*TraceQueryParameters) GetOperationName

func (x *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetServiceName

func (x *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax

func (x *TraceQueryParameters) GetStartTimeMax() *timestamppb.Timestamp

func (*TraceQueryParameters) GetStartTimeMin

func (x *TraceQueryParameters) GetStartTimeMin() *timestamppb.Timestamp

func (*TraceQueryParameters) GetTags

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

func (*TraceQueryParameters) ProtoMessage

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) ProtoReflect

func (x *TraceQueryParameters) ProtoReflect() protoreflect.Message

func (*TraceQueryParameters) Reset

func (x *TraceQueryParameters) Reset()

func (*TraceQueryParameters) String

func (x *TraceQueryParameters) String() string

type UnimplementedArchiveSpanReaderPluginServer

type UnimplementedArchiveSpanReaderPluginServer struct {
}

UnimplementedArchiveSpanReaderPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedArchiveSpanReaderPluginServer) GetArchiveTrace

type UnimplementedArchiveSpanWriterPluginServer

type UnimplementedArchiveSpanWriterPluginServer struct {
}

UnimplementedArchiveSpanWriterPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedArchiveSpanWriterPluginServer) WriteArchiveSpan

type UnimplementedDependenciesReaderPluginServer

type UnimplementedDependenciesReaderPluginServer struct {
}

UnimplementedDependenciesReaderPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedDependenciesReaderPluginServer) GetDependencies

type UnimplementedPluginCapabilitiesServer

type UnimplementedPluginCapabilitiesServer struct {
}

UnimplementedPluginCapabilitiesServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginCapabilitiesServer) Capabilities

type UnimplementedSpanReaderPluginServer

type UnimplementedSpanReaderPluginServer struct {
}

UnimplementedSpanReaderPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedSpanReaderPluginServer) FindTraceIDs

func (UnimplementedSpanReaderPluginServer) FindTraces

func (UnimplementedSpanReaderPluginServer) GetOperations

func (UnimplementedSpanReaderPluginServer) GetServices

func (UnimplementedSpanReaderPluginServer) GetTrace

type UnimplementedSpanWriterPluginServer

type UnimplementedSpanWriterPluginServer struct {
}

UnimplementedSpanWriterPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedSpanWriterPluginServer) Close

func (UnimplementedSpanWriterPluginServer) WriteSpan

type UnimplementedStreamingSpanWriterPluginServer

type UnimplementedStreamingSpanWriterPluginServer struct {
}

UnimplementedStreamingSpanWriterPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamingSpanWriterPluginServer) WriteSpanStream

type UnsafeArchiveSpanReaderPluginServer

type UnsafeArchiveSpanReaderPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeArchiveSpanReaderPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ArchiveSpanReaderPluginServer will result in compilation errors.

type UnsafeArchiveSpanWriterPluginServer

type UnsafeArchiveSpanWriterPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeArchiveSpanWriterPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ArchiveSpanWriterPluginServer will result in compilation errors.

type UnsafeDependenciesReaderPluginServer

type UnsafeDependenciesReaderPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeDependenciesReaderPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DependenciesReaderPluginServer will result in compilation errors.

type UnsafePluginCapabilitiesServer

type UnsafePluginCapabilitiesServer interface {
	// contains filtered or unexported methods
}

UnsafePluginCapabilitiesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginCapabilitiesServer will result in compilation errors.

type UnsafeSpanReaderPluginServer

type UnsafeSpanReaderPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeSpanReaderPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SpanReaderPluginServer will result in compilation errors.

type UnsafeSpanWriterPluginServer

type UnsafeSpanWriterPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeSpanWriterPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SpanWriterPluginServer will result in compilation errors.

type UnsafeStreamingSpanWriterPluginServer

type UnsafeStreamingSpanWriterPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingSpanWriterPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingSpanWriterPluginServer will result in compilation errors.

type WriteSpanRequest

type WriteSpanRequest struct {
	Span *v2.Span `protobuf:"bytes,1,opt,name=span,proto3" json:"span,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteSpanRequest) Descriptor deprecated

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

Deprecated: Use WriteSpanRequest.ProtoReflect.Descriptor instead.

func (*WriteSpanRequest) GetSpan

func (x *WriteSpanRequest) GetSpan() *v2.Span

func (*WriteSpanRequest) ProtoMessage

func (*WriteSpanRequest) ProtoMessage()

func (*WriteSpanRequest) ProtoReflect

func (x *WriteSpanRequest) ProtoReflect() protoreflect.Message

func (*WriteSpanRequest) Reset

func (x *WriteSpanRequest) Reset()

func (*WriteSpanRequest) String

func (x *WriteSpanRequest) String() string

type WriteSpanResponse

type WriteSpanResponse struct {
	// contains filtered or unexported fields
}

empty; extensible in the future

func (*WriteSpanResponse) Descriptor deprecated

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

Deprecated: Use WriteSpanResponse.ProtoReflect.Descriptor instead.

func (*WriteSpanResponse) ProtoMessage

func (*WriteSpanResponse) ProtoMessage()

func (*WriteSpanResponse) ProtoReflect

func (x *WriteSpanResponse) ProtoReflect() protoreflect.Message

func (*WriteSpanResponse) Reset

func (x *WriteSpanResponse) Reset()

func (*WriteSpanResponse) String

func (x *WriteSpanResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL