saga

Documentation

Index

• Variables
• func Init(pers event.Persistence, dataTypeVersion, name string, story Story, ...) (out *saga, err error)
• type Action
  • func (a *Action) UnmarshalJSON(data []byte) error
• type Arc
• type Saga
• type Story

Variables

var BaseArcActionMismatchError = errors.New("base arc can only and needs one action")

var NotEnoughArcsError = errors.New("a story need more than one arc")

Functions

func Init

func Init(pers event.Persistence, dataTypeVersion, name string, story Story,
	p event.CryptoKeyProvider, ctx context.Context) (out *saga, err error)

Types

type Action

type Action struct {
	Id string `json:"id"`
	//Requires []string `json:"requires"`
	Type string   `json:"type"` //I might want to simplify this.
	Body executor `json:"body"`
}

func (*Action) UnmarshalJSON

func (a *Action) UnmarshalJSON(data []byte) error

type Arc

type Arc struct {
	Actions []Action
	// contains filtered or unexported fields
}

type Saga

type Saga interface {
	ExecuteFirst(e executor) error
	Close()
}

type Story

type Story struct {
	Name string
	Arcs []Arc
}