Versions in this module Expand all Collapse all v1 v1.0.0 Dec 28, 2021 Changes in this version + func DeleteMessageURL(client *gophercloud.ServiceClient, queueName string, messageID string) string + func List(client *gophercloud.ServiceClient, queueName string, opts ListOptsBuilder) pagination.Pager + type BatchCreateOpts []CreateOpts + func (opts BatchCreateOpts) ToMessageCreateMap() (map[string]interface{}, error) + type CreateOpts struct + Body map[string]interface{} + Delay int + TTL int + func (opts CreateOpts) ToMap() (map[string]interface{}, error) + type CreateOptsBuilder interface + ToMessageCreateMap func() (map[string]interface{}, error) + type CreateResult struct + func Create(client *gophercloud.ServiceClient, queueName string, opts CreateOptsBuilder) (r CreateResult) + func (r CreateResult) Extract() (ResourceList, error) + type DeleteMessagesOpts struct + IDs []string + func (opts DeleteMessagesOpts) ToMessagesDeleteQuery() (string, error) + type DeleteMessagesOptsBuilder interface + ToMessagesDeleteQuery func() (string, error) + type DeleteOpts struct + ClaimID string + func (opts DeleteOpts) ToMessageDeleteQuery() (string, error) + type DeleteOptsBuilder interface + ToMessageDeleteQuery func() (string, error) + type DeleteResult struct + func Delete(client *gophercloud.ServiceClient, queueName string, messageID string, ...) (r DeleteResult) + func DeleteMessages(client *gophercloud.ServiceClient, queueName string, ...) (r DeleteResult) + type GetMessagesOpts struct + IDs []string + func (opts GetMessagesOpts) ToGetMessagesListQuery() (string, error) + type GetMessagesOptsBuilder interface + ToGetMessagesListQuery func() (string, error) + type GetMessagesResult struct + func GetMessages(client *gophercloud.ServiceClient, queueName string, ...) (r GetMessagesResult) + func (r GetMessagesResult) Extract() ([]Message, error) + type GetResult struct + func Get(client *gophercloud.ServiceClient, queueName string, messageID string) (r GetResult) + func (r GetResult) Extract() (Message, error) + type ListOpts struct + Echo bool + IncludeClaimed bool + IncludeDelayed bool + Limit int + Marker string + func (opts ListOpts) ToMessageListQuery() (string, error) + type ListOptsBuilder interface + ToMessageListQuery func() (string, error) + type Message struct + Age int + Body map[string]interface{} + Checksum string + Href string + ID string + TTL int + func ExtractMessages(r pagination.Page) ([]Message, error) + type MessagePage struct + func (r MessagePage) IsEmpty() (bool, error) + func (r MessagePage) NextPageURL() (string, error) + type PopMessage struct + Age int + Body map[string]interface{} + ClaimCount int + ClaimID string + ID string + TTL int + type PopMessagesOpts struct + Pop int + func (opts PopMessagesOpts) ToMessagesPopQuery() (string, error) + type PopMessagesOptsBuilder interface + ToMessagesPopQuery func() (string, error) + type PopResult struct + func PopMessages(client *gophercloud.ServiceClient, queueName string, ...) (r PopResult) + func (r PopResult) Extract() ([]PopMessage, error) + type ResourceList struct + Resources []string Other modules containing this package github.com/pierreprinetti/gophercloud/v2 github.com/pierreprinetti/gophercloud/v3
Go to main page