Documentation
¶
Index ¶
- type Factory
- func (f *Factory) AddFlags(flagSet *flag.FlagSet)
- func (f *Factory) CreateDependencyReader() (dependencystore.Reader, error)
- func (f *Factory) CreateSpanReader() (spanstore.Reader, error)
- func (f *Factory) CreateSpanWriter() (spanstore.Writer, error)
- func (f *Factory) InitFromViper(v *viper.Viper)
- func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger) error
- type Options
- type Store
- func (m *Store) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
- func (m *Store) GetDependencies(endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
- func (m *Store) GetOperations(ctx context.Context, service string) ([]string, error)
- func (m *Store) GetServices(ctx context.Context) ([]string, error)
- func (m *Store) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
- func (m *Store) WriteSpan(span *model.Span) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
Factory implements storage.Factory and creates storage components backed by memory store.
func (*Factory) CreateDependencyReader ¶
func (f *Factory) CreateDependencyReader() (dependencystore.Reader, error)
CreateDependencyReader implements storage.Factory
func (*Factory) CreateSpanReader ¶
CreateSpanReader implements storage.Factory
func (*Factory) CreateSpanWriter ¶
CreateSpanWriter implements storage.Factory
func (*Factory) InitFromViper ¶ added in v1.5.0
InitFromViper implements plugin.Configurable
type Options ¶ added in v1.5.0
type Options struct {
Configuration config.Configuration
}
Options stores the configuration entries for this storage
func (*Options) InitFromViper ¶ added in v1.5.0
InitFromViper initializes the options struct with values from Viper
type Store ¶
Store is an in-memory store of traces
func WithConfiguration ¶ added in v1.5.0
func WithConfiguration(configuration config.Configuration) *Store
WithConfiguration creates a new in memory storage based on the given configuration
func (*Store) FindTraces ¶
func (m *Store) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
FindTraces returns all traces in the query parameters are satisfied by a trace's span
func (*Store) GetDependencies ¶
func (m *Store) GetDependencies(endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
GetDependencies returns dependencies between services
func (*Store) GetOperations ¶
GetOperations returns the operations of a given service
func (*Store) GetServices ¶
GetServices returns a list of all known services
Source Files