Versions in this module Expand all Collapse all v0 v0.24.1 Jan 27, 2022 Changes in this version + type AckID interface + type AckInfo struct + AckID AckID + IsAck bool + type Message struct + AckID AckID + AfterSend func(asFunc func(interface{}) bool) error + AsFunc func(interface{}) bool + BeforeSend func(asFunc func(interface{}) bool) error + Body []byte + LoggableID string + Metadata map[string]string + func (m *Message) ByteSize() int + type Subscription interface + As func(i interface{}) bool + CanNack func() bool + Close func() error + ErrorAs func(error, interface{}) bool + ErrorCode func(error) gcerrors.ErrorCode + IsRetryable func(err error) bool + ReceiveBatch func(ctx context.Context, maxMessages int) ([]*Message, error) + SendAcks func(ctx context.Context, ackIDs []AckID) error + SendNacks func(ctx context.Context, ackIDs []AckID) error + type Topic interface + As func(i interface{}) bool + Close func() error + ErrorAs func(error, interface{}) bool + ErrorCode func(error) gcerrors.ErrorCode + IsRetryable func(err error) bool + SendBatch func(ctx context.Context, ms []*Message) error