redis_timeseries_go

Jul 23, 2020

Changes in this version

type Client

+ func (client *Client) MultiReverseRangeWithOptions(fromTimestamp int64, toTimestamp int64, mrangeOptions MultiRangeOptions, ...) (ranges []Range, err error)

+ func (client *Client) ReverseRangeWithOptions(key string, fromTimestamp int64, toTimestamp int64, rangeOptions RangeOptions) (dataPoints []DataPoint, err error)

Jul 20, 2020

Changes in this version

+ var DefaultMultiGetOptions = MultiGetOptions

+ func AddCounterArgs(key string, timestamp int64, value float64, options CreateOptions) (redis.Args, error)

type Client

+ func NewClientFromPool(pool *redis.Pool, name string) *Client

+ func (client *Client) AlterKeyWithOptions(key string, options CreateOptions) (err error)

+ func (client *Client) DecrBy(key string, timestamp int64, value float64, options CreateOptions) (int64, error)

+ func (client *Client) IncrBy(key string, timestamp int64, value float64, options CreateOptions) (int64, error)

+ func (client *Client) MultiAdd(samples ...Sample) (timestamps []interface{}, err error)

+ func (client *Client) MultiGetWithOptions(multiGetOptions MultiGetOptions, filters ...string) (ranges []Range, err error)

+ func (client *Client) QueryIndex(filters ...string) (keys []string, err error)

type ConnPool

+ Close func() error

+ type MultiGetOptions struct

+ WithLabels bool

+ func NewMultiGetOptions() *MultiGetOptions

+ func (mgetopts *MultiGetOptions) SetWithLabels(value bool) *MultiGetOptions

type MultiHostPool

+ func (p *MultiHostPool) Close() (err error)

+ type Sample struct

+ DataPoint DataPoint

+ Key string

Jan 27, 2020

Changes in this version

+ const TimeRangeFull

+ const TimeRangeMaximum

+ const TimeRangeMinimum

+ var DefaultCreateOptions = CreateOptions

+ var DefaultMultiRangeOptions = MultiRangeOptions

+ var DefaultRangeOptions = *NewRangeOptions()

+ func ParseLabels(res interface{}) (labels map[string]string, err error)

type AggregationType

+ const StdPAggregation

+ const StdSAggregation

+ const VarPAggregation

+ const VarSAggregation

type Client

+ func (client *Client) AddAutoTs(key string, value float64) (storedTimestamp int64, err error)

+ func (client *Client) AddAutoTsWithOptions(key string, value float64, options CreateOptions) (storedTimestamp int64, err error)

+ func (client *Client) Get(key string) (dataPoint *DataPoint, err error)

+ func (client *Client) MultiGet(filters ...string) (ranges []Range, err error)

+ func (client *Client) MultiRangeWithOptions(fromTimestamp int64, toTimestamp int64, mrangeOptions MultiRangeOptions, ...) (ranges []Range, err error)

+ func (client *Client) RangeWithOptions(key string, fromTimestamp int64, toTimestamp int64, rangeOptions RangeOptions) (dataPoints []DataPoint, err error)

type CreateOptions

+ RetentionMSecs time.Duration

+ Uncompressed bool

+ func (options *CreateOptions) Serialize(args []interface{}) (result []interface{}, err error)

type DataPoint

+ func NewDataPoint(timestamp int64, value float64) *DataPoint

+ func ParseDataPoint(rawDataPoint interface{}) (dataPoint *DataPoint, err error)

+ func ParseDataPoints(info interface{}) (dataPoints []DataPoint, err error)

type KeyInfo

+ Labels map[string]string

+ type MultiRangeOptions struct

+ AggType AggregationType

+ Count int64

+ TimeBucket int

+ WithLabels bool

+ func NewMultiRangeOptions() *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetAggregation(aggType AggregationType, timeBucket int) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetCount(count int64) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetWithLabels(value bool) *MultiRangeOptions

type Range

+ func ParseRanges(info interface{}) (ranges []Range, err error)

+ func ParseRangesSingleDataPoint(info interface{}) (ranges []Range, err error)

+ type RangeOptions struct

+ AggType AggregationType

+ Count int64

+ TimeBucket int

+ func NewRangeOptions() *RangeOptions

+ func (rangeopts *RangeOptions) SetAggregation(aggType AggregationType, timeBucket int) *RangeOptions

+ func (rangeopts *RangeOptions) SetCount(count int64) *RangeOptions

Aug 4, 2019

Changes in this version

type Client

+ func (client *Client) AddWithOptions(key string, timestamp int64, value float64, options CreateOptions) (err error)

+ func (client *Client) AddWithRetention(key string, timestamp int64, value float64, duration int64) (err error)

+ func (client *Client) AggMultiRange(fromTimestamp int64, toTimestamp int64, aggType AggregationType, ...) (ranges []Range, err error)

+ func (client *Client) CreateKeyWithOptions(key string, options CreateOptions) (err error)

+ type CreateOptions struct

+ Labels map[string]string

+ RetentionSecs time.Duration

+ func (options *CreateOptions) Append(args []interface{}) (result []interface{})

+ type Range struct

+ DataPoints []DataPoint

+ Labels map[string]string

+ Name string

Jun 24, 2019

Changes in this version

type Client

+ Name string

+ Pool ConnPool

type KeyInfo

+ RetentionTime int64

Mar 7, 2019

Changes in this version

+ func MakeStringPtr(s string) *string

+ type AggregationType int

+ const AvgAggregation

+ const CountAggregation

+ const FirstAggregation

+ const LastAggregation

+ const MaxAggregation

+ const MinAggregation

+ const SumAggregation

+ func (aggType AggregationType) String() string

+ type Client struct

+ func NewClient(addr, name string, authPass *string) *Client

+ func (client *Client) Add(key string, timestamp int64, value float64) (err error)

+ func (client *Client) AggRange(key string, fromTimestamp int64, toTimestamp int64, aggType AggregationType, ...) (dataPoints []DataPoint, err error)

+ func (client *Client) CreateKey(key string, retentionSecs time.Duration) (err error)

+ func (client *Client) CreateRule(sourceKey string, aggType AggregationType, bucketSizeSec uint, ...) (err error)

+ func (client *Client) DeleteRule(sourceKey string, destinationKey string) (err error)

+ func (client *Client) Info(key string) (res KeyInfo, err error)

+ func (client *Client) Range(key string, fromTimestamp int64, toTimestamp int64) (dataPoints []DataPoint, err error)

+ type ConnPool interface

+ Get func() redis.Conn

+ type DataPoint struct

+ Timestamp int64

+ Value float64

+ type KeyInfo struct

+ ChunkCount int64

+ LastTimestamp int64

+ MaxSamplesPerChunk int64

+ RetentionSecs int64

+ Rules []Rule

+ func ParseInfo(result interface{}, err error) (info KeyInfo, outErr error)

+ type MultiHostPool struct

+ func NewMultiHostPool(hosts []string, authPass *string) *MultiHostPool

+ func (p *MultiHostPool) Get() redis.Conn

+ type Rule struct

+ AggType AggregationType

+ BucketSizeSec int

+ DestKey string

+ func ParseRules(ruleInterface interface{}, err error) (rules []Rule, retErr error)

+ type SingleHostPool struct

+ func NewSingleHostPool(host string, authPass *string) *SingleHostPool