events

type Consumer interface {
	ReadMessage(ctx context.Context) (*Message, error)
	Topic() string
	Handlers() []EventHandler
	Close() error
	BrokerType() EventBrokerType
}

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

type EventBrokerType string

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

type EventHandler interface {
	Name() string
	CanHandleMessage(ctx context.Context, message *Message) bool
	Handle(ctx context.Context, message *Message) error
}

type EventPatchAnchorPlatformTransactionCompletionData struct {
	PaymentID string `json:"payment_id"`
}

type EventReceiverWalletSMSInvitationData struct {
	ReceiverWalletID string `json:"id"`
}

type HandlerError struct {
	// FailedAt timestamp for the time of failure.
	FailedAt time.Time `json:"failed_at"`
	// ErrorMessage detailed error message. Used for displaying.
	ErrorMessage string `json:"error_message"`
	// HandlerName name of the handler where the error occurred.
	HandlerName string `json:"handler_name"`
	// Err full handler error.
	Err error `json:"-"`
}

type HandlerSuccess struct {
	// ExecutedAt timestamp for the time of successful handling
	ExecutedAt time.Time `json:"executed_at"`
	// HandlerName name of the handler that succeeded
	HandlerName string `json:"handler_name"`
}

type KafkaConfig struct {
	Brokers              []string
	SecurityProtocol     KafkaSecurityProtocol
	SASLUsername         string
	SASLPassword         string
	SSLAccessKey         string
	SSLAccessCertificate string
}

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

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

type KafkaSecurityProtocol string

type Message struct {
	Topic                string           `json:"topic"`
	Key                  string           `json:"key"`
	TenantID             string           `json:"tenant_id"`
	Type                 string           `json:"type"`
	Data                 any              `json:"data"`
	Errors               []HandlerError   `json:"errors,omitempty"`
	SuccessfulExecutions []HandlerSuccess `json:"successful_executions,omitempty"`
}

type MockConsumer struct {
	mock.Mock
}

type MockEventHandler struct {
	mock.Mock
}

type MockProducer struct {
	mock.Mock
}

type NoopProducer struct{}

type Producer interface {
	WriteMessages(ctx context.Context, messages ...Message) error
	Ping(ctx context.Context) error
	Close(ctx context.Context)
	BrokerType() EventBrokerType
}