storage

Documentation

Index

• Constants
• type FakeStorage
  • func (f *FakeStorage) Insert(_ *Result) error
  • func (f *FakeStorage) Select(_ string, _, _ time.Time) ([]float64, error)
• type Reader
• type Result
• type Storage
  • func NewStorage(partitionDuration time.Duration) (Storage, error)
• type Writer

Constants

const (
	LatencyMetricName = "latency"
	P50MetricName     = "p50"
	P90MetricName     = "p90"
	P95MetricName     = "p95"
	P99MetricName     = "p99"
)

Types

type FakeStorage

type FakeStorage struct {
	Values []float64
	// contains filtered or unexported fields
}

func (*FakeStorage) Insert

func (f *FakeStorage) Insert(_ *Result) error

func (*FakeStorage) Select

func (f *FakeStorage) Select(_ string, _, _ time.Time) ([]float64, error)

type Reader

type Reader interface {
	Select(metric string, start, end time.Time) ([]float64, error)
}

type Result

type Result struct {
	Code      uint16
	Timestamp time.Time
	Latency   time.Duration
	P50       time.Duration
	P90       time.Duration
	P95       time.Duration
	P99       time.Duration
}

Result contains the results of a single HTTP request.

type Storage

type Storage interface {
	Writer
	Reader
}

Storage provides goroutine safe capabilities of insertion into and retrieval from the time-series storage. Backed by "nakabonne/tstorage"

func NewStorage

func NewStorage(partitionDuration time.Duration) (Storage, error)

type Writer

type Writer interface {
	Insert(result *Result) error
}