pubsub

Documentation

Index

• func CreatePublishToTopic(ctx context.Context, c *pubsub.Client, t string, msg []byte) error
• func ListenTopicWithClient(ctx context.Context, topicName string, c *pubsub.Client) (chan Msg, chan struct{}, error)
• func PublishToExistingTopic(ctx context.Context, c *pubsub.Client, t string, msg []byte) error
• type Msg
  • func (m *Msg) Ack()
  • func (m *Msg) Read() []byte

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