utils

type KeyTagger ¶ added in v0.2.1

type KeyTagger struct{}

KeyTagger is a decorate that records all Set/Delete operations performed by it's children and adds all those keys as DeliverTx tags.

Tags is the hex encoded key, value is "s" (for set) or "d" (for delete)

Desired behavior, impossible as tendermint will collapse multiple tags with same key:

Tags are added as Key=<bucket name>, Value=<hex of remainder>,
like Key=cash, Value=00CAFE00

func NewKeyTagger() KeyTagger

func (KeyTagger) Check(ctx weave.Context, db weave.KVStore, tx weave.Tx,
	next weave.Checker) (weave.CheckResult, error)

func (KeyTagger) Deliver(ctx weave.Context, db weave.KVStore, tx weave.Tx,
	next weave.Deliverer) (weave.DeliverResult, error)

type Logging ¶

type Logging struct{}

Logging is a decorator to log messages as they pass through

func NewLogging() Logging

func (r Logging) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Checker) (weave.CheckResult, error)

func (r Logging) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Deliverer) (weave.DeliverResult, error)

type Recovery ¶

type Recovery struct{}

Recovery is a decorator to recover from panics in transactions, so we can log them as errors

func NewRecovery() Recovery

func (r Recovery) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Checker) (res weave.CheckResult, err error)

func (r Recovery) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Deliverer) (res weave.DeliverResult, err error)

type Savepoint ¶

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

Savepoint will isolate all data inside of the call, and commit/rollback to savepoint based on if error

func NewSavepoint() Savepoint

func (s Savepoint) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Checker) (weave.CheckResult, error)

func (s Savepoint) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx,
	next weave.Deliverer) (weave.DeliverResult, error)

func (s Savepoint) OnCheck() Savepoint

func (s Savepoint) OnDeliver() Savepoint