beam: github.com/apache/beam/sdks/go/pkg/beam/io/pubsubio Index | Files | Directories

package pubsubio

import "github.com/apache/beam/sdks/go/pkg/beam/io/pubsubio"

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

Index

Package Files

pubsubio.go

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.

Directories

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