share

Documentation

Index

• type ShareCache
  • func NewShareCache(dbPath string, socket string, batch ...string) *ShareCache
  • func (a *ShareCache) Close() error
  • func (a *ShareCache) Delete(k ...[]byte) error
  • func (a *ShareCache) Get(k []byte) ([]byte, error)
  • func (s *ShareCache) OpenStore() (cache.RecursionCache, error)
  • func (a *ShareCache) Put(k []byte, v []byte) error
  • func (a *ShareCache) Range(f func(key []byte, value []byte) bool) error

Types

type ShareCache

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

ShareCache open local bbotdb or connect to unix socket grpc

func NewShareCache

func NewShareCache(dbPath string, socket string, batch ...string) *ShareCache

func (*ShareCache) Close

func (a *ShareCache) Close() error

func (*ShareCache) Delete

func (a *ShareCache) Delete(k ...[]byte) error

func (*ShareCache) Get

func (a *ShareCache) Get(k []byte) ([]byte, error)

func (*ShareCache) OpenStore

func (s *ShareCache) OpenStore() (cache.RecursionCache, error)

OpenStore open local db or try to connect remote db

func (*ShareCache) Put

func (a *ShareCache) Put(k []byte, v []byte) error

func (*ShareCache) Range

func (a *ShareCache) Range(f func(key []byte, value []byte) bool) error