Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

redis_timeseries_go

package module

Go to main page

Versions in this module

v0

v0.4.1

Oct 17, 2023

v0.4.1-beta1

Oct 17, 2023

v0.4.0

Jul 12, 2023

Changes in this version

+ const ADD_CMD

+ const ALTER_CMD

+ const CREATERULE_CMD

+ const CREATE_CMD

+ const DECRBY_CMD

+ const DELETERULE_CMD

+ const DEL_CMD

+ const GET_CMD

+ const INCRBY_CMD

+ const INFO_CMD

+ const MADD_CMD

+ const MGET_CMD

+ const MRANGE_CMD

+ const MREVRANGE_CMD

+ const QUERYINDEX_CMD

+ const RANGE_CMD

+ const REVRANGE_CMD

+ const TS_DEL_CMD

+ const TimeRangeFull

+ const TimeRangeMaximum

+ const TimeRangeMinimum

+ var DefaultCreateOptions = CreateOptions

+ var DefaultGetOptions = *NewGetOptions()

+ var DefaultMultiGetOptions = *NewMultiGetOptions()

+ var DefaultMultiRangeOptions = *NewMultiRangeOptions()

+ var DefaultRangeOptions = *NewRangeOptions()

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

+ func MakeStringPtr(s string) *string

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

+ type AggregationType string

+ const AvgAggregation

+ const CountAggregation

+ const FirstAggregation

+ const LastAggregation

+ const MaxAggregation

+ const MinAggregation

+ const RangeAggregation

+ const StdPAggregation

+ const StdSAggregation

+ const SumAggregation

+ const TwaAggregation

+ const VarPAggregation

+ const VarSAggregation

+ type BucketTimestamp string

+ const HighBucketTimestamp

+ const LowBucketTimestamp

+ const MidBucketTimestamp

+ type ChunkType string

+ const CompressedChunkType

+ const UncompressedChunkType

+ type Client struct

+ Name string

+ Pool ConnPool

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

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

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

+ 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) AddWithOptions(key string, timestamp int64, value float64, options CreateOptions) (storedTimestamp int64, err error)

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

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

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

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

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

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

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

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

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

+ func (client *Client) DeleteRange(key string, fromTimestamp int64, toTimestamp int64) (totalDeletedSamples int64, err error)

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

+ func (client *Client) DeleteSerie(key string) (err error)

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

+ func (client *Client) GetWithOptions(key string, getOptions GetOptions) (dataPoint *DataPoint, err error)

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

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

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

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

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

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

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

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

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

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

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

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

+ type ConnPool interface

+ Close func() error

+ Get func() redis.Conn

+ type CreateOptions struct

+ ChunkSize int64

+ DuplicatePolicy DuplicatePolicyType

+ Labels map[string]string

+ RetentionMSecs time.Duration

+ Uncompressed bool

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

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

+ type DataPoint struct

+ Timestamp int64

+ Value float64

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

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

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

+ type DuplicatePolicyType string

+ const BlockDuplicatePolicy

+ const FirstDuplicatePolicy

+ const LastDuplicatePolicy

+ const MaxDuplicatePolicy

+ const MinDuplicatePolicy

+ type GetOptions struct

+ Latest bool

+ func NewGetOptions() *GetOptions

+ func (getOptions *GetOptions) SetLatest(latest bool) *GetOptions

+ type KeyInfo struct

+ ChunkCount int64

+ ChunkSize int64

+ ChunkType ChunkType

+ DuplicatePolicy DuplicatePolicyType

+ FirstTimestamp int64

+ Labels map[string]string

+ LastTimestamp int64

+ MaxSamplesPerChunk int64

+ MemoryUsage int64

+ RetentionTime int64

+ Rules []Rule

+ SourceKey string

+ TotalSamples int64

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

+ type MultiGetOptions struct

+ Latest bool

+ WithLabels bool

+ func NewMultiGetOptions() *MultiGetOptions

+ func (mgetOpts *MultiGetOptions) SetLatest(latest bool) *MultiGetOptions

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

+ type MultiHostPool struct

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

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

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

+ type MultiRangeOptions struct

+ AggType AggregationType

+ Align int64

+ BucketTimestamp BucketTimestamp

+ Count int64

+ Empty bool

+ FilterByTs []int64

+ FilterByValueMax *float64

+ FilterByValueMin *float64

+ GroupBy string

+ Latest bool

+ Reduce ReducerType

+ SelectedLabels []string

+ TimeBucket int

+ WithLabels bool

+ func NewMultiRangeOptions() *MultiRangeOptions

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

+ func (mrangeopts *MultiRangeOptions) SetAlign(byTimeStamp int64) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetBucketTimestamp(bucketTimestamp BucketTimestamp) *MultiRangeOptions

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

+ func (mrangeopts *MultiRangeOptions) SetEmpty(empty bool) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetFilterByTs(filterByTS []int64) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetFilterByValue(min, max float64) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetGroupByReduce(byLabel string, reducer ReducerType) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetLatest(latest bool) *MultiRangeOptions

+ func (mrangeopts *MultiRangeOptions) SetSelectedLabels(labels []string) *MultiRangeOptions

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

+ type Range struct

+ DataPoints []DataPoint

+ Labels map[string]string

+ Name string

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

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

+ type RangeOptions struct

+ AggType AggregationType

+ Align int64

+ BucketTimestamp BucketTimestamp

+ Count int64

+ Empty bool

+ FilterByTs []int64

+ FilterByValueMax *float64

+ FilterByValueMin *float64

+ Latest bool

+ TimeBucket int

+ func NewRangeOptions() *RangeOptions

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

+ func (rangeopts *RangeOptions) SetAlign(byTimeStamp int64) *RangeOptions

+ func (rangeopts *RangeOptions) SetBucketTimestamp(bucketTimestamp BucketTimestamp) *RangeOptions

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

+ func (rangeopts *RangeOptions) SetEmpty(empty bool) *RangeOptions

+ func (rangeopts *RangeOptions) SetFilterByTs(filterByTS []int64) *RangeOptions

+ func (rangeopts *RangeOptions) SetFilterByValue(min, max float64) *RangeOptions

+ func (rangeopts *RangeOptions) SetLatest(latest bool) *RangeOptions

+ type ReducerType string

+ const MaxReducer

+ const MinReducer

+ const SumReducer

+ type Rule struct

+ AggType AggregationType

+ BucketSizeSec int

+ DestKey string

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

+ type Sample struct

+ DataPoint DataPoint

+ Key string

+ type SingleHostPool struct

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