Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

redists

package module

Go to main page

Versions in this module

v0

v0.5.2

May 18, 2022

v0.5.1

Mar 4, 2022

Changes in this version

+ type Duration interface

+ Milliseconds func() int64

type OptionAlter

+ func AlterWithChunkSize(cs int) OptionAlter

+ func AlterWithDuplicatePolicy(dp DuplicatePolicy) OptionAlter

v0.5.0

Jan 5, 2022

Changes in this version

+ const AggregationTypeAvg

+ const AggregationTypeCount

+ const AggregationTypeFirst

+ const AggregationTypeLast

+ const AggregationTypeMax

+ const AggregationTypeMin

+ const AggregationTypeRange

+ const AggregationTypeStdP

+ const AggregationTypeStdS

+ const AggregationTypeSum

+ const AggregationTypeVarP

+ const AggregationTypeVarS

+ const DuplicatePolicyBlock

+ const DuplicatePolicyFirst

+ const DuplicatePolicyLast

+ const DuplicatePolicyMax

+ const DuplicatePolicyMin

+ const DuplicatePolicySum

+ const EncodingCompressed

+ const EncodingUncompressed

+ const ReducerMax

+ const ReducerMin

+ const ReducerSum

+ type Aggregation struct

+ TimeBucket time.Duration

+ Type AggregationType

+ type AggregationType string

+ type ChunkInfo struct

+ BytesPerSample float64

+ EndTimestamp time.Time

+ Samples int64

+ Size int64

+ StartTimestamp time.Time

+ type Client struct

+ func NewClient(d Doer) *Client

+ func (c *Client) Add(ctx context.Context, s Sample, options ...OptionAdd) (time.Time, error)

+ func (c *Client) Alter(ctx context.Context, key string, options ...OptionAlter) error

+ func (c *Client) Create(ctx context.Context, key string, options ...OptionCreate) error

+ func (c *Client) CreateRule(ctx context.Context, srcKey, destKey string, a AggregationType, ...) error

+ func (c *Client) DecrBy(ctx context.Context, key string, value float64, options ...OptionCounter) (time.Time, error)

+ func (c *Client) Del(ctx context.Context, key string, from time.Time, to time.Time) (int64, error)

+ func (c *Client) DeleteRule(ctx context.Context, srcKey, destKey string) error

+ func (c *Client) Get(ctx context.Context, key string) (*DataPoint, error)

+ func (c *Client) IncrBy(ctx context.Context, key string, value float64, options ...OptionCounter) (time.Time, error)

+ func (c *Client) Info(ctx context.Context, key string, options ...OptionInfo) (Info, error)

+ func (c *Client) MAdd(ctx context.Context, s []Sample) ([]MultiResult, error)

+ func (c *Client) MGet(ctx context.Context, filters []Filter, options ...OptionMGet) ([]LastDatapoint, error)

+ func (c *Client) MRange(ctx context.Context, from Timestamp, to Timestamp, filters []Filter, ...) ([]TimeSeries, error)

+ func (c *Client) MRevRange(ctx context.Context, from Timestamp, to Timestamp, filters []Filter, ...) ([]TimeSeries, error)

+ func (c *Client) QueryIndex(ctx context.Context, filters []Filter) ([]string, error)

+ func (c *Client) Range(ctx context.Context, key string, from Timestamp, to Timestamp, ...) ([]DataPoint, error)

+ func (c *Client) RevRange(ctx context.Context, key string, from Timestamp, to Timestamp, ...) ([]DataPoint, error)

+ type DataPoint struct

+ Timestamp time.Time

+ Value float64

+ type Doer interface

+ Do func(ctx context.Context, cmd string, args ...interface{}) (interface{}, error)

+ type DuplicatePolicy string

+ type Encoding string

+ type Filter struct

+ Equal bool

+ Label string

+ Values []string

+ func FilterEqual(label string, values ...string) Filter

+ func FilterNotEqual(label string, values ...string) Filter

+ func (f Filter) Arg() interface{}

+ type GroupBy struct

+ Label string

+ Reducer ReducerType

+ type Info struct

+ ChunkCount int64

+ ChunkSize int64

+ ChunkType Encoding

+ Chunks []ChunkInfo

+ DuplicatePolicy *DuplicatePolicy

+ FirstTimestamp time.Time

+ Labels Labels

+ LastTimestamp time.Time

+ MemoryUsage int64

+ RetentionTime time.Duration

+ Rules Rules

+ SourceKey string

+ TotalSamples int64

+ type Labels map[string]string

+ type LastDatapoint struct

+ DataPoint *DataPoint

+ Key string

+ Labels Labels

+ type MultiResult struct

+ func (r MultiResult) Err() error

+ func (r MultiResult) Time() time.Time

+ type OptionAdd func(cmd *cmdAdd)

+ func AddWithChunkSize(cs int) OptionAdd

+ func AddWithEncoding(e Encoding) OptionAdd

+ func AddWithLabels(ls Labels) OptionAdd

+ func AddWithOnDuplicate(dp DuplicatePolicy) OptionAdd

+ func AddWithRetention(r time.Duration) OptionAdd

+ type OptionAlter func(cmd *cmdAlter)

+ func AlterWithLabels(ls Labels) OptionAlter

+ func AlterWithRetention(r time.Duration) OptionAlter

+ type OptionCounter func(cmd *cmdCounter)

+ func CounterWithChunkSize(cs int) OptionCounter

+ func CounterWithEncoding(e Encoding) OptionCounter

+ func CounterWithLabels(ls Labels) OptionCounter

+ func CounterWithRetention(r time.Duration) OptionCounter

+ func CounterWithTimestamp(t time.Time) OptionCounter

+ type OptionCreate func(cmd *cmdCreate)

+ func CreateWithChunkSize(cs int) OptionCreate

+ func CreateWithDuplicatePolicy(dp DuplicatePolicy) OptionCreate

+ func CreateWithEncoding(e Encoding) OptionCreate

+ func CreateWithLabels(ls Labels) OptionCreate

+ func CreateWithRetention(r time.Duration) OptionCreate

+ type OptionInfo func(cmd *cmdInfo)

+ func InfoWithDebug() OptionInfo

+ type OptionMGet func(cmd *cmdMGet)

+ func MGetWithLabels(labels ...string) OptionMGet

+ type OptionMRanger func(cmd *cmdMRanger)

+ func MRangerWithAggregation(t AggregationType, timeBucket time.Duration) OptionMRanger

+ func MRangerWithAlign(a Timestamp) OptionMRanger

+ func MRangerWithCount(c int64) OptionMRanger

+ func MRangerWithGroupBy(label string, reducer ReducerType) OptionMRanger

+ func MRangerWithLabels(labels ...string) OptionMRanger

+ func MRangerWithTSFilter(tss ...time.Time) OptionMRanger

+ func MRangerWithValueFilter(min float64, max float64) OptionMRanger

+ type OptionRanger func(cmd *cmdRanger)

+ func RangerWithAggregation(t AggregationType, timeBucket time.Duration) OptionRanger

+ func RangerWithAlign(a Timestamp) OptionRanger

+ func RangerWithCount(c int64) OptionRanger

+ func RangerWithTSFilter(tss ...time.Time) OptionRanger

+ func RangerWithValueFilter(min float64, max float64) OptionRanger

+ type ReducerType string

+ type Rules map[string]Aggregation

+ type Sample struct

+ Key string

+ Timestamp Timestamp

+ Value float64

+ func NewSample(key string, timestamp Timestamp, value float64) Sample

+ type TS struct

+ func TSAuto() TS

+ func TSMax() TS

+ func TSMin() TS

+ func (t TS) Auto() bool

+ func (t TS) Max() bool

+ func (t TS) Min() bool

+ type TimeSeries struct

+ DataPoints []DataPoint

+ Key string

+ Labels Labels

+ type Timestamp interface

+ UnixMilli func() int64

+ type TimestampAuto interface

+ Auto func() bool

+ type TimestampMax interface

+ Max func() bool

+ type TimestampMin interface

+ Min func() bool