gcppubsub

package

v0.0.0-...-8ee1375 Latest Latest Go to latest Published: Jan 2, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var ErrFailedToEstablishClient = errors.New("failed to establish pubsub client")

ErrFailedToEstablishClient indicates failure to create a Pub/Sub client.

View Source

var ErrFailedToPublishMessage = errors.New("failed to publish message")

ErrFailedToPublishMessage indicates failure to publish a message.

View Source

var ErrFailedToReceiveMessage = errors.New("failed to receive message")

ErrFailedToReceiveMessage indicates failure to receive messages.

This section is empty.

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

func NewClient(ctx context.Context, projectID string) (*Client, error)

NewClient creates a new Pub/Sub client. It automatically respects PUBSUB_EMULATOR_HOST env var.

func (c *Client) Close() error

func (c *Client) Publish(ctx context.Context, topicID string, data []byte) (string, error)

func (c *Client) Subscribe(ctx context.Context, subID string,
	handler func(ctx context.Context, msgID string, data []byte) error) error

Path	Synopsis
gcppubsubadapters