pubsub

Documentation

Index

• Variables
• func DecodeJSONEvent(m Message, dst interface{}) errors.ErouskaError
• type Client
  • func (c Client) Publish(topic string, msg interface{}) error
• type EventPublisher
• type Message
• type MockClient
  • func (c MockClient) Publish(topic string, msg interface{}) error

Variables

var PubSubClient *pubsub.Client

PubSubClient -_-

Functions

func DecodeJSONEvent

func DecodeJSONEvent(m Message, dst interface{}) errors.ErouskaError

DecodeJSONEvent Decodes and validates PubSub message into given interface.

Types

type Client

type Client struct{}

Client Real PubSub client.

func (Client) Publish

func (c Client) Publish(topic string, msg interface{}) error

Publish Publish message to some topic.

type EventPublisher

type EventPublisher interface {
	Publish(topic string, msg interface{}) error
}

EventPublisher is an abstraction over PubSub

type Message

type Message struct {
	Data []byte `json:"data"`
}

Message is the payload of a Pub/Sub event.

type MockClient

type MockClient struct{}

MockClient NOOP PubSub client.

func (MockClient) Publish

func (c MockClient) Publish(topic string, msg interface{}) error

Publish Publish message to some topic.