package
Version:
v0.11.1
Opens a new window with list of versions in this module.
Published: Nov 9, 2020
License: Apache-2.0
Opens a new window with license information.
Imports: 12
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
Package pubsub implements the "pubsub" surfacer. This surfacer type is in
experimental phase right now.
IsCompressed takes message attribute map and returns true if compressed
attribute is set to true.
StartTime takes message attributes map and returns the value of the
starttime attribute.
Surfacer implements a pubsub surfacer.
New initializes a Surfacer for publishing data to a pubsub topic.
Write queues the incoming data into a channel. This channel is watched by a
goroutine that actually publishes it to a pubsub topic.
Source Files
¶
Directories
¶
Click to show internal directories.
Click to hide internal directories.