store

Documentation

Index

• Variables
• type StoreDB
  • func (st *StoreDB) CloseDB() error
  • func (st *StoreDB) DelKV(key string) (kv StoreKV)
  • func (st *StoreDB) GetKV(key string) (kv StoreKV)
  • func (st *StoreDB) IndexJSON(name, pattern, jpath string) error
  • func (st *StoreDB) SetKV(key, value string, ttl time.Duration) (kv StoreKV)
  • func (st *StoreDB) ShrinkDB() error
  • func (st *StoreDB) TruncateDB() error
• type StoreKV
• type UserStore
  • func (store *UserStore) Open() *UserStore
  • func (us *UserStore) UserAdd(ctx context.Context, in *model.User) (out *model.User, err error)
  • func (us *UserStore) UserDel(ctx context.Context, in *model.User) (*model.User, error)
  • func (us *UserStore) UserGetList(ctx context.Context, in *model.UserSelect) (*model.Users, error)

Variables

var UnimplementedUserServer serv.UnimplementedUserServer

Types

type StoreDB

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

func (*StoreDB) CloseDB

func (st *StoreDB) CloseDB() error

Close releases all database resources. All transactions must be closed before closing the database.

func (*StoreDB) DelKV

func (st *StoreDB) DelKV(key string) (kv StoreKV)

func (*StoreDB) GetKV

func (st *StoreDB) GetKV(key string) (kv StoreKV)

func (*StoreDB) IndexJSON

func (st *StoreDB) IndexJSON(name, pattern, jpath string) error

func (*StoreDB) SetKV

func (st *StoreDB) SetKV(key, value string, ttl time.Duration) (kv StoreKV)

func (*StoreDB) ShrinkDB

func (st *StoreDB) ShrinkDB() error

Shrink will make the database file smaller by removing redundant log entries. This operation does not block the database.

func (*StoreDB) TruncateDB

func (st *StoreDB) TruncateDB() error

TruncateKVStore truncates entire store database

type StoreKV

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

type UserStore

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

func (*UserStore) Open

func (store *UserStore) Open() *UserStore

func (*UserStore) UserAdd

func (us *UserStore) UserAdd(ctx context.Context, in *model.User) (out *model.User, err error)

DONE UserAdd

func (*UserStore) UserDel

func (us *UserStore) UserDel(ctx context.Context, in *model.User) (*model.User, error)

DONE Del - gw delete: "/users/{userid}"

func (*UserStore) UserGetList

func (us *UserStore) UserGetList(ctx context.Context, in *model.UserSelect) (*model.Users, error)

DONE UserGetList