redis

Documentation

Index

• Constants
• Variables
• func Close()
• func Get(table RedisDatabase, key string, unmarshal func([]byte) (interface{}, error)) (value interface{}, err error)
• func GetBytes(key string, start int64, end int64) ([]byte, error)
• func GetClient() (*redis.Client, error)
• func Initialize()
• func Invalid(table RedisDatabase, key string) (err error)
• func PutClient(c *redis.Client)
• func Remove(table RedisDatabase, key string) (err error)
• func Set(table RedisDatabase, key string, value interface{}) (err error)
• func SetBytes(key string, value []byte) (err error)
• type RedisDatabase
  • func TableFromChannelName(name string) (r RedisDatabase, err error)
  • func (r RedisDatabase) InvalidQueue() string
  • func (r RedisDatabase) String() string

Constants

const InvalidQueueName = "InvalidQueue"

Variables

var DataTables = []RedisDatabase{FileTable}

var MetadataTables = []RedisDatabase{UserTable, BucketTable, ObjectTable, ClusterTable}

Functions

func Close

func Close()

func Get

func Get(table RedisDatabase, key string,
	unmarshal func([]byte) (interface{}, error)) (value interface{}, err error)

func GetBytes

func GetBytes(key string, start int64, end int64) ([]byte, error)

Get file bytes `start` and `end` are inclusive FIXME: this API causes an extra memory copy, need to patch radix to fix it

func GetClient

func GetClient() (*redis.Client, error)

func Initialize

func Initialize()

func Invalid

func Invalid(table RedisDatabase, key string) (err error)

Publish the invalid message to other YIG instances through Redis

func PutClient

func PutClient(c *redis.Client)

func Remove

func Remove(table RedisDatabase, key string) (err error)

func Set

func Set(table RedisDatabase, key string, value interface{}) (err error)

func SetBytes

func SetBytes(key string, value []byte) (err error)

Set file bytes

Types

type RedisDatabase

type RedisDatabase int

const (
	UserTable RedisDatabase = iota
	BucketTable
	ObjectTable
	FileTable
	ClusterTable
)

func TableFromChannelName

func TableFromChannelName(name string) (r RedisDatabase, err error)

func (RedisDatabase) InvalidQueue

func (r RedisDatabase) InvalidQueue() string

func (RedisDatabase) String

func (r RedisDatabase) String() string