memory

Documentation

Index

• type Store
  • func NewStore() *Store
  • func (s *Store) Add(namespace, typ, key string, value []byte) error
  • func (s *Store) Del(namespace, typ, key string) error
  • func (s *Store) Event() <-chan struct{}
  • func (s *Store) Exist(namespace, typ, key string) bool
  • func (s *Store) Get(namespace, typ, key string) ([]byte, error)
  • func (s *Store) GetKeys(namespace, typ string) ([]string, error)
  • func (s *Store) Start() error
  • func (s *Store) Stop()
  • func (s *Store) Subscribe(namespace string) error
  • func (s *Store) UnSubscribe(namespace string) error
  • func (s *Store) Update(namespace, typ, key string, value []byte) error

Types

type Store

type Store struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Store is a in memory implement of Store.

func NewStore

func NewStore() *Store

NewStore return a new Store.

func (*Store) Add

func (s *Store) Add(namespace, typ, key string, value []byte) error

func (*Store) Del

func (s *Store) Del(namespace, typ, key string) error

func (*Store) Event

func (s *Store) Event() <-chan struct{}

func (*Store) Exist

func (s *Store) Exist(namespace, typ, key string) bool

func (*Store) Get

func (s *Store) Get(namespace, typ, key string) ([]byte, error)

func (*Store) GetKeys

func (s *Store) GetKeys(namespace, typ string) ([]string, error)

func (*Store) Start

func (s *Store) Start() error

func (*Store) Stop

func (s *Store) Stop()

func (*Store) Subscribe

func (s *Store) Subscribe(namespace string) error

func (*Store) UnSubscribe

func (s *Store) UnSubscribe(namespace string) error

func (*Store) Update

func (s *Store) Update(namespace, typ, key string, value []byte) error