cacheme

Dec 3, 2021

Changes in this version

type StoreSchema

+ MetaData bool

Nov 11, 2021

Changes in this version

type RedisMemoLock

+ func (r *RedisMemoLock) SingleGroup() *singleflight.Group

+ func (r *RedisMemoLock) WaitSingle(ctx context.Context, key string) ([]byte, error)

Oct 24, 2021

Changes in this version

+ type Logger interface

+ Log func(store string, key string, op string)

+ type NOPLogger struct

+ func (l *NOPLogger) Log(store string, key string, op string)

type RedisMemoLock

+ func (r *RedisMemoLock) GetCachedSingle(ctx context.Context, key string) ([]byte, bool, error)

type StoreSchema

+ Singleflight bool

Oct 10, 2021

Changes in this version

+ var ErrClosing = errors.New("operation canceled by close()")

+ var ErrLockRenew = errors.New("unable to renew the lock")

+ var ErrTimeOut = errors.New("operation timed out")

+ func Check(stores []CacheStore)

+ func InvalidAll(ctx context.Context, group string, client RedisClient) error

+ func InvalidAllCluster(ctx context.Context, group string, client RedisClient) error

+ func Marshal(v interface{}) ([]byte, error)

+ func SchemaToStore(prefix string, stores []*StoreSchema, imports []string, save bool) error

+ func Unmarshal(data []byte, v interface{}) error

+ func UpdateMemoLockAll(stores []CacheStore) error

+ type CachePipeline struct

+ Executed chan bool

+ Pipeline redis.Pipeliner

+ Wg *sync.WaitGroup

+ func NewPipeline(client RedisClient) *CachePipeline

+ func (p *CachePipeline) Execute(ctx context.Context) error

+ type CacheStore interface

+ AddMemoLock func() error

+ Initialized func() bool

+ Tag func() string

+ type ExternalFetchFunc = func() error

+ type FetchFunc = func() (string, time.Duration, error)

+ type LockRenewFunc = func(time.Duration) error

+ type RedisClient interface

+ PSubscribe func(ctx context.Context, channels ...string) *redis.PubSub

+ type RedisMemoLock struct

+ func NewRedisMemoLock(ctx context.Context, prefix string, client RedisClient, resourceTag string, ...) (*RedisMemoLock, error)

+ func (r *RedisMemoLock) AddGroup(ctx context.Context, group string, key string) error

+ func (r *RedisMemoLock) Close()

+ func (r *RedisMemoLock) DeleteCache(ctx context.Context, key string) error

+ func (r *RedisMemoLock) GetCached(ctx context.Context, key string) ([]byte, error)

+ func (r *RedisMemoLock) GetCachedP(ctx context.Context, pipe redis.Pipeliner, key string) *redis.StringCmd

+ func (r *RedisMemoLock) Lock(ctx context.Context, key string) (bool, error)

+ func (r *RedisMemoLock) SetCache(ctx context.Context, key string, value []byte, ttl time.Duration) error

+ func (r *RedisMemoLock) Wait(ctx context.Context, key string) ([]byte, error)

+ type RenewableFetchFunc = func(LockRenewFunc) (string, time.Duration, error)

+ type StoreSchema struct

+ Key string

+ Name string

+ TTL time.Duration

+ To string

+ Vars []string

+ Version int

+ func (s *StoreSchema) SetVars(a []string)

+ func (s *StoreSchema) ToType() string