redisstack

Documentation

Index

• Constants
• func AddArgs(sample *Sample, option *Option) []any
• func AlterArgs(key string, option *Option) []any
• func CreateArgs(key string, option *Option) []any
• func CreateRuleArgs(srcKey string, destKey string, aggregateType AggregateType, ...) []any
• func DelArgs(key string, fromTime *time.Time, toTime *time.Time) []any
• func DelResult(val any) (int64, error)
• func DeleteRuleArgs(srcKey string, destKey string) []any
• func GetArgs(key string) []any
• func MAddArgs(samples []*Sample) []any
• func MAddResult(val any) ([]*time.Time, error)
• func MGetArgs(q *MultiQuery) []any
• func MGetResult(val any) (map[string]*MultiSample, error)
• func MRangeArgs(q *MultiQuery) []any
• func MRangeResult(val any) (map[string]*MultiSample, error)
• func MRevRangeArgs(q *MultiQuery) []any
• func MRevRangeResult(val any) (map[string]*MultiSample, error)
• func QueryIndexArgs(filters []string) []any
• func QueryIndexResult(val any) ([]string, error)
• func RangeArgs(key string, q *MultiQuery) []any
• func RevRangeArgs(key string, q *MultiQuery) []any
• type AggregateType
• type DupPolicy
• type MultiQuery
• type MultiQueryAggregation
• type MultiSample
• type Option
• type Sample
  • func GetResult(val any) (*Sample, error)
  • func RangeResult(val any) ([]*Sample, error)
  • func RevRangeResult(val any) ([]*Sample, error)

Constants

const (
	DupPolicyNone = DupPolicy(iota)
	DupPolicyBlock
	DupPolicyFirst
	DupPolicyLast
	DupPolicyMin
	DupPolicyMax
	DupPolicySum
)

const (
	AggregateTypeNone = AggregateType(iota)
	AggregateTypeAvg
	AggregateTypeFirst
	AggregateTypeLast
	AggregateTypeMin
	AggregateTypeMax
	AggregateTypeSum
	AggregateTypeRange
	AggregateTypeCount
	AggregateTypeStdP
	AggregateTypeStdS
	AggregateTypeVarP
	AggregateTypeVarS
	AggregateTypeTWA
)

Functions

func AddArgs

func AddArgs(sample *Sample, option *Option) []any

func AlterArgs

func AlterArgs(key string, option *Option) []any

func CreateArgs

func CreateArgs(key string, option *Option) []any

func CreateRuleArgs

func CreateRuleArgs(srcKey string, destKey string, aggregateType AggregateType, alignTime *time.Duration) []any

func DelArgs

func DelArgs(key string, fromTime *time.Time, toTime *time.Time) []any

func DelResult

func DelResult(val any) (int64, error)

func DeleteRuleArgs

func DeleteRuleArgs(srcKey string, destKey string) []any

func GetArgs

func GetArgs(key string) []any

func MAddArgs

func MAddArgs(samples []*Sample) []any

func MAddResult

func MAddResult(val any) ([]*time.Time, error)

func MGetArgs

func MGetArgs(q *MultiQuery) []any

func MGetResult

func MGetResult(val any) (map[string]*MultiSample, error)

func MRangeArgs

func MRangeArgs(q *MultiQuery) []any

func MRangeResult

func MRangeResult(val any) (map[string]*MultiSample, error)

func MRevRangeArgs

func MRevRangeArgs(q *MultiQuery) []any

func MRevRangeResult

func MRevRangeResult(val any) (map[string]*MultiSample, error)

func QueryIndexArgs

func QueryIndexArgs(filters []string) []any

func QueryIndexResult

func QueryIndexResult(val any) ([]string, error)

func RangeArgs

func RangeArgs(key string, q *MultiQuery) []any

func RevRangeArgs

func RevRangeArgs(key string, q *MultiQuery) []any

Types

type AggregateType

type AggregateType byte

type DupPolicy

type DupPolicy byte

type MultiQuery

type MultiQuery struct {
	FromTime         *time.Time
	ToTime           *time.Time
	Latest           bool
	FiltersByTime    []*time.Time
	FilterByValueMin *float64
	FilterByValueMax *float64
	WithLabels       bool
	SelectedLabels   []string
	Count            *int
	Aggregation      *MultiQueryAggregation
	Filters          []string
	GroupByLabel     string
	Reducer          AggregateType
}

type MultiQueryAggregation

type MultiQueryAggregation struct {
	Align           string
	Aggregator      AggregateType
	BucketDuration  time.Duration
	BucketTimestamp string
	Empty           bool
}

type MultiSample

type MultiSample struct {
	Labels  [][2]string
	Samples []*Sample
}

type Option

type Option struct {
	Retention    *time.Duration
	Uncompressed bool
	ChunkSize    *int64
	DupPolicy    DupPolicy
	Labels       [][2]string
}

type Sample

type Sample struct {
	Key   string
	Time  *time.Time
	Value float64
}

func GetResult

func GetResult(val any) (*Sample, error)

func RangeResult

func RangeResult(val any) ([]*Sample, error)

func RevRangeResult

func RevRangeResult(val any) ([]*Sample, error)