local

Documentation

Index

• type Filter
• type LocalBloomFilters
  • func NewLocalBloomFilters(filters map[string]*gobloom.GoBloomChain, ...) *LocalBloomFilters
  • func (lbf *LocalBloomFilters) AddFilter(key string, filter Filter) bool
  • func (lbf *LocalBloomFilters) Get(ctx context.Context, key interface{}, args ...interface{}) ([]interface{}, error)
  • func (lbf *LocalBloomFilters) Load(ctx context.Context, key interface{}, args ...interface{}) error
  • func (lbf *LocalBloomFilters) Set(ctx context.Context, key interface{}, args ...interface{}) error
• type LocalCache
• type LocalCuckooFilter
• type LocalCuckooFilters
  • func NewLocalCuckooFilters(filters map[string]*gocuckoo.GoCuckooFilterImpl, ...) *LocalCuckooFilters
  • func (lcf *LocalCuckooFilters) AddFilter(key string, filter *gocuckoo.GoCuckooFilterImpl)
  • func (lcf *LocalCuckooFilters) Del(ctx context.Context, key interface{}, args ...interface{}) error
  • func (lcf *LocalCuckooFilters) Get(ctx context.Context, key interface{}, args ...interface{}) ([]interface{}, error)
  • func (lcf *LocalCuckooFilters) Load(ctx context.Context, key interface{}, args ...interface{}) error
  • func (lcf *LocalCuckooFilters) Set(ctx context.Context, key interface{}, args ...interface{}) error
• type LocalFilters
• type LocalKeyValueCacheImpl
  • func NewLocalCache(ctx context.Context, maxEntries int) (*LocalKeyValueCacheImpl, error)
  • func (lc *LocalKeyValueCacheImpl) Del(ctx context.Context, key interface{}, args ...interface{}) error
  • func (lc *LocalKeyValueCacheImpl) Get(ctx context.Context, key interface{}, args ...interface{}) ([]interface{}, error)
  • func (lc *LocalKeyValueCacheImpl) Load(ctx context.Context, key interface{}, args ...interface{}) error
  • func (lc *LocalKeyValueCacheImpl) Set(ctx context.Context, key interface{}, args ...interface{}) error

Types

type Filter

type Filter interface {
	// LocalCache
	Check(value []byte) bool
	Add(value []byte) bool
}

type LocalBloomFilters

type LocalBloomFilters struct {
	// contains filtered or unexported fields
}

func NewLocalBloomFilters

func NewLocalBloomFilters(filters map[string]*gobloom.GoBloomChain, buildOptions gobloom.BloomBuildOptions) *LocalBloomFilters

func (*LocalBloomFilters) AddFilter

func (lbf *LocalBloomFilters) AddFilter(key string, filter Filter) bool

func (*LocalBloomFilters) Get

func (lbf *LocalBloomFilters) Get(ctx context.Context, key interface{}, args ...interface{}) ([]interface{}, error)

func (*LocalBloomFilters) Load

func (lbf *LocalBloomFilters) Load(ctx context.Context, key interface{}, args ...interface{}) error

func (*LocalBloomFilters) Set

func (lbf *LocalBloomFilters) Set(ctx context.Context, key interface{}, args ...interface{}) error

type LocalCache

type LocalCache interface {
	Get(ctx context.Context, key interface{}, args ...interface{}) ([]interface{}, error)
	Set(ctx context.Context, key interface{}, args ...interface{}) error
	Load(ctx context.Context, key interface{}, args ...interface{}) error
}

type LocalCuckooFilter

type LocalCuckooFilter interface {
	LocalFilters
	Del(ctx context.Context, key string, value []byte) error
}

type LocalCuckooFilters

type LocalCuckooFilters struct {
	// contains filtered or unexported fields
}

func NewLocalCuckooFilters

func NewLocalCuckooFilters(filters map[string]*gocuckoo.GoCuckooFilterImpl, buildOptions gocuckoo.CuckooBuildOptions) *LocalCuckooFilters

DelOnLocal(ctx context.Context,key interface{},args ...interface{})error

func (*LocalCuckooFilters) AddFilter

func (lcf *LocalCuckooFilters) AddFilter(key string, filter *gocuckoo.GoCuckooFilterImpl)

func (*LocalCuckooFilters) Del

func (lcf *LocalCuckooFilters) Del(ctx context.Context, key interface{}, args ...interface{}) error

func (*LocalCuckooFilters) Get

func (lcf *LocalCuckooFilters) Get(ctx context.Context, key interface{}, args ...interface{}) ([]interface{}, error)

func (*LocalCuckooFilters) Load

func (lcf *LocalCuckooFilters) Load(ctx context.Context, key interface{}, args ...interface{}) error

func (*LocalCuckooFilters) Set

func (lcf *LocalCuckooFilters) Set(ctx context.Context, key interface{}, args ...interface{}) error

type LocalFilters

type LocalFilters interface {
	LocalCache
	Filter
	AddFilter(key string, filter Filter) error
}

type LocalKeyValueCacheImpl

type LocalKeyValueCacheImpl struct {
	*cache.LocalCacheImpl
}

func NewLocalCache

func NewLocalCache(ctx context.Context, maxEntries int) (*LocalKeyValueCacheImpl, error)

func (*LocalKeyValueCacheImpl) Del

func (lc *LocalKeyValueCacheImpl) Del(ctx context.Context, key interface{}, args ...interface{}) error

func (*LocalKeyValueCacheImpl) Get

func (lc *LocalKeyValueCacheImpl) Get(ctx context.Context, key interface{}, args ...interface{}) ([]interface{}, error)

func (*LocalKeyValueCacheImpl) Load

func (lc *LocalKeyValueCacheImpl) Load(ctx context.Context, key interface{}, args ...interface{}) error

func (*LocalKeyValueCacheImpl) Set

func (lc *LocalKeyValueCacheImpl) Set(ctx context.Context, key interface{}, args ...interface{}) error

Set key value

NOTE