sqs

Documentation

Index

• Constants
• type BatchResultError
• type ChangeMessageVisibilityRequest
  • func NewChangeMessageVisibilityRequest() *ChangeMessageVisibilityRequest
  • func (gir ChangeMessageVisibilityRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
  • func (gir ChangeMessageVisibilityRequest) Request() (*ChangeMessageVisibilityResponse, error)
  • func (gir *ChangeMessageVisibilityRequest) VerifyInput() error
• type ChangeMessageVisibilityResponse
• type DeleteMessageRequest
  • func NewDeleteMessageRequest() *DeleteMessageRequest
  • func (gir DeleteMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
  • func (gir DeleteMessageRequest) Request() (*DeleteMessageResponse, error)
  • func (gir *DeleteMessageRequest) VerifyInput() error
• type DeleteMessageResponse
• type ReceiveMessageRequest
  • func NewReceiveMessageRequest() *ReceiveMessageRequest
  • func (gir ReceiveMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
  • func (gir ReceiveMessageRequest) Request() (*ReceiveMessageResponse, error)
  • func (gir *ReceiveMessageRequest) VerifyInput() error
• type ReceiveMessageResponse
• type ReceiveMessageResult
• type RecieveMessageResultMessage
• type SendBatchMessageRequest
  • func NewSendBatchMessageRequest() *SendBatchMessageRequest
  • func (gir SendBatchMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
  • func (gir SendBatchMessageRequest) Request() (*SendBatchMessageResponse, error)
  • func (gir *SendBatchMessageRequest) VerifyInput() error
• type SendBatchMessageResponse
• type SendMessageBatchRequestEntry
• type SendMessageBatchResult
• type SendMessageRequest
  • func NewSendMessageRequest() *SendMessageRequest
  • func (gir SendMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}
  • func (gir SendMessageRequest) Request() (*SendMessageResponse, error)
  • func (gir *SendMessageRequest) VerifyInput() error
• type SendMessageResponse
• type SendMessageResult
• type SqsAttributes

Constants

const (
	SQS_RECEIVE_ATTR_NAME_All              = "All"
	SQS_RECEIVE_ATTR_NAME_SenderId         = "SenderId"
	SQS_RECEIVE_ATTR_NAME_SentTimestamp    = "SentTimestamp"
	SQS_RECEIVE_ATTR_NAME_ReceiveCount     = "ApproximateReceiveCount"
	SQS_RECEIVE_ATTR_NAME_FirstReceiveTime = "ApproximateFirstReceiveTimestamp"
)

Types

type BatchResultError

type BatchResultError struct {
	Code        string
	Id          string
	Message     string
	SenderFault bool
}

type ChangeMessageVisibilityRequest

type ChangeMessageVisibilityRequest struct {
	awsgo.RequestBuilder

	ReceiptHandle     string
	VisibilityTimeout int
	TaskQueue         string
}

func NewChangeMessageVisibilityRequest

func NewChangeMessageVisibilityRequest() *ChangeMessageVisibilityRequest

func (ChangeMessageVisibilityRequest) DeMarshalResponse

func (gir ChangeMessageVisibilityRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}

func (ChangeMessageVisibilityRequest) Request

func (gir ChangeMessageVisibilityRequest) Request() (*ChangeMessageVisibilityResponse, error)

func (*ChangeMessageVisibilityRequest) VerifyInput

func (gir *ChangeMessageVisibilityRequest) VerifyInput() error

type ChangeMessageVisibilityResponse

type ChangeMessageVisibilityResponse struct {
	ResponseMetadata awsgo.ResponseMetaData
}

type DeleteMessageRequest

type DeleteMessageRequest struct {
	awsgo.RequestBuilder

	ReceiptHandle string
	TaskQueue     string
}

func NewDeleteMessageRequest

func NewDeleteMessageRequest() *DeleteMessageRequest

func (DeleteMessageRequest) DeMarshalResponse

func (gir DeleteMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}

func (DeleteMessageRequest) Request

func (gir DeleteMessageRequest) Request() (*DeleteMessageResponse, error)

func (*DeleteMessageRequest) VerifyInput

func (gir *DeleteMessageRequest) VerifyInput() error

type DeleteMessageResponse

type DeleteMessageResponse struct {
	ResponseMetadata awsgo.ResponseMetaData
}

type ReceiveMessageRequest

type ReceiveMessageRequest struct {
	awsgo.RequestBuilder

	AttributeToGet         []string
	MessageAttributesToGet []string
	MaxNumberOfMessages    int
	VisibilityTimeout      int
	WaitTimeSeconds        int
	TaskQueue              string
}

func NewReceiveMessageRequest

func NewReceiveMessageRequest() *ReceiveMessageRequest

func (ReceiveMessageRequest) DeMarshalResponse

func (gir ReceiveMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}

func (ReceiveMessageRequest) Request

func (gir ReceiveMessageRequest) Request() (*ReceiveMessageResponse, error)

func (*ReceiveMessageRequest) VerifyInput

func (gir *ReceiveMessageRequest) VerifyInput() error

type ReceiveMessageResponse

type ReceiveMessageResponse struct {
	ReceiveMessageResult ReceiveMessageResult
	ResponseMetadata     awsgo.ResponseMetaData
}

type ReceiveMessageResult

type ReceiveMessageResult struct {
	Message RecieveMessageResultMessage
}

type RecieveMessageResultMessage

type RecieveMessageResultMessage struct {
	MessageId     string
	ReceiptHandle string
	MD5OfBody     string
	Body          string
	Attribute     []SqsAttributes
	AttributeMap  map[string]string
}

type SendBatchMessageRequest

type SendBatchMessageRequest struct {
	awsgo.RequestBuilder

	QueueUrl string
	Entries  []SendMessageBatchRequestEntry
}

func NewSendBatchMessageRequest

func NewSendBatchMessageRequest() *SendBatchMessageRequest

func (SendBatchMessageRequest) DeMarshalResponse

func (gir SendBatchMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}

func (SendBatchMessageRequest) Request

func (gir SendBatchMessageRequest) Request() (*SendBatchMessageResponse, error)

func (*SendBatchMessageRequest) VerifyInput

func (gir *SendBatchMessageRequest) VerifyInput() error

type SendBatchMessageResponse

type SendBatchMessageResponse struct {
	SendMessageBatchResult []SendMessageBatchResult `xml:"SendMessageBatchResultEntry>member"`
	BatchResultError       []BatchResultError       `xml:"BatchResultErrorEntry>member"`
	ResponseMetadata       awsgo.ResponseMetaData
}

type SendMessageBatchRequestEntry

type SendMessageBatchRequestEntry struct {
	DelaySeconds int64
	Id           string
	MessageBody  string
}

type SendMessageBatchResult

type SendMessageBatchResult struct {
	Id               string
	MessageId        string
	MD5OfMessageBody string
}

type SendMessageRequest

type SendMessageRequest struct {
	awsgo.RequestBuilder

	MessageBody  string
	DelaySeconds int
	TaskQueue    string
}

func NewSendMessageRequest

func NewSendMessageRequest() *SendMessageRequest

func (SendMessageRequest) DeMarshalResponse

func (gir SendMessageRequest) DeMarshalResponse(response []byte, headers map[string]string, statusCode int) interface{}

func (SendMessageRequest) Request

func (gir SendMessageRequest) Request() (*SendMessageResponse, error)

func (*SendMessageRequest) VerifyInput

func (gir *SendMessageRequest) VerifyInput() error

type SendMessageResponse

type SendMessageResponse struct {
	SendMessageResult SendMessageResult
	ResponseMetadata  awsgo.ResponseMetaData
}

type SendMessageResult

type SendMessageResult struct {
	MessageId        string
	MD5OfMessageBody string
}

type SqsAttributes

type SqsAttributes struct {
	Name  string
	Value string
}