Documentation ¶
Index ¶
- Variables
- func NewRedBull(cfg Config) (*redbull, error)
- type Config
- type Factory
- func (f *Factory) AddFlags(flagset *flag.FlagSet)
- func (rb Factory) Close() error
- func (f *Factory) CreateDependencyReader() (dependencystore.Reader, error)
- func (f *Factory) CreateSpanReader() (spanstore.Reader, error)
- func (f *Factory) CreateSpanWriter() (spanstore.Writer, error)
- func (rb Factory) DependencyReader() dependencystore.Reader
- func (rb Factory) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
- func (rb Factory) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
- func (rb Factory) GetDependencies(endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
- func (rb Factory) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
- func (rb Factory) GetServices(ctx context.Context) ([]string, error)
- func (rb Factory) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
- func (f *Factory) InitFromViper(v *viper.Viper)
- func (f *Factory) Initialize(metricsFactory metrics.Factory, zapLogger *zap.Logger) error
- func (rb Factory) SpanReader() spanstore.Reader
- func (rb Factory) SpanWriter() spanstore.Writer
- func (rb Factory) WriteSpan(span *model.Span) error
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 ¶
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 (*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) DependencyReader ¶
func (rb Factory) DependencyReader() dependencystore.Reader
func (Factory) FindTraceIDs ¶
func (Factory) FindTraces ¶
func (Factory) GetDependencies ¶
func (Factory) GetOperations ¶
func (*Factory) InitFromViper ¶
InitFromViper implements plugin.Configurable.
func (*Factory) Initialize ¶
Initialize implements storage.Factory.
func (Factory) SpanReader ¶
func (Factory) SpanWriter ¶
Click to show internal directories.
Click to hide internal directories.