pubsub

Documentation

Index

• func AddTopicHandler(topic string, router chi.Router, handler func(event *CloudEvent) error)
• func Subscribe(pubSubName string, topics []string, router chi.Router)
• type CloudEvent

Functions

func AddTopicHandler

func AddTopicHandler(topic string, router chi.Router, handler func(event *CloudEvent) error)

AddTopicHandler is a way to plug in a handler for receiving messages from a Dapr pub-sub topic It's pretty simple and the handler is passed the CloudEvent data, for them to decode

func Subscribe

func Subscribe(pubSubName string, topics []string, router chi.Router)

Subscribe is a HTTP handler that lets Dapr know what topics we subscribe to

Types

type CloudEvent

type CloudEvent struct {
	ID   string      `json:"id"`
	Data interface{} `json:"data"`
}