...

Package queue

import "github.com/oracle/oci-go-sdk/queue"
Overview
Index

Overview ▾

Index ▾

func GetActionTypeEnumStringValues() []string
func GetListQueuesSortByEnumStringValues() []string
func GetListQueuesSortOrderEnumStringValues() []string
func GetOperationStatusEnumStringValues() []string
func GetOperationTypeEnumStringValues() []string
func GetPurgeQueueDetailsPurgeTypeEnumStringValues() []string
func GetQueueLifecycleStateEnumStringValues() []string
func GetSortOrderEnumStringValues() []string
type ActionTypeEnum
    func GetActionTypeEnumValues() []ActionTypeEnum
    func GetMappingActionTypeEnum(val string) (ActionTypeEnum, bool)
type ChangeQueueCompartmentDetails
    func (m ChangeQueueCompartmentDetails) String() string
    func (m ChangeQueueCompartmentDetails) ValidateEnumValue() (bool, error)
type ChangeQueueCompartmentRequest
    func (request ChangeQueueCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request ChangeQueueCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request ChangeQueueCompartmentRequest) RetryPolicy() *common.RetryPolicy
    func (request ChangeQueueCompartmentRequest) String() string
    func (request ChangeQueueCompartmentRequest) ValidateEnumValue() (bool, error)
type ChangeQueueCompartmentResponse
    func (response ChangeQueueCompartmentResponse) HTTPResponse() *http.Response
    func (response ChangeQueueCompartmentResponse) String() string
type ChannelCollection
    func (m ChannelCollection) String() string
    func (m ChannelCollection) ValidateEnumValue() (bool, error)
type CreateQueueDetails
    func (m CreateQueueDetails) String() string
    func (m CreateQueueDetails) ValidateEnumValue() (bool, error)
type CreateQueueRequest
    func (request CreateQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request CreateQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request CreateQueueRequest) RetryPolicy() *common.RetryPolicy
    func (request CreateQueueRequest) String() string
    func (request CreateQueueRequest) ValidateEnumValue() (bool, error)
type CreateQueueResponse
    func (response CreateQueueResponse) HTTPResponse() *http.Response
    func (response CreateQueueResponse) String() string
type DeleteMessageRequest
    func (request DeleteMessageRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request DeleteMessageRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request DeleteMessageRequest) RetryPolicy() *common.RetryPolicy
    func (request DeleteMessageRequest) String() string
    func (request DeleteMessageRequest) ValidateEnumValue() (bool, error)
type DeleteMessageResponse
    func (response DeleteMessageResponse) HTTPResponse() *http.Response
    func (response DeleteMessageResponse) String() string
type DeleteMessagesDetails
    func (m DeleteMessagesDetails) String() string
    func (m DeleteMessagesDetails) ValidateEnumValue() (bool, error)
type DeleteMessagesDetailsEntry
    func (m DeleteMessagesDetailsEntry) String() string
    func (m DeleteMessagesDetailsEntry) ValidateEnumValue() (bool, error)
type DeleteMessagesRequest
    func (request DeleteMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request DeleteMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request DeleteMessagesRequest) RetryPolicy() *common.RetryPolicy
    func (request DeleteMessagesRequest) String() string
    func (request DeleteMessagesRequest) ValidateEnumValue() (bool, error)
type DeleteMessagesResponse
    func (response DeleteMessagesResponse) HTTPResponse() *http.Response
    func (response DeleteMessagesResponse) String() string
type DeleteMessagesResult
    func (m DeleteMessagesResult) String() string
    func (m DeleteMessagesResult) ValidateEnumValue() (bool, error)
type DeleteMessagesResultEntry
    func (m DeleteMessagesResultEntry) String() string
    func (m DeleteMessagesResultEntry) ValidateEnumValue() (bool, error)
type DeleteQueueRequest
    func (request DeleteQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request DeleteQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request DeleteQueueRequest) RetryPolicy() *common.RetryPolicy
    func (request DeleteQueueRequest) String() string
    func (request DeleteQueueRequest) ValidateEnumValue() (bool, error)
type DeleteQueueResponse
    func (response DeleteQueueResponse) HTTPResponse() *http.Response
    func (response DeleteQueueResponse) String() string
type GetMessage
    func (m GetMessage) String() string
    func (m GetMessage) ValidateEnumValue() (bool, error)
type GetMessages
    func (m GetMessages) String() string
    func (m GetMessages) ValidateEnumValue() (bool, error)
type GetMessagesRequest
    func (request GetMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request GetMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request GetMessagesRequest) RetryPolicy() *common.RetryPolicy
    func (request GetMessagesRequest) String() string
    func (request GetMessagesRequest) ValidateEnumValue() (bool, error)
type GetMessagesResponse
    func (response GetMessagesResponse) HTTPResponse() *http.Response
    func (response GetMessagesResponse) String() string
type GetQueueRequest
    func (request GetQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request GetQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request GetQueueRequest) RetryPolicy() *common.RetryPolicy
    func (request GetQueueRequest) String() string
    func (request GetQueueRequest) ValidateEnumValue() (bool, error)
type GetQueueResponse
    func (response GetQueueResponse) HTTPResponse() *http.Response
    func (response GetQueueResponse) String() string
type GetStatsRequest
    func (request GetStatsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request GetStatsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request GetStatsRequest) RetryPolicy() *common.RetryPolicy
    func (request GetStatsRequest) String() string
    func (request GetStatsRequest) ValidateEnumValue() (bool, error)
type GetStatsResponse
    func (response GetStatsResponse) HTTPResponse() *http.Response
    func (response GetStatsResponse) String() string
type GetWorkRequestRequest
    func (request GetWorkRequestRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request GetWorkRequestRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request GetWorkRequestRequest) RetryPolicy() *common.RetryPolicy
    func (request GetWorkRequestRequest) String() string
    func (request GetWorkRequestRequest) ValidateEnumValue() (bool, error)
type GetWorkRequestResponse
    func (response GetWorkRequestResponse) HTTPResponse() *http.Response
    func (response GetWorkRequestResponse) String() string
type ListChannelsRequest
    func (request ListChannelsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request ListChannelsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request ListChannelsRequest) RetryPolicy() *common.RetryPolicy
    func (request ListChannelsRequest) String() string
    func (request ListChannelsRequest) ValidateEnumValue() (bool, error)
type ListChannelsResponse
    func (response ListChannelsResponse) HTTPResponse() *http.Response
    func (response ListChannelsResponse) String() string
type ListQueuesRequest
    func (request ListQueuesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request ListQueuesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request ListQueuesRequest) RetryPolicy() *common.RetryPolicy
    func (request ListQueuesRequest) String() string
    func (request ListQueuesRequest) ValidateEnumValue() (bool, error)
type ListQueuesResponse
    func (response ListQueuesResponse) HTTPResponse() *http.Response
    func (response ListQueuesResponse) String() string
type ListQueuesSortByEnum
    func GetListQueuesSortByEnumValues() []ListQueuesSortByEnum
    func GetMappingListQueuesSortByEnum(val string) (ListQueuesSortByEnum, bool)
type ListQueuesSortOrderEnum
    func GetListQueuesSortOrderEnumValues() []ListQueuesSortOrderEnum
    func GetMappingListQueuesSortOrderEnum(val string) (ListQueuesSortOrderEnum, bool)
type ListWorkRequestErrorsRequest
    func (request ListWorkRequestErrorsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request ListWorkRequestErrorsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request ListWorkRequestErrorsRequest) RetryPolicy() *common.RetryPolicy
    func (request ListWorkRequestErrorsRequest) String() string
    func (request ListWorkRequestErrorsRequest) ValidateEnumValue() (bool, error)
type ListWorkRequestErrorsResponse
    func (response ListWorkRequestErrorsResponse) HTTPResponse() *http.Response
    func (response ListWorkRequestErrorsResponse) String() string
type ListWorkRequestLogsRequest
    func (request ListWorkRequestLogsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request ListWorkRequestLogsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request ListWorkRequestLogsRequest) RetryPolicy() *common.RetryPolicy
    func (request ListWorkRequestLogsRequest) String() string
    func (request ListWorkRequestLogsRequest) ValidateEnumValue() (bool, error)
type ListWorkRequestLogsResponse
    func (response ListWorkRequestLogsResponse) HTTPResponse() *http.Response
    func (response ListWorkRequestLogsResponse) String() string
type ListWorkRequestsRequest
    func (request ListWorkRequestsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request ListWorkRequestsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request ListWorkRequestsRequest) RetryPolicy() *common.RetryPolicy
    func (request ListWorkRequestsRequest) String() string
    func (request ListWorkRequestsRequest) ValidateEnumValue() (bool, error)
type ListWorkRequestsResponse
    func (response ListWorkRequestsResponse) HTTPResponse() *http.Response
    func (response ListWorkRequestsResponse) String() string
type MessageMetadata
    func (m MessageMetadata) String() string
    func (m MessageMetadata) ValidateEnumValue() (bool, error)
type OperationStatusEnum
    func GetMappingOperationStatusEnum(val string) (OperationStatusEnum, bool)
    func GetOperationStatusEnumValues() []OperationStatusEnum
type OperationTypeEnum
    func GetMappingOperationTypeEnum(val string) (OperationTypeEnum, bool)
    func GetOperationTypeEnumValues() []OperationTypeEnum
type PurgeQueueDetails
    func (m PurgeQueueDetails) String() string
    func (m PurgeQueueDetails) ValidateEnumValue() (bool, error)
type PurgeQueueDetailsPurgeTypeEnum
    func GetMappingPurgeQueueDetailsPurgeTypeEnum(val string) (PurgeQueueDetailsPurgeTypeEnum, bool)
    func GetPurgeQueueDetailsPurgeTypeEnumValues() []PurgeQueueDetailsPurgeTypeEnum
type PurgeQueueRequest
    func (request PurgeQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request PurgeQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request PurgeQueueRequest) RetryPolicy() *common.RetryPolicy
    func (request PurgeQueueRequest) String() string
    func (request PurgeQueueRequest) ValidateEnumValue() (bool, error)
type PurgeQueueResponse
    func (response PurgeQueueResponse) HTTPResponse() *http.Response
    func (response PurgeQueueResponse) String() string
type PutMessage
    func (m PutMessage) String() string
    func (m PutMessage) ValidateEnumValue() (bool, error)
type PutMessages
    func (m PutMessages) String() string
    func (m PutMessages) ValidateEnumValue() (bool, error)
type PutMessagesDetails
    func (m PutMessagesDetails) String() string
    func (m PutMessagesDetails) ValidateEnumValue() (bool, error)
type PutMessagesDetailsEntry
    func (m PutMessagesDetailsEntry) String() string
    func (m PutMessagesDetailsEntry) ValidateEnumValue() (bool, error)
type PutMessagesRequest
    func (request PutMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request PutMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request PutMessagesRequest) RetryPolicy() *common.RetryPolicy
    func (request PutMessagesRequest) String() string
    func (request PutMessagesRequest) ValidateEnumValue() (bool, error)
type PutMessagesResponse
    func (response PutMessagesResponse) HTTPResponse() *http.Response
    func (response PutMessagesResponse) String() string
type Queue
    func (m Queue) String() string
    func (m Queue) ValidateEnumValue() (bool, error)
type QueueAdminClient
    func NewQueueAdminClientWithConfigurationProvider(configProvider common.ConfigurationProvider) (client QueueAdminClient, err error)
    func NewQueueAdminClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string) (client QueueAdminClient, err error)
    func (client QueueAdminClient) ChangeQueueCompartment(ctx context.Context, request ChangeQueueCompartmentRequest) (response ChangeQueueCompartmentResponse, err error)
    func (client *QueueAdminClient) ConfigurationProvider() *common.ConfigurationProvider
    func (client QueueAdminClient) CreateQueue(ctx context.Context, request CreateQueueRequest) (response CreateQueueResponse, err error)
    func (client QueueAdminClient) DeleteQueue(ctx context.Context, request DeleteQueueRequest) (response DeleteQueueResponse, err error)
    func (client QueueAdminClient) GetQueue(ctx context.Context, request GetQueueRequest) (response GetQueueResponse, err error)
    func (client QueueAdminClient) GetWorkRequest(ctx context.Context, request GetWorkRequestRequest) (response GetWorkRequestResponse, err error)
    func (client QueueAdminClient) ListQueues(ctx context.Context, request ListQueuesRequest) (response ListQueuesResponse, err error)
    func (client QueueAdminClient) ListWorkRequestErrors(ctx context.Context, request ListWorkRequestErrorsRequest) (response ListWorkRequestErrorsResponse, err error)
    func (client QueueAdminClient) ListWorkRequestLogs(ctx context.Context, request ListWorkRequestLogsRequest) (response ListWorkRequestLogsResponse, err error)
    func (client QueueAdminClient) ListWorkRequests(ctx context.Context, request ListWorkRequestsRequest) (response ListWorkRequestsResponse, err error)
    func (client QueueAdminClient) PurgeQueue(ctx context.Context, request PurgeQueueRequest) (response PurgeQueueResponse, err error)
    func (client *QueueAdminClient) SetRegion(region string)
    func (client QueueAdminClient) UpdateQueue(ctx context.Context, request UpdateQueueRequest) (response UpdateQueueResponse, err error)
type QueueClient
    func NewQueueClientWithConfigurationProvider(configProvider common.ConfigurationProvider) (client QueueClient, err error)
    func NewQueueClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string) (client QueueClient, err error)
    func (client *QueueClient) ConfigurationProvider() *common.ConfigurationProvider
    func (client QueueClient) DeleteMessage(ctx context.Context, request DeleteMessageRequest) (response DeleteMessageResponse, err error)
    func (client QueueClient) DeleteMessages(ctx context.Context, request DeleteMessagesRequest) (response DeleteMessagesResponse, err error)
    func (client QueueClient) GetMessages(ctx context.Context, request GetMessagesRequest) (response GetMessagesResponse, err error)
    func (client QueueClient) GetStats(ctx context.Context, request GetStatsRequest) (response GetStatsResponse, err error)
    func (client QueueClient) ListChannels(ctx context.Context, request ListChannelsRequest) (response ListChannelsResponse, err error)
    func (client QueueClient) PutMessages(ctx context.Context, request PutMessagesRequest) (response PutMessagesResponse, err error)
    func (client *QueueClient) SetRegion(region string)
    func (client QueueClient) UpdateMessage(ctx context.Context, request UpdateMessageRequest) (response UpdateMessageResponse, err error)
    func (client QueueClient) UpdateMessages(ctx context.Context, request UpdateMessagesRequest) (response UpdateMessagesResponse, err error)
type QueueCollection
    func (m QueueCollection) String() string
    func (m QueueCollection) ValidateEnumValue() (bool, error)
type QueueLifecycleStateEnum
    func GetMappingQueueLifecycleStateEnum(val string) (QueueLifecycleStateEnum, bool)
    func GetQueueLifecycleStateEnumValues() []QueueLifecycleStateEnum
type QueueStats
    func (m QueueStats) String() string
    func (m QueueStats) ValidateEnumValue() (bool, error)
type QueueSummary
    func (m QueueSummary) String() string
    func (m QueueSummary) ValidateEnumValue() (bool, error)
type SortOrderEnum
    func GetMappingSortOrderEnum(val string) (SortOrderEnum, bool)
    func GetSortOrderEnumValues() []SortOrderEnum
type Stats
    func (m Stats) String() string
    func (m Stats) ValidateEnumValue() (bool, error)
type UpdateMessageDetails
    func (m UpdateMessageDetails) String() string
    func (m UpdateMessageDetails) ValidateEnumValue() (bool, error)
type UpdateMessageRequest
    func (request UpdateMessageRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request UpdateMessageRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request UpdateMessageRequest) RetryPolicy() *common.RetryPolicy
    func (request UpdateMessageRequest) String() string
    func (request UpdateMessageRequest) ValidateEnumValue() (bool, error)
type UpdateMessageResponse
    func (response UpdateMessageResponse) HTTPResponse() *http.Response
    func (response UpdateMessageResponse) String() string
type UpdateMessagesDetails
    func (m UpdateMessagesDetails) String() string
    func (m UpdateMessagesDetails) ValidateEnumValue() (bool, error)
type UpdateMessagesDetailsEntry
    func (m UpdateMessagesDetailsEntry) String() string
    func (m UpdateMessagesDetailsEntry) ValidateEnumValue() (bool, error)
type UpdateMessagesRequest
    func (request UpdateMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request UpdateMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request UpdateMessagesRequest) RetryPolicy() *common.RetryPolicy
    func (request UpdateMessagesRequest) String() string
    func (request UpdateMessagesRequest) ValidateEnumValue() (bool, error)
type UpdateMessagesResponse
    func (response UpdateMessagesResponse) HTTPResponse() *http.Response
    func (response UpdateMessagesResponse) String() string
type UpdateMessagesResult
    func (m UpdateMessagesResult) String() string
    func (m UpdateMessagesResult) ValidateEnumValue() (bool, error)
type UpdateMessagesResultEntry
    func (m UpdateMessagesResultEntry) String() string
    func (m UpdateMessagesResultEntry) ValidateEnumValue() (bool, error)
type UpdateQueueDetails
    func (m UpdateQueueDetails) String() string
    func (m UpdateQueueDetails) ValidateEnumValue() (bool, error)
type UpdateQueueRequest
    func (request UpdateQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
    func (request UpdateQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
    func (request UpdateQueueRequest) RetryPolicy() *common.RetryPolicy
    func (request UpdateQueueRequest) String() string
    func (request UpdateQueueRequest) ValidateEnumValue() (bool, error)
type UpdateQueueResponse
    func (response UpdateQueueResponse) HTTPResponse() *http.Response
    func (response UpdateQueueResponse) String() string
type UpdatedMessage
    func (m UpdatedMessage) String() string
    func (m UpdatedMessage) ValidateEnumValue() (bool, error)
type WorkRequest
    func (m WorkRequest) String() string
    func (m WorkRequest) ValidateEnumValue() (bool, error)
type WorkRequestError
    func (m WorkRequestError) String() string
    func (m WorkRequestError) ValidateEnumValue() (bool, error)
type WorkRequestErrorCollection
    func (m WorkRequestErrorCollection) String() string
    func (m WorkRequestErrorCollection) ValidateEnumValue() (bool, error)
type WorkRequestLogEntry
    func (m WorkRequestLogEntry) String() string
    func (m WorkRequestLogEntry) ValidateEnumValue() (bool, error)
type WorkRequestLogEntryCollection
    func (m WorkRequestLogEntryCollection) String() string
    func (m WorkRequestLogEntryCollection) ValidateEnumValue() (bool, error)
type WorkRequestResource
    func (m WorkRequestResource) String() string
    func (m WorkRequestResource) ValidateEnumValue() (bool, error)
type WorkRequestSummary
    func (m WorkRequestSummary) String() string
    func (m WorkRequestSummary) ValidateEnumValue() (bool, error)
type WorkRequestSummaryCollection
    func (m WorkRequestSummaryCollection) String() string
    func (m WorkRequestSummaryCollection) ValidateEnumValue() (bool, error)

Package files

action_type.go change_queue_compartment_details.go change_queue_compartment_request_response.go channel_collection.go create_queue_details.go create_queue_request_response.go delete_message_request_response.go delete_messages_details.go delete_messages_details_entry.go delete_messages_request_response.go delete_messages_result.go delete_messages_result_entry.go delete_queue_request_response.go get_message.go get_messages.go get_messages_request_response.go get_queue_request_response.go get_stats_request_response.go get_work_request_request_response.go list_channels_request_response.go list_queues_request_response.go list_work_request_errors_request_response.go list_work_request_logs_request_response.go list_work_requests_request_response.go message_metadata.go operation_status.go operation_type.go purge_queue_details.go purge_queue_request_response.go put_message.go put_messages.go put_messages_details.go put_messages_details_entry.go put_messages_request_response.go queue.go queue_client.go queue_collection.go queue_queueadmin_client.go queue_stats.go queue_summary.go sort_order.go stats.go update_message_details.go update_message_request_response.go update_messages_details.go update_messages_details_entry.go update_messages_request_response.go update_messages_result.go update_messages_result_entry.go update_queue_details.go update_queue_request_response.go updated_message.go work_request.go work_request_error.go work_request_error_collection.go work_request_log_entry.go work_request_log_entry_collection.go work_request_resource.go work_request_summary.go work_request_summary_collection.go

func GetActionTypeEnumStringValues

func GetActionTypeEnumStringValues() []string

GetActionTypeEnumStringValues Enumerates the set of values in String for ActionTypeEnum

func GetListQueuesSortByEnumStringValues

func GetListQueuesSortByEnumStringValues() []string

GetListQueuesSortByEnumStringValues Enumerates the set of values in String for ListQueuesSortByEnum

func GetListQueuesSortOrderEnumStringValues

func GetListQueuesSortOrderEnumStringValues() []string

GetListQueuesSortOrderEnumStringValues Enumerates the set of values in String for ListQueuesSortOrderEnum

func GetOperationStatusEnumStringValues

func GetOperationStatusEnumStringValues() []string

GetOperationStatusEnumStringValues Enumerates the set of values in String for OperationStatusEnum

func GetOperationTypeEnumStringValues

func GetOperationTypeEnumStringValues() []string

GetOperationTypeEnumStringValues Enumerates the set of values in String for OperationTypeEnum

func GetPurgeQueueDetailsPurgeTypeEnumStringValues

func GetPurgeQueueDetailsPurgeTypeEnumStringValues() []string

GetPurgeQueueDetailsPurgeTypeEnumStringValues Enumerates the set of values in String for PurgeQueueDetailsPurgeTypeEnum

func GetQueueLifecycleStateEnumStringValues

func GetQueueLifecycleStateEnumStringValues() []string

GetQueueLifecycleStateEnumStringValues Enumerates the set of values in String for QueueLifecycleStateEnum

func GetSortOrderEnumStringValues

func GetSortOrderEnumStringValues() []string

GetSortOrderEnumStringValues Enumerates the set of values in String for SortOrderEnum

type ActionTypeEnum

ActionTypeEnum Enum with underlying type: string

type ActionTypeEnum string

Set of constants representing the allowable values for ActionTypeEnum

const (
    ActionTypeCreated    ActionTypeEnum = "CREATED"
    ActionTypeUpdated    ActionTypeEnum = "UPDATED"
    ActionTypeDeleted    ActionTypeEnum = "DELETED"
    ActionTypeInProgress ActionTypeEnum = "IN_PROGRESS"
    ActionTypeRelated    ActionTypeEnum = "RELATED"
)

func GetActionTypeEnumValues

func GetActionTypeEnumValues() []ActionTypeEnum

GetActionTypeEnumValues Enumerates the set of values for ActionTypeEnum

func GetMappingActionTypeEnum

func GetMappingActionTypeEnum(val string) (ActionTypeEnum, bool)

GetMappingActionTypeEnum performs case Insensitive comparison on enum value and return the desired enum

type ChangeQueueCompartmentDetails

ChangeQueueCompartmentDetails The information to be updated.

type ChangeQueueCompartmentDetails struct {

    // The OCID (https://docs.cloud.oracle.com/Content/General/Concepts/identifiers.htm) of the compartment
    // into which the resource should be moved.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`
}

func (ChangeQueueCompartmentDetails) String

func (m ChangeQueueCompartmentDetails) String() string

func (ChangeQueueCompartmentDetails) ValidateEnumValue

func (m ChangeQueueCompartmentDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type ChangeQueueCompartmentRequest

ChangeQueueCompartmentRequest wrapper for the ChangeQueueCompartment operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ChangeQueueCompartment.go.html to see an example of how to use ChangeQueueCompartmentRequest.

type ChangeQueueCompartmentRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // The information to be updated.
    ChangeQueueCompartmentDetails `contributesTo:"body"`

    // For optimistic concurrency control. In the PUT or DELETE call
    // for a resource, set the `if-match` parameter to the value of the
    // etag from a previous GET or POST response for that resource.
    // The resource will be updated or deleted only if the etag you
    // provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (ChangeQueueCompartmentRequest) BinaryRequestBody

func (request ChangeQueueCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (ChangeQueueCompartmentRequest) HTTPRequest

func (request ChangeQueueCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ChangeQueueCompartmentRequest) RetryPolicy

func (request ChangeQueueCompartmentRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ChangeQueueCompartmentRequest) String

func (request ChangeQueueCompartmentRequest) String() string

func (ChangeQueueCompartmentRequest) ValidateEnumValue

func (request ChangeQueueCompartmentRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type ChangeQueueCompartmentResponse

ChangeQueueCompartmentResponse wrapper for the ChangeQueueCompartment operation

type ChangeQueueCompartmentResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the asynchronous request. You can use this to query status of the asynchronous operation.
    OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (ChangeQueueCompartmentResponse) HTTPResponse

func (response ChangeQueueCompartmentResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ChangeQueueCompartmentResponse) String

func (response ChangeQueueCompartmentResponse) String() string

type ChannelCollection

ChannelCollection List of IDs of non-empty channels.

type ChannelCollection struct {

    // The approximate list of IDs of non-empty channels.
    Items []string `mandatory:"true" json:"items"`
}

func (ChannelCollection) String

func (m ChannelCollection) String() string

func (ChannelCollection) ValidateEnumValue

func (m ChannelCollection) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type CreateQueueDetails

CreateQueueDetails The information about a new queue.

type CreateQueueDetails struct {

    // The user-friendly name of the queue.
    DisplayName *string `mandatory:"true" json:"displayName"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the compartment containing the queue.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The retention period of messages in the queue, in seconds.
    RetentionInSeconds *int `mandatory:"false" json:"retentionInSeconds"`

    // The default visibility timeout of the messages consumed from the queue, in seconds.
    VisibilityInSeconds *int `mandatory:"false" json:"visibilityInSeconds"`

    // The default polling timeout of the messages in the queue, in seconds.
    TimeoutInSeconds *int `mandatory:"false" json:"timeoutInSeconds"`

    // The percentage of allocated queue resources that can be consumed by a single channel. For example, if a queue has a storage limit of 2Gb, and a single channel consumption limit is 0.1 (10%), that means data size of a single channel  can't exceed 200Mb. Consumption limit of 100% (default) means that a single channel can consume up-to all allocated queue's resources.
    ChannelConsumptionLimit *int `mandatory:"false" json:"channelConsumptionLimit"`

    // The number of times a message can be delivered to a consumer before being moved to the dead letter queue. A value of 0 indicates that the DLQ is not used.
    DeadLetterQueueDeliveryCount *int `mandatory:"false" json:"deadLetterQueueDeliveryCount"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the custom encryption key to be used to encrypt messages content.
    CustomEncryptionKeyId *string `mandatory:"false" json:"customEncryptionKeyId"`

    // Simple key-value pair that is applied without any predefined name, type or scope. Exists for cross-compatibility only.
    // Example: `{"bar-key": "value"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace.
    // Example: `{"foo-namespace": {"bar-key": "value"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

func (CreateQueueDetails) String

func (m CreateQueueDetails) String() string

func (CreateQueueDetails) ValidateEnumValue

func (m CreateQueueDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type CreateQueueRequest

CreateQueueRequest wrapper for the CreateQueue operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/CreateQueue.go.html to see an example of how to use CreateQueueRequest.

type CreateQueueRequest struct {

    // Details for the new Queue.
    CreateQueueDetails `contributesTo:"body"`

    // A token that uniquely identifies a request so it can be retried in case of a timeout or
    // server error without risk of executing that same action again. Retry tokens expire after 24
    // hours, but can be invalidated before then due to conflicting operations. For example, if a resource
    // has been deleted and purged from the system, then a retry of the original creation request
    // might be rejected.
    OpcRetryToken *string `mandatory:"false" contributesTo:"header" name:"opc-retry-token"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (CreateQueueRequest) BinaryRequestBody

func (request CreateQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (CreateQueueRequest) HTTPRequest

func (request CreateQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (CreateQueueRequest) RetryPolicy

func (request CreateQueueRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (CreateQueueRequest) String

func (request CreateQueueRequest) String() string

func (CreateQueueRequest) ValidateEnumValue

func (request CreateQueueRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type CreateQueueResponse

CreateQueueResponse wrapper for the CreateQueue operation

type CreateQueueResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the asynchronous request. You can use this to query status of the asynchronous operation.
    OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (CreateQueueResponse) HTTPResponse

func (response CreateQueueResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (CreateQueueResponse) String

func (response CreateQueueResponse) String() string

type DeleteMessageRequest

DeleteMessageRequest wrapper for the DeleteMessage operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/DeleteMessage.go.html to see an example of how to use DeleteMessageRequest.

type DeleteMessageRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // The receipt of the message retrieved from a GetMessages call.
    MessageReceipt *string `mandatory:"true" contributesTo:"path" name:"messageReceipt"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (DeleteMessageRequest) BinaryRequestBody

func (request DeleteMessageRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (DeleteMessageRequest) HTTPRequest

func (request DeleteMessageRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (DeleteMessageRequest) RetryPolicy

func (request DeleteMessageRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (DeleteMessageRequest) String

func (request DeleteMessageRequest) String() string

func (DeleteMessageRequest) ValidateEnumValue

func (request DeleteMessageRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type DeleteMessageResponse

DeleteMessageResponse wrapper for the DeleteMessage operation

type DeleteMessageResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (DeleteMessageResponse) HTTPResponse

func (response DeleteMessageResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (DeleteMessageResponse) String

func (response DeleteMessageResponse) String() string

type DeleteMessagesDetails

DeleteMessagesDetails The details of a DeleteMessages request.

type DeleteMessagesDetails struct {

    // The array of messages to delete from a queue.
    Entries []DeleteMessagesDetailsEntry `mandatory:"true" json:"entries"`
}

func (DeleteMessagesDetails) String

func (m DeleteMessagesDetails) String() string

func (DeleteMessagesDetails) ValidateEnumValue

func (m DeleteMessagesDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type DeleteMessagesDetailsEntry

DeleteMessagesDetailsEntry Object that represents a message to delete from a queue.

type DeleteMessagesDetailsEntry struct {

    // The receipt of the message to delete.
    Receipt *string `mandatory:"true" json:"receipt"`
}

func (DeleteMessagesDetailsEntry) String

func (m DeleteMessagesDetailsEntry) String() string

func (DeleteMessagesDetailsEntry) ValidateEnumValue

func (m DeleteMessagesDetailsEntry) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type DeleteMessagesRequest

DeleteMessagesRequest wrapper for the DeleteMessages operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/DeleteMessages.go.html to see an example of how to use DeleteMessagesRequest.

type DeleteMessagesRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // Details for the messages to delete.
    DeleteMessagesDetails `contributesTo:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (DeleteMessagesRequest) BinaryRequestBody

func (request DeleteMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (DeleteMessagesRequest) HTTPRequest

func (request DeleteMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (DeleteMessagesRequest) RetryPolicy

func (request DeleteMessagesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (DeleteMessagesRequest) String

func (request DeleteMessagesRequest) String() string

func (DeleteMessagesRequest) ValidateEnumValue

func (request DeleteMessagesRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type DeleteMessagesResponse

DeleteMessagesResponse wrapper for the DeleteMessages operation

type DeleteMessagesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The DeleteMessagesResult instance
    DeleteMessagesResult `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (DeleteMessagesResponse) HTTPResponse

func (response DeleteMessagesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (DeleteMessagesResponse) String

func (response DeleteMessagesResponse) String() string

type DeleteMessagesResult

DeleteMessagesResult The response to a DeleteMessages request. It indicates the number of server and client failures as well as an array of entries for successful and failed actions.

type DeleteMessagesResult struct {

    // The number of messages that failed to be deleted from the queue because of a server failure.
    ServerFailures *int `mandatory:"true" json:"serverFailures"`

    // The number of messages that failed to be deleted from the queue because of a client failure such as an invalid receipt.
    ClientFailures *int `mandatory:"true" json:"clientFailures"`

    // An array of items representing the result of each action.
    // The order is guaranteed to be the same as in the `DeleteMessagesDetails` object.
    // If a message was successfully deleted from the queue, the entry does not contain any fields.
    // If a message failed to be deleted from the queue, the entry includes the `errorCode` and `errorMessage` fields.
    Entries []DeleteMessagesResultEntry `mandatory:"true" json:"entries"`
}

func (DeleteMessagesResult) String

func (m DeleteMessagesResult) String() string

func (DeleteMessagesResult) ValidateEnumValue

func (m DeleteMessagesResult) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type DeleteMessagesResultEntry

DeleteMessagesResultEntry Represents the result of a DeleteMessages request, whether it was successful or not. If a message was successfully deleted from the queue, the entry does not contain any fields. If a message failed to be deleted from the queue, the entry includes the `errorCode` and `errorMessage` fields.

type DeleteMessagesResultEntry struct {

    // The error code, in case the message was not successfully deleted from the queue.
    ErrorCode *int `mandatory:"false" json:"errorCode"`

    // A human-readable error message associated with the error code.
    ErrorMessage *string `mandatory:"false" json:"errorMessage"`
}

func (DeleteMessagesResultEntry) String

func (m DeleteMessagesResultEntry) String() string

func (DeleteMessagesResultEntry) ValidateEnumValue

func (m DeleteMessagesResultEntry) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type DeleteQueueRequest

DeleteQueueRequest wrapper for the DeleteQueue operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/DeleteQueue.go.html to see an example of how to use DeleteQueueRequest.

type DeleteQueueRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // For optimistic concurrency control. In the PUT or DELETE call
    // for a resource, set the `if-match` parameter to the value of the
    // etag from a previous GET or POST response for that resource.
    // The resource will be updated or deleted only if the etag you
    // provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (DeleteQueueRequest) BinaryRequestBody

func (request DeleteQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (DeleteQueueRequest) HTTPRequest

func (request DeleteQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (DeleteQueueRequest) RetryPolicy

func (request DeleteQueueRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (DeleteQueueRequest) String

func (request DeleteQueueRequest) String() string

func (DeleteQueueRequest) ValidateEnumValue

func (request DeleteQueueRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type DeleteQueueResponse

DeleteQueueResponse wrapper for the DeleteQueue operation

type DeleteQueueResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the asynchronous request. You can use this to query status of the asynchronous operation.
    OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (DeleteQueueResponse) HTTPResponse

func (response DeleteQueueResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (DeleteQueueResponse) String

func (response DeleteQueueResponse) String() string

type GetMessage

GetMessage A message consumed from a queue.

type GetMessage struct {

    // The ID of the message. This ID is only used for tracing and debugging purposes and isn't used as a parameter in any request.
    Id *int64 `mandatory:"true" json:"id"`

    // The content of the message.
    Content *string `mandatory:"true" json:"content"`

    // A receipt is a base64urlencode opaque token, uniquely representing a message.
    // The receipt can be used to delete a message or update its visibility.
    Receipt *string `mandatory:"true" json:"receipt"`

    // The number of times that the message has been delivered to a consumer.
    DeliveryCount *int `mandatory:"true" json:"deliveryCount"`

    // The time after which the message will be visible to other consumers, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    VisibleAfter *common.SDKTime `mandatory:"true" json:"visibleAfter"`

    // The time after which the message will be automatically deleted, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    ExpireAfter *common.SDKTime `mandatory:"true" json:"expireAfter"`

    Metadata *MessageMetadata `mandatory:"false" json:"metadata"`
}

func (GetMessage) String

func (m GetMessage) String() string

func (GetMessage) ValidateEnumValue

func (m GetMessage) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type GetMessages

GetMessages A list of messages from a queue.

type GetMessages struct {

    // List of messages from a queue.
    Messages []GetMessage `mandatory:"true" json:"messages"`
}

func (GetMessages) String

func (m GetMessages) String() string

func (GetMessages) ValidateEnumValue

func (m GetMessages) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type GetMessagesRequest

GetMessagesRequest wrapper for the GetMessages operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetMessages.go.html to see an example of how to use GetMessagesRequest.

type GetMessagesRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // If the `visibilityInSeconds` parameter is set, messages will be hidden for `visibilityInSeconds` seconds and won't be consumable by other consumers during that time.
    // If it isn't set it defaults to the value set at the queue level.
    // Using a `visibilityInSeconds` value of 0 effectively acts as a peek functionality.
    // Messages retrieved that way aren't meant to be deleted because they will most likely be delivered to another consumer as their visibility won't change, but will still increase the delivery count by one.
    VisibilityInSeconds *int `mandatory:"false" contributesTo:"query" name:"visibilityInSeconds"`

    // If the `timeoutInSeconds parameter` isn't set or it is set to a value greater than 0, the request is using the long-polling mode and will only return when a message is available for consumption (it does not wait for limit messages but still only returns at-most limit messages) or after `timeoutInSeconds` seconds (in which case it will return an empty response), whichever comes first.
    // If the parameter is set to 0, the request is using the short-polling mode and immediately returns whether messages have been retrieved or not.
    // In same rare-cases a long-polling request could be interrupted (returned with empty response) before the end of the timeout.
    TimeoutInSeconds *int `mandatory:"false" contributesTo:"query" name:"timeoutInSeconds"`

    // The limit parameter controls how many messages is returned at-most.
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Optional parameter to filter the channels.
    ChannelFilter *string `mandatory:"false" contributesTo:"query" name:"channelFilter"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (GetMessagesRequest) BinaryRequestBody

func (request GetMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (GetMessagesRequest) HTTPRequest

func (request GetMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetMessagesRequest) RetryPolicy

func (request GetMessagesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetMessagesRequest) String

func (request GetMessagesRequest) String() string

func (GetMessagesRequest) ValidateEnumValue

func (request GetMessagesRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type GetMessagesResponse

GetMessagesResponse wrapper for the GetMessages operation

type GetMessagesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The GetMessages instance
    GetMessages `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (GetMessagesResponse) HTTPResponse

func (response GetMessagesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetMessagesResponse) String

func (response GetMessagesResponse) String() string

type GetQueueRequest

GetQueueRequest wrapper for the GetQueue operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetQueue.go.html to see an example of how to use GetQueueRequest.

type GetQueueRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (GetQueueRequest) BinaryRequestBody

func (request GetQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (GetQueueRequest) HTTPRequest

func (request GetQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetQueueRequest) RetryPolicy

func (request GetQueueRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetQueueRequest) String

func (request GetQueueRequest) String() string

func (GetQueueRequest) ValidateEnumValue

func (request GetQueueRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type GetQueueResponse

GetQueueResponse wrapper for the GetQueue operation

type GetQueueResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The Queue instance
    Queue `presentIn:"body"`

    // For optimistic concurrency control. See `if-match`.
    Etag *string `presentIn:"header" name:"etag"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (GetQueueResponse) HTTPResponse

func (response GetQueueResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetQueueResponse) String

func (response GetQueueResponse) String() string

type GetStatsRequest

GetStatsRequest wrapper for the GetStats operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetStats.go.html to see an example of how to use GetStatsRequest.

type GetStatsRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Id to specify channel.
    ChannelId *string `mandatory:"false" contributesTo:"query" name:"channelId"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (GetStatsRequest) BinaryRequestBody

func (request GetStatsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (GetStatsRequest) HTTPRequest

func (request GetStatsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetStatsRequest) RetryPolicy

func (request GetStatsRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetStatsRequest) String

func (request GetStatsRequest) String() string

func (GetStatsRequest) ValidateEnumValue

func (request GetStatsRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type GetStatsResponse

GetStatsResponse wrapper for the GetStats operation

type GetStatsResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The QueueStats instance
    QueueStats `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (GetStatsResponse) HTTPResponse

func (response GetStatsResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetStatsResponse) String

func (response GetStatsResponse) String() string

type GetWorkRequestRequest

GetWorkRequestRequest wrapper for the GetWorkRequest operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetWorkRequest.go.html to see an example of how to use GetWorkRequestRequest.

type GetWorkRequestRequest struct {

    // The ID of the asynchronous request.
    WorkRequestId *string `mandatory:"true" contributesTo:"path" name:"workRequestId"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (GetWorkRequestRequest) BinaryRequestBody

func (request GetWorkRequestRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (GetWorkRequestRequest) HTTPRequest

func (request GetWorkRequestRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (GetWorkRequestRequest) RetryPolicy

func (request GetWorkRequestRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (GetWorkRequestRequest) String

func (request GetWorkRequestRequest) String() string

func (GetWorkRequestRequest) ValidateEnumValue

func (request GetWorkRequestRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type GetWorkRequestResponse

GetWorkRequestResponse wrapper for the GetWorkRequest operation

type GetWorkRequestResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The WorkRequest instance
    WorkRequest `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // A decimal number representing the number of seconds the client should wait before polling this endpoint again.
    RetryAfter *int `presentIn:"header" name:"retry-after"`
}

func (GetWorkRequestResponse) HTTPResponse

func (response GetWorkRequestResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (GetWorkRequestResponse) String

func (response GetWorkRequestResponse) String() string

type ListChannelsRequest

ListChannelsRequest wrapper for the ListChannels operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListChannels.go.html to see an example of how to use ListChannelsRequest.

type ListChannelsRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For list pagination. The maximum number of results per page, or items to return in a paginated "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // For list pagination. The value of the opc-next-page response header from the previous "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // Optional parameter to filter the channels.
    ChannelFilter *string `mandatory:"false" contributesTo:"query" name:"channelFilter"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (ListChannelsRequest) BinaryRequestBody

func (request ListChannelsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (ListChannelsRequest) HTTPRequest

func (request ListChannelsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListChannelsRequest) RetryPolicy

func (request ListChannelsRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListChannelsRequest) String

func (request ListChannelsRequest) String() string

func (ListChannelsRequest) ValidateEnumValue

func (request ListChannelsRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type ListChannelsResponse

ListChannelsResponse wrapper for the ListChannels operation

type ListChannelsResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of ChannelCollection instances
    ChannelCollection `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For pagination of a list of items. When paging through a list, if this header appears in the response,
    // then a partial list might have been returned. Include this value as the `page` parameter for the
    // subsequent GET request to get the next batch of items.
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`
}

func (ListChannelsResponse) HTTPResponse

func (response ListChannelsResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListChannelsResponse) String

func (response ListChannelsResponse) String() string

type ListQueuesRequest

ListQueuesRequest wrapper for the ListQueues operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListQueues.go.html to see an example of how to use ListQueuesRequest.

type ListQueuesRequest struct {

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the compartment in which to list resources.
    CompartmentId *string `mandatory:"false" contributesTo:"query" name:"compartmentId"`

    // A filter to return only resources their lifecycleState matches the given lifecycleState.
    LifecycleState QueueLifecycleStateEnum `mandatory:"false" contributesTo:"query" name:"lifecycleState" omitEmpty:"true"`

    // A filter to return only resources that match the entire display name given.
    DisplayName *string `mandatory:"false" contributesTo:"query" name:"displayName"`

    // The unique queue identifier.
    Id *string `mandatory:"false" contributesTo:"query" name:"id"`

    // For list pagination. The maximum number of results per page, or items to return in a paginated "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // For list pagination. The value of the opc-next-page response header from the previous "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // The sort order to use, either 'asc' or 'desc'.
    SortOrder ListQueuesSortOrderEnum `mandatory:"false" contributesTo:"query" name:"sortOrder" omitEmpty:"true"`

    // The field to sort by. Only one sort order may be provided. Default order for timeCreated is descending. Default order for displayName is ascending. If no value is specified timeCreated is default.
    SortBy ListQueuesSortByEnum `mandatory:"false" contributesTo:"query" name:"sortBy" omitEmpty:"true"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (ListQueuesRequest) BinaryRequestBody

func (request ListQueuesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (ListQueuesRequest) HTTPRequest

func (request ListQueuesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListQueuesRequest) RetryPolicy

func (request ListQueuesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListQueuesRequest) String

func (request ListQueuesRequest) String() string

func (ListQueuesRequest) ValidateEnumValue

func (request ListQueuesRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type ListQueuesResponse

ListQueuesResponse wrapper for the ListQueues operation

type ListQueuesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of QueueCollection instances
    QueueCollection `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For pagination of a list of items. When paging through a list, if this header appears in the response,
    // then a partial list might have been returned. Include this value as the `page` parameter for the
    // subsequent GET request to get the next batch of items.
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`
}

func (ListQueuesResponse) HTTPResponse

func (response ListQueuesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListQueuesResponse) String

func (response ListQueuesResponse) String() string

type ListQueuesSortByEnum

ListQueuesSortByEnum Enum with underlying type: string

type ListQueuesSortByEnum string

Set of constants representing the allowable values for ListQueuesSortByEnum

const (
    ListQueuesSortByTimecreated ListQueuesSortByEnum = "timeCreated"
    ListQueuesSortByDisplayname ListQueuesSortByEnum = "displayName"
)

func GetListQueuesSortByEnumValues

func GetListQueuesSortByEnumValues() []ListQueuesSortByEnum

GetListQueuesSortByEnumValues Enumerates the set of values for ListQueuesSortByEnum

func GetMappingListQueuesSortByEnum

func GetMappingListQueuesSortByEnum(val string) (ListQueuesSortByEnum, bool)

GetMappingListQueuesSortByEnum performs case Insensitive comparison on enum value and return the desired enum

type ListQueuesSortOrderEnum

ListQueuesSortOrderEnum Enum with underlying type: string

type ListQueuesSortOrderEnum string

Set of constants representing the allowable values for ListQueuesSortOrderEnum

const (
    ListQueuesSortOrderAsc  ListQueuesSortOrderEnum = "ASC"
    ListQueuesSortOrderDesc ListQueuesSortOrderEnum = "DESC"
)

func GetListQueuesSortOrderEnumValues

func GetListQueuesSortOrderEnumValues() []ListQueuesSortOrderEnum

GetListQueuesSortOrderEnumValues Enumerates the set of values for ListQueuesSortOrderEnum

func GetMappingListQueuesSortOrderEnum

func GetMappingListQueuesSortOrderEnum(val string) (ListQueuesSortOrderEnum, bool)

GetMappingListQueuesSortOrderEnum performs case Insensitive comparison on enum value and return the desired enum

type ListWorkRequestErrorsRequest

ListWorkRequestErrorsRequest wrapper for the ListWorkRequestErrors operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListWorkRequestErrors.go.html to see an example of how to use ListWorkRequestErrorsRequest.

type ListWorkRequestErrorsRequest struct {

    // The ID of the asynchronous request.
    WorkRequestId *string `mandatory:"true" contributesTo:"path" name:"workRequestId"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For list pagination. The value of the opc-next-page response header from the previous "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // For list pagination. The maximum number of results per page, or items to return in a paginated "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (ListWorkRequestErrorsRequest) BinaryRequestBody

func (request ListWorkRequestErrorsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (ListWorkRequestErrorsRequest) HTTPRequest

func (request ListWorkRequestErrorsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListWorkRequestErrorsRequest) RetryPolicy

func (request ListWorkRequestErrorsRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListWorkRequestErrorsRequest) String

func (request ListWorkRequestErrorsRequest) String() string

func (ListWorkRequestErrorsRequest) ValidateEnumValue

func (request ListWorkRequestErrorsRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type ListWorkRequestErrorsResponse

ListWorkRequestErrorsResponse wrapper for the ListWorkRequestErrors operation

type ListWorkRequestErrorsResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of WorkRequestErrorCollection instances
    WorkRequestErrorCollection `presentIn:"body"`

    // For pagination of a list of items. When paging through a list, if this header appears in the response,
    // then a partial list might have been returned. Include this value as the `page` parameter for the
    // subsequent GET request to get the next batch of items.
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (ListWorkRequestErrorsResponse) HTTPResponse

func (response ListWorkRequestErrorsResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListWorkRequestErrorsResponse) String

func (response ListWorkRequestErrorsResponse) String() string

type ListWorkRequestLogsRequest

ListWorkRequestLogsRequest wrapper for the ListWorkRequestLogs operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListWorkRequestLogs.go.html to see an example of how to use ListWorkRequestLogsRequest.

type ListWorkRequestLogsRequest struct {

    // The ID of the asynchronous request.
    WorkRequestId *string `mandatory:"true" contributesTo:"path" name:"workRequestId"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For list pagination. The value of the opc-next-page response header from the previous "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // For list pagination. The maximum number of results per page, or items to return in a paginated "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (ListWorkRequestLogsRequest) BinaryRequestBody

func (request ListWorkRequestLogsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (ListWorkRequestLogsRequest) HTTPRequest

func (request ListWorkRequestLogsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListWorkRequestLogsRequest) RetryPolicy

func (request ListWorkRequestLogsRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListWorkRequestLogsRequest) String

func (request ListWorkRequestLogsRequest) String() string

func (ListWorkRequestLogsRequest) ValidateEnumValue

func (request ListWorkRequestLogsRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type ListWorkRequestLogsResponse

ListWorkRequestLogsResponse wrapper for the ListWorkRequestLogs operation

type ListWorkRequestLogsResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of WorkRequestLogEntryCollection instances
    WorkRequestLogEntryCollection `presentIn:"body"`

    // For pagination of a list of items. When paging through a list, if this header appears in the response,
    // then a partial list might have been returned. Include this value as the `page` parameter for the
    // subsequent GET request to get the next batch of items.
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (ListWorkRequestLogsResponse) HTTPResponse

func (response ListWorkRequestLogsResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListWorkRequestLogsResponse) String

func (response ListWorkRequestLogsResponse) String() string

type ListWorkRequestsRequest

ListWorkRequestsRequest wrapper for the ListWorkRequests operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListWorkRequests.go.html to see an example of how to use ListWorkRequestsRequest.

type ListWorkRequestsRequest struct {

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the compartment in which to list resources.
    CompartmentId *string `mandatory:"false" contributesTo:"query" name:"compartmentId"`

    // The ID of the asynchronous work request.
    WorkRequestId *string `mandatory:"false" contributesTo:"query" name:"workRequestId"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // For list pagination. The value of the opc-next-page response header from the previous "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Page *string `mandatory:"false" contributesTo:"query" name:"page"`

    // For list pagination. The maximum number of results per page, or items to return in a paginated "List" call. For important details about how pagination works, see List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine).
    Limit *int `mandatory:"false" contributesTo:"query" name:"limit"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (ListWorkRequestsRequest) BinaryRequestBody

func (request ListWorkRequestsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (ListWorkRequestsRequest) HTTPRequest

func (request ListWorkRequestsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (ListWorkRequestsRequest) RetryPolicy

func (request ListWorkRequestsRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (ListWorkRequestsRequest) String

func (request ListWorkRequestsRequest) String() string

func (ListWorkRequestsRequest) ValidateEnumValue

func (request ListWorkRequestsRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type ListWorkRequestsResponse

ListWorkRequestsResponse wrapper for the ListWorkRequests operation

type ListWorkRequestsResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // A list of WorkRequestSummaryCollection instances
    WorkRequestSummaryCollection `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`

    // For pagination of a list of items. When paging through a list, if this header appears in the response,
    // then a partial list might have been returned. Include this value as the `page` parameter for the
    // subsequent GET request to get the next batch of items.
    OpcNextPage *string `presentIn:"header" name:"opc-next-page"`
}

func (ListWorkRequestsResponse) HTTPResponse

func (response ListWorkRequestsResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (ListWorkRequestsResponse) String

func (response ListWorkRequestsResponse) String() string

type MessageMetadata

MessageMetadata Object that represents metadata for message.

type MessageMetadata struct {

    // The channel ID which specifies the channel to publish or retrieve messages.
    ChannelId *string `mandatory:"true" json:"channelId"`

    // Additional message properties
    CustomProperties map[string]string `mandatory:"false" json:"customProperties"`
}

func (MessageMetadata) String

func (m MessageMetadata) String() string

func (MessageMetadata) ValidateEnumValue

func (m MessageMetadata) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type OperationStatusEnum

OperationStatusEnum Enum with underlying type: string

type OperationStatusEnum string

Set of constants representing the allowable values for OperationStatusEnum

const (
    OperationStatusAccepted   OperationStatusEnum = "ACCEPTED"
    OperationStatusInProgress OperationStatusEnum = "IN_PROGRESS"
    OperationStatusFailed     OperationStatusEnum = "FAILED"
    OperationStatusSucceeded  OperationStatusEnum = "SUCCEEDED"
    OperationStatusCanceling  OperationStatusEnum = "CANCELING"
    OperationStatusCanceled   OperationStatusEnum = "CANCELED"
)

func GetMappingOperationStatusEnum

func GetMappingOperationStatusEnum(val string) (OperationStatusEnum, bool)

GetMappingOperationStatusEnum performs case Insensitive comparison on enum value and return the desired enum

func GetOperationStatusEnumValues

func GetOperationStatusEnumValues() []OperationStatusEnum

GetOperationStatusEnumValues Enumerates the set of values for OperationStatusEnum

type OperationTypeEnum

OperationTypeEnum Enum with underlying type: string

type OperationTypeEnum string

Set of constants representing the allowable values for OperationTypeEnum

const (
    OperationTypeCreateQueue OperationTypeEnum = "CREATE_QUEUE"
    OperationTypeUpdateQueue OperationTypeEnum = "UPDATE_QUEUE"
    OperationTypeDeleteQueue OperationTypeEnum = "DELETE_QUEUE"
    OperationTypeMoveQueue   OperationTypeEnum = "MOVE_QUEUE"
    OperationTypePurgeQueue  OperationTypeEnum = "PURGE_QUEUE"
)

func GetMappingOperationTypeEnum

func GetMappingOperationTypeEnum(val string) (OperationTypeEnum, bool)

GetMappingOperationTypeEnum performs case Insensitive comparison on enum value and return the desired enum

func GetOperationTypeEnumValues

func GetOperationTypeEnumValues() []OperationTypeEnum

GetOperationTypeEnumValues Enumerates the set of values for OperationTypeEnum

type PurgeQueueDetails

PurgeQueueDetails Purge parameters.

type PurgeQueueDetails struct {

    // Type of the purge to perform:
    // - NORMAL - purge only the normal queue
    // - DLQ - purge only the dead letter queue
    // - BOTH - purge both the normal queue and the dead letter queue
    PurgeType PurgeQueueDetailsPurgeTypeEnum `mandatory:"true" json:"purgeType"`

    // Optional parameter to specify the destination of purge operation.
    // If the channel ID is specified, the purge operation will delete all the messages in the specific channels.
    // If the channel ID is not specified, the purge operation will delete all the messages in the queue and in the child channels.
    ChannelIds []string `mandatory:"false" json:"channelIds"`
}

func (PurgeQueueDetails) String

func (m PurgeQueueDetails) String() string

func (PurgeQueueDetails) ValidateEnumValue

func (m PurgeQueueDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type PurgeQueueDetailsPurgeTypeEnum

PurgeQueueDetailsPurgeTypeEnum Enum with underlying type: string

type PurgeQueueDetailsPurgeTypeEnum string

Set of constants representing the allowable values for PurgeQueueDetailsPurgeTypeEnum

const (
    PurgeQueueDetailsPurgeTypeNormal PurgeQueueDetailsPurgeTypeEnum = "NORMAL"
    PurgeQueueDetailsPurgeTypeDlq    PurgeQueueDetailsPurgeTypeEnum = "DLQ"
    PurgeQueueDetailsPurgeTypeBoth   PurgeQueueDetailsPurgeTypeEnum = "BOTH"
)

func GetMappingPurgeQueueDetailsPurgeTypeEnum

func GetMappingPurgeQueueDetailsPurgeTypeEnum(val string) (PurgeQueueDetailsPurgeTypeEnum, bool)

GetMappingPurgeQueueDetailsPurgeTypeEnum performs case Insensitive comparison on enum value and return the desired enum

func GetPurgeQueueDetailsPurgeTypeEnumValues

func GetPurgeQueueDetailsPurgeTypeEnumValues() []PurgeQueueDetailsPurgeTypeEnum

GetPurgeQueueDetailsPurgeTypeEnumValues Enumerates the set of values for PurgeQueueDetailsPurgeTypeEnum

type PurgeQueueRequest

PurgeQueueRequest wrapper for the PurgeQueue operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/PurgeQueue.go.html to see an example of how to use PurgeQueueRequest.

type PurgeQueueRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // The information to be updated.
    PurgeQueueDetails `contributesTo:"body"`

    // For optimistic concurrency control. In the PUT or DELETE call
    // for a resource, set the `if-match` parameter to the value of the
    // etag from a previous GET or POST response for that resource.
    // The resource will be updated or deleted only if the etag you
    // provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (PurgeQueueRequest) BinaryRequestBody

func (request PurgeQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (PurgeQueueRequest) HTTPRequest

func (request PurgeQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (PurgeQueueRequest) RetryPolicy

func (request PurgeQueueRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (PurgeQueueRequest) String

func (request PurgeQueueRequest) String() string

func (PurgeQueueRequest) ValidateEnumValue

func (request PurgeQueueRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type PurgeQueueResponse

PurgeQueueResponse wrapper for the PurgeQueue operation

type PurgeQueueResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the asynchronous request. You can use this to query status of the asynchronous operation.
    OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (PurgeQueueResponse) HTTPResponse

func (response PurgeQueueResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (PurgeQueueResponse) String

func (response PurgeQueueResponse) String() string

type PutMessage

PutMessage A message that has been published to a queue.

type PutMessage struct {

    // The ID of the message.
    Id *int64 `mandatory:"true" json:"id"`

    // The time after which the message will be automatically deleted, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    ExpireAfter *common.SDKTime `mandatory:"false" json:"expireAfter"`
}

func (PutMessage) String

func (m PutMessage) String() string

func (PutMessage) ValidateEnumValue

func (m PutMessage) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type PutMessages

PutMessages A list of the messages published to a queue.

type PutMessages struct {

    // The messages that have been published to a queue.
    Messages []PutMessage `mandatory:"true" json:"messages"`
}

func (PutMessages) String

func (m PutMessages) String() string

func (PutMessages) ValidateEnumValue

func (m PutMessages) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type PutMessagesDetails

PutMessagesDetails The details of a PutMessages request.

type PutMessagesDetails struct {

    // The array of messages to put into a queue.
    Messages []PutMessagesDetailsEntry `mandatory:"true" json:"messages"`
}

func (PutMessagesDetails) String

func (m PutMessagesDetails) String() string

func (PutMessagesDetails) ValidateEnumValue

func (m PutMessagesDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type PutMessagesDetailsEntry

PutMessagesDetailsEntry Object that represents a message to publish into a queue.

type PutMessagesDetailsEntry struct {

    // The content of the message
    Content *string `mandatory:"true" json:"content"`

    Metadata *MessageMetadata `mandatory:"false" json:"metadata"`
}

func (PutMessagesDetailsEntry) String

func (m PutMessagesDetailsEntry) String() string

func (PutMessagesDetailsEntry) ValidateEnumValue

func (m PutMessagesDetailsEntry) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type PutMessagesRequest

PutMessagesRequest wrapper for the PutMessages operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/PutMessages.go.html to see an example of how to use PutMessagesRequest.

type PutMessagesRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // Details for the messages to publish.
    PutMessagesDetails `contributesTo:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (PutMessagesRequest) BinaryRequestBody

func (request PutMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (PutMessagesRequest) HTTPRequest

func (request PutMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (PutMessagesRequest) RetryPolicy

func (request PutMessagesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (PutMessagesRequest) String

func (request PutMessagesRequest) String() string

func (PutMessagesRequest) ValidateEnumValue

func (request PutMessagesRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type PutMessagesResponse

PutMessagesResponse wrapper for the PutMessages operation

type PutMessagesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The PutMessages instance
    PutMessages `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (PutMessagesResponse) HTTPResponse

func (response PutMessagesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (PutMessagesResponse) String

func (response PutMessagesResponse) String() string

type Queue

Queue A detailed representation of a queue and its configuration.

type Queue struct {

    // A unique identifier for the queue that is immutable on creation.
    Id *string `mandatory:"true" json:"id"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the compartment containing the queue.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The time that the queue was created, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    // The time that the queue was updated, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeUpdated *common.SDKTime `mandatory:"true" json:"timeUpdated"`

    // The current state of the queue.
    LifecycleState QueueLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The endpoint to use to consume or publish messages in the queue.
    MessagesEndpoint *string `mandatory:"true" json:"messagesEndpoint"`

    // The retention period of the messages in the queue, in seconds.
    RetentionInSeconds *int `mandatory:"true" json:"retentionInSeconds"`

    // The default visibility timeout of the messages consumed from the queue, in seconds.
    VisibilityInSeconds *int `mandatory:"true" json:"visibilityInSeconds"`

    // The default polling timeout of the messages in the queue, in seconds.
    TimeoutInSeconds *int `mandatory:"true" json:"timeoutInSeconds"`

    // The number of times a message can be delivered to a consumer before being moved to the dead letter queue. A value of 0 indicates that the DLQ is not used.
    DeadLetterQueueDeliveryCount *int `mandatory:"true" json:"deadLetterQueueDeliveryCount"`

    // A user-friendly name for the queue. Does not have to be unique, and it's changeable. Avoid entering confidential information.
    DisplayName *string `mandatory:"false" json:"displayName"`

    // Any additional details about the current state of the queue.
    LifecycleDetails *string `mandatory:"false" json:"lifecycleDetails"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the custom encryption key to be used to encrypt messages content.
    CustomEncryptionKeyId *string `mandatory:"false" json:"customEncryptionKeyId"`

    // Simple key-value pair that is applied without any predefined name, type or scope. Exists for cross-compatibility only.
    // Example: `{"bar-key": "value"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace.
    // Example: `{"foo-namespace": {"bar-key": "value"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`

    // Usage of system tag keys. These predefined keys are scoped to namespaces.
    // Example: `{"orcl-cloud": {"free-tier-retained": "true"}}`
    SystemTags map[string]map[string]interface{} `mandatory:"false" json:"systemTags"`

    // The percentage of allocated queue resources that can be consumed by a single channel. For example, if a queue has a storage limit of 2Gb, and a single channel consumption limit is 0.1 (10%), that means data size of a single channel  can't exceed 200Mb. Consumption limit of 100% (default) means that a single channel can consume up-to all allocated queue's resources.
    ChannelConsumptionLimit *int `mandatory:"false" json:"channelConsumptionLimit"`
}

func (Queue) String

func (m Queue) String() string

func (Queue) ValidateEnumValue

func (m Queue) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type QueueAdminClient

QueueAdminClient a client for QueueAdmin

type QueueAdminClient struct {
    common.BaseClient
    // contains filtered or unexported fields
}

func NewQueueAdminClientWithConfigurationProvider

func NewQueueAdminClientWithConfigurationProvider(configProvider common.ConfigurationProvider) (client QueueAdminClient, err error)

NewQueueAdminClientWithConfigurationProvider Creates a new default QueueAdmin client with the given configuration provider. the configuration provider will be used for the default signer as well as reading the region

func NewQueueAdminClientWithOboToken

func NewQueueAdminClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string) (client QueueAdminClient, err error)

NewQueueAdminClientWithOboToken Creates a new default QueueAdmin client with the given configuration provider. The obotoken will be added to default headers and signed; the configuration provider will be used for the signer

as well as reading the region

func (QueueAdminClient) ChangeQueueCompartment

func (client QueueAdminClient) ChangeQueueCompartment(ctx context.Context, request ChangeQueueCompartmentRequest) (response ChangeQueueCompartmentResponse, err error)

ChangeQueueCompartment Moves a queue from one compartment to another. When provided, If-Match is checked against ETag values of the resource.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ChangeQueueCompartment.go.html to see an example of how to use ChangeQueueCompartment API. A default retry strategy applies to this operation ChangeQueueCompartment()

func (*QueueAdminClient) ConfigurationProvider

func (client *QueueAdminClient) ConfigurationProvider() *common.ConfigurationProvider

ConfigurationProvider the ConfigurationProvider used in this client, or null if none set

func (QueueAdminClient) CreateQueue

func (client QueueAdminClient) CreateQueue(ctx context.Context, request CreateQueueRequest) (response CreateQueueResponse, err error)

CreateQueue Creates a new queue.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/CreateQueue.go.html to see an example of how to use CreateQueue API. A default retry strategy applies to this operation CreateQueue()

func (QueueAdminClient) DeleteQueue

func (client QueueAdminClient) DeleteQueue(ctx context.Context, request DeleteQueueRequest) (response DeleteQueueResponse, err error)

DeleteQueue Deletes a queue resource by identifier.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/DeleteQueue.go.html to see an example of how to use DeleteQueue API. A default retry strategy applies to this operation DeleteQueue()

func (QueueAdminClient) GetQueue

func (client QueueAdminClient) GetQueue(ctx context.Context, request GetQueueRequest) (response GetQueueResponse, err error)

GetQueue Gets a queue by identifier.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetQueue.go.html to see an example of how to use GetQueue API. A default retry strategy applies to this operation GetQueue()

func (QueueAdminClient) GetWorkRequest

func (client QueueAdminClient) GetWorkRequest(ctx context.Context, request GetWorkRequestRequest) (response GetWorkRequestResponse, err error)

GetWorkRequest Gets the status of the work request with the given ID.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetWorkRequest.go.html to see an example of how to use GetWorkRequest API. A default retry strategy applies to this operation GetWorkRequest()

func (QueueAdminClient) ListQueues

func (client QueueAdminClient) ListQueues(ctx context.Context, request ListQueuesRequest) (response ListQueuesResponse, err error)

ListQueues Returns a list of queues.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListQueues.go.html to see an example of how to use ListQueues API. A default retry strategy applies to this operation ListQueues()

func (QueueAdminClient) ListWorkRequestErrors

func (client QueueAdminClient) ListWorkRequestErrors(ctx context.Context, request ListWorkRequestErrorsRequest) (response ListWorkRequestErrorsResponse, err error)

ListWorkRequestErrors Return a (paginated) list of errors for a given work request.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListWorkRequestErrors.go.html to see an example of how to use ListWorkRequestErrors API. A default retry strategy applies to this operation ListWorkRequestErrors()

func (QueueAdminClient) ListWorkRequestLogs

func (client QueueAdminClient) ListWorkRequestLogs(ctx context.Context, request ListWorkRequestLogsRequest) (response ListWorkRequestLogsResponse, err error)

ListWorkRequestLogs Return a (paginated) list of logs for a given work request.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListWorkRequestLogs.go.html to see an example of how to use ListWorkRequestLogs API. A default retry strategy applies to this operation ListWorkRequestLogs()

func (QueueAdminClient) ListWorkRequests

func (client QueueAdminClient) ListWorkRequests(ctx context.Context, request ListWorkRequestsRequest) (response ListWorkRequestsResponse, err error)

ListWorkRequests Lists the work requests in a compartment.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListWorkRequests.go.html to see an example of how to use ListWorkRequests API. A default retry strategy applies to this operation ListWorkRequests()

func (QueueAdminClient) PurgeQueue

func (client QueueAdminClient) PurgeQueue(ctx context.Context, request PurgeQueueRequest) (response PurgeQueueResponse, err error)

PurgeQueue Deletes all messages present in the queue, or deletes all the messages in the specific channel at the time of invocation. Only one concurrent purge operation is supported for any given queue. However multiple concurrent purge operations are supported for different queues. Purge request without specification of target channels will clean up all messages in the queue and in the child channels.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/PurgeQueue.go.html to see an example of how to use PurgeQueue API. A default retry strategy applies to this operation PurgeQueue()

func (*QueueAdminClient) SetRegion

func (client *QueueAdminClient) SetRegion(region string)

SetRegion overrides the region of this client.

func (QueueAdminClient) UpdateQueue

func (client QueueAdminClient) UpdateQueue(ctx context.Context, request UpdateQueueRequest) (response UpdateQueueResponse, err error)

UpdateQueue Updates the specified queue.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/UpdateQueue.go.html to see an example of how to use UpdateQueue API. A default retry strategy applies to this operation UpdateQueue()

type QueueClient

QueueClient a client for Queue

type QueueClient struct {
    common.BaseClient
    // contains filtered or unexported fields
}

func NewQueueClientWithConfigurationProvider

func NewQueueClientWithConfigurationProvider(configProvider common.ConfigurationProvider) (client QueueClient, err error)

NewQueueClientWithConfigurationProvider Creates a new default Queue client with the given configuration provider. the configuration provider will be used for the default signer as well as reading the region

func NewQueueClientWithOboToken

func NewQueueClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string) (client QueueClient, err error)

NewQueueClientWithOboToken Creates a new default Queue client with the given configuration provider. The obotoken will be added to default headers and signed; the configuration provider will be used for the signer

as well as reading the region

func (*QueueClient) ConfigurationProvider

func (client *QueueClient) ConfigurationProvider() *common.ConfigurationProvider

ConfigurationProvider the ConfigurationProvider used in this client, or null if none set

func (QueueClient) DeleteMessage

func (client QueueClient) DeleteMessage(ctx context.Context, request DeleteMessageRequest) (response DeleteMessageResponse, err error)

DeleteMessage Deletes the message represented by the receipt from the queue. You must use the messages endpoint (https://docs.cloud.oracle.com/iaas/Content/queue/messages.htm#messages__messages-endpoint) to delete messages. The messages endpoint may be different for different queues. Use GetQueue to find the queue's `messagesEndpoint`.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/DeleteMessage.go.html to see an example of how to use DeleteMessage API. A default retry strategy applies to this operation DeleteMessage()

func (QueueClient) DeleteMessages

func (client QueueClient) DeleteMessages(ctx context.Context, request DeleteMessagesRequest) (response DeleteMessagesResponse, err error)

DeleteMessages Deletes multiple messages from the queue. You must use the messages endpoint (https://docs.cloud.oracle.com/iaas/Content/queue/messages.htm#messages__messages-endpoint) to delete messages. The messages endpoint may be different for different queues. Use GetQueue to find the queue's `messagesEndpoint`.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/DeleteMessages.go.html to see an example of how to use DeleteMessages API. A default retry strategy applies to this operation DeleteMessages()

func (QueueClient) GetMessages

func (client QueueClient) GetMessages(ctx context.Context, request GetMessagesRequest) (response GetMessagesResponse, err error)

GetMessages Consumes messages from the queue. You must use the messages endpoint (https://docs.cloud.oracle.com/iaas/Content/queue/messages.htm#messages__messages-endpoint) to consume messages. The messages endpoint may be different for different queues. Use GetQueue to find the queue's `messagesEndpoint`. GetMessages accepts optional channelFilter query parameter that can filter source channels of the messages. When channelFilter is present, service will return available messages from the channel which ID exactly matched the filter. When filter is not specified, messages will be returned from a random non-empty channel within a queue.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetMessages.go.html to see an example of how to use GetMessages API.

func (QueueClient) GetStats

func (client QueueClient) GetStats(ctx context.Context, request GetStatsRequest) (response GetStatsResponse, err error)

GetStats Gets the statistics for the queue and its dead letter queue. You must use the messages endpoint (https://docs.cloud.oracle.com/iaas/Content/queue/messages.htm#messages__messages-endpoint) to get a queue's statistics. The messages endpoint may be different for different queues. Use GetQueue to find the queue's `messagesEndpoint`.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/GetStats.go.html to see an example of how to use GetStats API. A default retry strategy applies to this operation GetStats()

func (QueueClient) ListChannels

func (client QueueClient) ListChannels(ctx context.Context, request ListChannelsRequest) (response ListChannelsResponse, err error)

ListChannels Gets the list of IDs of non-empty channels. It will return an approximate list of IDs of non-empty channels. That information is based on the queue level statistics. API supports optional channelFilter parameter which will filter the returned results according to the specified filter. List of channel IDs is approximate, because statistics is refreshed once per-second, and that list represents a snapshot of the past information. API is paginated.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/ListChannels.go.html to see an example of how to use ListChannels API. A default retry strategy applies to this operation ListChannels()

func (QueueClient) PutMessages

func (client QueueClient) PutMessages(ctx context.Context, request PutMessagesRequest) (response PutMessagesResponse, err error)

PutMessages Puts messages into the queue. You must use the messages endpoint (https://docs.cloud.oracle.com/iaas/Content/queue/messages.htm#messages__messages-endpoint) to produce messages. The messages endpoint may be different for different queues. Use GetQueue to find the queue's `messagesEndpoint`.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/PutMessages.go.html to see an example of how to use PutMessages API.

func (*QueueClient) SetRegion

func (client *QueueClient) SetRegion(region string)

SetRegion overrides the region of this client.

func (QueueClient) UpdateMessage

func (client QueueClient) UpdateMessage(ctx context.Context, request UpdateMessageRequest) (response UpdateMessageResponse, err error)

UpdateMessage Updates the visibility of the message represented by the receipt. You must use the messages endpoint (https://docs.cloud.oracle.com/iaas/Content/queue/messages.htm#messages__messages-endpoint) to update messages. The messages endpoint may be different for different queues. Use GetQueue to find the queue's `messagesEndpoint`.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/UpdateMessage.go.html to see an example of how to use UpdateMessage API. A default retry strategy applies to this operation UpdateMessage()

func (QueueClient) UpdateMessages

func (client QueueClient) UpdateMessages(ctx context.Context, request UpdateMessagesRequest) (response UpdateMessagesResponse, err error)

UpdateMessages Updates multiple messages in the queue. You must use the messages endpoint (https://docs.cloud.oracle.com/iaas/Content/queue/messages.htm#messages__messages-endpoint) to update messages. The messages endpoint may be different for different queues. Use GetQueue to find the queue's `messagesEndpoint`.

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/UpdateMessages.go.html to see an example of how to use UpdateMessages API. A default retry strategy applies to this operation UpdateMessages()

type QueueCollection

QueueCollection Results of a queue search. Contains both QueueSummary items and other information, such as metadata.

type QueueCollection struct {

    // List of queues.
    Items []QueueSummary `mandatory:"true" json:"items"`
}

func (QueueCollection) String

func (m QueueCollection) String() string

func (QueueCollection) ValidateEnumValue

func (m QueueCollection) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type QueueLifecycleStateEnum

QueueLifecycleStateEnum Enum with underlying type: string

type QueueLifecycleStateEnum string

Set of constants representing the allowable values for QueueLifecycleStateEnum

const (
    QueueLifecycleStateCreating QueueLifecycleStateEnum = "CREATING"
    QueueLifecycleStateUpdating QueueLifecycleStateEnum = "UPDATING"
    QueueLifecycleStateActive   QueueLifecycleStateEnum = "ACTIVE"
    QueueLifecycleStateDeleting QueueLifecycleStateEnum = "DELETING"
    QueueLifecycleStateDeleted  QueueLifecycleStateEnum = "DELETED"
    QueueLifecycleStateFailed   QueueLifecycleStateEnum = "FAILED"
)

func GetMappingQueueLifecycleStateEnum

func GetMappingQueueLifecycleStateEnum(val string) (QueueLifecycleStateEnum, bool)

GetMappingQueueLifecycleStateEnum performs case Insensitive comparison on enum value and return the desired enum

func GetQueueLifecycleStateEnumValues

func GetQueueLifecycleStateEnumValues() []QueueLifecycleStateEnum

GetQueueLifecycleStateEnumValues Enumerates the set of values for QueueLifecycleStateEnum

type QueueStats

QueueStats The stats for a queue and its dead letter queue. If channelId is specified in request field, it will return channel specific stats response.

type QueueStats struct {
    Queue *Stats `mandatory:"true" json:"queue"`

    Dlq *Stats `mandatory:"true" json:"dlq"`

    // If channelId is presented in GetStats call, the channel id will be returned in the GetStats response.
    ChannelId *string `mandatory:"false" json:"channelId"`
}

func (QueueStats) String

func (m QueueStats) String() string

func (QueueStats) ValidateEnumValue

func (m QueueStats) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type QueueSummary

QueueSummary Summary of the queue.

type QueueSummary struct {

    // A unique identifier for the queue that is immutable on creation.
    Id *string `mandatory:"true" json:"id"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the compartment containing the queue.
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The time that the queue was created, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"`

    // The time that the queue was updated, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    TimeUpdated *common.SDKTime `mandatory:"true" json:"timeUpdated"`

    // The current state of the queue.
    LifecycleState QueueLifecycleStateEnum `mandatory:"true" json:"lifecycleState"`

    // The endpoint to use to consume or publish messages in the queue.
    MessagesEndpoint *string `mandatory:"true" json:"messagesEndpoint"`

    // A user-friendly name for the queue. Does not have to be unique, and it's changeable. Avoid entering confidential information.
    DisplayName *string `mandatory:"false" json:"displayName"`

    // Any additional details about the current state of the queue.
    LifecycleDetails *string `mandatory:"false" json:"lifecycleDetails"`

    // Simple key-value pair that is applied without any predefined name, type or scope. Exists for cross-compatibility only.
    // Example: `{"bar-key": "value"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace.
    // Example: `{"foo-namespace": {"bar-key": "value"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`

    // Usage of system tag keys. These predefined keys are scoped to namespaces.
    // Example: `{"orcl-cloud": {"free-tier-retained": "true"}}`
    SystemTags map[string]map[string]interface{} `mandatory:"false" json:"systemTags"`
}

func (QueueSummary) String

func (m QueueSummary) String() string

func (QueueSummary) ValidateEnumValue

func (m QueueSummary) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type SortOrderEnum

SortOrderEnum Enum with underlying type: string

type SortOrderEnum string

Set of constants representing the allowable values for SortOrderEnum

const (
    SortOrderAsc  SortOrderEnum = "ASC"
    SortOrderDesc SortOrderEnum = "DESC"
)

func GetMappingSortOrderEnum

func GetMappingSortOrderEnum(val string) (SortOrderEnum, bool)

GetMappingSortOrderEnum performs case Insensitive comparison on enum value and return the desired enum

func GetSortOrderEnumValues

func GetSortOrderEnumValues() []SortOrderEnum

GetSortOrderEnumValues Enumerates the set of values for SortOrderEnum

type Stats

Stats The stats for a queue or a dead letter queue.

type Stats struct {

    // The approximate number of visible messages (available for delivery) currently in the queue.
    VisibleMessages *int64 `mandatory:"true" json:"visibleMessages"`

    // The approximate number of messages delivered to a consumer but not yet deleted and so unavailable for re-delivery.
    InFlightMessages *int64 `mandatory:"true" json:"inFlightMessages"`

    // The approximate size of the queue in bytes. Sum of the size of visible and in-flight messages.
    SizeInBytes *int64 `mandatory:"true" json:"sizeInBytes"`
}

func (Stats) String

func (m Stats) String() string

func (Stats) ValidateEnumValue

func (m Stats) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateMessageDetails

UpdateMessageDetails Updates the visibility of a message

type UpdateMessageDetails struct {

    // The new visibility of the message relative to the current time (as-per the clock of the server receiving the request).
    VisibilityInSeconds *int `mandatory:"true" json:"visibilityInSeconds"`
}

func (UpdateMessageDetails) String

func (m UpdateMessageDetails) String() string

func (UpdateMessageDetails) ValidateEnumValue

func (m UpdateMessageDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateMessageRequest

UpdateMessageRequest wrapper for the UpdateMessage operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/UpdateMessage.go.html to see an example of how to use UpdateMessageRequest.

type UpdateMessageRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // The receipt of the message retrieved from a GetMessages call.
    MessageReceipt *string `mandatory:"true" contributesTo:"path" name:"messageReceipt"`

    // Details for the message to update.
    UpdateMessageDetails `contributesTo:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (UpdateMessageRequest) BinaryRequestBody

func (request UpdateMessageRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (UpdateMessageRequest) HTTPRequest

func (request UpdateMessageRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (UpdateMessageRequest) RetryPolicy

func (request UpdateMessageRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (UpdateMessageRequest) String

func (request UpdateMessageRequest) String() string

func (UpdateMessageRequest) ValidateEnumValue

func (request UpdateMessageRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateMessageResponse

UpdateMessageResponse wrapper for the UpdateMessage operation

type UpdateMessageResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The UpdatedMessage instance
    UpdatedMessage `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (UpdateMessageResponse) HTTPResponse

func (response UpdateMessageResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (UpdateMessageResponse) String

func (response UpdateMessageResponse) String() string

type UpdateMessagesDetails

UpdateMessagesDetails The details of an UpdateMessages request.

type UpdateMessagesDetails struct {

    // The array of messages to update in a queue.
    Entries []UpdateMessagesDetailsEntry `mandatory:"true" json:"entries"`
}

func (UpdateMessagesDetails) String

func (m UpdateMessagesDetails) String() string

func (UpdateMessagesDetails) ValidateEnumValue

func (m UpdateMessagesDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateMessagesDetailsEntry

UpdateMessagesDetailsEntry Object that represents a message to update in a queue.

type UpdateMessagesDetailsEntry struct {

    // The receipt of the message to update.
    Receipt *string `mandatory:"true" json:"receipt"`

    // The new visibility of the message relative to the current time (as-per the clock of the server receiving the request).
    VisibilityInSeconds *int `mandatory:"true" json:"visibilityInSeconds"`
}

func (UpdateMessagesDetailsEntry) String

func (m UpdateMessagesDetailsEntry) String() string

func (UpdateMessagesDetailsEntry) ValidateEnumValue

func (m UpdateMessagesDetailsEntry) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateMessagesRequest

UpdateMessagesRequest wrapper for the UpdateMessages operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/UpdateMessages.go.html to see an example of how to use UpdateMessagesRequest.

type UpdateMessagesRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // Details for the messages to update.
    UpdateMessagesDetails `contributesTo:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (UpdateMessagesRequest) BinaryRequestBody

func (request UpdateMessagesRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (UpdateMessagesRequest) HTTPRequest

func (request UpdateMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (UpdateMessagesRequest) RetryPolicy

func (request UpdateMessagesRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (UpdateMessagesRequest) String

func (request UpdateMessagesRequest) String() string

func (UpdateMessagesRequest) ValidateEnumValue

func (request UpdateMessagesRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateMessagesResponse

UpdateMessagesResponse wrapper for the UpdateMessages operation

type UpdateMessagesResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // The UpdateMessagesResult instance
    UpdateMessagesResult `presentIn:"body"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (UpdateMessagesResponse) HTTPResponse

func (response UpdateMessagesResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (UpdateMessagesResponse) String

func (response UpdateMessagesResponse) String() string

type UpdateMessagesResult

UpdateMessagesResult The response to a UpdateMessages request. It indicates the number of server and client failures as well as an array of entries for successful and failed actions.

type UpdateMessagesResult struct {

    // The number of messages that failed to be updated in the queue because of a server failure.
    ServerFailures *int `mandatory:"true" json:"serverFailures"`

    // The number of messages that failed to be updated in the queue because of a client failure such as an invalid receipt or invalid `visibilityInSeconds`.
    ClientFailures *int `mandatory:"true" json:"clientFailures"`

    // An array of items representing the result of each action.
    // The order is guaranteed to be the same as in the `UpdateMessagesDetails` object.
    // If a message was successfully updated in the queue, the entry includes the `id` and `visibleAfter` fields.
    // If a message failed to be updated in the queue, the entry includes the `errorCode` and `errorMessage` fields.
    Entries []UpdateMessagesResultEntry `mandatory:"true" json:"entries"`
}

func (UpdateMessagesResult) String

func (m UpdateMessagesResult) String() string

func (UpdateMessagesResult) ValidateEnumValue

func (m UpdateMessagesResult) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateMessagesResultEntry

UpdateMessagesResultEntry Represents the result of a UpdateMessages request, whether it was successful or not. If a message was successfully updated in the queue, the entry includes the `id` and `visibleAfter` fields. If a message failed to be updated in the queue, the entry includes the `errorCode` and `errorMessage` fields.

type UpdateMessagesResultEntry struct {

    // The ID of the message that's been updated.
    Id *int64 `mandatory:"false" json:"id"`

    // The time after which the message will be visible to other consumers, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    VisibleAfter *common.SDKTime `mandatory:"false" json:"visibleAfter"`

    // The error code, in case the message was not successfully updated in the queue.
    ErrorCode *int `mandatory:"false" json:"errorCode"`

    // A human-readable error message associated with the error code.
    ErrorMessage *string `mandatory:"false" json:"errorMessage"`
}

func (UpdateMessagesResultEntry) String

func (m UpdateMessagesResultEntry) String() string

func (UpdateMessagesResultEntry) ValidateEnumValue

func (m UpdateMessagesResultEntry) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateQueueDetails

UpdateQueueDetails The information to be updated.

type UpdateQueueDetails struct {

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the queue.
    DisplayName *string `mandatory:"false" json:"displayName"`

    // The default visibility timeout of the messages consumed from the queue, in seconds.
    VisibilityInSeconds *int `mandatory:"false" json:"visibilityInSeconds"`

    // The default polling timeout of the messages in the queue, in seconds.
    TimeoutInSeconds *int `mandatory:"false" json:"timeoutInSeconds"`

    // The percentage of allocated queue resources that can be consumed by a single channel. For example, if a queue has a storage limit of 2Gb, and a single channel consumption limit is 0.1 (10%), that means data size of a single channel  can't exceed 200Mb. Consumption limit of 100% (default) means that a single channel can consume up-to all allocated queue's resources.
    ChannelConsumptionLimit *int `mandatory:"false" json:"channelConsumptionLimit"`

    // The number of times a message can be delivered to a consumer before being moved to the dead letter queue.
    // A value of 0 indicates that the DLQ is not used.
    // Changing that value to a lower threshold does not retroactively move in-flight messages in the dead letter queue.
    DeadLetterQueueDeliveryCount *int `mandatory:"false" json:"deadLetterQueueDeliveryCount"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the custom encryption key to be used to encrypt messages content. A string with a length of 0 means the custom key should be removed from queue.
    CustomEncryptionKeyId *string `mandatory:"false" json:"customEncryptionKeyId"`

    // Simple key-value pair that is applied without any predefined name, type or scope. Exists for cross-compatibility only.
    // Example: `{"bar-key": "value"}`
    FreeformTags map[string]string `mandatory:"false" json:"freeformTags"`

    // Defined tags for this resource. Each key is predefined and scoped to a namespace.
    // Example: `{"foo-namespace": {"bar-key": "value"}}`
    DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"`
}

func (UpdateQueueDetails) String

func (m UpdateQueueDetails) String() string

func (UpdateQueueDetails) ValidateEnumValue

func (m UpdateQueueDetails) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateQueueRequest

UpdateQueueRequest wrapper for the UpdateQueue operation

# See also

Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/65.62.0/queue/UpdateQueue.go.html to see an example of how to use UpdateQueueRequest.

type UpdateQueueRequest struct {

    // The unique queue identifier.
    QueueId *string `mandatory:"true" contributesTo:"path" name:"queueId"`

    // The information to be updated.
    UpdateQueueDetails `contributesTo:"body"`

    // For optimistic concurrency control. In the PUT or DELETE call
    // for a resource, set the `if-match` parameter to the value of the
    // etag from a previous GET or POST response for that resource.
    // The resource will be updated or deleted only if the etag you
    // provide matches the resource's current etag value.
    IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"`

    // Unique Oracle-assigned identifier for the request. If you need to contact Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"`

    // Metadata about the request. This information will not be transmitted to the service, but
    // represents information that the SDK will consume to drive retry behavior.
    RequestMetadata common.RequestMetadata
}

func (UpdateQueueRequest) BinaryRequestBody

func (request UpdateQueueRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)

BinaryRequestBody implements the OCIRequest interface

func (UpdateQueueRequest) HTTPRequest

func (request UpdateQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)

HTTPRequest implements the OCIRequest interface

func (UpdateQueueRequest) RetryPolicy

func (request UpdateQueueRequest) RetryPolicy() *common.RetryPolicy

RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.

func (UpdateQueueRequest) String

func (request UpdateQueueRequest) String() string

func (UpdateQueueRequest) ValidateEnumValue

func (request UpdateQueueRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type UpdateQueueResponse

UpdateQueueResponse wrapper for the UpdateQueue operation

type UpdateQueueResponse struct {

    // The underlying http response
    RawResponse *http.Response

    // Unique Oracle-assigned identifier for the asynchronous request. You can use this to query status of the asynchronous operation.
    OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"`

    // Unique Oracle-assigned identifier for the request. If you need to contact
    // Oracle about a particular request, please provide the request ID.
    OpcRequestId *string `presentIn:"header" name:"opc-request-id"`
}

func (UpdateQueueResponse) HTTPResponse

func (response UpdateQueueResponse) HTTPResponse() *http.Response

HTTPResponse implements the OCIResponse interface

func (UpdateQueueResponse) String

func (response UpdateQueueResponse) String() string

type UpdatedMessage

UpdatedMessage An updated message with the new visibility.

type UpdatedMessage struct {

    // The ID of the message that's been updated.
    Id *int64 `mandatory:"true" json:"id"`

    // The time after which the message will be visible to other consumers, expressed in RFC 3339 (https://tools.ietf.org/rfc/rfc3339) timestamp format.
    // Example: `2018-04-20T00:00:07.405Z`
    VisibleAfter *common.SDKTime `mandatory:"true" json:"visibleAfter"`
}

func (UpdatedMessage) String

func (m UpdatedMessage) String() string

func (UpdatedMessage) ValidateEnumValue

func (m UpdatedMessage) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequest

WorkRequest A description of workrequest status

type WorkRequest struct {

    // Type of the work request
    OperationType OperationTypeEnum `mandatory:"true" json:"operationType"`

    // Status of current work request.
    Status OperationStatusEnum `mandatory:"true" json:"status"`

    // The id of the work request.
    Id *string `mandatory:"true" json:"id"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the compartment that contains the work request. Work requests should be scoped to
    // the same compartment as the resource the work request affects. If the work request affects multiple resources,
    // and those resources are not in the same compartment, it is up to the service team to pick the primary
    // resource whose compartment should be used
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The resources affected by this work request.
    Resources []WorkRequestResource `mandatory:"true" json:"resources"`

    // Percentage of the request completed.
    PercentComplete *float32 `mandatory:"true" json:"percentComplete"`

    // The date and time the request was created, as described in
    // RFC 3339 (https://tools.ietf.org/rfc/rfc3339), section 14.29.
    TimeAccepted *common.SDKTime `mandatory:"true" json:"timeAccepted"`

    // The date and time the request was started, as described in RFC 3339 (https://tools.ietf.org/rfc/rfc3339),
    // section 14.29.
    TimeStarted *common.SDKTime `mandatory:"false" json:"timeStarted"`

    // The date and time the object was finished, as described in RFC 3339 (https://tools.ietf.org/rfc/rfc3339).
    TimeFinished *common.SDKTime `mandatory:"false" json:"timeFinished"`
}

func (WorkRequest) String

func (m WorkRequest) String() string

func (WorkRequest) ValidateEnumValue

func (m WorkRequest) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequestError

WorkRequestError An error encountered while executing a work request.

type WorkRequestError struct {

    // A machine-usable code for the error that occured. Error codes are listed on
    // (https://docs.cloud.oracle.com/Content/API/References/apierrors.htm)
    Code *string `mandatory:"true" json:"code"`

    // A human readable description of the issue encountered.
    Message *string `mandatory:"true" json:"message"`

    // The time the error occured. An RFC 3339 (https://tools.ietf.org/rfc/rfc3339) formatted datetime string.
    Timestamp *common.SDKTime `mandatory:"true" json:"timestamp"`
}

func (WorkRequestError) String

func (m WorkRequestError) String() string

func (WorkRequestError) ValidateEnumValue

func (m WorkRequestError) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequestErrorCollection

WorkRequestErrorCollection Results of a workRequestError search. Contains both WorkRequestError items and other information, such as metadata.

type WorkRequestErrorCollection struct {

    // List of workRequestError objects.
    Items []WorkRequestError `mandatory:"true" json:"items"`
}

func (WorkRequestErrorCollection) String

func (m WorkRequestErrorCollection) String() string

func (WorkRequestErrorCollection) ValidateEnumValue

func (m WorkRequestErrorCollection) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequestLogEntry

WorkRequestLogEntry A log message from the execution of a work request.

type WorkRequestLogEntry struct {

    // Human-readable log message.
    Message *string `mandatory:"true" json:"message"`

    // The time the log message was written. An RFC 3339 (https://tools.ietf.org/rfc/rfc3339) formatted datetime string
    Timestamp *common.SDKTime `mandatory:"true" json:"timestamp"`
}

func (WorkRequestLogEntry) String

func (m WorkRequestLogEntry) String() string

func (WorkRequestLogEntry) ValidateEnumValue

func (m WorkRequestLogEntry) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequestLogEntryCollection

WorkRequestLogEntryCollection Results of a workRequestLog search. Contains both workRequestLog items and other information, such as metadata.

type WorkRequestLogEntryCollection struct {

    // List of workRequestLogEntries.
    Items []WorkRequestLogEntry `mandatory:"true" json:"items"`
}

func (WorkRequestLogEntryCollection) String

func (m WorkRequestLogEntryCollection) String() string

func (WorkRequestLogEntryCollection) ValidateEnumValue

func (m WorkRequestLogEntryCollection) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequestResource

WorkRequestResource A resource created or operated on by a work request.

type WorkRequestResource struct {

    // The resource type the work request affects.
    EntityType *string `mandatory:"true" json:"entityType"`

    // The way in which this resource is affected by the work tracked in the work request.
    // A resource being created, updated, or deleted will remain in the IN_PROGRESS state until
    // work is complete for that resource at which point it will transition to CREATED, UPDATED,
    // or DELETED, respectively.
    ActionType ActionTypeEnum `mandatory:"true" json:"actionType"`

    // The identifier of the resource the work request affects.
    Identifier *string `mandatory:"true" json:"identifier"`

    // The URI path that the user can do a GET on to access the resource metadata
    EntityUri *string `mandatory:"false" json:"entityUri"`
}

func (WorkRequestResource) String

func (m WorkRequestResource) String() string

func (WorkRequestResource) ValidateEnumValue

func (m WorkRequestResource) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequestSummary

WorkRequestSummary A summary of the status of a work request.

type WorkRequestSummary struct {

    // Type of the work request
    OperationType OperationTypeEnum `mandatory:"true" json:"operationType"`

    // Status of current work request.
    Status OperationStatusEnum `mandatory:"true" json:"status"`

    // The ID of the work request.
    Id *string `mandatory:"true" json:"id"`

    // The OCID (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/identifiers.htm) of the compartment that contains the work request. Work requests should be scoped to
    // the same compartment as the resource the work request affects. If the work request affects multiple resources,
    // and those resources are not in the same compartment, it is up to the service team to pick the primary
    // resource whose compartment should be used
    CompartmentId *string `mandatory:"true" json:"compartmentId"`

    // The resources affected by this work request.
    Resources []WorkRequestResource `mandatory:"true" json:"resources"`

    // Percentage of the request completed.
    PercentComplete *float32 `mandatory:"true" json:"percentComplete"`

    // The date and time the request was created, as described in
    // RFC 3339 (https://tools.ietf.org/rfc/rfc3339), section 14.29.
    TimeAccepted *common.SDKTime `mandatory:"true" json:"timeAccepted"`

    // The date and time the request was started, as described in RFC 3339 (https://tools.ietf.org/rfc/rfc3339),
    // section 14.29.
    TimeStarted *common.SDKTime `mandatory:"false" json:"timeStarted"`

    // The date and time the object was finished, as described in RFC 3339 (https://tools.ietf.org/rfc/rfc3339).
    TimeFinished *common.SDKTime `mandatory:"false" json:"timeFinished"`
}

func (WorkRequestSummary) String

func (m WorkRequestSummary) String() string

func (WorkRequestSummary) ValidateEnumValue

func (m WorkRequestSummary) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly

type WorkRequestSummaryCollection

WorkRequestSummaryCollection Results of a workRequest search. Contains both WorkRequest items and other information, such as metadata.

type WorkRequestSummaryCollection struct {

    // List of workRequestSummary objects.
    Items []WorkRequestSummary `mandatory:"true" json:"items"`
}

func (WorkRequestSummaryCollection) String

func (m WorkRequestSummaryCollection) String() string

func (WorkRequestSummaryCollection) ValidateEnumValue

func (m WorkRequestSummaryCollection) ValidateEnumValue() (bool, error)

ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly