redis

Documentation

Index

• Constants
• func DeserializeByTag(i interface{}, typeTag string) (interface{}, error)
• func SerializeByTag(i interface{}, typeTag string) (s string, err error)
• func SerializeByValue(i interface{}) (string, error)
• func SerializeRedisKey(revisionID int, entityKey interface{}) (string, error)
• type DB
  • func Open(opt *types.RedisOpt) *DB
  • func (db *DB) Get(ctx context.Context, opt online.GetOpt) (dbutil.RowMap, error)
  • func (db *DB) Import(ctx context.Context, opt online.ImportOpt) error
  • func (db *DB) MultiGet(ctx context.Context, opt online.MultiGetOpt) (map[string]dbutil.RowMap, error)
  • func (db *DB) Purge(ctx context.Context, revisionID int) error

Constants

const PipelineBatchSize = 10

const SerializeIntBase = 36

Functions

func DeserializeByTag

func DeserializeByTag(i interface{}, typeTag string) (interface{}, error)

func SerializeByTag

func SerializeByTag(i interface{}, typeTag string) (s string, err error)

func SerializeByValue

func SerializeByValue(i interface{}) (string, error)

func SerializeRedisKey

func SerializeRedisKey(revisionID int, entityKey interface{}) (string, error)

Types

type DB

type DB struct {
	*redis.Client
}

func Open

func Open(opt *types.RedisOpt) *DB

func (*DB) Get

func (db *DB) Get(ctx context.Context, opt online.GetOpt) (dbutil.RowMap, error)

func (*DB) Import

func (db *DB) Import(ctx context.Context, opt online.ImportOpt) error

func (*DB) MultiGet

func (db *DB) MultiGet(ctx context.Context, opt online.MultiGetOpt) (map[string]dbutil.RowMap, error)

response: map[entity_key]map[feature_name]feature_value

func (*DB) Purge

func (db *DB) Purge(ctx context.Context, revisionID int) error