binder

Documentation

Index

• type PkvBindings
  • func NewPKV(pkv store.PlugStateKV, tenantid, plugId, agentid string) PkvBindings
  • func (pkv *PkvBindings) Commit(txid uint32) error
  • func (pkv *PkvBindings) Del(txid uint32, key string) error
  • func (pkv *PkvBindings) DelBatch(txid uint32, keys []string) error
  • func (pkv *PkvBindings) Get(txid uint32, key string) (*entities.PlugKV, error)
  • func (pkv *PkvBindings) NewTxn() (uint32, error)
  • func (pkv *PkvBindings) Query(txid uint32, query *store.PkvQuery) ([]*entities.PlugKV, error)
  • func (pkv *PkvBindings) RollBack(txid uint32) error
  • func (pkv *PkvBindings) Set(txid uint32, key, value string, opts *store.SetOptions) error
  • func (pkv *PkvBindings) Update(txid uint32, key, value string, opts *store.UpdateOptions) error

Types

type PkvBindings

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

func NewPKV

func NewPKV(pkv store.PlugStateKV, tenantid, plugId, agentid string) PkvBindings

func (*PkvBindings) Commit

func (pkv *PkvBindings) Commit(txid uint32) error

func (*PkvBindings) Del

func (pkv *PkvBindings) Del(txid uint32, key string) error

func (*PkvBindings) DelBatch

func (pkv *PkvBindings) DelBatch(txid uint32, keys []string) error

func (*PkvBindings) Get

func (pkv *PkvBindings) Get(txid uint32, key string) (*entities.PlugKV, error)

func (*PkvBindings) NewTxn

func (pkv *PkvBindings) NewTxn() (uint32, error)

func (*PkvBindings) Query

func (pkv *PkvBindings) Query(txid uint32, query *store.PkvQuery) ([]*entities.PlugKV, error)

func (*PkvBindings) RollBack

func (pkv *PkvBindings) RollBack(txid uint32) error

func (*PkvBindings) Set

func (pkv *PkvBindings) Set(txid uint32, key, value string, opts *store.SetOptions) error

func (*PkvBindings) Update

func (pkv *PkvBindings) Update(txid uint32, key, value string, opts *store.UpdateOptions) error