hermes

package module

Go to main page

Versions in this module

v1

v1.0.1

Apr 11, 2025

Changes in this version

type APIHandler

+ func (h *APIHandler) DecrByHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) ExpireHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) IncrByHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) LTrimHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) PersistHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SAddHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SCardHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SIsMemberHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SMembersHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SRemHandler(w http.ResponseWriter, r *http.Request)

type DB

+ func (db *DB) DecrBy(ctx context.Context, key string, decrement int64) (int64, error)

+ func (db *DB) Expire(ctx context.Context, key string, ttl int) (bool, error)

+ func (db *DB) GetRawEntry(ctx context.Context, key string) (types.Entry, error)

+ func (db *DB) IncrBy(ctx context.Context, key string, increment int64) (int64, error)

+ func (db *DB) LTrim(ctx context.Context, key string, start, stop int) error

+ func (db *DB) Persist(ctx context.Context, key string) (bool, error)

+ func (db *DB) RestoreRawEntry(ctx context.Context, key string, e types.Entry) error

+ func (db *DB) SAdd(ctx context.Context, key string, members ...interface{}) error

+ func (db *DB) SCard(ctx context.Context, key string) (int, error)

+ func (db *DB) SIsMember(ctx context.Context, key string, member interface{}) (bool, error)

+ func (db *DB) SMembers(ctx context.Context, key string) ([]interface{}, error)

+ func (db *DB) SRem(ctx context.Context, key string, members ...interface{}) error

type Transaction

+ func (t *Transaction) DecrBy(ctx context.Context, key string, decrement int64) error

+ func (t *Transaction) Expire(ctx context.Context, key string, ttl int) error

+ func (t *Transaction) IncrBy(ctx context.Context, key string, increment int64) error

+ func (t *Transaction) LTrim(ctx context.Context, key string, start, stop int) error

+ func (t *Transaction) Persist(ctx context.Context, key string) error

+ func (t *Transaction) SAdd(ctx context.Context, key string, members ...interface{}) error

+ func (t *Transaction) SCard(ctx context.Context, key string) (int, error)

+ func (t *Transaction) SIsMember(ctx context.Context, key string, member interface{}) (bool, error)

+ func (t *Transaction) SMembers(ctx context.Context, key string) ([]interface{}, error)

+ func (t *Transaction) SRem(ctx context.Context, key string, members ...interface{}) error

v1.0.0

Mar 30, 2025

Changes in this version

+ var ErrContextCanceled = errors.New("operation canceled")

+ var ErrEmptyList = errors.New("list is empty")

+ var ErrEmptyValues = errors.New("empty value")

+ var ErrInvalidKey = errors.New("invalid key")

+ var ErrInvalidTTL = errors.New("invalid TTL value")

+ var ErrInvalidType = errors.New("invalid data type")

+ var ErrInvalidValueType = errors.New("invalid value type")

+ var ErrKeyExists = errors.New("key already exists")

+ var ErrKeyExpired = errors.New("key expired")

+ var ErrKeyNotFound = errors.New("key not found")

+ var ErrTransactionFailed = errors.New("transaction failed")

+ var ErrTransactionNotActive = errors.New("transaction is not active")

+ var ErrValueMismatch = errors.New("value mismatch")

+ func BenchmarkParallelGet()

+ func BenchmarkParallelSet()

+ func IsContextCanceled(err error) bool

+ func IsEmptyList(err error) bool

+ func IsInvalidKey(err error) bool

+ func IsInvalidTTL(err error) bool

+ func IsInvalidType(err error) bool

+ func IsInvalidValueType(err error) bool

+ func IsKeyExists(err error) bool

+ func IsKeyExpired(err error) bool

+ func IsKeyNotFound(err error) bool

+ func IsTransactionFailed(err error) bool

+ func IsTransactionNotActive(err error) bool

+ func IsValueMismatch(err error) bool

+ type APIHandler struct

+ func NewAPIHandler(ctx context.Context, db contracts.StoreHandler) *APIHandler

+ func (h *APIHandler) CloseAllSubscriptionsHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) DecrHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) DeleteHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) DropAllHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) ExistsHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) FindByValueHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) GetHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) GetSetHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) GetWithDetailsHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) HDelHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) HExistsHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) HGetAllHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) HGetHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) HLenHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) HSetHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) IncrHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) LLenHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) LPopHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) LPushHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) LRangeHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) ListSubscriptionsHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) RPopHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) RPushHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) RenameHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) RunServer(port, prefix string, middlewares ...func(http.Handler) http.Handler)

+ func (h *APIHandler) SetCASHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SetHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SetNXHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SetXXHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) SubscribeHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) TypeHandler(w http.ResponseWriter, r *http.Request)

+ func (h *APIHandler) UpdateTTLHandler(w http.ResponseWriter, r *http.Request)

+ type CommandAPI struct

+ func NewCommandAPI(db contracts.StoreHandler) *CommandAPI

+ func (c *CommandAPI) Execute(ctx context.Context, parts []string) (string, error)

+ type Config struct

+ CleanupInterval time.Duration

+ EnableLogging bool

+ LogBufferSize int

+ LogFile string

+ MinLevel logger.LogLevel

+ PubSubBufferSize int

+ ShardCount int

+ type DB struct

+ func NewStore(config Config) *DB

+ func (db *DB) Close() error

+ func (db *DB) CloseAllSubscriptionsForKey(key string)

+ func (db *DB) Commands() contracts.CommandsHandler

+ func (db *DB) Decr(ctx context.Context, key string) (int64, error)

+ func (db *DB) Delete(ctx context.Context, key string) error

+ func (db *DB) DropAll(ctx context.Context) error

+ func (db *DB) Exists(ctx context.Context, key string) (bool, error)

+ func (db *DB) FindByValue(ctx context.Context, value interface{}) ([]string, error)

+ func (db *DB) Get(ctx context.Context, key string) (interface{}, error)

+ func (db *DB) GetSet(ctx context.Context, key string, newValue interface{}, ttl int) (interface{}, error)

+ func (db *DB) GetWithDetails(ctx context.Context, key string) (interface{}, int, error)

+ func (db *DB) HDel(ctx context.Context, key string, field string) error

+ func (db *DB) HExists(ctx context.Context, key string, field string) (bool, error)

+ func (db *DB) HGet(ctx context.Context, key string, field string) (interface{}, error)

+ func (db *DB) HGetAll(ctx context.Context, key string) (map[string]interface{}, error)

+ func (db *DB) HLen(ctx context.Context, key string) (int, error)

+ func (db *DB) HSet(ctx context.Context, key string, field string, value interface{}, ttl int) error

+ func (db *DB) Incr(ctx context.Context, key string) (int64, error)

+ func (db *DB) LLen(ctx context.Context, key string) (int, error)

+ func (db *DB) LPop(ctx context.Context, key string) (interface{}, error)

+ func (db *DB) LPush(ctx context.Context, key string, values ...interface{}) error

+ func (db *DB) LRange(ctx context.Context, key string, start, end int) ([]interface{}, error)

+ func (db *DB) ListSubscriptions() []string

+ func (db *DB) Logger() contracts.LoggerHandler

+ func (db *DB) RPop(ctx context.Context, key string) (interface{}, error)

+ func (db *DB) RPush(ctx context.Context, key string, values ...interface{}) error

+ func (db *DB) Rename(ctx context.Context, oldKey, newKey string) error

+ func (db *DB) Set(ctx context.Context, key string, value interface{}, ttl int) error

+ func (db *DB) SetCAS(ctx context.Context, key string, oldValue, newValue interface{}, ttl int) error

+ func (db *DB) SetNX(ctx context.Context, key string, value interface{}, ttl int) (bool, error)

+ func (db *DB) SetXX(ctx context.Context, key string, value interface{}, ttl int) (bool, error)

+ func (db *DB) Subscribe(key string) chan string

+ func (db *DB) Transaction() contracts.TransactionHandler

+ func (db *DB) Type(ctx context.Context, key string) (interface{}, error)

+ func (db *DB) Unsubscribe(key string, ch chan string)

+ func (db *DB) UpdateTTL(ctx context.Context, key string, ttl int) error

+ type DataType int

+ const Hash

+ const List

+ const String

+ type Entry struct

+ Expiration time.Time

+ Type DataType

+ Value interface{}

+ type Transaction struct

+ func NewTransaction(db contracts.StoreHandler) *Transaction

+ func (t *Transaction) Commit() error

+ func (t *Transaction) Decr(ctx context.Context, key string) error

+ func (t *Transaction) Delete(ctx context.Context, key string) error

+ func (t *Transaction) Exists(ctx context.Context, key string) (bool, error)

+ func (t *Transaction) FindByValue(ctx context.Context, value interface{}) ([]string, error)

+ func (t *Transaction) Get(ctx context.Context, key string) (interface{}, error)

+ func (t *Transaction) GetSet(ctx context.Context, key string, newValue interface{}, ttl int) (interface{}, error)

+ func (t *Transaction) GetWithDetails(ctx context.Context, key string) (interface{}, int, error)

+ func (t *Transaction) HDel(ctx context.Context, key, field string) error

+ func (t *Transaction) HExists(ctx context.Context, key, field string) (bool, error)

+ func (t *Transaction) HGet(ctx context.Context, key, field string) (interface{}, error)

+ func (t *Transaction) HGetAll(ctx context.Context, key string) (map[string]interface{}, error)

+ func (t *Transaction) HLen(ctx context.Context, key string) (int, error)

+ func (t *Transaction) HSet(ctx context.Context, key, field string, value interface{}, ttl int) error

+ func (t *Transaction) Incr(ctx context.Context, key string) error

+ func (t *Transaction) LLen(ctx context.Context, key string) (int, error)

+ func (t *Transaction) LPop(ctx context.Context, key string) (interface{}, error)

+ func (t *Transaction) LPush(ctx context.Context, key string, values ...interface{}) error

+ func (t *Transaction) LRange(ctx context.Context, key string, start, end int) ([]interface{}, error)

+ func (t *Transaction) RPop(ctx context.Context, key string) (interface{}, error)

+ func (t *Transaction) RPush(ctx context.Context, key string, values ...interface{}) error

+ func (t *Transaction) Rename(ctx context.Context, oldKey, newKey string) error

+ func (t *Transaction) Rollback() error

+ func (t *Transaction) Set(ctx context.Context, key string, value interface{}, ttl int) error

+ func (t *Transaction) SetCAS(ctx context.Context, key string, oldValue, newValue interface{}, ttl int) error

+ func (t *Transaction) SetNX(ctx context.Context, key string, value interface{}, ttl int) error

+ func (t *Transaction) SetXX(ctx context.Context, key string, value interface{}, ttl int) error

+ func (t *Transaction) Type(ctx context.Context, key string) (interface{}, error)

+ func (t *Transaction) UpdateTTL(ctx context.Context, key string, ttl int) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL