bus

package

v0.6.0 Latest Latest Go to latest Published: Dec 17, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/oxygenpay/oxygen

Links

Open Source Insights

Documentation ¶

Index ¶

func Bind[T comparable](input Message) (T, error)
type Consumer
type FormSubmittedEvent
type Handler
type Message
type PaymentStatusUpdateEvent
type PubSub
- func NewPubSub(ctx context.Context, async bool, logger *zerolog.Logger) *PubSub
type Publisher
type Topic
type UserRegisteredEvent
type WithdrawalCreatedEvent

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Bind ¶

func Bind[T comparable](input Message) (T, error)

Types ¶

type Consumer ¶

type Consumer func(ctx context.Context, message Message) error

type FormSubmittedEvent ¶

type FormSubmittedEvent struct {
	RequestType string
	Message     string
	UserID      int64
}

type Handler ¶

type Handler interface {
	Consumers() map[Topic][]Consumer
}

type Message ¶

type Message []byte

type PaymentStatusUpdateEvent ¶

type PaymentStatusUpdateEvent struct {
	MerchantID int64
	PaymentID  int64
}

type PubSub ¶

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

PubSub simple pub-sub implementation. Works locally using in-memory store. No persistence, no semaphores. Should do the job until we switch to a real bus (e.g. Kafka).

func NewPubSub ¶

func NewPubSub(ctx context.Context, async bool, logger *zerolog.Logger) *PubSub

func (*PubSub) Publish ¶

func (p *PubSub) Publish(topic Topic, message any) error

func (*PubSub) RegisterHandler ¶

func (p *PubSub) RegisterHandler(h Handler) error

func (*PubSub) Shutdown ¶

func (p *PubSub) Shutdown() error

func (p *PubSub) Subscribe(topic Topic, fn Consumer) error

type Publisher ¶

type Publisher interface {
	Publish(topic Topic, message any) error
}

type Topic ¶

type Topic string

const (
	TopicPaymentStatusUpdate Topic = "payment.status"
	TopicWithdrawals         Topic = "withdrawal"
	TopicFormSubmissions     Topic = "form.submitted"
	TopicUserRegistered      Topic = "user.registered"
)

type UserRegisteredEvent ¶

type UserRegisteredEvent struct {
	UserID int64
}

type WithdrawalCreatedEvent ¶

type WithdrawalCreatedEvent struct {
	MerchantID int64
	PaymentID  int64
}

Source Files ¶

View all Source files

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