Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetPublishResult ¶
func SetPublishResult(r *PublishResult, sid string, err error)
SetPublishResult sets the server ID and error for a publish result and closes the Ready channel.
Types ¶
type AckHandler ¶
type AckHandler interface {
// OnAck processes a message ack.
OnAck()
// OnNack processes a message nack.
OnNack()
}
AckHandler implements ack/nack handling.
func MessageAckHandler ¶
func MessageAckHandler(m *Message) AckHandler
MessageAckHandler provides access to the internal field Message.ackh.
type Message ¶
type Message struct {
// ID identifies this message. This ID is assigned by the server and is
// populated for Messages obtained from a subscription.
//
// This field is read-only.
ID string
// Data is the actual data in the message.
Data []byte
// Attributes represents the key-value pairs the current message is
// labelled with.
Attributes map[string]string
// PublishTime is the time at which the message was published. This is
// populated by the server for Messages obtained from a subscription.
//
// This field is read-only.
PublishTime time.Time
// DeliveryAttempt is the number of times a message has been delivered.
// This is part of the dead lettering feature that forwards messages that
// fail to be processed (from nack/ack deadline timeout) to a dead letter topic.
// If dead lettering is enabled, this will be set on all attempts, starting
// with value 1. Otherwise, the value will be nil.
// This field is read-only.
DeliveryAttempt *int
// OrderingKey identifies related messages for which publish order should
// be respected. If empty string is used, message will be sent unordered.
OrderingKey string
// contains filtered or unexported fields
}
Message represents a Pub/Sub message.
func NewMessage ¶
func NewMessage(ackh AckHandler) *Message
NewMessage creates a message with an AckHandler implementation, which should not be nil.
func (*Message) Ack ¶
func (m *Message) Ack()
Ack indicates successful processing of a Message passed to the Subscriber.Receive callback. It should not be called on any other Message value. If message acknowledgement fails, the Message will be redelivered. Client code must call Ack or Nack when finished for each received Message. Calls to Ack or Nack have no effect after the first call.
func (*Message) Nack ¶
func (m *Message) Nack()
Nack indicates that the client will not or cannot process a Message passed to the Subscriber.Receive callback. It should not be called on any other Message value. Nack will result in the Message being redelivered more quickly than if it were allowed to expire. Client code must call Ack or Nack when finished for each received Message. Calls to Ack or Nack have no effect after the first call.
type PublishResult ¶
type PublishResult struct {
// contains filtered or unexported fields
}
A PublishResult holds the result from a call to Publish.
func NewPublishResult ¶
func NewPublishResult() *PublishResult
NewPublishResult creates a PublishResult.
func (*PublishResult) Get ¶
func (r *PublishResult) Get(ctx context.Context) (serverID string, err error)
Get returns the server-generated message ID and/or error result of a Publish call. Get blocks until the Publish call completes or the context is done.
func (*PublishResult) Ready ¶
func (r *PublishResult) Ready() <-chan struct{}
Ready returns a channel that is closed when the result is ready. When the Ready channel is closed, Get is guaranteed not to block.
Source Files