blackhole

Documentation

Index

• type Factory
  • func NewFactory() *Factory
  • func (f *Factory) CreateArchiveSpanReader() (spanstore.Reader, error)
  • func (f *Factory) CreateArchiveSpanWriter() (spanstore.Writer, error)
  • func (f *Factory) CreateDependencyReader() (dependencystore.Reader, error)
  • func (f *Factory) CreateSpanReader() (spanstore.Reader, error)
  • func (f *Factory) CreateSpanWriter() (spanstore.Writer, error)
  • func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger) error
• type Store
  • func NewStore() *Store
  • func (m *Store) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (st *Store) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (st *Store) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
  • func (st *Store) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (st *Store) GetServices(ctx context.Context) ([]string, error)
  • func (st *Store) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
  • func (st *Store) WriteSpan(ctx context.Context, span *model.Span) error

Types

type Factory

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

Factory implements storage.Factory and creates blackhole storage components.

func NewFactory

func NewFactory() *Factory

NewFactory creates a new Factory.

func (*Factory) CreateArchiveSpanReader

func (f *Factory) CreateArchiveSpanReader() (spanstore.Reader, error)

CreateArchiveSpanReader implements storage.ArchiveFactory

func (*Factory) CreateArchiveSpanWriter

func (f *Factory) CreateArchiveSpanWriter() (spanstore.Writer, error)

CreateArchiveSpanWriter implements storage.ArchiveFactory

func (*Factory) CreateDependencyReader

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

CreateDependencyReader implements storage.Factory

func (*Factory) CreateSpanReader

func (f *Factory) CreateSpanReader() (spanstore.Reader, error)

CreateSpanReader implements storage.Factory

func (*Factory) CreateSpanWriter

func (f *Factory) CreateSpanWriter() (spanstore.Writer, error)

CreateSpanWriter implements storage.Factory

func (*Factory) Initialize

func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger) error

Initialize implements storage.Factory

type Store

type Store struct {
}

Store is a blackhole. It creates an artificial micro-singularity and forwards all writes to it. We do not know what happens to the data once it reaches the singulatiry, but we know that we cannot get it back.

func NewStore

func NewStore() *Store

NewStore creates a blackhole store.

func (*Store) FindTraceIDs

func (m *Store) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)

FindTraceIDs returns nothing.

func (*Store) FindTraces

func (st *Store) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

FindTraces returns nothing.

func (*Store) GetDependencies

func (st *Store) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)

GetDependencies returns nothing.

func (*Store) GetOperations

func (st *Store) GetOperations(
	ctx context.Context,
	query spanstore.OperationQueryParameters,
) ([]spanstore.Operation, error)

GetOperations returns nothing.

func (*Store) GetServices

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

GetServices returns nothing.

func (*Store) GetTrace

func (st *Store) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

GetTrace gets nothing.

func (*Store) WriteSpan

func (st *Store) WriteSpan(ctx context.Context, span *model.Span) error

WriteSpan writes the given span to blackhole.