utils

Documentation

Index

• type Logging
  • 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
  • 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
  • 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

Types

type Logging

type Logging struct{}

Logging is a decorator to log messages as they pass through

func NewLogging

func NewLogging() Logging

NewLogging creates a Logging decorator

func (Logging) Check

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

Check logs error -> info, success -> debug

func (Logging) Deliver

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

Deliver logs error -> error, success -> info

type Recovery

type Recovery struct{}

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

func NewRecovery

func NewRecovery() Recovery

NewRecovery creates a Recovery decorator

func (Recovery) Check

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

Check turns panics into normal errors

func (Recovery) Deliver

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

Deliver turns panics into normal errors

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

func NewSavepoint() Savepoint

NewSavepoint creates a Savepoint decorator, but you must call OnCheck/OnDeliver so it will be triggered

func (Savepoint) Check

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

Check will optionally set a checkpoint

func (Savepoint) Deliver

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

Deliver will optionally set a checkpoint

func (Savepoint) OnCheck

func (s Savepoint) OnCheck() Savepoint

OnCheck returns a savepoint that will trigger on CheckTx

func (Savepoint) OnDeliver

func (s Savepoint) OnDeliver() Savepoint

OnDeliver returns a savepoint that will trigger on DeliverTx