Documentation
¶
Index ¶
- type Backend
- func (b *Backend) Ack(ctx context.Context, topic, consumerGroup string, messageIDs ...string) error
- func (b *Backend) DeleteConsumer(ctx context.Context, topic, consumerGroup, consumerName string) error
- func (b *Backend) Publish(ctx context.Context, topic string, events ...*event.CloudEvent) ([]string, error)
- func (b *Backend) Subscribe(ctx context.Context, topic, consumerGroup, consumerName string, ...) iter.Seq2[pubsub.Message, error]
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Backend ¶
type Backend struct {
// contains filtered or unexported fields
}
func NewBackend ¶
func (*Backend) DeleteConsumer ¶
type Option ¶ added in v19.3.0
type Option func(*Backend)
func WithReadBlockTimeout ¶ added in v19.3.0
WithReadBlockTimeout overrides how long a blocking stream read waits for new entries before coming back empty. A subscriber has no "stream exhausted" signal to stop on, so anything wanting to establish that nothing more is coming has to outwait this.
Click to show internal directories.
Click to hide internal directories.