Documentation
¶
Index ¶
- Variables
- func AddStateStore(name string, stateStore StateStore)
- func StateStores() map[string]StateStore
- type BigCacheStateStore
- func (b *BigCacheStateStore) Delete(ctx context.Context, key string) error
- func (b *BigCacheStateStore) Get(ctx context.Context, key string) ([]byte, error)
- func (b *BigCacheStateStore) Keys(ctx context.Context, limit int) ([]string, error)
- func (b *BigCacheStateStore) Put(ctx context.Context, key string, val []byte) error
- func (b *BigCacheStateStore) PutWithExpireTime(ctx context.Context, key string, val []byte, expireSeconds int) error
- type FreeCacheStateStore
- func (f *FreeCacheStateStore) Delete(ctx context.Context, key string) error
- func (f *FreeCacheStateStore) Get(ctx context.Context, key string) ([]byte, error)
- func (f *FreeCacheStateStore) Keys(ctx context.Context, limit int) ([]string, error)
- func (f *FreeCacheStateStore) Put(ctx context.Context, key string, val []byte) error
- func (f *FreeCacheStateStore) PutWithExpireTime(ctx context.Context, key string, val []byte, expireSeconds int) error
- type MemcachedStateStore
- func (m *MemcachedStateStore) Delete(ctx context.Context, key string) error
- func (m *MemcachedStateStore) Get(ctx context.Context, key string) ([]byte, error)
- func (m *MemcachedStateStore) Keys(ctx context.Context, limit int) ([]string, error)
- func (m *MemcachedStateStore) Put(ctx context.Context, key string, val []byte) error
- func (m *MemcachedStateStore) PutWithExpireTime(ctx context.Context, key string, val []byte, expireSeconds int) error
- type RedisStateStore
- func (r *RedisStateStore) Delete(ctx context.Context, key string) error
- func (r *RedisStateStore) Get(ctx context.Context, key string) ([]byte, error)
- func (r *RedisStateStore) Keys(ctx context.Context, limit int) ([]string, error)
- func (r *RedisStateStore) Put(ctx context.Context, key string, val []byte) error
- func (r *RedisStateStore) PutWithExpireTime(ctx context.Context, key string, val []byte, expireSeconds int) error
- type StateStore
- type StateStoreWrapper
- func (w *StateStoreWrapper) Delete(ctx context.Context, key string) error
- func (w *StateStoreWrapper) Get(ctx context.Context, key string) ([]byte, error)
- func (w *StateStoreWrapper) Keys(ctx context.Context, limit int) ([]string, error)
- func (w *StateStoreWrapper) Put(ctx context.Context, key string, val []byte) error
- func (w *StateStoreWrapper) PutWithExpireTime(ctx context.Context, key string, val []byte, expireSeconds int) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotImplemented error = fmt.Errorf("not Implemented")
Functions ¶
func AddStateStore ¶ added in v0.4.2
func AddStateStore(name string, stateStore StateStore)
func StateStores ¶ added in v0.4.2
func StateStores() map[string]StateStore
Types ¶
type BigCacheStateStore ¶
type BigCacheStateStore struct {
StateStore
// contains filtered or unexported fields
}
func (*BigCacheStateStore) Delete ¶
func (b *BigCacheStateStore) Delete(ctx context.Context, key string) error
func (*BigCacheStateStore) PutWithExpireTime ¶
type FreeCacheStateStore ¶
type FreeCacheStateStore struct {
StateStore
// contains filtered or unexported fields
}
func (*FreeCacheStateStore) Delete ¶
func (f *FreeCacheStateStore) Delete(ctx context.Context, key string) error
func (*FreeCacheStateStore) PutWithExpireTime ¶
type MemcachedStateStore ¶ added in v0.4.4
type MemcachedStateStore struct {
StateStore
// contains filtered or unexported fields
}
func (*MemcachedStateStore) Delete ¶ added in v0.4.4
func (m *MemcachedStateStore) Delete(ctx context.Context, key string) error
func (*MemcachedStateStore) PutWithExpireTime ¶ added in v0.4.4
type RedisStateStore ¶
type RedisStateStore struct {
StateStore
// contains filtered or unexported fields
}
func (*RedisStateStore) Delete ¶
func (r *RedisStateStore) Delete(ctx context.Context, key string) error
func (*RedisStateStore) PutWithExpireTime ¶
type StateStore ¶
type StateStore interface {
Get(ctx context.Context, key string) ([]byte, error)
Put(ctx context.Context, key string, val []byte) error
PutWithExpireTime(ctx context.Context, key string, val []byte, expireSeconds int) error
Delete(ctx context.Context, key string) error
Keys(ctx context.Context, limit int) ([]string, error)
}
func NewBigCacheStateStore ¶
func NewBigCacheStateStore() (StateStore, error)
func NewFreeCacheStateStore ¶
func NewFreeCacheStateStore() (StateStore, error)
func NewMemcachedStateStore ¶ added in v0.4.4
func NewMemcachedStateStore(name string) (StateStore, error)
func NewRedisStateStore ¶
func NewRedisStateStore(name string) (StateStore, error)
type StateStoreWrapper ¶ added in v0.5.21
type StateStoreWrapper struct {
StateStore
// contains filtered or unexported fields
}
func NewStateStoreWrapper ¶ added in v0.5.21
func NewStateStoreWrapper(s StateStore, metricsClient *utils.MetricsClient) *StateStoreWrapper
func (*StateStoreWrapper) Delete ¶ added in v0.5.21
func (w *StateStoreWrapper) Delete(ctx context.Context, key string) error
func (*StateStoreWrapper) PutWithExpireTime ¶ added in v0.5.21
Source Files
Click to show internal directories.
Click to hide internal directories.