Versions in this module Expand all Collapse all v1 v1.1.3 Apr 24, 2024retracted v1.1.2 Jan 3, 2019retracted v1.1.1 Dec 29, 2018retracted v1.1.0 Dec 29, 2018retracted Changes in this version type Environment + LogMessages bool type ErrorResult + RequestId string v0 v0.4.8 Apr 24, 2024 v0.4.7 Apr 24, 2024 v0.4.6 Apr 10, 2024 Changes in this version type EnvQueue + VisibilityTimeout int v0.4.5 Nov 4, 2023 v0.4.4 Nov 4, 2023 v0.4.3 Sep 29, 2023 v0.4.2 Aug 3, 2023 Changes in this version type Message + DelaySecs int type Queue + DelaySecs int v0.4.1 Mar 2, 2023 v0.4.0 Mar 2, 2023 v0.3.2 Feb 28, 2023 Changes in this version + const ErrNoDefaultElementInJSON + var DeduplicationPeriod = 5 * time.Minute + var SnsErrors map[string]SnsErrorType + var SqsErrors map[string]SqsErrorType + var SyncQueues = struct{ ... } + var SyncTopics = struct{ ... } + func HasFIFOQueueName(queueName string) bool + type Attribute struct + Name string + Value string + type BatchResultErrorEntry struct + Code string + Id string + Message string + SenderFault bool + type ChangeMessageVisibilityResult struct + Metadata ResponseMetadata + Xmlns string + type ConfirmSubscriptionResponse struct + Metadata ResponseMetadata + Result SubscribeResult + Xmlns string + type CreateQueueResponse struct + Metadata ResponseMetadata + Result CreateQueueResult + Xmlns string + type CreateQueueResult struct + QueueUrl string + type CreateTopicResponse struct + Metadata ResponseMetadata + Result CreateTopicResult + Xmlns string + type CreateTopicResult struct + TopicArn string + type DeleteMessageBatchResponse struct + Metadata ResponseMetadata + Result DeleteMessageBatchResult + Xmlns string + type DeleteMessageBatchResult struct + Entry []DeleteMessageBatchResultEntry + Error []BatchResultErrorEntry + type DeleteMessageBatchResultEntry struct + Id string + type DeleteMessageResponse struct + Metadata ResponseMetadata + Xmlns string + type DeleteQueueResponse struct + Metadata ResponseMetadata + Xmlns string + type DeleteTopicResponse struct + Metadata ResponseMetadata + Xmlns string + type EnvQueue struct + MaximumMessageSize int + Name string + ReceiveMessageWaitTimeSeconds int + RedrivePolicy string + type EnvQueueAttributes struct + MaximumMessageSize int + ReceiveMessageWaitTimeSeconds int + VisibilityTimeout int + type EnvSubsciption struct + EndPoint string + FilterPolicy string + Protocol string + QueueName string + Raw bool + TopicArn string + type EnvTopic struct + Name string + Subscriptions []EnvSubsciption + type Environment struct + AccountID string + EnableDuplicates bool + Host string + LogFile string + LogToFile bool + Port string + QueueAttributeDefaults EnvQueueAttributes + Queues []EnvQueue + RandomLatency RandomLatency + Region string + SnsPort string + SqsPort string + Topics []EnvTopic + var CurrentEnvironment Environment + type ErrorResponse struct + RequestId string + Result ErrorResult + type ErrorResult struct + Code string + Message string + Type string + type FilterPolicy map[string][]string + func (fp *FilterPolicy) IsSatisfiedBy(msgAttrs map[string]MessageAttributeValue) bool + type GetQueueAttributesResponse struct + Metadata ResponseMetadata + Result GetQueueAttributesResult + Xmlns string + type GetQueueAttributesResult struct + Attrs []Attribute + type GetQueueUrlResponse struct + Metadata ResponseMetadata + Result GetQueueUrlResult + Xmlns string + type GetQueueUrlResult struct + QueueUrl string + type GetSubscriptionAttributesResponse struct + Metadata ResponseMetadata + Result GetSubscriptionAttributesResult + Xmlns string + type GetSubscriptionAttributesResult struct + SubscriptionAttributes SubscriptionAttributes + type ListQueuesResponse struct + Metadata ResponseMetadata + Result ListQueuesResult + Xmlns string + type ListQueuesResult struct + QueueUrl []string + type ListSubscriptionsByTopicResponse struct + Metadata ResponseMetadata + Result ListSubscriptionsResult + Xmlns string + type ListSubscriptionsByTopicResult struct + Subscriptions TopicSubscriptions + type ListSubscriptionsResponse struct + Metadata ResponseMetadata + Result ListSubscriptionsResult + Xmlns string + type ListSubscriptionsResult struct + Subscriptions TopicSubscriptions + type ListTopicsResponse struct + Metadata ResponseMetadata + Result ListTopicsResult + Xmlns string + type ListTopicsResult struct + Topics TopicNamestype + type Message struct + DeduplicationID string + GroupID string + MD5OfMessageAttributes string + MD5OfMessageBody string + MessageAttributes map[string]MessageAttributeValue + MessageBody []byte + NumberOfReceives int + ReceiptHandle string + ReceiptTime time.Time + Retry int + SentTime time.Time + Uuid string + VisibilityTimeout time.Time + func (m *Message) IsReadyForReceipt() bool + type MessageAttributeValue struct + DataType string + Name string + Value string + ValueKey string + type MessageStructure string + const MessageStructureJSON + type MsgAttr struct + Type string + Value string + type Protocol string + const ProtocolDefault + const ProtocolHTTP + const ProtocolHTTPS + const ProtocolSQS + type PublishResponse struct + Metadata ResponseMetadata + Result PublishResult + Xmlns string + type PublishResult struct + MessageId string + type PurgeQueueResponse struct + Metadata ResponseMetadata + Xmlns string + type Queue struct + Arn string + DeadLetterQueue *Queue + Duplicates map[string]time.Time + EnableDuplicates bool + FIFOMessages map[string]int + FIFOSequenceNumbers map[string]int + IsFIFO bool + MaxReceiveCount int + MaximumMessageSize int + Messages []Message + Name string + ReceiveWaitTimeSecs int + TimeoutSecs int + URL string + func (q *Queue) InitDuplicatation(deduplicationId string) + func (q *Queue) IsDuplicate(deduplicationId string) bool + func (q *Queue) IsLocked(groupId string) bool + func (q *Queue) LockGroup(groupId string) + func (q *Queue) NextSequenceNumber(groupId string) string + func (q *Queue) UnlockGroup(groupId string) + type RandomLatency struct + Max int + Min int + type ReceiveMessageResponse struct + Metadata ResponseMetadata + Result ReceiveMessageResult + Xmlns string + type ReceiveMessageResult struct + Message []*ResultMessage + type ResponseMetadata struct + RequestId string + type ResultAttribute struct + Name string + Value string + type ResultMessage struct + Attributes []*ResultAttribute + Body []byte + MD5OfBody string + MD5OfMessageAttributes string + MessageAttributes []*ResultMessageAttribute + MessageId string + ReceiptHandle string + type ResultMessageAttribute struct + Name string + Value *ResultMessageAttributeValue + type ResultMessageAttributeValue struct + BinaryValue string + DataType string + StringValue string + type SNSMessage struct + Message string + MessageAttributes map[string]MsgAttr + MessageId string + Signature string + SignatureVersion string + SigningCertURL string + Subject string + SubscribeURL string + Timestamp string + Token string + TopicArn string + Type string + UnsubscribeURL string + type SendMessageBatchResponse struct + Metadata ResponseMetadata + Result SendMessageBatchResult + Xmlns string + type SendMessageBatchResult struct + Entry []SendMessageBatchResultEntry + Error []BatchResultErrorEntry + type SendMessageBatchResultEntry struct + Id string + MD5OfMessageAttributes string + MD5OfMessageBody string + MessageId string + SequenceNumber string + type SendMessageResponse struct + Metadata ResponseMetadata + Result SendMessageResult + Xmlns string + type SendMessageResult struct + MD5OfMessageAttributes string + MD5OfMessageBody string + MessageId string + SequenceNumber string + type SetQueueAttributesResponse struct + Metadata ResponseMetadata + Xmlns string + type SetSubscriptionAttributesResponse struct + Metadata ResponseMetadata + Xmlns string + type SnsErrorType struct + Code string + HttpError int + Message string + Type string + type SqsErrorType struct + Code string + HttpError int + Message string + Type string + func (s *SqsErrorType) Error() string + type SubscribeResponse struct + Metadata ResponseMetadata + Result SubscribeResult + Xmlns string + type SubscribeResult struct + SubscriptionArn string + type Subscription struct + EndPoint string + FilterPolicy *FilterPolicy + Protocol string + Raw bool + SubscriptionArn string + TopicArn string + type SubscriptionAttributeEntry struct + Key string + Value string + type SubscriptionAttributes struct + Entries []SubscriptionAttributeEntry + type Topic struct + Arn string + Name string + Subscriptions []*Subscription + type TopicArnResult struct + TopicArn string + type TopicMemberResult struct + Endpoint string + Owner string + Protocol string + SubscriptionArn string + TopicArn string + type TopicNamestype struct + Member []TopicArnResult + type TopicSubscriptions struct + Member []TopicMemberResult + type UnsubscribeResponse struct + Metadata ResponseMetadata + Xmlns string
Go to main page