redistimeseries-go

Go client for RedisTimeSeries (https://github.com/RedisTimeSeries/redistimeseries), based on redigo.

Client and ConnPool based on the work of dvirsky and mnunberg on https://github.com/RediSearch/redisearch-go

Installing

$ go get github.com/0x090909/redis-timeseries

Running tests

A simple test suite is provided, and can be run with:

$ go test

The tests expect a Redis server with the RedisTimeSeries module loaded to be available at localhost:6379

Example Code

package main 

import (
        "fmt"
        redistimeseries "github.com/0x090909/redis-timeseries"
)

func main() {
	// Connect to localhost with no password
	var dbNumber = 0
	var authPWD = nil
        var client = redistimeseries.NewClient("localhost:6379", "nohelp", authPWD, dbNumber)
        var keyname = "mytest"
        _, haveit := client.Info(keyname)
        if haveit != nil {
			client.CreateKeyWithOptions(keyname, redistimeseries.DefaultCreateOptions)
			client.CreateKeyWithOptions(keyname+"_avg", redistimeseries.DefaultCreateOptions)
			client.CreateRule(keyname, redistimeseries.AvgAggregation, 60, keyname+"_avg")
        }
		// Add sample with timestamp from server time and value 100
        // TS.ADD mytest * 100 
        _, err := client.AddAutoTs(keyname, 100)
        if err != nil {
                fmt.Println("Error:", err)
        }
}

Supported RedisTimeSeries Commands

Command	Recommended API and godoc
TS.CREATE	CreateKeyWithOptions
TS.ALTER	AlterKeyWithOptions
TS.ADD	Add AddAutoTs AddWithOptions AddAutoTsWithOptions
TS.MADD	MultiAdd
TS.INCRBY/TS.DECRBY	IncrBy / DecrBy
TS.CREATERULE	CreateRule
TS.DELETERULE	DeleteRule
TS.RANGE	RangeWithOptions
TS.REVRANGE	ReverseRangeWithOptions
TS.MRANGE	MultiRangeWithOptions
TS.MREVRANGE	MultiReverseRangeWithOptions
TS.GET	Get
TS.MGET	MultiGet MultiGetWithOptions
TS.INFO	Info
TS.QUERYINDEX	QueryIndex

License

redistimeseries-go is distributed under the Apache-2 license - see LICENSE