pubsub

package
Version: v0.0.0-...-b4b8f64 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 20, 2017 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreatePublishToTopic

func CreatePublishToTopic(ctx context.Context, c *pubsub.Client, t string, msg []byte) error

func ListenTopicWithClient

func ListenTopicWithClient(ctx context.Context, topicName string, c *pubsub.Client) (chan Msg, chan struct{}, error)

func PublishToExistingTopic

func PublishToExistingTopic(ctx context.Context, c *pubsub.Client, t string, msg []byte) error

Types

type Msg

type Msg struct {
	// contains filtered or unexported fields
}

func (*Msg) Ack

func (m *Msg) Ack()

func (*Msg) Read

func (m *Msg) Read() []byte

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL