Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AccountCreatedPublisher ¶
type AccountCreatedPublisher struct {
// contains filtered or unexported fields
}
func NewAccountCreatedPublisher ¶
func NewAccountCreatedPublisher(host string, port int, topic string, partition int) *AccountCreatedPublisher
func (*AccountCreatedPublisher) PublishAccountCreated ¶
func (a *AccountCreatedPublisher) PublishAccountCreated(ctx context.Context, account domain.Account) error
PublishAccountCreated implements service.AccountCreatedPublisher.
type AccountDeletedPublisher ¶
type AccountDeletedPublisher struct {
// contains filtered or unexported fields
}
func NewAccountDeletedPublisher ¶
func NewAccountDeletedPublisher(host string, port int, topic string, partition int) *AccountDeletedPublisher
func (*AccountDeletedPublisher) PublishAccountDeleted ¶
PublishAccountDeleted implements service.AccountDeletedPublisher.
Source Files
Click to show internal directories.
Click to hide internal directories.