beam: Index | Files | Directories

package pubsubio

import ""

Package pubsubio provides access to PubSub on Dataflow streaming. Experimental.


Package Files


func Read Uses

func Read(s beam.Scope, project, topic string, opts *ReadOptions) beam.PCollection

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>.

func Write Uses

func Write(s beam.Scope, project, topic string, col beam.PCollection)

Write writes PubSubMessages or bytes to the given pubsub topic.

type ReadOptions Uses

type ReadOptions struct {
    Subscription       string
    IDAttribute        string
    TimestampAttribute string
    WithAttributes     bool

ReadOptions represents options for reading from PubSub.


v1Package v1 is a generated protocol buffer package.

Package pubsubio imports 9 packages (graph) and is imported by 1 packages. Updated 2019-08-27. Refresh now. Tools for package owners.