domainevent

Documentation

Index

• type EventManager
  • func GetEventManager() *EventManager
  • func (manager *EventManager) Booting(sb freedom.SingleBoot)
  • func (manager *EventManager) GetPublisherChan() <-chan freedom.DomainEvent
  • func (manager *EventManager) InsertSubEvent(event freedom.DomainEvent) error
  • func (manager *EventManager) RetryPubEvent(event freedom.DomainEvent)
  • func (manager *EventManager) RetrySubEvent(event freedom.DomainEvent, function interface{})
  • func (manager *EventManager) Save(repo *freedom.Repository, entity freedom.Entity) (e error)
  • func (manager *EventManager) SetRetryPolicy(delay, interval time.Duration, retries int)
• type EventTransaction
  • func (et *EventTransaction) Execute(fun func() error) (e error)
  • func (et *EventTransaction) ExecuteTx(ctx context.Context, fun func() error, opts *sql.TxOptions) (e error)

Types

type EventManager

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

EventManager .

func GetEventManager

func GetEventManager() *EventManager

GetEventManager .

func (*EventManager) Booting

func (manager *EventManager) Booting(sb freedom.SingleBoot)

Booting .

func (*EventManager) GetPublisherChan

func (manager *EventManager) GetPublisherChan() <-chan freedom.DomainEvent

GetPublisherChan .

func (*EventManager) InsertSubEvent

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

InsertSubEvent .

func (*EventManager) RetryPubEvent

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

RetryPubEvent .

func (*EventManager) RetrySubEvent

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

RetrySubEvent .

func (*EventManager) Save

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

Save .

func (*EventManager) SetRetryPolicy

func (manager *EventManager) SetRetryPolicy(delay, interval 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 .

func (*EventTransaction) ExecuteTx

func (et *EventTransaction) ExecuteTx(ctx context.Context, fun func() error, opts *sql.TxOptions) (e error)

ExecuteTx .