domainevent

package
v1.8.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 15, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventManager

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

EventManager .

func GetEventManager

func GetEventManager() *EventManager

GetEventManager .

func (*EventManager) BindRetryPubEvent added in v1.8.10

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

BindRetryPubEvent .

func (*EventManager) BindRetrySubEvent added in v1.8.10

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

BindRetrySubEvent .

func (*EventManager) Booting

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

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) 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 added in v1.8.8

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 .

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL