Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AccountCreated ¶
type AccountCreated struct {
// contains filtered or unexported fields
}
func NewAccountCreated ¶
func NewAccountCreated(kafkaURL string, commandBus command.Dispatcher, logger *zap.Logger) AccountCreated
func (AccountCreated) Close ¶
func (c AccountCreated) Close() error
type AccountCreatedMessage ¶
type AccountCreatedMessage struct {
AccountID string `json:"accountId"`
}
type AccountTransactionRecorded ¶
type AccountTransactionRecorded struct {
// contains filtered or unexported fields
}
func NewAccountTransactionRecorded ¶
func NewAccountTransactionRecorded( kafkaURL string, commandBus command.Dispatcher, logger *zap.Logger, ) AccountTransactionRecorded
func (AccountTransactionRecorded) Close ¶
func (c AccountTransactionRecorded) Close() error
Click to show internal directories.
Click to hide internal directories.