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

samplingstore

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Jan 4, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SamplingStore

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

SamplingStore handles all insertions and queries for sampling data to and from Cassandra

func New

func New(session cassandra.Session, factory metrics.Factory, logger *zap.Logger) *SamplingStore

New creates a new cassandra sampling store.

func (*SamplingStore) GetLatestProbabilities

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

GetLatestProbabilities implements samplingstore.Reader#GetLatestProbabilities.

func (*SamplingStore) GetProbabilitiesAndQPS

func (s *SamplingStore) GetProbabilitiesAndQPS(start, end time.Time) (map[string][]model.ServiceOperationData, error)

GetProbabilitiesAndQPS implements samplingstore.Reader#GetProbabilitiesAndQPS.

func (*SamplingStore) GetThroughput

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

GetThroughput implements samplingstore.Reader#GetThroughput.

func (*SamplingStore) InsertProbabilitiesAndQPS

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

InsertProbabilitiesAndQPS implements samplingstore.Writer#InsertProbabilitiesAndQPS.

func (*SamplingStore) InsertThroughput

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

InsertThroughput implements samplingstore.Writer#InsertThroughput.

Jump to

Keyboard shortcuts

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