redis2

Documentation

Index

• Constants
• type Redis2Store
  • func (store *Redis2Store) GetName() string
  • func (store *Redis2Store) Initialize(configuration util.Configuration, prefix string) (err error)
• type RedisCluster2Store
  • func (store *RedisCluster2Store) GetName() string
  • func (store *RedisCluster2Store) Initialize(configuration util.Configuration, prefix string) (err error)
• type UniversalRedis2Store
  • func (store *UniversalRedis2Store) BeginTransaction(ctx context.Context) (context.Context, error)
  • func (store *UniversalRedis2Store) CommitTransaction(ctx context.Context) error
  • func (store *UniversalRedis2Store) DeleteEntry(ctx context.Context, fullpath util.FullPath) (err error)
  • func (store *UniversalRedis2Store) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) (err error)
  • func (store *UniversalRedis2Store) FindEntry(ctx context.Context, fullpath util.FullPath) (entry *filer.Entry, err error)
  • func (store *UniversalRedis2Store) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)
  • func (store *UniversalRedis2Store) KvDelete(ctx context.Context, key []byte) (err error)
  • func (store *UniversalRedis2Store) KvGet(ctx context.Context, key []byte) (value []byte, err error)
  • func (store *UniversalRedis2Store) KvPut(ctx context.Context, key []byte, value []byte) (err error)
  • func (store *UniversalRedis2Store) ListDirectoryEntries(ctx context.Context, fullpath util.FullPath, startFileName string, ...) (entries []*filer.Entry, err error)
  • func (store *UniversalRedis2Store) ListDirectoryPrefixedEntries(ctx context.Context, fullpath util.FullPath, startFileName string, ...) (entries []*filer.Entry, err error)
  • func (store *UniversalRedis2Store) RollbackTransaction(ctx context.Context) error
  • func (store *UniversalRedis2Store) Shutdown()
  • func (store *UniversalRedis2Store) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)

Constants

const (
	DIR_LIST_MARKER = "\x00"
)

Types

type Redis2Store

type Redis2Store struct {
	UniversalRedis2Store
}

func (*Redis2Store) GetName

func (store *Redis2Store) GetName() string

func (*Redis2Store) Initialize

func (store *Redis2Store) Initialize(configuration util.Configuration, prefix string) (err error)

type RedisCluster2Store

type RedisCluster2Store struct {
	UniversalRedis2Store
}

func (*RedisCluster2Store) GetName

func (store *RedisCluster2Store) GetName() string

func (*RedisCluster2Store) Initialize

func (store *RedisCluster2Store) Initialize(configuration util.Configuration, prefix string) (err error)

type UniversalRedis2Store

type UniversalRedis2Store struct {
	Client redis.UniversalClient
}

func (*UniversalRedis2Store) BeginTransaction

func (store *UniversalRedis2Store) BeginTransaction(ctx context.Context) (context.Context, error)

func (*UniversalRedis2Store) CommitTransaction

func (store *UniversalRedis2Store) CommitTransaction(ctx context.Context) error

func (*UniversalRedis2Store) DeleteEntry

func (store *UniversalRedis2Store) DeleteEntry(ctx context.Context, fullpath util.FullPath) (err error)

func (*UniversalRedis2Store) DeleteFolderChildren

func (store *UniversalRedis2Store) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) (err error)

func (*UniversalRedis2Store) FindEntry

func (store *UniversalRedis2Store) FindEntry(ctx context.Context, fullpath util.FullPath) (entry *filer.Entry, err error)

func (*UniversalRedis2Store) InsertEntry

func (store *UniversalRedis2Store) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)

func (*UniversalRedis2Store) KvDelete

func (store *UniversalRedis2Store) KvDelete(ctx context.Context, key []byte) (err error)

func (*UniversalRedis2Store) KvGet

func (store *UniversalRedis2Store) KvGet(ctx context.Context, key []byte) (value []byte, err error)

func (*UniversalRedis2Store) KvPut

func (store *UniversalRedis2Store) KvPut(ctx context.Context, key []byte, value []byte) (err error)

func (*UniversalRedis2Store) ListDirectoryEntries

func (store *UniversalRedis2Store) ListDirectoryEntries(ctx context.Context, fullpath util.FullPath, startFileName string, inclusive bool,
	limit int) (entries []*filer.Entry, err error)

func (*UniversalRedis2Store) ListDirectoryPrefixedEntries

func (store *UniversalRedis2Store) ListDirectoryPrefixedEntries(ctx context.Context, fullpath util.FullPath, startFileName string, inclusive bool, limit int, prefix string) (entries []*filer.Entry, err error)

func (*UniversalRedis2Store) RollbackTransaction

func (store *UniversalRedis2Store) RollbackTransaction(ctx context.Context) error

func (*UniversalRedis2Store) Shutdown

func (store *UniversalRedis2Store) Shutdown()

func (*UniversalRedis2Store) UpdateEntry

func (store *UniversalRedis2Store) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)