redis

Documentation

Index

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

Constants

const (
	DIR_LIST_MARKER = "\x00"
)

Types

type RedisClusterStore

type RedisClusterStore struct {
	UniversalRedisStore
}

func (*RedisClusterStore) GetName

func (store *RedisClusterStore) GetName() string

func (*RedisClusterStore) Initialize

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

type RedisStore

type RedisStore struct {
	UniversalRedisStore
}

func (*RedisStore) GetName

func (store *RedisStore) GetName() string

func (*RedisStore) Initialize

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

type UniversalRedisStore

type UniversalRedisStore struct {
	Client redis.UniversalClient
}

func (*UniversalRedisStore) BeginTransaction

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

func (*UniversalRedisStore) CommitTransaction

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

func (*UniversalRedisStore) DeleteEntry

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

func (*UniversalRedisStore) DeleteFolderChildren

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

func (*UniversalRedisStore) FindEntry

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

func (*UniversalRedisStore) InsertEntry

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

func (*UniversalRedisStore) KvDelete

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

func (*UniversalRedisStore) KvGet

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

func (*UniversalRedisStore) KvPut

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

func (*UniversalRedisStore) ListDirectoryEntries

func (store *UniversalRedisStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*UniversalRedisStore) ListDirectoryPrefixedEntries

func (store *UniversalRedisStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, prefix string, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*UniversalRedisStore) RollbackTransaction

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

func (*UniversalRedisStore) Shutdown

func (store *UniversalRedisStore) Shutdown()

func (*UniversalRedisStore) UpdateEntry

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