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(ctx context.Context) (redigo.Conn, error)
• func HashSum(ObjectName string) (string, error)
• func Initialize()
• func Invalid(table RedisDatabase, key string) (err error)
• func Pool() *redigo.Pool
• 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 (r RedisDatabase) InvalidQueue() string
  • func (r RedisDatabase) String() string

Constants

const InvalidQueueName = "InvalidQueue"

Variables

var (
	CacheCircuit *circuit.Circuit
)

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(ctx context.Context) (redigo.Conn, error)

func HashSum

func HashSum(ObjectName string) (string, error)

Get Object to HighWayHash for redis

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 Pool

func Pool() *redigo.Pool

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 (RedisDatabase) InvalidQueue

func (r RedisDatabase) InvalidQueue() string

func (RedisDatabase) String

func (r RedisDatabase) String() string