redis_lua

Documentation

Index

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

Constants

const (
	DIR_LIST_MARKER = "\x00"
)

Types

type RedisLuaClusterStore

type RedisLuaClusterStore struct {
	UniversalRedisLuaStore
}

func (*RedisLuaClusterStore) GetName

func (store *RedisLuaClusterStore) GetName() string

func (*RedisLuaClusterStore) Initialize

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

type RedisLuaSentinelStore

type RedisLuaSentinelStore struct {
	UniversalRedisLuaStore
}

func (*RedisLuaSentinelStore) GetName

func (store *RedisLuaSentinelStore) GetName() string

func (*RedisLuaSentinelStore) Initialize

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

type RedisLuaStore

type RedisLuaStore struct {
	UniversalRedisLuaStore
}

func (*RedisLuaStore) GetName

func (store *RedisLuaStore) GetName() string

func (*RedisLuaStore) Initialize

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

type UniversalRedisLuaStore

type UniversalRedisLuaStore struct {
	Client redis.UniversalClient
	// contains filtered or unexported fields
}

func (*UniversalRedisLuaStore) BeginTransaction

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

func (*UniversalRedisLuaStore) CommitTransaction

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

func (*UniversalRedisLuaStore) DeleteEntry

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

func (*UniversalRedisLuaStore) DeleteFolderChildren

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

func (*UniversalRedisLuaStore) FindEntry

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

func (*UniversalRedisLuaStore) InsertEntry

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

func (*UniversalRedisLuaStore) KvDelete

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

func (*UniversalRedisLuaStore) KvGet

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

func (*UniversalRedisLuaStore) KvPut

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

func (*UniversalRedisLuaStore) ListDirectoryEntries

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

func (*UniversalRedisLuaStore) ListDirectoryPrefixedEntries

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

func (*UniversalRedisLuaStore) RollbackTransaction

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

func (*UniversalRedisLuaStore) Shutdown

func (store *UniversalRedisLuaStore) Shutdown()

func (*UniversalRedisLuaStore) UpdateEntry

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