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 (*Store) FindTraceIDs(context.Context, *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (*Store) FindTraces(context.Context, *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (*Store) GetDependencies(context.Context, time.Time, time.Duration) ([]model.DependencyLink, error)
  • func (*Store) GetOperations(context.Context, spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (*Store) GetServices(context.Context) ([]string, error)
  • func (*Store) GetTrace(context.Context, model.TraceID) (*model.Trace, error)
  • func (*Store) WriteSpan(context.Context, *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 (*Store) FindTraceIDs(context.Context, *spanstore.TraceQueryParameters) ([]model.TraceID, error)

FindTraceIDs returns nothing.

func (*Store) FindTraces

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

FindTraces returns nothing.

func (*Store) GetDependencies

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

GetDependencies returns nothing.

func (*Store) GetOperations

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

GetOperations returns nothing.

func (*Store) GetServices

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

GetServices returns nothing.

func (*Store) GetTrace

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

GetTrace gets nothing.

func (*Store) WriteSpan

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

WriteSpan writes the given span to blackhole.