Documentation
¶
Index ¶
- type Config
- type DependencyReader
- type Factory
- type Handler
- func (h *Handler) Export(ctx context.Context, request ptraceotlp.ExportRequest) (ptraceotlp.ExportResponse, error)
- func (h *Handler) FindTraceIDs(ctx context.Context, req *storage.FindTracesRequest) (*storage.FindTraceIDsResponse, error)
- func (h *Handler) FindTraces(req *storage.FindTracesRequest, srv storage.TraceReader_FindTracesServer) error
- func (h *Handler) GetDependencies(ctx context.Context, req *storage.GetDependenciesRequest) (*storage.GetDependenciesResponse, error)
- func (h *Handler) GetOperations(ctx context.Context, req *storage.GetOperationsRequest) (*storage.GetOperationsResponse, error)
- func (h *Handler) GetServices(ctx context.Context, _ *storage.GetServicesRequest) (*storage.GetServicesResponse, error)
- func (h *Handler) GetTraces(req *storage.GetTracesRequest, srv storage.TraceReader_GetTracesServer) error
- func (h *Handler) Register(ss *grpc.Server, hs *health.Server)
- type TraceReader
- func (tr *TraceReader) FindTraceIDs(ctx context.Context, params tracestore.TraceQueryParams) iter.Seq2[[]tracestore.FoundTraceID, error]
- func (tr *TraceReader) FindTraces(ctx context.Context, params tracestore.TraceQueryParams) iter.Seq2[[]ptrace.Traces, error]
- func (tr *TraceReader) GetOperations(ctx context.Context, params tracestore.OperationQueryParams) ([]tracestore.Operation, error)
- func (tr *TraceReader) GetServices(ctx context.Context) ([]string, error)
- func (tr *TraceReader) GetTraces(ctx context.Context, traceIDs ...tracestore.GetTraceParams) iter.Seq2[[]ptrace.Traces, error]
- type TraceWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { configgrpc.ClientConfig `mapstructure:",squash"` // Writer allows overriding the endpoint for writes, e.g. to an OTLP receiver. // If not defined the main endpoint is used for reads and writes. Writer configgrpc.ClientConfig `mapstructure:"writer"` Tenancy tenancy.Options `mapstructure:"multi_tenancy"` exporterhelper.TimeoutConfig `mapstructure:",squash"` }
func DefaultConfig ¶
func DefaultConfig() Config
type DependencyReader ¶
type DependencyReader struct {
// contains filtered or unexported fields
}
func NewDependencyReader ¶
func NewDependencyReader(conn *grpc.ClientConn) *DependencyReader
NewDependencyReader creates a DependencyReader that communicates with a remote gRPC storage server. The provided gRPC connection is used exclusively for reading dependencies, meaning it is safe to enable instrumentation on the connection.
func (*DependencyReader) GetDependencies ¶
func (dr *DependencyReader) GetDependencies( ctx context.Context, query depstore.QueryParameters, ) ([]model.DependencyLink, error)
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
func NewFactory ¶
NewFactory initializes a new gRPC (remote) storage backend.
func (*Factory) CreateDependencyReader ¶
func (*Factory) CreateTraceReader ¶
func (f *Factory) CreateTraceReader() (tracestore.Reader, error)
func (*Factory) CreateTraceWriter ¶
func (f *Factory) CreateTraceWriter() (tracestore.Writer, error)
type Handler ¶ added in v1.69.0
type Handler struct { storage.UnimplementedTraceReaderServer storage.UnimplementedDependencyReaderServer ptraceotlp.UnimplementedGRPCServer // contains filtered or unexported fields }
func NewHandler ¶ added in v1.69.0
func NewHandler( traceReader tracestore.Reader, traceWriter tracestore.Writer, depReader depstore.Reader, ) *Handler
func (*Handler) Export ¶ added in v1.69.0
func (h *Handler) Export(ctx context.Context, request ptraceotlp.ExportRequest) ( ptraceotlp.ExportResponse, error, )
func (*Handler) FindTraceIDs ¶ added in v1.69.0
func (*Handler) FindTraces ¶ added in v1.69.0
func (*Handler) GetDependencies ¶ added in v1.69.0
func (*Handler) GetOperations ¶ added in v1.69.0
func (*Handler) GetServices ¶ added in v1.69.0
type TraceReader ¶
type TraceReader struct {
// contains filtered or unexported fields
}
func NewTraceReader ¶
func NewTraceReader(conn *grpc.ClientConn) *TraceReader
NewTraceReader creates a TraceReader that communicates with a remote gRPC storage server. The provided gRPC connection is used exclusively for reading traces, meaning it is safe to enable instrumentation on the connection without risk of recursively generating traces.
func (*TraceReader) FindTraceIDs ¶
func (tr *TraceReader) FindTraceIDs( ctx context.Context, params tracestore.TraceQueryParams, ) iter.Seq2[[]tracestore.FoundTraceID, error]
func (*TraceReader) FindTraces ¶
func (tr *TraceReader) FindTraces( ctx context.Context, params tracestore.TraceQueryParams, ) iter.Seq2[[]ptrace.Traces, error]
func (*TraceReader) GetOperations ¶
func (tr *TraceReader) GetOperations( ctx context.Context, params tracestore.OperationQueryParams, ) ([]tracestore.Operation, error)
func (*TraceReader) GetServices ¶
func (tr *TraceReader) GetServices(ctx context.Context) ([]string, error)
func (*TraceReader) GetTraces ¶
func (tr *TraceReader) GetTraces( ctx context.Context, traceIDs ...tracestore.GetTraceParams, ) iter.Seq2[[]ptrace.Traces, error]
type TraceWriter ¶
type TraceWriter struct {
// contains filtered or unexported fields
}
func NewTraceWriter ¶
func NewTraceWriter(conn *grpc.ClientConn) *TraceWriter
NewTraceWriter creates a TraceWriter that exports traces to a remote gRPC storage server.
The provided gRPC connection is used exclusively for sending trace data to the backend. To prevent recursive trace generation, this connection should not have instrumentation enabled.