messaging

Documentation

Index

• Constants
• func NewCombinedDispatcher(dispatchers ...Dispatcher) *combinedDispatcher
• type Dispatcher
  • func NewKafkaDispatcher(ctx context.Context) Dispatcher
  • func NewLocalDispatcher() Dispatcher
• type HandlerFunc
• type Message
  • func NewMessage(data []byte, messageType MessageType) Message
• type MessageType

Constants

const (
	MessageTypeLocal = iota
	MessageTypeRemote
)

Functions

func NewCombinedDispatcher

func NewCombinedDispatcher(dispatchers ...Dispatcher) *combinedDispatcher

Types

type Dispatcher

type Dispatcher interface {
	Error() error
	Publish(topic string, message Message)
	Subscribe(topic string, fn HandlerFunc)
}

Dispatcher manages the communication between services.

func NewKafkaDispatcher

func NewKafkaDispatcher(ctx context.Context) Dispatcher

NewKafkaDispatcher creates a new instance of kafkaDispatcher.

func NewLocalDispatcher

func NewLocalDispatcher() Dispatcher

NewLocalDispatcher creates a new instance of locallocalDispatcher.

type HandlerFunc

type HandlerFunc func(message Message) error

HandlerFunc is a function that handles a message and returns nil if the message was handled successfully or an error if there was an issue handling the message.

type Message

type Message struct {
	Data []byte
	Type MessageType
}

Message represents a message that can be sent or received. It contains the data and type of the message which can be internal or external.

Internal messages are used for communication within the same service. External messages are used for communication between different services.

func NewMessage

func NewMessage(data []byte, messageType MessageType) Message

NewMessage creates a new message with the given data and type.

type MessageType

type MessageType int

MessageType represents the type of a message.