delay_queue

Documentation

Index

• type DelayMessageRequest
• type DelayMessageResponse
• type DelayQueue

Types

type DelayMessageRequest

type DelayMessageRequest struct {
	// Required. The name of the DelayQueue component
	ComponentName string `json:"component_name,omitempty"`
	// Required. The pubsub topic
	Topic string `json:"topic,omitempty"`
	// Required. The data which will be published to topic.
	Data []byte `json:"data,omitempty"`
	// The content type for the data (optional).
	DataContentType string `json:"data_content_type,omitempty"`
	// The length of time, in seconds, for which the delivery
	// of this messages is delayed.  Default: 0.
	DelayInSeconds int32 `json:"delay_in_seconds,omitempty"`
	// The metadata passing to pub components
	//
	// metadata property:
	// - key : the key of the message.
	Metadata map[string]string `json:"metadata,omitempty"`
}

DelayMessageRequest is the message to publish

type DelayMessageResponse

type DelayMessageResponse struct {
	// The message identifier
	MessageId string `json:"message_id,omitempty"`
}

DelayMessageResponse is the response

type DelayQueue

type DelayQueue interface {
	PublishDelayMessage(context.Context, *DelayMessageRequest) (*DelayMessageResponse, error)
}