Versions in this module Expand all Collapse all v1 v1.5.0-1 Jun 24, 2023 v1.2.1 Mar 20, 2023 Changes in this version + func List(client *gophercloud.ServiceClient, opts ListOptsBuilder) pagination.Pager + type BatchUpdateOpts []UpdateOpts + func (opts BatchUpdateOpts) ToQueueUpdateMap() ([]map[string]interface{}, error) + type CreateOpts struct + DeadLetterQueue string + DeadLetterQueueMessagesTTL int + DefaultMessageDelay int + DefaultMessageTTL int + EnableEncryptMessages *bool + Extra map[string]interface{} + Flavor string + MaxClaimCount int + MaxMessagesPostSize int + QueueName string + func (opts CreateOpts) ToQueueCreateMap() (map[string]interface{}, error) + type CreateOptsBuilder interface + ToQueueCreateMap func() (map[string]interface{}, error) + type CreateResult struct + func Create(client *gophercloud.ServiceClient, opts CreateOptsBuilder) (r CreateResult) + type DeleteResult struct + func Delete(client *gophercloud.ServiceClient, queueName string) (r DeleteResult) + type GetResult struct + func Get(client *gophercloud.ServiceClient, queueName string) (r GetResult) + func (r GetResult) Extract() (QueueDetails, error) + type ListOpts struct + Detailed bool + Limit int + Marker string + Name bool + WithCount bool + func (opts ListOpts) ToQueueListQuery() (string, error) + type ListOptsBuilder interface + ToQueueListQuery func() (string, error) + type PurgeOpts struct + ResourceTypes []PurgeResource + func (opts PurgeOpts) ToQueuePurgeMap() (map[string]interface{}, error) + type PurgeOptsBuilder interface + ToQueuePurgeMap func() (map[string]interface{}, error) + type PurgeResource string + const ResourceMessages + const ResourceSubscriptions + type PurgeResult struct + func Purge(client *gophercloud.ServiceClient, queueName string, opts PurgeOptsBuilder) (r PurgeResult) + type Queue struct + Href string + Metadata QueueDetails + Methods []string + Name string + Paths []string + ResourceTypes []string + func ExtractQueues(r pagination.Page) ([]Queue, error) + type QueueDetails struct + DeadLetterQueue string + DeadLetterQueueMessageTTL int + DefaultMessageDelay int + DefaultMessageTTL int + EnableEncryptMessages bool + Extra map[string]interface{} + Flavor string + MaxClaimCount int + MaxMessagesPostSize int + func (r *QueueDetails) UnmarshalJSON(b []byte) error + type QueuePage struct + func (r QueuePage) GetCount() (int, error) + func (r QueuePage) IsEmpty() (bool, error) + func (r QueuePage) NextPageURL() (string, error) + type QueueShare struct + Expires string + Methods []string + Paths []string + Project string + Signature string + type ShareMethod string + const MethodGet + const MethodPatch + const MethodPost + const MethodPut + type ShareOpts struct + Expires string + Methods []ShareMethod + Paths []SharePath + func (opts ShareOpts) ToQueueShareMap() (map[string]interface{}, error) + type ShareOptsBuilder interface + ToQueueShareMap func() (map[string]interface{}, error) + type SharePath string + const PathClaims + const PathMessages + const PathSubscriptions + type ShareResult struct + func Share(client *gophercloud.ServiceClient, queueName string, opts ShareOptsBuilder) (r ShareResult) + func (r ShareResult) Extract() (QueueShare, error) + type StatResult struct + func GetStats(client *gophercloud.ServiceClient, queueName string) (r StatResult) + func (r StatResult) Extract() (Stats, error) + type Stats struct + Claimed int + Free int + Total int + type UpdateOp string + const AddOp + const RemoveOp + const ReplaceOp + type UpdateOpts struct + Op UpdateOp + Path string + Value interface{} + func (opts UpdateOpts) ToMap() (map[string]interface{}, error) + type UpdateOptsBuilder interface + ToQueueUpdateMap func() ([]map[string]interface{}, error) + type UpdateResult struct + func Update(client *gophercloud.ServiceClient, queueName string, opts UpdateOptsBuilder) (r UpdateResult) + func (r UpdateResult) Extract() (QueueDetails, error)
Go to main page