Documentation ¶
Index ¶
- func ListenForPubSubMessages(cmp *component.Component)
- func NewPubSubEventPublisher(project, topic string) (*pubsubEventPublisher, error)
- func PublishEventsToPubSub(cmp *component.Component, gcpProjectID string, gcpPubSubTopic string) error
- type MessageHandler
- type PubSubMessageEventAdapter
- type PubSubMessageHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ListenForPubSubMessages ¶
func NewPubSubEventPublisher ¶
Types ¶
type MessageHandler ¶
type PubSubMessageEventAdapter ¶
type PubSubMessageEventAdapter struct {
event.EventHandler
}
func (*PubSubMessageEventAdapter) HandleMessage ¶
type PubSubMessageHandler ¶
type PubSubMessageHandler struct { MessageHandler *zap.Logger }
func (*PubSubMessageHandler) ServeHTTP ¶
func (h *PubSubMessageHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
Click to show internal directories.
Click to hide internal directories.