domainevent

Documentation

Index

• type EventManager
  • func GetEventManager() *EventManager
  • func (manager *EventManager) BindRetryPubEvent(event freedom.DomainEvent)
  • func (manager *EventManager) BindRetrySubEvent(event freedom.DomainEvent, function interface{})
  • func (manager *EventManager) Booting(bootManager freedom.BootManager)
  • func (manager *EventManager) InsertSubEvent(event freedom.DomainEvent) error
  • func (manager *EventManager) Retry()
  • func (manager *EventManager) Save(repo *freedom.Repository, entity freedom.Entity) (e error)
  • func (manager *EventManager) SetRetryPolicy(delay time.Duration, retries int)
• type EventTransaction
  • func (et *EventTransaction) Execute(fun func() error) (e error)

Types

type EventManager

type EventManager struct {
	freedom.Infra
	// contains filtered or unexported fields
}

EventManager .

func GetEventManager

func GetEventManager() *EventManager

GetEventManager .

func (*EventManager) BindRetryPubEvent

func (manager *EventManager) BindRetryPubEvent(event freedom.DomainEvent)

BindRetryPubEvent .

func (*EventManager) BindRetrySubEvent

func (manager *EventManager) BindRetrySubEvent(event freedom.DomainEvent, function interface{})

BindRetrySubEvent .

func (*EventManager) Booting

func (manager *EventManager) Booting(bootManager freedom.BootManager)

Booting .

func (*EventManager) InsertSubEvent

func (manager *EventManager) InsertSubEvent(event freedom.DomainEvent) error

InsertSubEvent .

func (*EventManager) Retry

func (manager *EventManager) Retry()

Retry .

func (*EventManager) Save

func (manager *EventManager) Save(repo *freedom.Repository, entity freedom.Entity) (e error)

Save .

func (*EventManager) SetRetryPolicy

func (manager *EventManager) SetRetryPolicy(delay time.Duration, retries int)

SetRetryPolicy Set the rules for retry.

type EventTransaction

type EventTransaction struct {
	transaction.GormImpl
}

EventTransaction .

func (*EventTransaction) Execute

func (et *EventTransaction) Execute(fun func() error) (e error)

Execute .