Module Awso_sqs_async.SqsSource

Sourceval add_permission : Awso.Cfg.t -> queue_url:string -> label:string -> aws_account_ids:string list -> actions:string list -> unit Async.Deferred.t
Sourceval change_message_visibility : Awso.Cfg.t -> queue_url:string -> receipt_handle:string -> visibility_timeout:int -> unit Async.Deferred.t
Sourceval change_message_visibility_batch : Awso.Cfg.t -> queue_url:string -> entries:Awso_sqs.Values.ChangeMessageVisibilityBatchRequestEntry.t list -> Awso_sqs.Values.ChangeMessageVisibilityBatchResult.t Async.Deferred.t
Sourceval create_queue : ?attributes:(Awso_sqs.Values.QueueAttributeName.t * string) list -> Awso.Cfg.t -> queue_name:string -> Awso_sqs.Values.CreateQueueResult.t Async.Deferred.t
Sourceval delete_message : Awso.Cfg.t -> queue_url:string -> receipt_handle:string -> unit Async.Deferred.t
Sourceval delete_message_batch : Awso.Cfg.t -> queue_url:string -> entries:Awso_sqs.Values.DeleteMessageBatchRequestEntry.t list -> Awso_sqs.Values.DeleteMessageBatchResult.t Async.Deferred.t
Sourceval delete_queue : Awso.Cfg.t -> queue_url:string -> unit Async.Deferred.t
Sourceval get_queue_attributes : ?attribute_names:Awso_sqs.Values.QueueAttributeName.t list -> Awso.Cfg.t -> queue_url:string -> Awso_sqs.Values.GetQueueAttributesResult.t Async.Deferred.t
Sourceval get_queue_url : ?queue_owner_aws_account_id:string -> Awso.Cfg.t -> queue_name:string -> Awso_sqs.Values.GetQueueUrlResult.t Async.Deferred.t
Sourceval list_dead_letter_source_queues : Awso.Cfg.t -> queue_url:string -> Awso_sqs.Values.ListDeadLetterSourceQueuesResult.t Async.Deferred.t
Sourceval list_queue_tags : Awso.Cfg.t -> queue_url:string -> Awso_sqs.Values.ListQueueTagsResult.t Async.Deferred.t
Sourceval list_queues : ?queue_name_prefix:string -> Awso.Cfg.t -> Awso_sqs.Values.ListQueuesResult.t Async.Deferred.t
Sourceval purge_queue : Awso.Cfg.t -> queue_url:string -> unit Async.Deferred.t
Sourceval receive_message : ?attribute_names:Awso_sqs.Values.QueueAttributeName.t list -> ?message_attribute_names:string list -> ?max_number_of_messages:int -> ?visibility_timeout:int -> ?wait_time_seconds:int -> ?receive_request_attempt_id:string -> Awso.Cfg.t -> queue_url:string -> Awso_sqs.Values.ReceiveMessageResult.t Async.Deferred.t
Sourceval remove_permission : Awso.Cfg.t -> queue_url:string -> label:string -> unit Async.Deferred.t
Sourceval send_message : ?delay_seconds:int -> ?message_attributes:(string * Awso_sqs.Values.MessageAttributeValue.t) list -> ?message_deduplication_id:string -> ?message_group_id:string -> Awso.Cfg.t -> queue_url:string -> message_body:string -> Awso_sqs.Values.SendMessageResult.t Async.Deferred.t
Sourceval send_message_batch : Awso.Cfg.t -> queue_url:string -> entries:Awso_sqs.Values.SendMessageBatchRequestEntry.t list -> Awso_sqs.Values.SendMessageBatchResult.t Async.Deferred.t
Sourceval set_queue_attributes : Awso.Cfg.t -> queue_url:string -> attributes:(Awso_sqs.Values.QueueAttributeName.t * string) list -> unit Async.Deferred.t
Sourceval tag_queue : Awso.Cfg.t -> queue_url:string -> tags:(string * string) list -> unit Async.Deferred.t
Sourceval untag_queue : Awso.Cfg.t -> queue_url:string -> tag_keys:string list -> unit Async.Deferred.t