topic

Documentation

Index

• type PubSubPublisher
  • func NewPubSubPublisher(ctx context.Context, projectID, topicName string) (p *PubSubPublisher, err error)
  • func (p *PubSubPublisher) Publish(ctx context.Context, key []byte, content *msg.SimpleMessage) error

Types

type PubSubPublisher

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

PubSubPublisher represents GCP PubSub publisher

func NewPubSubPublisher

func NewPubSubPublisher(ctx context.Context, projectID, topicName string) (p *PubSubPublisher, err error)

NewPubSubPublisher creates a configured version of the GCP PubSub publisher

func (*PubSubPublisher) Publish

func (p *PubSubPublisher) Publish(ctx context.Context, key []byte, content *msg.SimpleMessage) error

Publish publishes messages to GCP PubSub