consumer

Documentation

Index

• type AccountCreated
  • func NewAccountCreated(kafkaURL string, commandBus command.Dispatcher, logger *zap.Logger) AccountCreated
  • func (c AccountCreated) Close() error
  • func (c AccountCreated) Start(ctx context.Context) error
• type AccountCreatedMessage
• type AccountTransactionRecorded
  • func NewAccountTransactionRecorded(kafkaURL string, commandBus command.Dispatcher, logger *zap.Logger) AccountTransactionRecorded
  • func (c AccountTransactionRecorded) Close() error
  • func (c AccountTransactionRecorded) Start(ctx context.Context) error

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

func (AccountCreated) Start

func (c AccountCreated) Start(ctx context.Context) 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

func (AccountTransactionRecorded) Start

func (c AccountTransactionRecorded) Start(ctx context.Context) error