messaging

Documentation

Overview

Package messaging implements messaging patterns like publish-subscribe to decouple local and remote services.

Index

• type Dispatcher
  • func NewExternalDispatcher() Dispatcher
  • func NewInternalDispatcher() Dispatcher
• type Message
  • func NewMessage(topic string, data []byte) Message
• type MessageState

Types

type Dispatcher

type Dispatcher interface {
	Publish(ctx context.Context, message Message) error
	Subscribe(ctx context.Context, topic string, fn service.Function[Message, MessageState]) error
}

Dispatcher is an interface for a message dispatcher.

func NewExternalDispatcher

func NewExternalDispatcher() Dispatcher

NewExternalDispatcher creates a new externalDispatcher instance.

func NewInternalDispatcher

func NewInternalDispatcher() Dispatcher

NewInternalDispatcher creates a new internalDispatcher instance.

type Message

type Message struct {
	Data  []byte       `json:"data"`
	State MessageState `json:"state"`
	Topic string       `json:"topic"`
}

Message is a struct that represents a message.

func NewMessage

func NewMessage(topic string, data []byte) Message

NewMessage creates a new message.

type MessageState

type MessageState int

MessageState is an enum that represents the state of a message.

const (
	MessageStateCreated MessageState = iota
	MessageStateCompleted
	MessageStateFailed
)