pubsub

Documentation

Index

• func NewMessage(topic string, data []byte, attr map[string]string) *message
• type Service
  • func NewService(projectID string) Service

Functions

func NewMessage

func NewMessage(topic string, data []byte, attr map[string]string) *message

NewMessage creates a new message.

Types

type Service

type Service interface {
	Publish(context.Context, *message) *pubsub.PublishResult
}

Service implements methods to publish messages to a topic.

func NewService

func NewService(projectID string) Service

NewService creates a new Service.