cache

Feb 13, 2023

Changes in this version

+ const DefaultCacheTimeout

+ const LOCK_ACK

+ const LOCK_ACK_SUFFIX

+ const LOCK_NACK

+ const LOCK_NACK_SUFFIX

+ const MEMORY

+ const POOL_PREFIX

+ const PROCESSING_POOL_SUFFIX

+ const RECOVERY_BREAKPOINT_KEY

+ const RECOVERY_FINISHED

+ const RECOVERY_RUNNING

+ const RECOVERY_STORAGE_BREAKPOINT_KEY

+ const REDIS

+ var LOCK_ACK_POOL_REGEX = regexp.MustCompile("(.+)" + LOCK_ACK_SUFFIX + "$")

+ var LOCK_NACK_POOL_REGEX = regexp.MustCompile("(.+)" + LOCK_NACK_SUFFIX + "$")

+ var PROCESSING_POOL_REGEX = regexp.MustCompile("(.+)" + PROCESSING_POOL_SUFFIX + "$")

+ type Cache interface

+ Close func(ctx context.Context) error

+ Flush func(ctx context.Context)

+ Get func(ctx context.Context, key string) (value string, err error)

+ Insert func(ctx context.Context, queue string, messages ...*entities.Message) (insertions []string, err error)

+ IsProcessing func(ctx context.Context, queue string, id string) (bool, error)

+ ListQueues func(ctx context.Context, pattern string, poolType entities.PoolType) (queues []string, err error)

+ LockMessage func(ctx context.Context, message *entities.Message, lockType LockType) (bool, error)

+ MakeAvailable func(ctx context.Context, message *entities.Message) (bool, error)

+ PullMessages func(ctx context.Context, queue string, n int64, scoreFilter int64) (ids []string, err error)

+ Remove func(ctx context.Context, queue string, ids ...string) (removed int64, err error)

+ Set func(ctx context.Context, key string, value string) error

+ TimeoutMessages func(ctx context.Context, queue string, timeout time.Duration) (ids []string, err error)

+ UnlockMessages func(ctx context.Context, queue string, lockType LockType) (messages []string, err error)

+ func CreateCache(ctx context.Context, cacheType Type) (Cache, error)

+ type LockType string

+ type MemoryCache struct

+ func NewMemoryCache() *MemoryCache

+ func (cache *MemoryCache) Close(ctx context.Context) error

+ func (cache *MemoryCache) Flush(_ context.Context)

+ func (cache *MemoryCache) Get(_ context.Context, key string) (value string, err error)

+ func (cache *MemoryCache) Insert(ctx context.Context, queue string, messages ...*entities.Message) ([]string, error)

+ func (cache *MemoryCache) IsProcessing(ctx context.Context, queue string, id string) (bool, error)

+ func (cache *MemoryCache) ListQueues(ctx context.Context, pattern string, poolType entities.PoolType) (queues []string, err error)

+ func (cache *MemoryCache) LockMessage(_ context.Context, message *entities.Message, lockType LockType) (bool, error)

+ func (cache *MemoryCache) MakeAvailable(_ context.Context, message *entities.Message) (bool, error)

+ func (cache *MemoryCache) PullMessages(ctx context.Context, queue string, n int64, scoreFilter int64) (ids []string, err error)

+ func (cache *MemoryCache) Remove(ctx context.Context, queue string, ids ...string) (removed int64, err error)

+ func (cache *MemoryCache) Set(_ context.Context, key string, value string) error

+ func (cache *MemoryCache) TimeoutMessages(_ context.Context, queue string, timeout time.Duration) (ids []string, err error)

+ func (cache *MemoryCache) UnlockMessages(ctx context.Context, queue string, lockType LockType) (messages []string, err error)

+ type MemoryMessageEntry struct

+ type RedisCache struct

+ Client *redis.Client

+ func NewRedisCache(ctx context.Context) (*RedisCache, error)

+ func (cache *RedisCache) Close(ctx context.Context) error

+ func (cache *RedisCache) Flush(ctx context.Context)

+ func (cache *RedisCache) Get(ctx context.Context, key string) (string, error)

+ func (cache *RedisCache) Insert(ctx context.Context, queue string, messages ...*entities.Message) ([]string, error)

+ func (cache *RedisCache) IsProcessing(ctx context.Context, queue string, id string) (bool, error)

+ func (cache *RedisCache) ListQueues(ctx context.Context, pattern string, poolType entities.PoolType) (queues []string, err error)

+ func (cache *RedisCache) LockMessage(ctx context.Context, message *entities.Message, lockType LockType) (bool, error)

+ func (cache *RedisCache) MakeAvailable(ctx context.Context, message *entities.Message) (bool, error)

+ func (cache *RedisCache) PullMessages(ctx context.Context, queue string, n int64, scoreFilter int64) (ids []string, err error)

+ func (cache *RedisCache) Remove(ctx context.Context, queue string, ids ...string) (removed int64, err error)

+ func (cache *RedisCache) Set(ctx context.Context, key string, value string) error

+ func (cache *RedisCache) TimeoutMessages(ctx context.Context, queue string, timeout time.Duration) ([]string, error)

+ func (cache *RedisCache) UnlockMessages(ctx context.Context, queue string, lockType LockType) ([]string, error)

+ type Type string