static

Documentation

Index

• Constants
• func AddFlags(flagSet *flag.FlagSet)
• func NewStrategyStore(options Options, logger *zap.Logger) (ss.StrategyStore, error)
• type Factory
  • func NewFactory() *Factory
  • func (f *Factory) AddFlags(flagSet *flag.FlagSet)
  • func (f *Factory) CreateStrategyStore() (strategystore.StrategyStore, error)
  • func (f *Factory) InitFromViper(v *viper.Viper)
  • func (f *Factory) Initialize(metricsFactory metrics.Factory, logger *zap.Logger) error
• type Options
  • func (opts *Options) InitFromViper(v *viper.Viper) *Options

Constants

const (
	// SamplingStrategiesFile contains the name of CLI opions for config file.
	SamplingStrategiesFile = "sampling.strategies-file"
)

Functions

func AddFlags

func AddFlags(flagSet *flag.FlagSet)

AddFlags adds flags for Options

func NewStrategyStore

func NewStrategyStore(options Options, logger *zap.Logger) (ss.StrategyStore, error)

NewStrategyStore creates a strategy store that holds static sampling strategies.

Types

type Factory

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

Factory implements strategystore.Factory for a static strategy store.

func NewFactory

func NewFactory() *Factory

NewFactory creates a new Factory.

func (*Factory) AddFlags

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

AddFlags implements plugin.Configurable

func (*Factory) CreateStrategyStore

func (f *Factory) CreateStrategyStore() (strategystore.StrategyStore, error)

CreateStrategyStore implements strategystore.Factory

func (*Factory) InitFromViper

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

InitFromViper implements plugin.Configurable

func (*Factory) Initialize

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

Initialize implements strategystore.Factory

type Options

type Options struct {
	// StrategiesFile is the path for the sampling strategies file in JSON format
	StrategiesFile string
	// ReloadInterval is the time interval to check and reload sampling strategies file
	ReloadInterval time.Duration
}

Options holds configuration for the static sampling strategy store.

func (*Options) InitFromViper

func (opts *Options) InitFromViper(v *viper.Viper) *Options

InitFromViper initializes Options with properties from viper