pubsub

Documentation

Overview

Package pubsub implements Google Cloud Pub Sub client

Index

• type CollectorPubSubClient
  • func NewPubSubClient(ctx context.Context, project string) (*CollectorPubSubClient, error)
  • func NewPubSubClientWithCredentialsFile(ctx context.Context, project string, credentialsFile string) (*CollectorPubSubClient, error)
  • func (c *CollectorPubSubClient) Close() error
  • func (c *CollectorPubSubClient) Publish(topicName string, message []byte) (string, error)

Types

type CollectorPubSubClient

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

func NewPubSubClient

func NewPubSubClient(ctx context.Context, project string) (*CollectorPubSubClient, error)

func NewPubSubClientWithCredentialsFile

func NewPubSubClientWithCredentialsFile(ctx context.Context, project string, credentialsFile string) (*CollectorPubSubClient, error)

func (*CollectorPubSubClient) Close

func (c *CollectorPubSubClient) Close() error

func (*CollectorPubSubClient) Publish

func (c *CollectorPubSubClient) Publish(topicName string, message []byte) (string, error)