memory

package
v1.76.0 Latest Latest
Warning

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

Go to latest
Published: Dec 3, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

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 NewFactory(cfg v1.Configuration, telset telemetry.Settings) (*Factory, error)

func (*Factory) CreateDependencyReader added in v1.71.0

func (f *Factory) CreateDependencyReader() (depstore.Reader, error)

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)

func (*Factory) Purge added in v1.71.0

func (f *Factory) Purge(_ context.Context) 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 (*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

func (st *Store) GetServices(ctx context.Context) ([]string, error)

GetServices returns a list of all known services

func (*Store) GetTraces added in v1.70.0

func (st *Store) GetTraces(ctx context.Context, traceIDs ...tracestore.GetTraceParams) iter.Seq2[[]ptrace.Traces, error]

func (*Store) Purge added in v1.71.0

func (st *Store) Purge() error

func (*Store) WriteTraces

func (st *Store) WriteTraces(ctx context.Context, td ptrace.Traces) error

WriteTraces write the traces into the tenant by grouping all the spans with same trace id together. The traces will not be saved as they are coming, rather they would be reshuffled.

type Tenant

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

Tenant is an in-memory store of traces for a single tenant

Jump to

Keyboard shortcuts

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