pubsublib

Documentation

Index

• func ReceiveToChannel(ctx context.Context, sub Receiver) <-chan MessageOrError
• type Message
• type MessageOrError
• type Receiver

Functions

func ReceiveToChannel

func ReceiveToChannel(ctx context.Context, sub Receiver) <-chan MessageOrError

ReceiveToChannel pulls messages from a subscription sub until it gets an error or its context is closed. It returns the channel for messages and/or errors and is never a blocking call.

Types

type Message

type Message interface {
	Attributes() map[string]string
	Body() []byte
	ID() string
	Ack()
}

Message describes the behaviors of a pubsub message.

type MessageOrError

type MessageOrError struct {
	Message Message
	Error   error
}

MessageOrError is a wrapper type for channels which need to transmit both messages and errors.

type Receiver

type Receiver interface {
	Receive(context.Context, func(context.Context, *pubsub.Message)) error
}

Receiver is an interface wrapping pubsub.Subscription's Receive method.