Discover Packages
github.com/sardine-ai/beam
sdks
go
pkg
beam
io
pubsubio
package
Version:
v2.23.0-RC1+incompatible
Opens a new window with list of versions in this module.
Published: Jul 9, 2020
License: Apache-2.0
Opens a new window with license information.
Imports: 9
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation Source Files Directories Overview Index Constants Variables Functions Types Read(s, project, topic, opts) Write(s, project, topic, col) type ReadOptions
Documentation
¶
Package pubsubio provides access to PubSub on Dataflow streaming.
Experimental.
Read reads an unbounded number of PubSubMessages from the given
pubsub topic. It produces an unbounded PCollecton<*PubSubMessage>,
if WithAttributes is set, or an unbounded PCollection<[]byte>.
Write writes PubSubMessages or bytes to the given pubsub topic.
type ReadOptions struct {
Subscription string
IDAttribute string
TimestampAttribute string
WithAttributes bool
}
ReadOptions represents options for reading from PubSub.
Source Files
¶
Directories
¶
Show internal
Collapse all
Package v1 is a generated protocol buffer package.
Package v1 is a generated protocol buffer package.
Click to show internal directories.
Click to hide internal directories.