Versions in this module Expand all Collapse all v0 v0.28.0 Jan 6, 2022 v0.27.0 Jan 6, 2022 v0.26.0 Jan 6, 2022 v0.24.3 Jan 6, 2022 v0.24.2 Jan 6, 2022 v0.24.1 Jan 6, 2022 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
Go to main page