pubsub

type Blackbox interface {
	contract.Base64Decoder
}

type Client interface {
	Blackbox
	MockPubSubPayload(msg contract.PubSubMessage, subscription string) (io.Reader, error)
	DecodePayload(r *http.Request) (contract.PubSubMessage, error)
}

type Payload struct {
	Message      pubsub.Message `json:"message,omitempty"`
	Subscription string         `json:"subscription,omitempty"`
}

type PubSubMessageWrapper struct {
	Msg *pubsub.Message
}