broker

Documentation

Index

• type CloudEventsNATSHandler
  • func NewCloudEventsNATSHandler(natsURL, subject, stream string, isConsumer bool) (*CloudEventsNATSHandler, error)
  • func (h *CloudEventsNATSHandler) Listen(subject string, durableName string, handlerFunc func(msg *nats.Msg))
  • func (h *CloudEventsNATSHandler) PublishEvent(ctx context.Context, subject string, data interface{}) error
• type Message

Types

type CloudEventsNATSHandler

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

CloudEventsNATSHandler handles CloudEvents publishing and NATS JetStream subscriptions.

func NewCloudEventsNATSHandler

func NewCloudEventsNATSHandler(natsURL, subject, stream string, isConsumer bool) (*CloudEventsNATSHandler, error)

func (*CloudEventsNATSHandler) Listen

func (h *CloudEventsNATSHandler) Listen(subject string, durableName string, handlerFunc func(msg *nats.Msg))

Listen subscribes to a NATS subject and processes messages with the provided handler function.

func (*CloudEventsNATSHandler) PublishEvent

func (h *CloudEventsNATSHandler) PublishEvent(ctx context.Context, subject string, data interface{}) error

PublishEvent sends a CloudEvent message.

type Message

type Message struct {
	Message   string    `json:"message"`
	Nick      string    `json:"nick"`
	Channel   string    `json:"channel"`
	Platform  string    `json:"platform"`
	Timestamp time.Time `json:"timestamp"`
}