store

Documentation

Index

• type Store
  • func NewStore(cfg *config.Config, log *logrus.Logger) (*Store, error)
  • func (s *Store) Close() error
  • func (s *Store) Connect() error
  • func (s *Store) Flush() error
  • func (_ *Store) FromGobToItem(b []byte, item interface{}) (interface{}, error)
  • func (_ *Store) FromJSONToItem(b []byte, item interface{}) (interface{}, error)
  • func (s *Store) Get(key string, item interface{}) (interface{}, error)
  • func (s *Store) GetAll(pattern string, emptyRecordFunc config.EmptyRecordFunc) ([]interface{}, error)
  • func (_ *Store) ItemToGob(item interface{}) ([]byte, error)
  • func (_ *Store) ItemToJSON(item interface{}) ([]byte, error)
  • func (s *Store) Remove(key string) error
  • func (s *Store) Set(key string, item interface{}) error

Types

type Store

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

func NewStore

func NewStore(cfg *config.Config, log *logrus.Logger) (*Store, error)

func (*Store) Close

func (s *Store) Close() error

func (*Store) Connect

func (s *Store) Connect() error

func (*Store) Flush

func (s *Store) Flush() error

func (*Store) FromGobToItem

func (_ *Store) FromGobToItem(b []byte, item interface{}) (interface{}, error)

Item deserializing

func (*Store) FromJSONToItem

func (_ *Store) FromJSONToItem(b []byte, item interface{}) (interface{}, error)

func (*Store) Get

func (s *Store) Get(key string, item interface{}) (interface{}, error)

func (*Store) GetAll

func (s *Store) GetAll(pattern string, emptyRecordFunc config.EmptyRecordFunc) ([]interface{}, error)

func (*Store) ItemToGob

func (_ *Store) ItemToGob(item interface{}) ([]byte, error)

Item serializing

func (*Store) ItemToJSON

func (_ *Store) ItemToJSON(item interface{}) ([]byte, error)

func (*Store) Remove

func (s *Store) Remove(key string) error

func (*Store) Set

func (s *Store) Set(key string, item interface{}) error