samplingstore

Documentation

Index

• type SamplingStore
  • func NewSamplingStore(p SamplingStoreParams) *SamplingStore
  • func (s *SamplingStore) GetLatestProbabilities() (model.ServiceOperationProbabilities, error)
  • func (s *SamplingStore) GetThroughput(start, end time.Time) ([]*model.Throughput, error)
  • func (s *SamplingStore) InsertProbabilitiesAndQPS(hostname string, probabilities model.ServiceOperationProbabilities, ...) error
  • func (s *SamplingStore) InsertThroughput(throughput []*model.Throughput) error
• type SamplingStoreParams
  • func (p *SamplingStoreParams) PrefixedIndexName() string

Types

type SamplingStore

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

func NewSamplingStore

func NewSamplingStore(p SamplingStoreParams) *SamplingStore

func (*SamplingStore) GetLatestProbabilities

func (s *SamplingStore) GetLatestProbabilities() (model.ServiceOperationProbabilities, error)

func (*SamplingStore) GetThroughput

func (s *SamplingStore) GetThroughput(start, end time.Time) ([]*model.Throughput, error)

func (*SamplingStore) InsertProbabilitiesAndQPS

func (s *SamplingStore) InsertProbabilitiesAndQPS(hostname string,
	probabilities model.ServiceOperationProbabilities,
	qps model.ServiceOperationQPS,
) error

func (*SamplingStore) InsertThroughput

func (s *SamplingStore) InsertThroughput(throughput []*model.Throughput) error

type SamplingStoreParams

type SamplingStoreParams struct {
	Client                 func() es.Client
	Logger                 *zap.Logger
	IndexPrefix            string
	IndexDateLayout        string
	IndexRolloverFrequency time.Duration
	Lookback               time.Duration
	MaxDocCount            int
}

func (*SamplingStoreParams) PrefixedIndexName

func (p *SamplingStoreParams) PrefixedIndexName() string