Documentation
¶
Index ¶
- type Factory
- func (f *Factory) CreateDependencyReader() (depstore.Reader, error)
- func (*Factory) CreateLock() (distributedlock.Lock, error)
- func (*Factory) CreateSamplingStore(buckets int) (samplingstore.Store, error)
- func (f *Factory) CreateTraceReader() (tracestore.Reader, error)
- func (f *Factory) CreateTraceWriter() (tracestore.Writer, error)
- func (f *Factory) Purge(_ context.Context) error
- type Store
- func (st *Store) FindTraceIDs(ctx context.Context, query tracestore.TraceQueryParams) iter.Seq2[[]tracestore.FoundTraceID, error]
- func (st *Store) FindTraces(ctx context.Context, query tracestore.TraceQueryParams) iter.Seq2[[]ptrace.Traces, error]
- func (st *Store) GetDependencies(ctx context.Context, query depstore.QueryParameters) ([]model.DependencyLink, error)
- func (st *Store) GetOperations(ctx context.Context, query tracestore.OperationQueryParams) ([]tracestore.Operation, error)
- func (st *Store) GetServices(ctx context.Context) ([]string, error)
- func (st *Store) GetTraces(ctx context.Context, traceIDs ...tracestore.GetTraceParams) iter.Seq2[[]ptrace.Traces, error]
- func (st *Store) Purge() error
- func (st *Store) WriteTraces(ctx context.Context, td ptrace.Traces) error
- type Tenant
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Factory ¶ added in v1.71.0
type Factory struct {
// contains filtered or unexported fields
}
func NewFactory ¶ added in v1.71.0
func (*Factory) CreateDependencyReader ¶ added in v1.71.0
func (*Factory) CreateLock ¶ added in v1.71.0
func (*Factory) CreateLock() (distributedlock.Lock, error)
func (*Factory) CreateSamplingStore ¶ added in v1.71.0
func (*Factory) CreateSamplingStore(buckets int) (samplingstore.Store, error)
func (*Factory) CreateTraceReader ¶ added in v1.71.0
func (f *Factory) CreateTraceReader() (tracestore.Reader, error)
func (*Factory) CreateTraceWriter ¶ added in v1.71.0
func (f *Factory) CreateTraceWriter() (tracestore.Writer, error)
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store is an in-memory store of traces
func NewStore ¶
func NewStore(cfg v1.Configuration) (*Store, error)
NewStore creates an in-memory store
func (*Store) FindTraceIDs ¶ added in v1.70.0
func (st *Store) FindTraceIDs(ctx context.Context, query tracestore.TraceQueryParams) iter.Seq2[[]tracestore.FoundTraceID, error]
func (*Store) FindTraces ¶ added in v1.70.0
func (st *Store) FindTraces(ctx context.Context, query tracestore.TraceQueryParams) iter.Seq2[[]ptrace.Traces, error]
func (*Store) GetDependencies ¶ added in v1.70.0
func (st *Store) GetDependencies(ctx context.Context, query depstore.QueryParameters) ([]model.DependencyLink, error)
func (*Store) GetOperations ¶
func (st *Store) GetOperations(ctx context.Context, query tracestore.OperationQueryParams) ([]tracestore.Operation, error)
GetOperations returns operations based on the service name and span kind
func (*Store) GetServices ¶
GetServices returns a list of all known services
Click to show internal directories.
Click to hide internal directories.