Help us shape the future of Go! Take the 2026 Go Developer Survey

memory

package
v1.4.1 Latest Latest
Warning

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

Go to latest
Published: Apr 21, 2018 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

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 NewFactory

func NewFactory() *Factory

NewFactory creates a new Factory.

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 {
	// TODO: make this a bounded memory store
	sync.RWMutex
	// contains filtered or unexported fields
}

Store is an unbounded in-memory store of traces

func NewStore

func NewStore() *Store

NewStore creates an in-memory store

func (*Store) FindTraces

func (m *Store) FindTraces(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

func (m *Store) GetOperations(service string) ([]string, error)

GetOperations returns the operations of a given service

func (*Store) GetServices

func (m *Store) GetServices() ([]string, error)

GetServices returns a list of all known services

func (*Store) GetTrace

func (m *Store) GetTrace(traceID model.TraceID) (*model.Trace, error)

GetTrace gets a trace

func (*Store) WriteSpan

func (m *Store) WriteSpan(span *model.Span) error

WriteSpan writes the given span

Jump to

Keyboard shortcuts

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