queue

package

Go to main page

Versions in this module

v65

v65.65.3

May 21, 2024

v65.65.2

May 14, 2024

v65.65.1

May 7, 2024

v65.65.0

Apr 30, 2024

v65.64.0

Apr 23, 2024

v65.63.2

Apr 16, 2024

v65.63.1

Apr 9, 2024

v65.63.0

Apr 2, 2024

v65.62.0

Mar 26, 2024

v65.61.2

Mar 19, 2024

v65.61.1

Mar 12, 2024

v65.61.0

Mar 5, 2024

v65.60.0

Feb 27, 2024

v65.59.0

Feb 20, 2024

v65.58.1

Feb 13, 2024

v65.58.0

Feb 6, 2024

v65.57.0

Jan 30, 2024

v65.56.1

Jan 23, 2024

v65.56.0

Jan 16, 2024

v65.55.1

Jan 9, 2024

v65.55.0

Dec 12, 2023

v65.54.0

Dec 4, 2023

v65.53.0

Nov 14, 2023

v65.52.1

Nov 7, 2023

v65.52.0

Oct 31, 2023

v65.51.0

Oct 24, 2023

v65.50.0

Oct 17, 2023

v65.49.4

Oct 10, 2023

v65.49.3

Oct 3, 2023

v65.49.2

Sep 26, 2023

v65.49.1

Sep 12, 2023

v65.49.0

Sep 5, 2023

Changes in this version

+ type ChannelCollection struct

+ Items []string

+ func (m ChannelCollection) String() string

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

type CreateQueueDetails

+ ChannelConsumptionLimit *int

type GetMessage

+ Metadata *MessageMetadata

type GetMessagesRequest

+ ChannelFilter *string

type GetStatsRequest

+ ChannelId *string

+ type ListChannelsRequest struct

+ ChannelFilter *string

+ Limit *int

+ OpcRequestId *string

+ Page *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request ListChannelsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request ListChannelsRequest) String() string

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

+ type ListChannelsResponse struct

+ OpcNextPage *string

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response ListChannelsResponse) String() string

+ type MessageMetadata struct

+ ChannelId *string

+ CustomProperties map[string]string

+ func (m MessageMetadata) String() string

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

type PurgeQueueDetails

+ ChannelIds []string

type PutMessage

+ ExpireAfter *common.SDKTime

type PutMessagesDetailsEntry

+ Metadata *MessageMetadata

type Queue

+ ChannelConsumptionLimit *int

type QueueClient

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

type QueueStats

+ ChannelId *string

type UpdateQueueDetails

+ ChannelConsumptionLimit *int

v65.48.0

Aug 29, 2023

v65.47.2

Aug 22, 2023

v65.47.1

Aug 15, 2023

v65.47.0

Aug 8, 2023

v65.46.0

Aug 1, 2023

v65.45.0

Jul 25, 2023

v65.44.0

Jul 18, 2023

v65.43.0

Jul 11, 2023

v65.42.0

Jun 27, 2023

v65.41.1

Jun 20, 2023

v65.41.0

Jun 13, 2023

v65.40.1

Jun 6, 2023

v65.40.0

May 30, 2023

v65.39.0

May 23, 2023

v65.38.0

May 16, 2023

v65.37.1

May 9, 2023

v65.37.0

May 2, 2023

v65.36.1

Apr 25, 2023

v65.36.0

Apr 18, 2023

v65.35.0

Apr 11, 2023

v65.34.0

Apr 4, 2023

v65.33.1

Mar 28, 2023

v65.33.0

Mar 21, 2023

v65.32.1

Mar 14, 2023

v65.32.0

Mar 7, 2023

v65.31.1

Feb 28, 2023

v65.31.0

Feb 21, 2023

v65.30.0

Feb 14, 2023

v65.29.0

Feb 7, 2023

v65.28.3

Jan 31, 2023

v65.28.2

Jan 24, 2023

v65.28.1

Jan 17, 2023

v65.28.0

Dec 13, 2022

Changes in this version

+ 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 string

+ const ActionTypeCreated

+ const ActionTypeDeleted

+ const ActionTypeInProgress

+ const ActionTypeRelated

+ const ActionTypeUpdated

+ func GetActionTypeEnumValues() []ActionTypeEnum

+ func GetMappingActionTypeEnum(val string) (ActionTypeEnum, bool)

+ type ChangeQueueCompartmentDetails struct

+ CompartmentId *string

+ func (m ChangeQueueCompartmentDetails) String() string

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

+ type ChangeQueueCompartmentRequest struct

+ IfMatch *string

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request ChangeQueueCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request ChangeQueueCompartmentRequest) String() string

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

+ type ChangeQueueCompartmentResponse struct

+ OpcRequestId *string

+ OpcWorkRequestId *string

+ RawResponse *http.Response

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

+ func (response ChangeQueueCompartmentResponse) String() string

+ type CreateQueueDetails struct

+ CompartmentId *string

+ CustomEncryptionKeyId *string

+ DeadLetterQueueDeliveryCount *int

+ DefinedTags map[string]map[string]interface{}

+ DisplayName *string

+ FreeformTags map[string]string

+ RetentionInSeconds *int

+ TimeoutInSeconds *int

+ VisibilityInSeconds *int

+ func (m CreateQueueDetails) String() string

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

+ type CreateQueueRequest struct

+ OpcRequestId *string

+ OpcRetryToken *string

+ RequestMetadata common.RequestMetadata

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

+ func (request CreateQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request CreateQueueRequest) String() string

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

+ type CreateQueueResponse struct

+ OpcRequestId *string

+ OpcWorkRequestId *string

+ RawResponse *http.Response

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

+ func (response CreateQueueResponse) String() string

+ type DeleteMessageRequest struct

+ MessageReceipt *string

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request DeleteMessageRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request DeleteMessageRequest) String() string

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

+ type DeleteMessageResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response DeleteMessageResponse) String() string

+ type DeleteMessagesDetails struct

+ Entries []DeleteMessagesDetailsEntry

+ func (m DeleteMessagesDetails) String() string

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

+ type DeleteMessagesDetailsEntry struct

+ Receipt *string

+ func (m DeleteMessagesDetailsEntry) String() string

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

+ type DeleteMessagesRequest struct

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request DeleteMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request DeleteMessagesRequest) String() string

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

+ type DeleteMessagesResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response DeleteMessagesResponse) String() string

+ type DeleteMessagesResult struct

+ ClientFailures *int

+ Entries []DeleteMessagesResultEntry

+ ServerFailures *int

+ func (m DeleteMessagesResult) String() string

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

+ type DeleteMessagesResultEntry struct

+ ErrorCode *int

+ ErrorMessage *string

+ func (m DeleteMessagesResultEntry) String() string

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

+ type DeleteQueueRequest struct

+ IfMatch *string

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request DeleteQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request DeleteQueueRequest) String() string

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

+ type DeleteQueueResponse struct

+ OpcRequestId *string

+ OpcWorkRequestId *string

+ RawResponse *http.Response

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

+ func (response DeleteQueueResponse) String() string

+ type GetMessage struct

+ Content *string

+ DeliveryCount *int

+ ExpireAfter *common.SDKTime

+ Id *int64

+ Receipt *string

+ VisibleAfter *common.SDKTime

+ func (m GetMessage) String() string

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

+ type GetMessages struct

+ Messages []GetMessage

+ func (m GetMessages) String() string

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

+ type GetMessagesRequest struct

+ Limit *int

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

+ TimeoutInSeconds *int

+ VisibilityInSeconds *int

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

+ func (request GetMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request GetMessagesRequest) String() string

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

+ type GetMessagesResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response GetMessagesResponse) String() string

+ type GetQueueRequest struct

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request GetQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request GetQueueRequest) String() string

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

+ type GetQueueResponse struct

+ Etag *string

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response GetQueueResponse) String() string

+ type GetStatsRequest struct

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request GetStatsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request GetStatsRequest) String() string

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

+ type GetStatsResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response GetStatsResponse) String() string

+ type GetWorkRequestRequest struct

+ OpcRequestId *string

+ RequestMetadata common.RequestMetadata

+ WorkRequestId *string

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

+ func (request GetWorkRequestRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request GetWorkRequestRequest) String() string

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

+ type GetWorkRequestResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

+ RetryAfter *int

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

+ func (response GetWorkRequestResponse) String() string

+ type ListQueuesRequest struct

+ CompartmentId *string

+ DisplayName *string

+ Id *string

+ LifecycleState QueueLifecycleStateEnum

+ Limit *int

+ OpcRequestId *string

+ Page *string

+ RequestMetadata common.RequestMetadata

+ SortBy ListQueuesSortByEnum

+ SortOrder ListQueuesSortOrderEnum

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

+ func (request ListQueuesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request ListQueuesRequest) String() string

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

+ type ListQueuesResponse struct

+ OpcNextPage *string

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response ListQueuesResponse) String() string

+ type ListQueuesSortByEnum string

+ const ListQueuesSortByDisplayname

+ const ListQueuesSortByTimecreated

+ func GetListQueuesSortByEnumValues() []ListQueuesSortByEnum

+ func GetMappingListQueuesSortByEnum(val string) (ListQueuesSortByEnum, bool)

+ type ListQueuesSortOrderEnum string

+ const ListQueuesSortOrderAsc

+ const ListQueuesSortOrderDesc

+ func GetListQueuesSortOrderEnumValues() []ListQueuesSortOrderEnum

+ func GetMappingListQueuesSortOrderEnum(val string) (ListQueuesSortOrderEnum, bool)

+ type ListWorkRequestErrorsRequest struct

+ Limit *int

+ OpcRequestId *string

+ Page *string

+ RequestMetadata common.RequestMetadata

+ WorkRequestId *string

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

+ func (request ListWorkRequestErrorsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request ListWorkRequestErrorsRequest) String() string

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

+ type ListWorkRequestErrorsResponse struct

+ OpcNextPage *string

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response ListWorkRequestErrorsResponse) String() string

+ type ListWorkRequestLogsRequest struct

+ Limit *int

+ OpcRequestId *string

+ Page *string

+ RequestMetadata common.RequestMetadata

+ WorkRequestId *string

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

+ func (request ListWorkRequestLogsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request ListWorkRequestLogsRequest) String() string

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

+ type ListWorkRequestLogsResponse struct

+ OpcNextPage *string

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response ListWorkRequestLogsResponse) String() string

+ type ListWorkRequestsRequest struct

+ CompartmentId *string

+ Limit *int

+ OpcRequestId *string

+ Page *string

+ RequestMetadata common.RequestMetadata

+ WorkRequestId *string

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

+ func (request ListWorkRequestsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request ListWorkRequestsRequest) String() string

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

+ type ListWorkRequestsResponse struct

+ OpcNextPage *string

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response ListWorkRequestsResponse) String() string

+ type OperationStatusEnum string

+ const OperationStatusAccepted

+ const OperationStatusCanceled

+ const OperationStatusCanceling

+ const OperationStatusFailed

+ const OperationStatusInProgress

+ const OperationStatusSucceeded

+ func GetMappingOperationStatusEnum(val string) (OperationStatusEnum, bool)

+ func GetOperationStatusEnumValues() []OperationStatusEnum

+ type OperationTypeEnum string

+ const OperationTypeCreateQueue

+ const OperationTypeDeleteQueue

+ const OperationTypeMoveQueue

+ const OperationTypePurgeQueue

+ const OperationTypeUpdateQueue

+ func GetMappingOperationTypeEnum(val string) (OperationTypeEnum, bool)

+ func GetOperationTypeEnumValues() []OperationTypeEnum

+ type PurgeQueueDetails struct

+ PurgeType PurgeQueueDetailsPurgeTypeEnum

+ func (m PurgeQueueDetails) String() string

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

+ type PurgeQueueDetailsPurgeTypeEnum string

+ const PurgeQueueDetailsPurgeTypeBoth

+ const PurgeQueueDetailsPurgeTypeDlq

+ const PurgeQueueDetailsPurgeTypeNormal

+ func GetMappingPurgeQueueDetailsPurgeTypeEnum(val string) (PurgeQueueDetailsPurgeTypeEnum, bool)

+ func GetPurgeQueueDetailsPurgeTypeEnumValues() []PurgeQueueDetailsPurgeTypeEnum

+ type PurgeQueueRequest struct

+ IfMatch *string

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request PurgeQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request PurgeQueueRequest) String() string

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

+ type PurgeQueueResponse struct

+ OpcRequestId *string

+ OpcWorkRequestId *string

+ RawResponse *http.Response

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

+ func (response PurgeQueueResponse) String() string

+ type PutMessage struct

+ Id *int64

+ func (m PutMessage) String() string

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

+ type PutMessages struct

+ Messages []PutMessage

+ func (m PutMessages) String() string

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

+ type PutMessagesDetails struct

+ Messages []PutMessagesDetailsEntry

+ func (m PutMessagesDetails) String() string

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

+ type PutMessagesDetailsEntry struct

+ Content *string

+ func (m PutMessagesDetailsEntry) String() string

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

+ type PutMessagesRequest struct

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request PutMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request PutMessagesRequest) String() string

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

+ type PutMessagesResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response PutMessagesResponse) String() string

+ type Queue struct

+ CompartmentId *string

+ CustomEncryptionKeyId *string

+ DeadLetterQueueDeliveryCount *int

+ DefinedTags map[string]map[string]interface{}

+ DisplayName *string

+ FreeformTags map[string]string

+ Id *string

+ LifecycleDetails *string

+ LifecycleState QueueLifecycleStateEnum

+ MessagesEndpoint *string

+ RetentionInSeconds *int

+ SystemTags map[string]map[string]interface{}

+ TimeCreated *common.SDKTime

+ TimeUpdated *common.SDKTime

+ TimeoutInSeconds *int

+ VisibilityInSeconds *int

+ func (m Queue) String() string

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

+ type QueueAdminClient struct

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

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

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

+ func (client *QueueAdminClient) SetRegion(region string)

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

+ 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) UpdateQueue(ctx context.Context, request UpdateQueueRequest) (response UpdateQueueResponse, err error)

+ type QueueClient struct

+ 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) SetRegion(region string)

+ 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) PutMessages(ctx context.Context, request PutMessagesRequest) (response PutMessagesResponse, err error)

+ 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 struct

+ Items []QueueSummary

+ func (m QueueCollection) String() string

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

+ type QueueLifecycleStateEnum string

+ const QueueLifecycleStateActive

+ const QueueLifecycleStateCreating

+ const QueueLifecycleStateDeleted

+ const QueueLifecycleStateDeleting

+ const QueueLifecycleStateFailed

+ const QueueLifecycleStateUpdating

+ func GetMappingQueueLifecycleStateEnum(val string) (QueueLifecycleStateEnum, bool)

+ func GetQueueLifecycleStateEnumValues() []QueueLifecycleStateEnum

+ type QueueStats struct

+ Dlq *Stats

+ Queue *Stats

+ func (m QueueStats) String() string

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

+ type QueueSummary struct

+ CompartmentId *string

+ DefinedTags map[string]map[string]interface{}

+ DisplayName *string

+ FreeformTags map[string]string

+ Id *string

+ LifecycleDetails *string

+ LifecycleState QueueLifecycleStateEnum

+ MessagesEndpoint *string

+ SystemTags map[string]map[string]interface{}

+ TimeCreated *common.SDKTime

+ TimeUpdated *common.SDKTime

+ func (m QueueSummary) String() string

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

+ type SortOrderEnum string

+ const SortOrderAsc

+ const SortOrderDesc

+ func GetMappingSortOrderEnum(val string) (SortOrderEnum, bool)

+ func GetSortOrderEnumValues() []SortOrderEnum

+ type Stats struct

+ InFlightMessages *int64

+ SizeInBytes *int64

+ VisibleMessages *int64

+ func (m Stats) String() string

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

+ type UpdateMessageDetails struct

+ VisibilityInSeconds *int

+ func (m UpdateMessageDetails) String() string

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

+ type UpdateMessageRequest struct

+ MessageReceipt *string

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request UpdateMessageRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request UpdateMessageRequest) String() string

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

+ type UpdateMessageResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response UpdateMessageResponse) String() string

+ type UpdateMessagesDetails struct

+ Entries []UpdateMessagesDetailsEntry

+ func (m UpdateMessagesDetails) String() string

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

+ type UpdateMessagesDetailsEntry struct

+ Receipt *string

+ VisibilityInSeconds *int

+ func (m UpdateMessagesDetailsEntry) String() string

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

+ type UpdateMessagesRequest struct

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request UpdateMessagesRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request UpdateMessagesRequest) String() string

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

+ type UpdateMessagesResponse struct

+ OpcRequestId *string

+ RawResponse *http.Response

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

+ func (response UpdateMessagesResponse) String() string

+ type UpdateMessagesResult struct

+ ClientFailures *int

+ Entries []UpdateMessagesResultEntry

+ ServerFailures *int

+ func (m UpdateMessagesResult) String() string

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

+ type UpdateMessagesResultEntry struct

+ ErrorCode *int

+ ErrorMessage *string

+ Id *int64

+ VisibleAfter *common.SDKTime

+ func (m UpdateMessagesResultEntry) String() string

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

+ type UpdateQueueDetails struct

+ CustomEncryptionKeyId *string

+ DeadLetterQueueDeliveryCount *int

+ DefinedTags map[string]map[string]interface{}

+ DisplayName *string

+ FreeformTags map[string]string

+ TimeoutInSeconds *int

+ VisibilityInSeconds *int

+ func (m UpdateQueueDetails) String() string

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

+ type UpdateQueueRequest struct

+ IfMatch *string

+ OpcRequestId *string

+ QueueId *string

+ RequestMetadata common.RequestMetadata

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

+ func (request UpdateQueueRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)

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

+ func (request UpdateQueueRequest) String() string

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

+ type UpdateQueueResponse struct

+ OpcRequestId *string

+ OpcWorkRequestId *string

+ RawResponse *http.Response

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

+ func (response UpdateQueueResponse) String() string

+ type UpdatedMessage struct

+ Id *int64

+ VisibleAfter *common.SDKTime

+ func (m UpdatedMessage) String() string

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

+ type WorkRequest struct

+ CompartmentId *string

+ Id *string

+ OperationType OperationTypeEnum

+ PercentComplete *float32

+ Resources []WorkRequestResource

+ Status OperationStatusEnum

+ TimeAccepted *common.SDKTime

+ TimeFinished *common.SDKTime

+ TimeStarted *common.SDKTime

+ func (m WorkRequest) String() string

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

+ type WorkRequestError struct

+ Code *string

+ Message *string

+ Timestamp *common.SDKTime

+ func (m WorkRequestError) String() string

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

+ type WorkRequestErrorCollection struct

+ Items []WorkRequestError

+ func (m WorkRequestErrorCollection) String() string

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

+ type WorkRequestLogEntry struct

+ Message *string

+ Timestamp *common.SDKTime

+ func (m WorkRequestLogEntry) String() string

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

+ type WorkRequestLogEntryCollection struct

+ Items []WorkRequestLogEntry

+ func (m WorkRequestLogEntryCollection) String() string

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

+ type WorkRequestResource struct

+ ActionType ActionTypeEnum

+ EntityType *string

+ EntityUri *string

+ Identifier *string

+ func (m WorkRequestResource) String() string

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

+ type WorkRequestSummary struct

+ CompartmentId *string

+ Id *string

+ OperationType OperationTypeEnum

+ PercentComplete *float32

+ Resources []WorkRequestResource

+ Status OperationStatusEnum

+ TimeAccepted *common.SDKTime

+ TimeFinished *common.SDKTime

+ TimeStarted *common.SDKTime

+ func (m WorkRequestSummary) String() string

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

+ type WorkRequestSummaryCollection struct

+ Items []WorkRequestSummary

+ func (m WorkRequestSummaryCollection) String() string

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL