pubsub

type Client struct {
	ServiceName string
	Provider    Provider
	Middleware  []Middleware
}

type MessageHandler func(message string) error

type Middleware interface {
	PublisherMsgInterceptor(serviceName string, next PublishHandler) PublishHandler
}

type NoopProvider struct{}

type Provider interface {
	Publish(topicARN string, message interface{}, messageAttributes map[string]interface{}) error
	PollMessages(queueURL string, handler MessageHandler) error
}

type PublishHandler func(topicARN string, message interface{}, messageAttributes map[string]interface{}) error