Documentation
¶
Overview ¶
Package sqsiface provides an interface to enable mocking the SQS service client for testing your code.
It is important to note that this interface will have breaking changes when the service model is updated and adds new API operations, paginators, and waiters.
Index ¶
- Constants
- type CreateQueueInput
- func (s CreateQueueInput) GoString() string
- func (s *CreateQueueInput) SetMessageRetentionPeriod(v int32) *CreateQueueInput
- func (s *CreateQueueInput) SetQueueDisplayName(v string) *CreateQueueInput
- func (s *CreateQueueInput) SetVisibilityTimeout(v int32) *CreateQueueInput
- func (s CreateQueueInput) String() string
- func (s *CreateQueueInput) Validate() error
- type CreateQueueOutput
- type DeleteMessageInput
- type DeleteMessageOutput
- type DeleteQueueInput
- type DeleteQueueOutput
- type GetQueueAttributesInput
- type GetQueueAttributesOutput
- func (s GetQueueAttributesOutput) GoString() string
- func (s *GetQueueAttributesOutput) SetCreatedAt(v string) *GetQueueAttributesOutput
- func (s *GetQueueAttributesOutput) SetMessageRetentionPeriod(v int32) *GetQueueAttributesOutput
- func (s *GetQueueAttributesOutput) SetQueueDisplayName(v string) *GetQueueAttributesOutput
- func (s *GetQueueAttributesOutput) SetQueueTrn(v string) *GetQueueAttributesOutput
- func (s *GetQueueAttributesOutput) SetVisibilityTimeout(v int32) *GetQueueAttributesOutput
- func (s GetQueueAttributesOutput) String() string
- type ListQueuesInput
- func (s ListQueuesInput) GoString() string
- func (s *ListQueuesInput) SetMaxResults(v int32) *ListQueuesInput
- func (s *ListQueuesInput) SetNextToken(v string) *ListQueuesInput
- func (s *ListQueuesInput) SetQueueDisplayNamePrefix(v string) *ListQueuesInput
- func (s ListQueuesInput) String() string
- func (s *ListQueuesInput) Validate() error
- type ListQueuesOutput
- func (s ListQueuesOutput) GoString() string
- func (s *ListQueuesOutput) SetNextToken(v string) *ListQueuesOutput
- func (s *ListQueuesOutput) SetQueues(v []*QueueForListQueuesOutput) *ListQueuesOutput
- func (s *ListQueuesOutput) SetTotalCount(v int32) *ListQueuesOutput
- func (s ListQueuesOutput) String() string
- type MessageForReceiveMessageOutput
- func (s MessageForReceiveMessageOutput) GoString() string
- func (s *MessageForReceiveMessageOutput) SetMessageBody(v string) *MessageForReceiveMessageOutput
- func (s *MessageForReceiveMessageOutput) SetMessageId(v string) *MessageForReceiveMessageOutput
- func (s *MessageForReceiveMessageOutput) SetReceiptHandle(v string) *MessageForReceiveMessageOutput
- func (s MessageForReceiveMessageOutput) String() string
- type QueueForListQueuesOutput
- func (s QueueForListQueuesOutput) GoString() string
- func (s *QueueForListQueuesOutput) SetCreatedAt(v string) *QueueForListQueuesOutput
- func (s *QueueForListQueuesOutput) SetQueueDisplayName(v string) *QueueForListQueuesOutput
- func (s *QueueForListQueuesOutput) SetQueueTrn(v string) *QueueForListQueuesOutput
- func (s QueueForListQueuesOutput) String() string
- type ReceiveMessageInput
- func (s ReceiveMessageInput) GoString() string
- func (s *ReceiveMessageInput) SetMaxNumberOfMessages(v int32) *ReceiveMessageInput
- func (s *ReceiveMessageInput) SetQueueTrn(v string) *ReceiveMessageInput
- func (s *ReceiveMessageInput) SetWaitTimeSeconds(v int32) *ReceiveMessageInput
- func (s ReceiveMessageInput) String() string
- func (s *ReceiveMessageInput) Validate() error
- type ReceiveMessageOutput
- type SQS
- func (c *SQS) CreateQueue(input *CreateQueueInput) (*CreateQueueOutput, error)
- func (c *SQS) CreateQueueCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) CreateQueueCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) CreateQueueCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) CreateQueueRequest(input *CreateQueueInput) (req *request.Request, output *CreateQueueOutput)
- func (c *SQS) CreateQueueWithContext(ctx volcengine.Context, input *CreateQueueInput, opts ...request.Option) (*CreateQueueOutput, error)
- func (c *SQS) DeleteMessage(input *DeleteMessageInput) (*DeleteMessageOutput, error)
- func (c *SQS) DeleteMessageCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) DeleteMessageCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) DeleteMessageCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) DeleteMessageRequest(input *DeleteMessageInput) (req *request.Request, output *DeleteMessageOutput)
- func (c *SQS) DeleteMessageWithContext(ctx volcengine.Context, input *DeleteMessageInput, opts ...request.Option) (*DeleteMessageOutput, error)
- func (c *SQS) DeleteQueue(input *DeleteQueueInput) (*DeleteQueueOutput, error)
- func (c *SQS) DeleteQueueCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) DeleteQueueCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) DeleteQueueCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) DeleteQueueRequest(input *DeleteQueueInput) (req *request.Request, output *DeleteQueueOutput)
- func (c *SQS) DeleteQueueWithContext(ctx volcengine.Context, input *DeleteQueueInput, opts ...request.Option) (*DeleteQueueOutput, error)
- func (c *SQS) GetQueueAttributes(input *GetQueueAttributesInput) (*GetQueueAttributesOutput, error)
- func (c *SQS) GetQueueAttributesCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) GetQueueAttributesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) GetQueueAttributesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) GetQueueAttributesRequest(input *GetQueueAttributesInput) (req *request.Request, output *GetQueueAttributesOutput)
- func (c *SQS) GetQueueAttributesWithContext(ctx volcengine.Context, input *GetQueueAttributesInput, opts ...request.Option) (*GetQueueAttributesOutput, error)
- func (c *SQS) ListQueues(input *ListQueuesInput) (*ListQueuesOutput, error)
- func (c *SQS) ListQueuesCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) ListQueuesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) ListQueuesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) ListQueuesRequest(input *ListQueuesInput) (req *request.Request, output *ListQueuesOutput)
- func (c *SQS) ListQueuesWithContext(ctx volcengine.Context, input *ListQueuesInput, opts ...request.Option) (*ListQueuesOutput, error)
- func (c *SQS) ReceiveMessage(input *ReceiveMessageInput) (*ReceiveMessageOutput, error)
- func (c *SQS) ReceiveMessageCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) ReceiveMessageCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) ReceiveMessageCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) ReceiveMessageRequest(input *ReceiveMessageInput) (req *request.Request, output *ReceiveMessageOutput)
- func (c *SQS) ReceiveMessageWithContext(ctx volcengine.Context, input *ReceiveMessageInput, opts ...request.Option) (*ReceiveMessageOutput, error)
- func (c *SQS) SendMessage(input *SendMessageInput) (*SendMessageOutput, error)
- func (c *SQS) SendMessageCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) SendMessageCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) SendMessageCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) SendMessageRequest(input *SendMessageInput) (req *request.Request, output *SendMessageOutput)
- func (c *SQS) SendMessageWithContext(ctx volcengine.Context, input *SendMessageInput, opts ...request.Option) (*SendMessageOutput, error)
- func (c *SQS) SetQueueAttributes(input *SetQueueAttributesInput) (*SetQueueAttributesOutput, error)
- func (c *SQS) SetQueueAttributesCommon(input *map[string]interface{}) (*map[string]interface{}, error)
- func (c *SQS) SetQueueAttributesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
- func (c *SQS) SetQueueAttributesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
- func (c *SQS) SetQueueAttributesRequest(input *SetQueueAttributesInput) (req *request.Request, output *SetQueueAttributesOutput)
- func (c *SQS) SetQueueAttributesWithContext(ctx volcengine.Context, input *SetQueueAttributesInput, opts ...request.Option) (*SetQueueAttributesOutput, error)
- type SQSAPI
- type SendMessageInput
- type SendMessageOutput
- type SetQueueAttributesInput
- func (s SetQueueAttributesInput) GoString() string
- func (s *SetQueueAttributesInput) SetMessageRetentionPeriod(v int32) *SetQueueAttributesInput
- func (s *SetQueueAttributesInput) SetQueueTrn(v string) *SetQueueAttributesInput
- func (s *SetQueueAttributesInput) SetVisibilityTimeout(v int32) *SetQueueAttributesInput
- func (s SetQueueAttributesInput) String() string
- func (s *SetQueueAttributesInput) Validate() error
- type SetQueueAttributesOutput
Constants ¶
const ( ServiceName = "sqs" // Name of service. EndpointsID = ServiceName // ID to lookup a service endpoint with. ServiceID = "sqs" // ServiceID is a unique identifer of a specific service. )
Service information constants
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreateQueueInput ¶
type CreateQueueInput struct {
MessageRetentionPeriod *int32 `min:"60" max:"604800" type:"int32" json:",omitempty"`
// QueueDisplayName is a required field
QueueDisplayName *string `min:"1" max:"255" type:"string" json:",omitempty" required:"true"`
VisibilityTimeout *int32 `max:"600" type:"int32" json:",omitempty"`
// contains filtered or unexported fields
}
func (CreateQueueInput) GoString ¶
func (s CreateQueueInput) GoString() string
GoString returns the string representation
func (*CreateQueueInput) SetMessageRetentionPeriod ¶
func (s *CreateQueueInput) SetMessageRetentionPeriod(v int32) *CreateQueueInput
SetMessageRetentionPeriod sets the MessageRetentionPeriod field's value.
func (*CreateQueueInput) SetQueueDisplayName ¶
func (s *CreateQueueInput) SetQueueDisplayName(v string) *CreateQueueInput
SetQueueDisplayName sets the QueueDisplayName field's value.
func (*CreateQueueInput) SetVisibilityTimeout ¶
func (s *CreateQueueInput) SetVisibilityTimeout(v int32) *CreateQueueInput
SetVisibilityTimeout sets the VisibilityTimeout field's value.
func (CreateQueueInput) String ¶
func (s CreateQueueInput) String() string
String returns the string representation
func (*CreateQueueInput) Validate ¶
func (s *CreateQueueInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateQueueOutput ¶
type CreateQueueOutput struct {
Metadata *response.ResponseMetadata
QueueTrn *string `type:"string" json:",omitempty"`
// contains filtered or unexported fields
}
func (CreateQueueOutput) GoString ¶
func (s CreateQueueOutput) GoString() string
GoString returns the string representation
func (*CreateQueueOutput) SetQueueTrn ¶
func (s *CreateQueueOutput) SetQueueTrn(v string) *CreateQueueOutput
SetQueueTrn sets the QueueTrn field's value.
func (CreateQueueOutput) String ¶
func (s CreateQueueOutput) String() string
String returns the string representation
type DeleteMessageInput ¶
type DeleteMessageInput struct {
// QueueTrn is a required field
QueueTrn *string `type:"string" json:",omitempty" required:"true"`
// ReceiptHandle is a required field
ReceiptHandle *string `type:"string" json:",omitempty" required:"true"`
// contains filtered or unexported fields
}
func (DeleteMessageInput) GoString ¶
func (s DeleteMessageInput) GoString() string
GoString returns the string representation
func (*DeleteMessageInput) SetQueueTrn ¶
func (s *DeleteMessageInput) SetQueueTrn(v string) *DeleteMessageInput
SetQueueTrn sets the QueueTrn field's value.
func (*DeleteMessageInput) SetReceiptHandle ¶
func (s *DeleteMessageInput) SetReceiptHandle(v string) *DeleteMessageInput
SetReceiptHandle sets the ReceiptHandle field's value.
func (DeleteMessageInput) String ¶
func (s DeleteMessageInput) String() string
String returns the string representation
func (*DeleteMessageInput) Validate ¶
func (s *DeleteMessageInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteMessageOutput ¶
type DeleteMessageOutput struct {
Metadata *response.ResponseMetadata
// contains filtered or unexported fields
}
func (DeleteMessageOutput) GoString ¶
func (s DeleteMessageOutput) GoString() string
GoString returns the string representation
func (DeleteMessageOutput) String ¶
func (s DeleteMessageOutput) String() string
String returns the string representation
type DeleteQueueInput ¶
type DeleteQueueInput struct {
// QueueTrn is a required field
QueueTrn *string `type:"string" json:",omitempty" required:"true"`
// contains filtered or unexported fields
}
func (DeleteQueueInput) GoString ¶
func (s DeleteQueueInput) GoString() string
GoString returns the string representation
func (*DeleteQueueInput) SetQueueTrn ¶
func (s *DeleteQueueInput) SetQueueTrn(v string) *DeleteQueueInput
SetQueueTrn sets the QueueTrn field's value.
func (DeleteQueueInput) String ¶
func (s DeleteQueueInput) String() string
String returns the string representation
func (*DeleteQueueInput) Validate ¶
func (s *DeleteQueueInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteQueueOutput ¶
type DeleteQueueOutput struct {
Metadata *response.ResponseMetadata
// contains filtered or unexported fields
}
func (DeleteQueueOutput) GoString ¶
func (s DeleteQueueOutput) GoString() string
GoString returns the string representation
func (DeleteQueueOutput) String ¶
func (s DeleteQueueOutput) String() string
String returns the string representation
type GetQueueAttributesInput ¶
type GetQueueAttributesInput struct {
// QueueTrn is a required field
QueueTrn *string `type:"string" json:",omitempty" required:"true"`
// contains filtered or unexported fields
}
func (GetQueueAttributesInput) GoString ¶
func (s GetQueueAttributesInput) GoString() string
GoString returns the string representation
func (*GetQueueAttributesInput) SetQueueTrn ¶
func (s *GetQueueAttributesInput) SetQueueTrn(v string) *GetQueueAttributesInput
SetQueueTrn sets the QueueTrn field's value.
func (GetQueueAttributesInput) String ¶
func (s GetQueueAttributesInput) String() string
String returns the string representation
func (*GetQueueAttributesInput) Validate ¶
func (s *GetQueueAttributesInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetQueueAttributesOutput ¶
type GetQueueAttributesOutput struct {
Metadata *response.ResponseMetadata
CreatedAt *string `type:"string" json:",omitempty"`
MessageRetentionPeriod *int32 `type:"int32" json:",omitempty"`
QueueDisplayName *string `type:"string" json:",omitempty"`
QueueTrn *string `type:"string" json:",omitempty"`
VisibilityTimeout *int32 `type:"int32" json:",omitempty"`
// contains filtered or unexported fields
}
func (GetQueueAttributesOutput) GoString ¶
func (s GetQueueAttributesOutput) GoString() string
GoString returns the string representation
func (*GetQueueAttributesOutput) SetCreatedAt ¶
func (s *GetQueueAttributesOutput) SetCreatedAt(v string) *GetQueueAttributesOutput
SetCreatedAt sets the CreatedAt field's value.
func (*GetQueueAttributesOutput) SetMessageRetentionPeriod ¶
func (s *GetQueueAttributesOutput) SetMessageRetentionPeriod(v int32) *GetQueueAttributesOutput
SetMessageRetentionPeriod sets the MessageRetentionPeriod field's value.
func (*GetQueueAttributesOutput) SetQueueDisplayName ¶
func (s *GetQueueAttributesOutput) SetQueueDisplayName(v string) *GetQueueAttributesOutput
SetQueueDisplayName sets the QueueDisplayName field's value.
func (*GetQueueAttributesOutput) SetQueueTrn ¶
func (s *GetQueueAttributesOutput) SetQueueTrn(v string) *GetQueueAttributesOutput
SetQueueTrn sets the QueueTrn field's value.
func (*GetQueueAttributesOutput) SetVisibilityTimeout ¶
func (s *GetQueueAttributesOutput) SetVisibilityTimeout(v int32) *GetQueueAttributesOutput
SetVisibilityTimeout sets the VisibilityTimeout field's value.
func (GetQueueAttributesOutput) String ¶
func (s GetQueueAttributesOutput) String() string
String returns the string representation
type ListQueuesInput ¶
type ListQueuesInput struct {
MaxResults *int32 `min:"1" max:"100" type:"int32" json:",omitempty"`
NextToken *string `type:"string" json:",omitempty"`
QueueDisplayNamePrefix *string `type:"string" json:",omitempty"`
// contains filtered or unexported fields
}
func (ListQueuesInput) GoString ¶
func (s ListQueuesInput) GoString() string
GoString returns the string representation
func (*ListQueuesInput) SetMaxResults ¶
func (s *ListQueuesInput) SetMaxResults(v int32) *ListQueuesInput
SetMaxResults sets the MaxResults field's value.
func (*ListQueuesInput) SetNextToken ¶
func (s *ListQueuesInput) SetNextToken(v string) *ListQueuesInput
SetNextToken sets the NextToken field's value.
func (*ListQueuesInput) SetQueueDisplayNamePrefix ¶
func (s *ListQueuesInput) SetQueueDisplayNamePrefix(v string) *ListQueuesInput
SetQueueDisplayNamePrefix sets the QueueDisplayNamePrefix field's value.
func (ListQueuesInput) String ¶
func (s ListQueuesInput) String() string
String returns the string representation
func (*ListQueuesInput) Validate ¶
func (s *ListQueuesInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListQueuesOutput ¶
type ListQueuesOutput struct {
Metadata *response.ResponseMetadata
NextToken *string `type:"string" json:",omitempty"`
Queues []*QueueForListQueuesOutput `type:"list" json:",omitempty"`
TotalCount *int32 `type:"int32" json:",omitempty"`
// contains filtered or unexported fields
}
func (ListQueuesOutput) GoString ¶
func (s ListQueuesOutput) GoString() string
GoString returns the string representation
func (*ListQueuesOutput) SetNextToken ¶
func (s *ListQueuesOutput) SetNextToken(v string) *ListQueuesOutput
SetNextToken sets the NextToken field's value.
func (*ListQueuesOutput) SetQueues ¶
func (s *ListQueuesOutput) SetQueues(v []*QueueForListQueuesOutput) *ListQueuesOutput
SetQueues sets the Queues field's value.
func (*ListQueuesOutput) SetTotalCount ¶
func (s *ListQueuesOutput) SetTotalCount(v int32) *ListQueuesOutput
SetTotalCount sets the TotalCount field's value.
func (ListQueuesOutput) String ¶
func (s ListQueuesOutput) String() string
String returns the string representation
type MessageForReceiveMessageOutput ¶
type MessageForReceiveMessageOutput struct {
MessageBody *string `type:"string" json:",omitempty"`
MessageId *string `type:"string" json:",omitempty"`
ReceiptHandle *string `type:"string" json:",omitempty"`
// contains filtered or unexported fields
}
func (MessageForReceiveMessageOutput) GoString ¶
func (s MessageForReceiveMessageOutput) GoString() string
GoString returns the string representation
func (*MessageForReceiveMessageOutput) SetMessageBody ¶
func (s *MessageForReceiveMessageOutput) SetMessageBody(v string) *MessageForReceiveMessageOutput
SetMessageBody sets the MessageBody field's value.
func (*MessageForReceiveMessageOutput) SetMessageId ¶
func (s *MessageForReceiveMessageOutput) SetMessageId(v string) *MessageForReceiveMessageOutput
SetMessageId sets the MessageId field's value.
func (*MessageForReceiveMessageOutput) SetReceiptHandle ¶
func (s *MessageForReceiveMessageOutput) SetReceiptHandle(v string) *MessageForReceiveMessageOutput
SetReceiptHandle sets the ReceiptHandle field's value.
func (MessageForReceiveMessageOutput) String ¶
func (s MessageForReceiveMessageOutput) String() string
String returns the string representation
type QueueForListQueuesOutput ¶
type QueueForListQueuesOutput struct {
CreatedAt *string `type:"string" json:",omitempty"`
QueueDisplayName *string `type:"string" json:",omitempty"`
QueueTrn *string `type:"string" json:",omitempty"`
// contains filtered or unexported fields
}
func (QueueForListQueuesOutput) GoString ¶
func (s QueueForListQueuesOutput) GoString() string
GoString returns the string representation
func (*QueueForListQueuesOutput) SetCreatedAt ¶
func (s *QueueForListQueuesOutput) SetCreatedAt(v string) *QueueForListQueuesOutput
SetCreatedAt sets the CreatedAt field's value.
func (*QueueForListQueuesOutput) SetQueueDisplayName ¶
func (s *QueueForListQueuesOutput) SetQueueDisplayName(v string) *QueueForListQueuesOutput
SetQueueDisplayName sets the QueueDisplayName field's value.
func (*QueueForListQueuesOutput) SetQueueTrn ¶
func (s *QueueForListQueuesOutput) SetQueueTrn(v string) *QueueForListQueuesOutput
SetQueueTrn sets the QueueTrn field's value.
func (QueueForListQueuesOutput) String ¶
func (s QueueForListQueuesOutput) String() string
String returns the string representation
type ReceiveMessageInput ¶
type ReceiveMessageInput struct {
MaxNumberOfMessages *int32 `min:"1" max:"10" type:"int32" json:",omitempty"`
// QueueTrn is a required field
QueueTrn *string `type:"string" json:",omitempty" required:"true"`
WaitTimeSeconds *int32 `max:"20" type:"int32" json:",omitempty"`
// contains filtered or unexported fields
}
func (ReceiveMessageInput) GoString ¶
func (s ReceiveMessageInput) GoString() string
GoString returns the string representation
func (*ReceiveMessageInput) SetMaxNumberOfMessages ¶
func (s *ReceiveMessageInput) SetMaxNumberOfMessages(v int32) *ReceiveMessageInput
SetMaxNumberOfMessages sets the MaxNumberOfMessages field's value.
func (*ReceiveMessageInput) SetQueueTrn ¶
func (s *ReceiveMessageInput) SetQueueTrn(v string) *ReceiveMessageInput
SetQueueTrn sets the QueueTrn field's value.
func (*ReceiveMessageInput) SetWaitTimeSeconds ¶
func (s *ReceiveMessageInput) SetWaitTimeSeconds(v int32) *ReceiveMessageInput
SetWaitTimeSeconds sets the WaitTimeSeconds field's value.
func (ReceiveMessageInput) String ¶
func (s ReceiveMessageInput) String() string
String returns the string representation
func (*ReceiveMessageInput) Validate ¶
func (s *ReceiveMessageInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ReceiveMessageOutput ¶
type ReceiveMessageOutput struct {
Metadata *response.ResponseMetadata
Messages []*MessageForReceiveMessageOutput `type:"list" json:",omitempty"`
// contains filtered or unexported fields
}
func (ReceiveMessageOutput) GoString ¶
func (s ReceiveMessageOutput) GoString() string
GoString returns the string representation
func (*ReceiveMessageOutput) SetMessages ¶
func (s *ReceiveMessageOutput) SetMessages(v []*MessageForReceiveMessageOutput) *ReceiveMessageOutput
SetMessages sets the Messages field's value.
func (ReceiveMessageOutput) String ¶
func (s ReceiveMessageOutput) String() string
String returns the string representation
type SQS ¶
SQS provides the API operation methods for making requests to SQS. See this package's package overview docs for details on the service.
SQS methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.
func New ¶
func New(p client.ConfigProvider, cfgs ...*volcengine.Config) *SQS
New create int can support ssl or region locate set
func (*SQS) CreateQueue ¶
func (c *SQS) CreateQueue(input *CreateQueueInput) (*CreateQueueOutput, error)
CreateQueue API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation CreateQueue for usage and error information.
func (*SQS) CreateQueueCommon ¶
CreateQueueCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation CreateQueueCommon for usage and error information.
func (*SQS) CreateQueueCommonRequest ¶
func (c *SQS) CreateQueueCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
CreateQueueCommonRequest generates a "volcengine/request.Request" representing the client's request for the CreateQueueCommon operation. The "output" return value will be populated with the CreateQueueCommon request's response once the request completes successfully.
Use "Send" method on the returned CreateQueueCommon Request to send the API call to the service. the "output" return value is not valid until after CreateQueueCommon Send returns without error.
See CreateQueueCommon for more information on using the CreateQueueCommon API call, and error handling.
// Example sending a request using the CreateQueueCommonRequest method.
req, resp := client.CreateQueueCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) CreateQueueCommonWithContext ¶
func (c *SQS) CreateQueueCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
CreateQueueCommonWithContext is the same as CreateQueueCommon with the addition of the ability to pass a context and additional request options.
See CreateQueueCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) CreateQueueRequest ¶
func (c *SQS) CreateQueueRequest(input *CreateQueueInput) (req *request.Request, output *CreateQueueOutput)
CreateQueueRequest generates a "volcengine/request.Request" representing the client's request for the CreateQueue operation. The "output" return value will be populated with the CreateQueueCommon request's response once the request completes successfully.
Use "Send" method on the returned CreateQueueCommon Request to send the API call to the service. the "output" return value is not valid until after CreateQueueCommon Send returns without error.
See CreateQueue for more information on using the CreateQueue API call, and error handling.
// Example sending a request using the CreateQueueRequest method.
req, resp := client.CreateQueueRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) CreateQueueWithContext ¶
func (c *SQS) CreateQueueWithContext(ctx volcengine.Context, input *CreateQueueInput, opts ...request.Option) (*CreateQueueOutput, error)
CreateQueueWithContext is the same as CreateQueue with the addition of the ability to pass a context and additional request options.
See CreateQueue for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) DeleteMessage ¶
func (c *SQS) DeleteMessage(input *DeleteMessageInput) (*DeleteMessageOutput, error)
DeleteMessage API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation DeleteMessage for usage and error information.
func (*SQS) DeleteMessageCommon ¶
DeleteMessageCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation DeleteMessageCommon for usage and error information.
func (*SQS) DeleteMessageCommonRequest ¶
func (c *SQS) DeleteMessageCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
DeleteMessageCommonRequest generates a "volcengine/request.Request" representing the client's request for the DeleteMessageCommon operation. The "output" return value will be populated with the DeleteMessageCommon request's response once the request completes successfully.
Use "Send" method on the returned DeleteMessageCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteMessageCommon Send returns without error.
See DeleteMessageCommon for more information on using the DeleteMessageCommon API call, and error handling.
// Example sending a request using the DeleteMessageCommonRequest method.
req, resp := client.DeleteMessageCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) DeleteMessageCommonWithContext ¶
func (c *SQS) DeleteMessageCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
DeleteMessageCommonWithContext is the same as DeleteMessageCommon with the addition of the ability to pass a context and additional request options.
See DeleteMessageCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) DeleteMessageRequest ¶
func (c *SQS) DeleteMessageRequest(input *DeleteMessageInput) (req *request.Request, output *DeleteMessageOutput)
DeleteMessageRequest generates a "volcengine/request.Request" representing the client's request for the DeleteMessage operation. The "output" return value will be populated with the DeleteMessageCommon request's response once the request completes successfully.
Use "Send" method on the returned DeleteMessageCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteMessageCommon Send returns without error.
See DeleteMessage for more information on using the DeleteMessage API call, and error handling.
// Example sending a request using the DeleteMessageRequest method.
req, resp := client.DeleteMessageRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) DeleteMessageWithContext ¶
func (c *SQS) DeleteMessageWithContext(ctx volcengine.Context, input *DeleteMessageInput, opts ...request.Option) (*DeleteMessageOutput, error)
DeleteMessageWithContext is the same as DeleteMessage with the addition of the ability to pass a context and additional request options.
See DeleteMessage for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) DeleteQueue ¶
func (c *SQS) DeleteQueue(input *DeleteQueueInput) (*DeleteQueueOutput, error)
DeleteQueue API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation DeleteQueue for usage and error information.
func (*SQS) DeleteQueueCommon ¶
DeleteQueueCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation DeleteQueueCommon for usage and error information.
func (*SQS) DeleteQueueCommonRequest ¶
func (c *SQS) DeleteQueueCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
DeleteQueueCommonRequest generates a "volcengine/request.Request" representing the client's request for the DeleteQueueCommon operation. The "output" return value will be populated with the DeleteQueueCommon request's response once the request completes successfully.
Use "Send" method on the returned DeleteQueueCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteQueueCommon Send returns without error.
See DeleteQueueCommon for more information on using the DeleteQueueCommon API call, and error handling.
// Example sending a request using the DeleteQueueCommonRequest method.
req, resp := client.DeleteQueueCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) DeleteQueueCommonWithContext ¶
func (c *SQS) DeleteQueueCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
DeleteQueueCommonWithContext is the same as DeleteQueueCommon with the addition of the ability to pass a context and additional request options.
See DeleteQueueCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) DeleteQueueRequest ¶
func (c *SQS) DeleteQueueRequest(input *DeleteQueueInput) (req *request.Request, output *DeleteQueueOutput)
DeleteQueueRequest generates a "volcengine/request.Request" representing the client's request for the DeleteQueue operation. The "output" return value will be populated with the DeleteQueueCommon request's response once the request completes successfully.
Use "Send" method on the returned DeleteQueueCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteQueueCommon Send returns without error.
See DeleteQueue for more information on using the DeleteQueue API call, and error handling.
// Example sending a request using the DeleteQueueRequest method.
req, resp := client.DeleteQueueRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) DeleteQueueWithContext ¶
func (c *SQS) DeleteQueueWithContext(ctx volcengine.Context, input *DeleteQueueInput, opts ...request.Option) (*DeleteQueueOutput, error)
DeleteQueueWithContext is the same as DeleteQueue with the addition of the ability to pass a context and additional request options.
See DeleteQueue for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) GetQueueAttributes ¶
func (c *SQS) GetQueueAttributes(input *GetQueueAttributesInput) (*GetQueueAttributesOutput, error)
GetQueueAttributes API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation GetQueueAttributes for usage and error information.
func (*SQS) GetQueueAttributesCommon ¶
func (c *SQS) GetQueueAttributesCommon(input *map[string]interface{}) (*map[string]interface{}, error)
GetQueueAttributesCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation GetQueueAttributesCommon for usage and error information.
func (*SQS) GetQueueAttributesCommonRequest ¶
func (c *SQS) GetQueueAttributesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
GetQueueAttributesCommonRequest generates a "volcengine/request.Request" representing the client's request for the GetQueueAttributesCommon operation. The "output" return value will be populated with the GetQueueAttributesCommon request's response once the request completes successfully.
Use "Send" method on the returned GetQueueAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after GetQueueAttributesCommon Send returns without error.
See GetQueueAttributesCommon for more information on using the GetQueueAttributesCommon API call, and error handling.
// Example sending a request using the GetQueueAttributesCommonRequest method.
req, resp := client.GetQueueAttributesCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) GetQueueAttributesCommonWithContext ¶
func (c *SQS) GetQueueAttributesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
GetQueueAttributesCommonWithContext is the same as GetQueueAttributesCommon with the addition of the ability to pass a context and additional request options.
See GetQueueAttributesCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) GetQueueAttributesRequest ¶
func (c *SQS) GetQueueAttributesRequest(input *GetQueueAttributesInput) (req *request.Request, output *GetQueueAttributesOutput)
GetQueueAttributesRequest generates a "volcengine/request.Request" representing the client's request for the GetQueueAttributes operation. The "output" return value will be populated with the GetQueueAttributesCommon request's response once the request completes successfully.
Use "Send" method on the returned GetQueueAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after GetQueueAttributesCommon Send returns without error.
See GetQueueAttributes for more information on using the GetQueueAttributes API call, and error handling.
// Example sending a request using the GetQueueAttributesRequest method.
req, resp := client.GetQueueAttributesRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) GetQueueAttributesWithContext ¶
func (c *SQS) GetQueueAttributesWithContext(ctx volcengine.Context, input *GetQueueAttributesInput, opts ...request.Option) (*GetQueueAttributesOutput, error)
GetQueueAttributesWithContext is the same as GetQueueAttributes with the addition of the ability to pass a context and additional request options.
See GetQueueAttributes for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) ListQueues ¶
func (c *SQS) ListQueues(input *ListQueuesInput) (*ListQueuesOutput, error)
ListQueues API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation ListQueues for usage and error information.
func (*SQS) ListQueuesCommon ¶
ListQueuesCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation ListQueuesCommon for usage and error information.
func (*SQS) ListQueuesCommonRequest ¶
func (c *SQS) ListQueuesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
ListQueuesCommonRequest generates a "volcengine/request.Request" representing the client's request for the ListQueuesCommon operation. The "output" return value will be populated with the ListQueuesCommon request's response once the request completes successfully.
Use "Send" method on the returned ListQueuesCommon Request to send the API call to the service. the "output" return value is not valid until after ListQueuesCommon Send returns without error.
See ListQueuesCommon for more information on using the ListQueuesCommon API call, and error handling.
// Example sending a request using the ListQueuesCommonRequest method.
req, resp := client.ListQueuesCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) ListQueuesCommonWithContext ¶
func (c *SQS) ListQueuesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
ListQueuesCommonWithContext is the same as ListQueuesCommon with the addition of the ability to pass a context and additional request options.
See ListQueuesCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) ListQueuesRequest ¶
func (c *SQS) ListQueuesRequest(input *ListQueuesInput) (req *request.Request, output *ListQueuesOutput)
ListQueuesRequest generates a "volcengine/request.Request" representing the client's request for the ListQueues operation. The "output" return value will be populated with the ListQueuesCommon request's response once the request completes successfully.
Use "Send" method on the returned ListQueuesCommon Request to send the API call to the service. the "output" return value is not valid until after ListQueuesCommon Send returns without error.
See ListQueues for more information on using the ListQueues API call, and error handling.
// Example sending a request using the ListQueuesRequest method.
req, resp := client.ListQueuesRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) ListQueuesWithContext ¶
func (c *SQS) ListQueuesWithContext(ctx volcengine.Context, input *ListQueuesInput, opts ...request.Option) (*ListQueuesOutput, error)
ListQueuesWithContext is the same as ListQueues with the addition of the ability to pass a context and additional request options.
See ListQueues for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) ReceiveMessage ¶
func (c *SQS) ReceiveMessage(input *ReceiveMessageInput) (*ReceiveMessageOutput, error)
ReceiveMessage API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation ReceiveMessage for usage and error information.
func (*SQS) ReceiveMessageCommon ¶
ReceiveMessageCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation ReceiveMessageCommon for usage and error information.
func (*SQS) ReceiveMessageCommonRequest ¶
func (c *SQS) ReceiveMessageCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
ReceiveMessageCommonRequest generates a "volcengine/request.Request" representing the client's request for the ReceiveMessageCommon operation. The "output" return value will be populated with the ReceiveMessageCommon request's response once the request completes successfully.
Use "Send" method on the returned ReceiveMessageCommon Request to send the API call to the service. the "output" return value is not valid until after ReceiveMessageCommon Send returns without error.
See ReceiveMessageCommon for more information on using the ReceiveMessageCommon API call, and error handling.
// Example sending a request using the ReceiveMessageCommonRequest method.
req, resp := client.ReceiveMessageCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) ReceiveMessageCommonWithContext ¶
func (c *SQS) ReceiveMessageCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
ReceiveMessageCommonWithContext is the same as ReceiveMessageCommon with the addition of the ability to pass a context and additional request options.
See ReceiveMessageCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) ReceiveMessageRequest ¶
func (c *SQS) ReceiveMessageRequest(input *ReceiveMessageInput) (req *request.Request, output *ReceiveMessageOutput)
ReceiveMessageRequest generates a "volcengine/request.Request" representing the client's request for the ReceiveMessage operation. The "output" return value will be populated with the ReceiveMessageCommon request's response once the request completes successfully.
Use "Send" method on the returned ReceiveMessageCommon Request to send the API call to the service. the "output" return value is not valid until after ReceiveMessageCommon Send returns without error.
See ReceiveMessage for more information on using the ReceiveMessage API call, and error handling.
// Example sending a request using the ReceiveMessageRequest method.
req, resp := client.ReceiveMessageRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) ReceiveMessageWithContext ¶
func (c *SQS) ReceiveMessageWithContext(ctx volcengine.Context, input *ReceiveMessageInput, opts ...request.Option) (*ReceiveMessageOutput, error)
ReceiveMessageWithContext is the same as ReceiveMessage with the addition of the ability to pass a context and additional request options.
See ReceiveMessage for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) SendMessage ¶
func (c *SQS) SendMessage(input *SendMessageInput) (*SendMessageOutput, error)
SendMessage API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation SendMessage for usage and error information.
func (*SQS) SendMessageCommon ¶
SendMessageCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation SendMessageCommon for usage and error information.
func (*SQS) SendMessageCommonRequest ¶
func (c *SQS) SendMessageCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
SendMessageCommonRequest generates a "volcengine/request.Request" representing the client's request for the SendMessageCommon operation. The "output" return value will be populated with the SendMessageCommon request's response once the request completes successfully.
Use "Send" method on the returned SendMessageCommon Request to send the API call to the service. the "output" return value is not valid until after SendMessageCommon Send returns without error.
See SendMessageCommon for more information on using the SendMessageCommon API call, and error handling.
// Example sending a request using the SendMessageCommonRequest method.
req, resp := client.SendMessageCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) SendMessageCommonWithContext ¶
func (c *SQS) SendMessageCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
SendMessageCommonWithContext is the same as SendMessageCommon with the addition of the ability to pass a context and additional request options.
See SendMessageCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) SendMessageRequest ¶
func (c *SQS) SendMessageRequest(input *SendMessageInput) (req *request.Request, output *SendMessageOutput)
SendMessageRequest generates a "volcengine/request.Request" representing the client's request for the SendMessage operation. The "output" return value will be populated with the SendMessageCommon request's response once the request completes successfully.
Use "Send" method on the returned SendMessageCommon Request to send the API call to the service. the "output" return value is not valid until after SendMessageCommon Send returns without error.
See SendMessage for more information on using the SendMessage API call, and error handling.
// Example sending a request using the SendMessageRequest method.
req, resp := client.SendMessageRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) SendMessageWithContext ¶
func (c *SQS) SendMessageWithContext(ctx volcengine.Context, input *SendMessageInput, opts ...request.Option) (*SendMessageOutput, error)
SendMessageWithContext is the same as SendMessage with the addition of the ability to pass a context and additional request options.
See SendMessage for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) SetQueueAttributes ¶
func (c *SQS) SetQueueAttributes(input *SetQueueAttributesInput) (*SetQueueAttributesOutput, error)
SetQueueAttributes API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation SetQueueAttributes for usage and error information.
func (*SQS) SetQueueAttributesCommon ¶
func (c *SQS) SetQueueAttributesCommon(input *map[string]interface{}) (*map[string]interface{}, error)
SetQueueAttributesCommon API operation for SQS.
Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.
See the VOLCENGINE API reference guide for SQS's API operation SetQueueAttributesCommon for usage and error information.
func (*SQS) SetQueueAttributesCommonRequest ¶
func (c *SQS) SetQueueAttributesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})
SetQueueAttributesCommonRequest generates a "volcengine/request.Request" representing the client's request for the SetQueueAttributesCommon operation. The "output" return value will be populated with the SetQueueAttributesCommon request's response once the request completes successfully.
Use "Send" method on the returned SetQueueAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after SetQueueAttributesCommon Send returns without error.
See SetQueueAttributesCommon for more information on using the SetQueueAttributesCommon API call, and error handling.
// Example sending a request using the SetQueueAttributesCommonRequest method.
req, resp := client.SetQueueAttributesCommonRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) SetQueueAttributesCommonWithContext ¶
func (c *SQS) SetQueueAttributesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)
SetQueueAttributesCommonWithContext is the same as SetQueueAttributesCommon with the addition of the ability to pass a context and additional request options.
See SetQueueAttributesCommon for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*SQS) SetQueueAttributesRequest ¶
func (c *SQS) SetQueueAttributesRequest(input *SetQueueAttributesInput) (req *request.Request, output *SetQueueAttributesOutput)
SetQueueAttributesRequest generates a "volcengine/request.Request" representing the client's request for the SetQueueAttributes operation. The "output" return value will be populated with the SetQueueAttributesCommon request's response once the request completes successfully.
Use "Send" method on the returned SetQueueAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after SetQueueAttributesCommon Send returns without error.
See SetQueueAttributes for more information on using the SetQueueAttributes API call, and error handling.
// Example sending a request using the SetQueueAttributesRequest method.
req, resp := client.SetQueueAttributesRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
func (*SQS) SetQueueAttributesWithContext ¶
func (c *SQS) SetQueueAttributesWithContext(ctx volcengine.Context, input *SetQueueAttributesInput, opts ...request.Option) (*SetQueueAttributesOutput, error)
SetQueueAttributesWithContext is the same as SetQueueAttributes with the addition of the ability to pass a context and additional request options.
See SetQueueAttributes for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
type SQSAPI ¶
type SQSAPI interface {
CreateQueueCommon(*map[string]interface{}) (*map[string]interface{}, error)
CreateQueueCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
CreateQueueCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
CreateQueue(*CreateQueueInput) (*CreateQueueOutput, error)
CreateQueueWithContext(volcengine.Context, *CreateQueueInput, ...request.Option) (*CreateQueueOutput, error)
CreateQueueRequest(*CreateQueueInput) (*request.Request, *CreateQueueOutput)
DeleteMessageCommon(*map[string]interface{}) (*map[string]interface{}, error)
DeleteMessageCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
DeleteMessageCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
DeleteMessage(*DeleteMessageInput) (*DeleteMessageOutput, error)
DeleteMessageWithContext(volcengine.Context, *DeleteMessageInput, ...request.Option) (*DeleteMessageOutput, error)
DeleteMessageRequest(*DeleteMessageInput) (*request.Request, *DeleteMessageOutput)
DeleteQueueCommon(*map[string]interface{}) (*map[string]interface{}, error)
DeleteQueueCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
DeleteQueueCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
DeleteQueue(*DeleteQueueInput) (*DeleteQueueOutput, error)
DeleteQueueWithContext(volcengine.Context, *DeleteQueueInput, ...request.Option) (*DeleteQueueOutput, error)
DeleteQueueRequest(*DeleteQueueInput) (*request.Request, *DeleteQueueOutput)
GetQueueAttributesCommon(*map[string]interface{}) (*map[string]interface{}, error)
GetQueueAttributesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
GetQueueAttributesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
GetQueueAttributes(*GetQueueAttributesInput) (*GetQueueAttributesOutput, error)
GetQueueAttributesWithContext(volcengine.Context, *GetQueueAttributesInput, ...request.Option) (*GetQueueAttributesOutput, error)
GetQueueAttributesRequest(*GetQueueAttributesInput) (*request.Request, *GetQueueAttributesOutput)
ListQueuesCommon(*map[string]interface{}) (*map[string]interface{}, error)
ListQueuesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
ListQueuesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
ListQueues(*ListQueuesInput) (*ListQueuesOutput, error)
ListQueuesWithContext(volcengine.Context, *ListQueuesInput, ...request.Option) (*ListQueuesOutput, error)
ListQueuesRequest(*ListQueuesInput) (*request.Request, *ListQueuesOutput)
ReceiveMessageCommon(*map[string]interface{}) (*map[string]interface{}, error)
ReceiveMessageCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
ReceiveMessageCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
ReceiveMessage(*ReceiveMessageInput) (*ReceiveMessageOutput, error)
ReceiveMessageWithContext(volcengine.Context, *ReceiveMessageInput, ...request.Option) (*ReceiveMessageOutput, error)
ReceiveMessageRequest(*ReceiveMessageInput) (*request.Request, *ReceiveMessageOutput)
SendMessageCommon(*map[string]interface{}) (*map[string]interface{}, error)
SendMessageCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
SendMessageCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
SendMessage(*SendMessageInput) (*SendMessageOutput, error)
SendMessageWithContext(volcengine.Context, *SendMessageInput, ...request.Option) (*SendMessageOutput, error)
SendMessageRequest(*SendMessageInput) (*request.Request, *SendMessageOutput)
SetQueueAttributesCommon(*map[string]interface{}) (*map[string]interface{}, error)
SetQueueAttributesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
SetQueueAttributesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})
SetQueueAttributes(*SetQueueAttributesInput) (*SetQueueAttributesOutput, error)
SetQueueAttributesWithContext(volcengine.Context, *SetQueueAttributesInput, ...request.Option) (*SetQueueAttributesOutput, error)
SetQueueAttributesRequest(*SetQueueAttributesInput) (*request.Request, *SetQueueAttributesOutput)
}
SQSAPI provides an interface to enable mocking the sqs.SQS service client's API operation,
// volcengine sdk func uses an SDK service client to make a request to
// SQS.
func myFunc(svc SQSAPI) bool {
// Make svc.CreateQueue request
}
func main() {
sess := session.New()
svc := sqs.New(sess)
myFunc(svc)
}
type SendMessageInput ¶
type SendMessageInput struct {
// MessageBody is a required field
MessageBody *string `min:"1" max:"262144" type:"string" json:",omitempty" required:"true"`
// QueueTrn is a required field
QueueTrn *string `type:"string" json:",omitempty" required:"true"`
// contains filtered or unexported fields
}
func (SendMessageInput) GoString ¶
func (s SendMessageInput) GoString() string
GoString returns the string representation
func (*SendMessageInput) SetMessageBody ¶
func (s *SendMessageInput) SetMessageBody(v string) *SendMessageInput
SetMessageBody sets the MessageBody field's value.
func (*SendMessageInput) SetQueueTrn ¶
func (s *SendMessageInput) SetQueueTrn(v string) *SendMessageInput
SetQueueTrn sets the QueueTrn field's value.
func (SendMessageInput) String ¶
func (s SendMessageInput) String() string
String returns the string representation
func (*SendMessageInput) Validate ¶
func (s *SendMessageInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type SendMessageOutput ¶
type SendMessageOutput struct {
Metadata *response.ResponseMetadata
MessageId *string `type:"string" json:",omitempty"`
// contains filtered or unexported fields
}
func (SendMessageOutput) GoString ¶
func (s SendMessageOutput) GoString() string
GoString returns the string representation
func (*SendMessageOutput) SetMessageId ¶
func (s *SendMessageOutput) SetMessageId(v string) *SendMessageOutput
SetMessageId sets the MessageId field's value.
func (SendMessageOutput) String ¶
func (s SendMessageOutput) String() string
String returns the string representation
type SetQueueAttributesInput ¶
type SetQueueAttributesInput struct {
MessageRetentionPeriod *int32 `min:"60" max:"604800" type:"int32" json:",omitempty"`
// QueueTrn is a required field
QueueTrn *string `type:"string" json:",omitempty" required:"true"`
VisibilityTimeout *int32 `max:"600" type:"int32" json:",omitempty"`
// contains filtered or unexported fields
}
func (SetQueueAttributesInput) GoString ¶
func (s SetQueueAttributesInput) GoString() string
GoString returns the string representation
func (*SetQueueAttributesInput) SetMessageRetentionPeriod ¶
func (s *SetQueueAttributesInput) SetMessageRetentionPeriod(v int32) *SetQueueAttributesInput
SetMessageRetentionPeriod sets the MessageRetentionPeriod field's value.
func (*SetQueueAttributesInput) SetQueueTrn ¶
func (s *SetQueueAttributesInput) SetQueueTrn(v string) *SetQueueAttributesInput
SetQueueTrn sets the QueueTrn field's value.
func (*SetQueueAttributesInput) SetVisibilityTimeout ¶
func (s *SetQueueAttributesInput) SetVisibilityTimeout(v int32) *SetQueueAttributesInput
SetVisibilityTimeout sets the VisibilityTimeout field's value.
func (SetQueueAttributesInput) String ¶
func (s SetQueueAttributesInput) String() string
String returns the string representation
func (*SetQueueAttributesInput) Validate ¶
func (s *SetQueueAttributesInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type SetQueueAttributesOutput ¶
type SetQueueAttributesOutput struct {
Metadata *response.ResponseMetadata
// contains filtered or unexported fields
}
func (SetQueueAttributesOutput) GoString ¶
func (s SetQueueAttributesOutput) GoString() string
GoString returns the string representation
func (SetQueueAttributesOutput) String ¶
func (s SetQueueAttributesOutput) String() string
String returns the string representation