messaging

Documentation

Index

• type MessageSubscriptionHandler
• type MessagingQueueSubscription
• type MessagingService
  • func NewKafkaProtobufMessagingService(bootstrapServers, schemaRegistryUrl string) (MessagingService, error)
  • func NewNatsMessagingService(cfg *config_api.MessagingAdapter) (MessagingService, error)
  • func NewService(adapter *config_api.MessagingAdapter) (MessagingService, error)

Types

type MessageSubscriptionHandler

type MessageSubscriptionHandler func(msg []byte) error

type MessagingQueueSubscription

type MessagingQueueSubscription interface {
	Unsubscribe() error
}

type MessagingService

type MessagingService interface {
	QueueSubscribe(topic string, group string, handler MessageSubscriptionHandler) (MessagingQueueSubscription, error)
	Publish(topic string, msg interface{}) error
}

func NewKafkaProtobufMessagingService

func NewKafkaProtobufMessagingService(bootstrapServers, schemaRegistryUrl string) (MessagingService, error)

func NewNatsMessagingService

func NewNatsMessagingService(cfg *config_api.MessagingAdapter) (MessagingService, error)

Coupled with protobuf encoder so expects protobuf serializable messages

func NewService

func NewService(adapter *config_api.MessagingAdapter) (MessagingService, error)