eventhandling

package
v0.0.0-...-ca54044 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2023 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BalancesUpdatedEvent

type BalancesUpdatedEvent struct {
	// contains filtered or unexported fields
}

func NewBalancesUpdatedEvent

func NewBalancesUpdatedEvent() *BalancesUpdatedEvent

func (*BalancesUpdatedEvent) GetDateTime

func (e *BalancesUpdatedEvent) GetDateTime() time.Time

func (*BalancesUpdatedEvent) GetName

func (e *BalancesUpdatedEvent) GetName() string

func (*BalancesUpdatedEvent) GetPayload

func (e *BalancesUpdatedEvent) GetPayload() interface{}

func (*BalancesUpdatedEvent) SetPayload

func (e *BalancesUpdatedEvent) SetPayload(payload interface{})

type BalancesUpdatedHandler

type BalancesUpdatedHandler struct {
	// contains filtered or unexported fields
}

func NewBalancesUpdatedHandler

func NewBalancesUpdatedHandler(producer *kafka.Producer) *BalancesUpdatedHandler

func (*BalancesUpdatedHandler) Handle

func (h *BalancesUpdatedHandler) Handle(message events.Event, wg *sync.WaitGroup)

type TransactionCreatedEvent

type TransactionCreatedEvent struct {
	// contains filtered or unexported fields
}

func NewTransactionCreatedEvent

func NewTransactionCreatedEvent() *TransactionCreatedEvent

func (*TransactionCreatedEvent) GetDateTime

func (e *TransactionCreatedEvent) GetDateTime() time.Time

func (*TransactionCreatedEvent) GetName

func (e *TransactionCreatedEvent) GetName() string

func (*TransactionCreatedEvent) GetPayload

func (e *TransactionCreatedEvent) GetPayload() interface{}

func (*TransactionCreatedEvent) SetPayload

func (e *TransactionCreatedEvent) SetPayload(payload interface{})

type TransactionCreatedHandler

type TransactionCreatedHandler struct {
	// contains filtered or unexported fields
}

func NewTransactionCreatedHandler

func NewTransactionCreatedHandler(producer *kafka.Producer) *TransactionCreatedHandler

func (*TransactionCreatedHandler) Handle

func (h *TransactionCreatedHandler) Handle(message events.Event, wg *sync.WaitGroup)

Jump to

Keyboard shortcuts

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