saga

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

type Glue struct {
	*gbus.Glogged
	// contains filtered or unexported fields
}

type Instance struct {
	ID                 string
	ConcurrencyCtrl    int
	UnderlyingInstance gbus.Saga
	MsgToMethodMap     []*MsgToFuncPair

	/*
		Will hold the service name that sent the command or event that started the saga
	*/
	StartedBy string
	/*
		If this saga has been started by a message originating from another saga instance
		this field will hold the saga_id of that instance
	*/
	StartedBySaga string

	//StartedByMessageID the message-id of the message that created the saga
	StartedByMessageID string
	//StartedByRPCID the rpc id of the message that created the saga
	StartedByRPCID string

	//CreatedAt the time.Now() timestamp when the saga was created
	CreatedAt time.Time
	// contains filtered or unexported fields
}

type MsgToFuncPair struct {
	Filter       *gbus.MessageFilter
	SagaFuncName string
}

type Store interface {
	gbus.Logged
	RegisterSagaType(saga gbus.Saga)
	GetSagaByID(tx *sql.Tx, sagaID string) (*Instance, error)
	GetSagasByType(tx *sql.Tx, sagaType reflect.Type) ([]*Instance, error)
	SaveNewSaga(tx *sql.Tx, sagaType reflect.Type, newInstance *Instance) error
	UpdateSaga(tx *sql.Tx, instance *Instance) error
	DeleteSaga(tx *sql.Tx, instance *Instance) error
	Purge() error
}