eventbus

Documentation

Index

• func BuildCloudEvent(eventType string, eventSource string, payload interface{}) event.Event
• func GetEventBody[E any](cloudEvent *event.Event) (*E, error)
• func NewAMQPPub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Publisher, error)
• func NewAMQPSub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Subscriber, error)
• func NewAwsSqsSub(conf config.AWSSDKConfig, serviceID string, logger *logrus.Entry) (*sqs.Subscriber, error)
• func NewEventBusPublisher(conf config.EventBusEngine, serviceID string, logger *logrus.Entry) (message.Publisher, error)
• func NewEventBusRouter(conf config.EventBusEngine, serviceID string, logger *logrus.Entry) (*message.Router, error)
• func NewEventBusSubscriber(conf config.EventBusEngine, serviceID string, logger *logrus.Entry) (message.Subscriber, error)
• func NewGoChannelPubSub(logger *logrus.Entry) (message.Publisher, message.Subscriber)
• func NewSnsExchangeSubscriber(builder SnsExchangeBuilder) message.Subscriber
• func ParseCloudEvent(msg []byte) (*event.Event, error)
• type MessagingEngine
• type SnsExchangeBuilder
• type SnsExchangePublisher
  • func NewSnsExchangePublisher(builder SnsExchangeBuilder) (*SnsExchangePublisher, error)
  • func (s *SnsExchangePublisher) Close() error
  • func (s *SnsExchangePublisher) Publish(topic string, messages ...*message.Message) error
• type SnsExchangeSubscriber

Functions

func BuildCloudEvent

func BuildCloudEvent(eventType string, eventSource string, payload interface{}) event.Event

func GetEventBody

func GetEventBody[E any](cloudEvent *event.Event) (*E, error)

func NewAMQPPub

func NewAMQPPub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Publisher, error)

func NewAMQPSub

func NewAMQPSub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Subscriber, error)

func NewAwsSqsSub

func NewAwsSqsSub(conf config.AWSSDKConfig, serviceID string, logger *logrus.Entry) (*sqs.Subscriber, error)

func NewEventBusPublisher

func NewEventBusPublisher(conf config.EventBusEngine, serviceID string, logger *logrus.Entry) (message.Publisher, error)

func NewEventBusRouter

func NewEventBusRouter(conf config.EventBusEngine, serviceID string, logger *logrus.Entry) (*message.Router, error)

func NewEventBusSubscriber

func NewEventBusSubscriber(conf config.EventBusEngine, serviceID string, logger *logrus.Entry) (message.Subscriber, error)

func NewGoChannelPubSub

func NewGoChannelPubSub(logger *logrus.Entry) (message.Publisher, message.Subscriber)

func NewSnsExchangeSubscriber

func NewSnsExchangeSubscriber(builder SnsExchangeBuilder) message.Subscriber

func ParseCloudEvent

func ParseCloudEvent(msg []byte) (*event.Event, error)

Types

type MessagingEngine

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

type SnsExchangeBuilder

type SnsExchangeBuilder struct {
	Config       config.AWSSDKConfig
	ExchangeName string
	ServiceID    string
	Logger       *logrus.Entry
}

type SnsExchangePublisher

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

func NewSnsExchangePublisher

func NewSnsExchangePublisher(builder SnsExchangeBuilder) (*SnsExchangePublisher, error)

func (*SnsExchangePublisher) Close

func (s *SnsExchangePublisher) Close() error

func (*SnsExchangePublisher) Publish

func (s *SnsExchangePublisher) Publish(topic string, messages ...*message.Message) error

type SnsExchangeSubscriber

type SnsExchangeSubscriber struct {
}