datastore

Documentation

Index

• func DialCassandra() *gocql.Session
• func DialRedisClient() *cache.Cache
• type Coordinator
• type EtcdStore
  • func NewEtcd() *EtcdStore
  • func (e *EtcdStore) GetNextRange() (start int, end int)

Functions

func DialCassandra

func DialCassandra() *gocql.Session

func DialRedisClient

func DialRedisClient() *cache.Cache

Types

type Coordinator

type Coordinator interface {
	GetNextRange() (start int, end int)
	Commit(head int)
}

type EtcdStore

type EtcdStore struct {
	KV  clientv3.KV
	CTX context.Context
	V3  *clientv3.Client
	COD Coordinator

	RangeCountKey string
}

func NewEtcd

func NewEtcd() *EtcdStore

func (*EtcdStore) GetNextRange

func (e *EtcdStore) GetNextRange() (start int, end int)