redbull

package
v0.0.0-...-bca447f Latest Latest
Warning

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

Go to latest
Published: Jul 3, 2020 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrServiceNameNotSet occurs when attempting to query with an empty service name
	ErrServiceNameNotSet = errors.New("service name must be set")

	// ErrStartTimeMinGreaterThanMax occurs when start time min is above start time max
	ErrStartTimeMinGreaterThanMax = errors.New("min start time is above max")

	// ErrDurationMinGreaterThanMax occurs when duration min is above duration max
	ErrDurationMinGreaterThanMax = errors.New("min duration is above max")

	// ErrMalformedRequestObject occurs when a request object is nil
	ErrMalformedRequestObject = errors.New("malformed request object")

	// ErrStartAndEndTimeNotSet occurs when start time and end time are not set
	ErrStartAndEndTimeNotSet = errors.New("start and end time must be set")

	// ErrUnableToFindTraceIDAggregation occurs when an aggregation query for TraceIDs fail.
	ErrUnableToFindTraceIDAggregation = errors.New("could not find aggregation of traceIDs")

	// ErrNotSupported during development, don't support every option - yet
	ErrNotSupported = errors.New("this query parameter is not supported yet")
)

Functions

func NewRedBull

func NewRedBull(cfg Config) (*redbull, error)

NewRedBull creates a redbull instance.

Types

type Config

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

Config holds the configuration for redbull.

type Factory

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

Factory is the redbull factory that implements storage.Factory.

func NewFactory

func NewFactory() *Factory

NewFactory returns a new factory.

func (*Factory) AddFlags

func (f *Factory) AddFlags(flagset *flag.FlagSet)

AddFlags implements plugin.Configurable.

func (Factory) Close

func (rb Factory) Close() error

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) DependencyReader

func (rb Factory) DependencyReader() dependencystore.Reader

func (Factory) FindTraceIDs

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

func (Factory) FindTraces

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

func (Factory) GetDependencies

func (rb Factory) GetDependencies(endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)

func (Factory) GetOperations

func (rb Factory) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

func (Factory) GetServices

func (rb Factory) GetServices(ctx context.Context) ([]string, error)

func (Factory) GetTrace

func (rb Factory) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

func (*Factory) InitFromViper

func (f *Factory) InitFromViper(v *viper.Viper)

InitFromViper implements plugin.Configurable.

func (*Factory) Initialize

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

Initialize implements storage.Factory.

func (Factory) SpanReader

func (rb Factory) SpanReader() spanstore.Reader

func (Factory) SpanWriter

func (rb Factory) SpanWriter() spanstore.Writer

func (Factory) WriteSpan

func (rb Factory) WriteSpan(span *model.Span) error

Jump to

Keyboard shortcuts

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