pubsub

Documentation

Overview

Package pubsub provides Google Pub/Sub implementation.

Index

• type Publisher
  • func NewPublisher(ctx context.Context, projectID string, opts ...option.ClientOption) (*Publisher, error)
  • func (p *Publisher) Publish(topic string, body []byte) error
  • func (p *Publisher) Stop() error
• type Receiver
  • func NewReceiver(projectID, subscriptionID string, connectTimeout time.Duration, ...) (*Receiver, error)
  • func (r *Receiver) Listen(h mq.Handler) (retErr error)
  • func (r *Receiver) Stop() error

Types

type Publisher

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

Publisher publish message.

func NewPublisher

func NewPublisher(ctx context.Context, projectID string, opts ...option.ClientOption) (*Publisher, error)

NewPublisher constructs new Publisher.

func (*Publisher) Publish

func (p *Publisher) Publish(topic string, body []byte) error

Publish message body to a topic.

func (*Publisher) Stop

func (p *Publisher) Stop() error

Stop the publisher.

type Receiver

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

Receiver receives message.

func NewReceiver

func NewReceiver(projectID, subscriptionID string, connectTimeout time.Duration, opts ...option.ClientOption) (*Receiver, error)

NewReceiver construct new Receiver.

func (*Receiver) Listen

func (r *Receiver) Listen(h mq.Handler) (retErr error)

Listen to the incoming message.

func (*Receiver) Stop

func (r *Receiver) Stop() error

Stop the receiver.