Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubsubClientGateway ¶ added in v0.14.1
PubSubClientGateway represents the gateway to a pubsub client.
func NewPubsubClientAdapter ¶ added in v0.14.1
func NewPubsubClientAdapter(client *pubsub.Client) PubsubClientGateway
NewPubSubClientAdapter creates a new PubsubClientGateway from a pubsub.Client
type Sink ¶
type Sink struct {
// contains filtered or unexported fields
}
Sink is a pubsub sink
func MustNew ¶
func MustNew(client PubsubClientGateway) (sink *Sink, closeFunc func())
MustNew creates a new pubsub sink or panics if fails
type SinkMessage ¶
SinkMessage is a message to be sent to a pubsub topic
Click to show internal directories.
Click to hide internal directories.