internal

Documentation

Index

• type Client
  • func NewClient(httpClient *http.Client) *Client
  • func (c *Client) Ack(ctx context.Context, project, subscription string, ids ...string) error
  • func (c *Client) Publish(ctx context.Context, project, topic string, messages ...Message) ([]string, error)
  • func (c *Client) Pull(ctx context.Context, project, subscription string, max int) ([]Message, error)
• type Error
  • func (e *Error) Error() string
• type Message

Types

type Client

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

Client is a Google Pub/Sub client.

func NewClient

func NewClient(httpClient *http.Client) *Client

NewClient creates a new PubSub client.

func (*Client) Ack

func (c *Client) Ack(ctx context.Context, project, subscription string, ids ...string) error

Ack acknowledges message receipt.

func (*Client) Publish

func (c *Client) Publish(ctx context.Context, project, topic string, messages ...Message) ([]string, error)

Publish publishes the supplied Messages to the topic.

func (*Client) Pull

func (c *Client) Pull(ctx context.Context, project, subscription string, max int) ([]Message, error)

Pull pulls a maximum number of N Messages for the subscription.

type Error

type Error struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Status  string `json:"status"`
}

Error represents a pubsub error message.

func (*Error) Error

func (e *Error) Error() string

Error returns the error message in string format.

type Message

type Message struct {
	MessageID   string            `json:"messageId"`
	AckID       string            `json:"-"`
	Data        []byte            `json:"data"`
	PublishTime time.Time         `json:"publishTime"`
	Attributes  map[string]string `json:"attributes"`
}

Message represents a pubsub message.