action

Documentation

Index

• func Rollback(actions []Action) error
• type Action
• type ActionQueue
  • func NewActionQueue(actions ...Action) *ActionQueue
  • func (m *ActionQueue) Execute(ctx context.Context) (error, error)

Functions

func Rollback

func Rollback(actions []Action) error

Types

type Action

type Action interface {
	// Execute executes this action, returning error if any.
	Execute(ctx context.Context) error
	// Rollback rollbacks this action, returning error if any.
	Rollback() error
}

Action is an abstraction of some action that can be rolled back.

type ActionQueue

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

ActionQueue represents a queue of executable actions. Any action that fails triggers cascade previous actions rollback.

func NewActionQueue

func NewActionQueue(actions ...Action) *ActionQueue

func (*ActionQueue) Execute

func (m *ActionQueue) Execute(ctx context.Context) (error, error)

Execute executes the action queue.

If any of actions fails a cascade previous actions rollback occurs resulting in a tuple of this's action error and rollback ones if any.