Package codec provides a codec, which encodes and decodes protocol buffers stored in Redis to/from JSON.

ConvertError converts Redis error into errors.Error.

DeduplicateProtos deduplicates protos using key k.

EntityRegex returns a regex that must match a given redis key format.

FindProto finds the protocol buffer stored under the key stored under k.

FindProtos gets protos stored under keys in k.

FindProtosSorted ensures that entries are sorted.

FindProtosWithKeys gets protos stored under keys in k including the keys.

FindProtosWithOffsetAndCount changes the offset and the limit of the query.

GenerateLockerID generates a unique locker ID to be used with a Redis mutex.

GetProto unmarshals protocol buffer message stored under key k in r into pb.

InitMutex initializes the mutex scripts at r.

InputTaskKey returns the subkey of k, where input tasks are stored.

IsConsumerGroupExistsErr returns true if error represents the redis BUSYGROUP error.

Key constructs the full key for entity identified by ks by joining ks using the default separator.

ListKey returns the key list for k is stored under.

ListProtos gets list of protos stored under key k.

LockedWatch locks the key k with a mutex, watches key k and executes f in a transaction.

LockKey returns the key lock for k is stored under.

LockMutex locks the value stored at k with a mutex with identifier id.

MarshalProto marshals pb into printable string.

New returns a new initialized Redis store.

NewContextWithPagination instructs the store to paginate the results.

PaginationLimitAndOffsetFromContext returns the pagination limit and the offset if they are present.

RangeStreams sequentially iterates over all non-acknowledged messages in streams calling f with at most count messages.

ReadyTaskKey returns the subkey of k, where ready tasks are stored.

SetPaginationDefaults should only be called at the initialization of the server.

SetPaginationTotal sets the total number of results inside the paginated context, if it was not set already.

SetProto marshals protocol buffer message represented by pb and stores it under key k in r.

UnlockMutex unlocks the key k with identifier id.

UnmarshalProto unmarshals string returned from MarshalProto into pb.

WaitingTaskKey returns the subkey of k, where waiting tasks are stored.

DefaultRangeCount is the default number of elements to be returned by a SCAN-family operation.

DefaultStreamBlockLimit is the duration for which stream blocking operations such as XRead and XReadGroup should block.

Client represents a Redis store client.

Config represents Redis configuration.

FailoverConfig represents Redis failover configuration.

PaginationDefaults sets default values for paginations options within the Redis store.

ProtoCmd is a command, which can unmarshal its result into a protocol buffer.

TaskQueue is a task queue.

WatchCmdable is transactional redis.Cmdable.

FindProtosOption is an option for the FindProtos query.

ProtosCmd is a command, which can unmarshal its result into multiple protocol buffers.

ProtosWithKeysCmd is a command, which can unmarshal its result into multiple protocol buffers given a key.