saga

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

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

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

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

type Store interface {
	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
}

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