domainevent

Documentation

Index

• func UserCreatedEvent(e *UserCreated) *event.Event
• func UserUpdatedEvent(e *UserUpdated) *event.Event
• type Tx
• type UserCreated
  • func (*UserCreated) EventName() string
• type UserCreatedListener
  • func (*UserCreatedListener) AsyncProcess() bool
  • func (*UserCreatedListener) EventHandler() event.Handler
• type UserUpdated
  • func (*UserUpdated) EventName() string
• type UserUpdatedListener
  • func (*UserUpdatedListener) AsyncProcess() bool
  • func (*UserUpdatedListener) EventHandler() event.Handler

Functions

func UserCreatedEvent

func UserCreatedEvent(e *UserCreated) *event.Event

func UserUpdatedEvent

func UserUpdatedEvent(e *UserUpdated) *event.Event

Types

type Tx

type Tx struct {
	// Mock as a DB transaction
	DSN string
	Tid int64
}

type UserCreated

type UserCreated struct {
	UserId   int
	UserName string
	Tx       *Tx
}

func (*UserCreated) EventName

func (*UserCreated) EventName() string

type UserCreatedListener

type UserCreatedListener struct {
}

func (*UserCreatedListener) AsyncProcess

func (*UserCreatedListener) AsyncProcess() bool

When we want to use a same DB transaction in event trigger and listener to get ACID assurance, then AsyncProcess must return false.

func (*UserCreatedListener) EventHandler

func (*UserCreatedListener) EventHandler() event.Handler

type UserUpdated

type UserUpdated struct {
	UserId   int
	UserName string
}

func (*UserUpdated) EventName

func (*UserUpdated) EventName() string

type UserUpdatedListener

type UserUpdatedListener struct {
}

func (*UserUpdatedListener) AsyncProcess

func (*UserUpdatedListener) AsyncProcess() bool

func (*UserUpdatedListener) EventHandler

func (*UserUpdatedListener) EventHandler() event.Handler