cacheetcd

package

v1.0.0-rc Latest Latest Go to latest Published: May 24, 2021 License: AGPL-3.0 Imports: 8 Imported by: 1

Details

LRU + Watch

This section is empty.

This section is empty.

This section is empty.

type CacheEtcdStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New(ctx context.Context, etcdDir string, cap int) (*CacheEtcdStore, error)

func (s *CacheEtcdStore) Get(ctx context.Context, key string) (storetypes.KeyValue, error)

func (s *CacheEtcdStore) PrefixGet(ctx context.Context, prefix string) ([]storetypes.KeyValue, error)

直接从etcd prefixget, 因为 mem 中是 lru, 所以读 etcd 是必然的, 那么直接跳过 lru prefixget

func (s *CacheEtcdStore) PrefixGetKey(ctx context.Context, prefix string) ([]storetypes.Key, error)

直接从etcd prefixgetkey, 因为 mem 中是 lru, 所以读 etcd 是必然的, 那么直接跳过 lru prefixgetkey

func (s *CacheEtcdStore) PrefixRemove(ctx context.Context, prefix string) ([]storetypes.KeyValue, error)

func (s *CacheEtcdStore) Put(ctx context.Context, key, value string) error

func (s *CacheEtcdStore) PutWithOption(ctx context.Context, key, value string, opts []interface{}) (interface{}, error)

func (s *CacheEtcdStore) Remove(ctx context.Context, key string) (*storetypes.KeyValue, error)

func (s *CacheEtcdStore) Watch(ctx context.Context, key string, isPrefix bool, filterDelete bool) (storetypes.WatchChan, error)