juggler

Documentation

Index

• Variables
• type GetPutDeleter
• type Juggler
  • func New(resources GetPutDeleter) *Juggler
  • func (J *Juggler) NewTx() *Tx
• type Tx
  • func (T *Tx) Delete(uid uint64) error
  • func (T *Tx) Finish() error
  • func (T *Tx) Get(uid uint64) ([]byte, error)
  • func (T *Tx) Put(uid uint64, data []byte) error
  • func (T *Tx) SetLimited() error

Variables

var ErrDropped = errors.New("process was dropped")

var ErrFinished = errors.New("process was finished")

var ErrLimited = errors.New("limited process try to get new")

var ErrNotInCharge = errors.New("try to change while not in charge")

Types

type GetPutDeleter

type GetPutDeleter interface {
	Get(uint64) ([]byte, error)
	Put(uint64, []byte) error
	Delete(uint64) error
}

type Juggler

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

func New

func New(resources GetPutDeleter) *Juggler

func (*Juggler) NewTx

func (J *Juggler) NewTx() *Tx

type Tx

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

func (*Tx) Delete

func (T *Tx) Delete(uid uint64) error

func (*Tx) Finish

func (T *Tx) Finish() error

func (*Tx) Get

func (T *Tx) Get(uid uint64) ([]byte, error)

func (*Tx) Put

func (T *Tx) Put(uid uint64, data []byte) error

func (*Tx) SetLimited

func (T *Tx) SetLimited() error