queues

type ASN = shared.ASN

type ASNParam = shared.ASNParam

type AuditLog = shared.AuditLog

type AuditLogAction = shared.AuditLogAction

type AuditLogActor = shared.AuditLogActor

type AuditLogActorType = shared.AuditLogActorType

type AuditLogOwner = shared.AuditLogOwner

type AuditLogResource = shared.AuditLogResource

type CertificateCA = shared.CertificateCA

type CertificateRequestType = shared.CertificateRequestType

type CloudflareTunnel = shared.CloudflareTunnel

type CloudflareTunnelConfigSrc = shared.CloudflareTunnelConfigSrc

type CloudflareTunnelConnection = shared.CloudflareTunnelConnection

type CloudflareTunnelStatus = shared.CloudflareTunnelStatus

type CloudflareTunnelTunType = shared.CloudflareTunnelTunType

type Consumer struct {
	// A Resource identifier.
	ConsumerID string `json:"consumer_id"`
	CreatedOn  string `json:"created_on"`
	// A Resource identifier.
	QueueID string `json:"queue_id"`
	// Name of a Worker
	Script string `json:"script"`
	// This field can have the runtime type of [ConsumerMqWorkerConsumerSettings],
	// [ConsumerMqHTTPConsumerSettings].
	Settings interface{}  `json:"settings"`
	Type     ConsumerType `json:"type"`
	JSON     consumerJSON `json:"-"`
	// contains filtered or unexported fields
}

type ConsumerDeleteParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type ConsumerDeleteResponse struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	// Indicates if the API call was successful or not.
	Success ConsumerDeleteResponseSuccess `json:"success"`
	JSON    consumerDeleteResponseJSON    `json:"-"`
}

type ConsumerDeleteResponseSuccess bool

type ConsumerGetParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type ConsumerGetResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Consumer              `json:"result"`
	// Indicates if the API call was successful or not.
	Success ConsumerGetResponseEnvelopeSuccess `json:"success"`
	JSON    consumerGetResponseEnvelopeJSON    `json:"-"`
}

type ConsumerGetResponseEnvelopeSuccess bool

type ConsumerListParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type ConsumerMqHTTPConsumer struct {
	// A Resource identifier.
	ConsumerID string `json:"consumer_id"`
	CreatedOn  string `json:"created_on"`
	// A Resource identifier.
	QueueID  string                         `json:"queue_id"`
	Settings ConsumerMqHTTPConsumerSettings `json:"settings"`
	Type     ConsumerMqHTTPConsumerType     `json:"type"`
	JSON     consumerMqHTTPConsumerJSON     `json:"-"`
}

type ConsumerMqHTTPConsumerParam struct {
	Settings param.Field[ConsumerMqHTTPConsumerSettingsParam] `json:"settings"`
	Type     param.Field[ConsumerMqHTTPConsumerType]          `json:"type"`
}

type ConsumerMqHTTPConsumerSettings struct {
	// The maximum number of messages to include in a batch.
	BatchSize float64 `json:"batch_size"`
	// The maximum number of retries
	MaxRetries float64 `json:"max_retries"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay float64 `json:"retry_delay"`
	// The number of milliseconds that a message is exclusively leased. After the
	// timeout, the message becomes available for another attempt.
	VisibilityTimeoutMs float64                            `json:"visibility_timeout_ms"`
	JSON                consumerMqHTTPConsumerSettingsJSON `json:"-"`
}

type ConsumerMqHTTPConsumerSettingsParam struct {
	// The maximum number of messages to include in a batch.
	BatchSize param.Field[float64] `json:"batch_size"`
	// The maximum number of retries
	MaxRetries param.Field[float64] `json:"max_retries"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay param.Field[float64] `json:"retry_delay"`
	// The number of milliseconds that a message is exclusively leased. After the
	// timeout, the message becomes available for another attempt.
	VisibilityTimeoutMs param.Field[float64] `json:"visibility_timeout_ms"`
}

type ConsumerMqHTTPConsumerType string

type ConsumerMqWorkerConsumer struct {
	// A Resource identifier.
	ConsumerID string `json:"consumer_id"`
	CreatedOn  string `json:"created_on"`
	// A Resource identifier.
	QueueID string `json:"queue_id"`
	// Name of a Worker
	Script   string                           `json:"script"`
	Settings ConsumerMqWorkerConsumerSettings `json:"settings"`
	Type     ConsumerMqWorkerConsumerType     `json:"type"`
	JSON     consumerMqWorkerConsumerJSON     `json:"-"`
}

type ConsumerMqWorkerConsumerParam struct {
	// Name of a Worker
	ScriptName param.Field[string]                                `json:"script_name"`
	Settings   param.Field[ConsumerMqWorkerConsumerSettingsParam] `json:"settings"`
	Type       param.Field[ConsumerMqWorkerConsumerType]          `json:"type"`
}

type ConsumerMqWorkerConsumerSettings struct {
	// The maximum number of messages to include in a batch.
	BatchSize float64 `json:"batch_size"`
	// Maximum number of concurrent consumers that may consume from this Queue. Set to
	// `null` to automatically opt in to the platform's maximum (recommended).
	MaxConcurrency float64 `json:"max_concurrency"`
	// The maximum number of retries
	MaxRetries float64 `json:"max_retries"`
	// The number of milliseconds to wait for a batch to fill up before attempting to
	// deliver it
	MaxWaitTimeMs float64 `json:"max_wait_time_ms"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay float64                              `json:"retry_delay"`
	JSON       consumerMqWorkerConsumerSettingsJSON `json:"-"`
}

type ConsumerMqWorkerConsumerSettingsParam struct {
	// The maximum number of messages to include in a batch.
	BatchSize param.Field[float64] `json:"batch_size"`
	// Maximum number of concurrent consumers that may consume from this Queue. Set to
	// `null` to automatically opt in to the platform's maximum (recommended).
	MaxConcurrency param.Field[float64] `json:"max_concurrency"`
	// The maximum number of retries
	MaxRetries param.Field[float64] `json:"max_retries"`
	// The number of milliseconds to wait for a batch to fill up before attempting to
	// deliver it
	MaxWaitTimeMs param.Field[float64] `json:"max_wait_time_ms"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay param.Field[float64] `json:"retry_delay"`
}

type ConsumerMqWorkerConsumerType string

type ConsumerNewParams struct {
	// A Resource identifier.
	AccountID param.Field[string]        `path:"account_id,required"`
	Body      ConsumerNewParamsBodyUnion `json:"body"`
}

type ConsumerNewParamsBody struct {
	DeadLetterQueue param.Field[string] `json:"dead_letter_queue"`
	// Name of a Worker
	ScriptName param.Field[string]                    `json:"script_name"`
	Settings   param.Field[interface{}]               `json:"settings"`
	Type       param.Field[ConsumerNewParamsBodyType] `json:"type"`
}

type ConsumerNewParamsBodyMqHTTPConsumer struct {
	DeadLetterQueue param.Field[string]                                      `json:"dead_letter_queue"`
	Settings        param.Field[ConsumerNewParamsBodyMqHTTPConsumerSettings] `json:"settings"`
	Type            param.Field[ConsumerNewParamsBodyMqHTTPConsumerType]     `json:"type"`
}

type ConsumerNewParamsBodyMqHTTPConsumerSettings struct {
	// The maximum number of messages to include in a batch.
	BatchSize param.Field[float64] `json:"batch_size"`
	// The maximum number of retries
	MaxRetries param.Field[float64] `json:"max_retries"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay param.Field[float64] `json:"retry_delay"`
	// The number of milliseconds that a message is exclusively leased. After the
	// timeout, the message becomes available for another attempt.
	VisibilityTimeoutMs param.Field[float64] `json:"visibility_timeout_ms"`
}

type ConsumerNewParamsBodyMqHTTPConsumerType string

type ConsumerNewParamsBodyMqWorkerConsumer struct {
	DeadLetterQueue param.Field[string] `json:"dead_letter_queue"`
	// Name of a Worker
	ScriptName param.Field[string]                                        `json:"script_name"`
	Settings   param.Field[ConsumerNewParamsBodyMqWorkerConsumerSettings] `json:"settings"`
	Type       param.Field[ConsumerNewParamsBodyMqWorkerConsumerType]     `json:"type"`
}

type ConsumerNewParamsBodyMqWorkerConsumerSettings struct {
	// The maximum number of messages to include in a batch.
	BatchSize param.Field[float64] `json:"batch_size"`
	// Maximum number of concurrent consumers that may consume from this Queue. Set to
	// `null` to automatically opt in to the platform's maximum (recommended).
	MaxConcurrency param.Field[float64] `json:"max_concurrency"`
	// The maximum number of retries
	MaxRetries param.Field[float64] `json:"max_retries"`
	// The number of milliseconds to wait for a batch to fill up before attempting to
	// deliver it
	MaxWaitTimeMs param.Field[float64] `json:"max_wait_time_ms"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay param.Field[float64] `json:"retry_delay"`
}

type ConsumerNewParamsBodyMqWorkerConsumerType string

type ConsumerNewParamsBodyType string

type ConsumerNewParamsBodyUnion interface {
	// contains filtered or unexported methods
}

type ConsumerNewResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Consumer              `json:"result"`
	// Indicates if the API call was successful or not.
	Success ConsumerNewResponseEnvelopeSuccess `json:"success"`
	JSON    consumerNewResponseEnvelopeJSON    `json:"-"`
}

type ConsumerNewResponseEnvelopeSuccess bool

type ConsumerParam struct {
	// Name of a Worker
	ScriptName param.Field[string]       `json:"script_name"`
	Settings   param.Field[interface{}]  `json:"settings"`
	Type       param.Field[ConsumerType] `json:"type"`
}

type ConsumerService struct {
	Options []option.RequestOption
}

type ConsumerType string

type ConsumerUnion interface {
	// contains filtered or unexported methods
}

type ConsumerUnionParam interface {
	// contains filtered or unexported methods
}

type ConsumerUpdateParams struct {
	// A Resource identifier.
	AccountID param.Field[string]           `path:"account_id,required"`
	Body      ConsumerUpdateParamsBodyUnion `json:"body,required"`
}

type ConsumerUpdateParamsBody struct {
	DeadLetterQueue param.Field[string] `json:"dead_letter_queue"`
	// Name of a Worker
	ScriptName param.Field[string]                       `json:"script_name"`
	Settings   param.Field[interface{}]                  `json:"settings"`
	Type       param.Field[ConsumerUpdateParamsBodyType] `json:"type"`
}

type ConsumerUpdateParamsBodyMqHTTPConsumer struct {
	DeadLetterQueue param.Field[string]                                         `json:"dead_letter_queue"`
	Settings        param.Field[ConsumerUpdateParamsBodyMqHTTPConsumerSettings] `json:"settings"`
	Type            param.Field[ConsumerUpdateParamsBodyMqHTTPConsumerType]     `json:"type"`
}

type ConsumerUpdateParamsBodyMqHTTPConsumerSettings struct {
	// The maximum number of messages to include in a batch.
	BatchSize param.Field[float64] `json:"batch_size"`
	// The maximum number of retries
	MaxRetries param.Field[float64] `json:"max_retries"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay param.Field[float64] `json:"retry_delay"`
	// The number of milliseconds that a message is exclusively leased. After the
	// timeout, the message becomes available for another attempt.
	VisibilityTimeoutMs param.Field[float64] `json:"visibility_timeout_ms"`
}

type ConsumerUpdateParamsBodyMqHTTPConsumerType string

type ConsumerUpdateParamsBodyMqWorkerConsumer struct {
	DeadLetterQueue param.Field[string] `json:"dead_letter_queue"`
	// Name of a Worker
	ScriptName param.Field[string]                                           `json:"script_name"`
	Settings   param.Field[ConsumerUpdateParamsBodyMqWorkerConsumerSettings] `json:"settings"`
	Type       param.Field[ConsumerUpdateParamsBodyMqWorkerConsumerType]     `json:"type"`
}

type ConsumerUpdateParamsBodyMqWorkerConsumerSettings struct {
	// The maximum number of messages to include in a batch.
	BatchSize param.Field[float64] `json:"batch_size"`
	// Maximum number of concurrent consumers that may consume from this Queue. Set to
	// `null` to automatically opt in to the platform's maximum (recommended).
	MaxConcurrency param.Field[float64] `json:"max_concurrency"`
	// The maximum number of retries
	MaxRetries param.Field[float64] `json:"max_retries"`
	// The number of milliseconds to wait for a batch to fill up before attempting to
	// deliver it
	MaxWaitTimeMs param.Field[float64] `json:"max_wait_time_ms"`
	// The number of seconds to delay before making the message available for another
	// attempt.
	RetryDelay param.Field[float64] `json:"retry_delay"`
}

type ConsumerUpdateParamsBodyMqWorkerConsumerType string

type ConsumerUpdateParamsBodyType string

type ConsumerUpdateParamsBodyUnion interface {
	// contains filtered or unexported methods
}

type ConsumerUpdateResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Consumer              `json:"result"`
	// Indicates if the API call was successful or not.
	Success ConsumerUpdateResponseEnvelopeSuccess `json:"success"`
	JSON    consumerUpdateResponseEnvelopeJSON    `json:"-"`
}

type ConsumerUpdateResponseEnvelopeSuccess bool

type Error = apierror.Error

type ErrorData = shared.ErrorData

type ErrorDataSource = shared.ErrorDataSource

type Member = shared.Member

type MemberPoliciesAccess = shared.MemberPoliciesAccess

type MemberPoliciesPermissionGroup = shared.MemberPoliciesPermissionGroup

type MemberPoliciesPermissionGroupsMeta = shared.MemberPoliciesPermissionGroupsMeta

type MemberPoliciesResourceGroup = shared.MemberPoliciesResourceGroup

type MemberPoliciesResourceGroupsMeta = shared.MemberPoliciesResourceGroupsMeta

type MemberPoliciesResourceGroupsScope = shared.MemberPoliciesResourceGroupsScope

type MemberPoliciesResourceGroupsScopeObject = shared.MemberPoliciesResourceGroupsScopeObject

type MemberPolicy = shared.MemberPolicy

type MemberStatus = shared.MemberStatus

type MemberUser = shared.MemberUser

type MessageAckParams struct {
	// A Resource identifier.
	AccountID param.Field[string]                  `path:"account_id,required"`
	Acks      param.Field[[]MessageAckParamsAck]   `json:"acks"`
	Retries   param.Field[[]MessageAckParamsRetry] `json:"retries"`
}

type MessageAckParamsAck struct {
	// An ID that represents an "in-flight" message that has been pulled from a Queue.
	// You must hold on to this ID and use it to acknowledge this message.
	LeaseID param.Field[string] `json:"lease_id"`
}

type MessageAckParamsRetry struct {
	// The number of seconds to delay before making the message available for another
	// attempt.
	DelaySeconds param.Field[float64] `json:"delay_seconds"`
	// An ID that represents an "in-flight" message that has been pulled from a Queue.
	// You must hold on to this ID and use it to acknowledge this message.
	LeaseID param.Field[string] `json:"lease_id"`
}

type MessageAckResponse struct {
	// The number of messages that were succesfully acknowledged.
	AckCount float64 `json:"ackCount"`
	// The number of messages that were succesfully retried.
	RetryCount float64                `json:"retryCount"`
	Warnings   []string               `json:"warnings"`
	JSON       messageAckResponseJSON `json:"-"`
}

type MessageAckResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   MessageAckResponse    `json:"result"`
	// Indicates if the API call was successful or not.
	Success MessageAckResponseEnvelopeSuccess `json:"success"`
	JSON    messageAckResponseEnvelopeJSON    `json:"-"`
}

type MessageAckResponseEnvelopeSuccess bool

type MessageBulkPushParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	// The number of seconds to wait for attempting to deliver this batch to consumers
	DelaySeconds param.Field[float64]                             `json:"delay_seconds"`
	Messages     param.Field[[]MessageBulkPushParamsMessageUnion] `json:"messages"`
}

type MessageBulkPushParamsMessage struct {
	Body        param.Field[interface{}]                              `json:"body"`
	ContentType param.Field[MessageBulkPushParamsMessagesContentType] `json:"content_type"`
	// The number of seconds to wait for attempting to deliver this message to
	// consumers
	DelaySeconds param.Field[float64] `json:"delay_seconds"`
}

type MessageBulkPushParamsMessageUnion interface {
	// contains filtered or unexported methods
}

type MessageBulkPushParamsMessagesContentType string

type MessageBulkPushParamsMessagesMqQueueMessageJson struct {
	Body        param.Field[interface{}]                                                `json:"body"`
	ContentType param.Field[MessageBulkPushParamsMessagesMqQueueMessageJsonContentType] `json:"content_type"`
	// The number of seconds to wait for attempting to deliver this message to
	// consumers
	DelaySeconds param.Field[float64] `json:"delay_seconds"`
}

type MessageBulkPushParamsMessagesMqQueueMessageJsonContentType string

type MessageBulkPushParamsMessagesMqQueueMessageText struct {
	Body        param.Field[string]                                                     `json:"body"`
	ContentType param.Field[MessageBulkPushParamsMessagesMqQueueMessageTextContentType] `json:"content_type"`
	// The number of seconds to wait for attempting to deliver this message to
	// consumers
	DelaySeconds param.Field[float64] `json:"delay_seconds"`
}

type MessageBulkPushParamsMessagesMqQueueMessageTextContentType string

type MessageBulkPushResponse struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	// Indicates if the API call was successful or not.
	Success MessageBulkPushResponseSuccess `json:"success"`
	JSON    messageBulkPushResponseJSON    `json:"-"`
}

type MessageBulkPushResponseSuccess bool

type MessagePullParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	// The maximum number of messages to include in a batch.
	BatchSize param.Field[float64] `json:"batch_size"`
	// The number of milliseconds that a message is exclusively leased. After the
	// timeout, the message becomes available for another attempt.
	VisibilityTimeoutMs param.Field[float64] `json:"visibility_timeout_ms"`
}

type MessagePullResponse struct {
	// The number of unacknowledged messages in the queue
	MessageBacklogCount float64                      `json:"message_backlog_count"`
	Messages            []MessagePullResponseMessage `json:"messages"`
	JSON                messagePullResponseJSON      `json:"-"`
}

type MessagePullResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   MessagePullResponse   `json:"result"`
	// Indicates if the API call was successful or not.
	Success MessagePullResponseEnvelopeSuccess `json:"success"`
	JSON    messagePullResponseEnvelopeJSON    `json:"-"`
}

type MessagePullResponseEnvelopeSuccess bool

type MessagePullResponseMessage struct {
	ID       string  `json:"id"`
	Attempts float64 `json:"attempts"`
	Body     string  `json:"body"`
	// An ID that represents an "in-flight" message that has been pulled from a Queue.
	// You must hold on to this ID and use it to acknowledge this message.
	LeaseID     string                         `json:"lease_id"`
	Metadata    interface{}                    `json:"metadata"`
	TimestampMs float64                        `json:"timestamp_ms"`
	JSON        messagePullResponseMessageJSON `json:"-"`
}

type MessagePushParams struct {
	// A Resource identifier.
	AccountID param.Field[string]        `path:"account_id,required"`
	Body      MessagePushParamsBodyUnion `json:"body"`
}

type MessagePushParamsBody struct {
	Body        param.Field[interface{}]                      `json:"body"`
	ContentType param.Field[MessagePushParamsBodyContentType] `json:"content_type"`
	// The number of seconds to wait for attempting to deliver this message to
	// consumers
	DelaySeconds param.Field[float64] `json:"delay_seconds"`
}

type MessagePushParamsBodyContentType string

type MessagePushParamsBodyMqQueueMessageJson struct {
	Body        param.Field[interface{}]                                        `json:"body"`
	ContentType param.Field[MessagePushParamsBodyMqQueueMessageJsonContentType] `json:"content_type"`
	// The number of seconds to wait for attempting to deliver this message to
	// consumers
	DelaySeconds param.Field[float64] `json:"delay_seconds"`
}

type MessagePushParamsBodyMqQueueMessageJsonContentType string

type MessagePushParamsBodyMqQueueMessageText struct {
	Body        param.Field[string]                                             `json:"body"`
	ContentType param.Field[MessagePushParamsBodyMqQueueMessageTextContentType] `json:"content_type"`
	// The number of seconds to wait for attempting to deliver this message to
	// consumers
	DelaySeconds param.Field[float64] `json:"delay_seconds"`
}

type MessagePushParamsBodyMqQueueMessageTextContentType string

type MessagePushParamsBodyUnion interface {
	// contains filtered or unexported methods
}

type MessagePushResponse struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	// Indicates if the API call was successful or not.
	Success MessagePushResponseSuccess `json:"success"`
	JSON    messagePushResponseJSON    `json:"-"`
}

type MessagePushResponseSuccess bool

type MessageService struct {
	Options []option.RequestOption
}

type Permission = shared.Permission

type PermissionGrant = shared.PermissionGrant

type PermissionGrantParam = shared.PermissionGrantParam

type PurgeService struct {
	Options []option.RequestOption
}

type PurgeStartParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	// Confimation that all messages will be deleted permanently.
	DeleteMessagesPermanently param.Field[bool] `json:"delete_messages_permanently"`
}

type PurgeStartResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Queue                 `json:"result"`
	// Indicates if the API call was successful or not.
	Success PurgeStartResponseEnvelopeSuccess `json:"success"`
	JSON    purgeStartResponseEnvelopeJSON    `json:"-"`
}

type PurgeStartResponseEnvelopeSuccess bool

type PurgeStatusParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type PurgeStatusResponse struct {
	// Indicates if the last purge operation completed successfully.
	Completed string `json:"completed"`
	// Timestamp when the last purge operation started.
	StartedAt string                  `json:"started_at"`
	JSON      purgeStatusResponseJSON `json:"-"`
}

type PurgeStatusResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   PurgeStatusResponse   `json:"result"`
	// Indicates if the API call was successful or not.
	Success PurgeStatusResponseEnvelopeSuccess `json:"success"`
	JSON    purgeStatusResponseEnvelopeJSON    `json:"-"`
}

type PurgeStatusResponseEnvelopeSuccess bool

type Queue struct {
	Consumers           []Consumer      `json:"consumers"`
	ConsumersTotalCount float64         `json:"consumers_total_count"`
	CreatedOn           string          `json:"created_on"`
	ModifiedOn          string          `json:"modified_on"`
	Producers           []QueueProducer `json:"producers"`
	ProducersTotalCount float64         `json:"producers_total_count"`
	QueueID             string          `json:"queue_id"`
	QueueName           string          `json:"queue_name"`
	Settings            QueueSettings   `json:"settings"`
	JSON                queueJSON       `json:"-"`
}

type QueueDeleteParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type QueueDeleteResponse struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	// Indicates if the API call was successful or not.
	Success QueueDeleteResponseSuccess `json:"success"`
	JSON    queueDeleteResponseJSON    `json:"-"`
}

type QueueDeleteResponseSuccess bool

type QueueEditParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	Queue     QueueParam          `json:"queue"`
}

type QueueEditResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Queue                 `json:"result"`
	// Indicates if the API call was successful or not.
	Success QueueEditResponseEnvelopeSuccess `json:"success"`
	JSON    queueEditResponseEnvelopeJSON    `json:"-"`
}

type QueueEditResponseEnvelopeSuccess bool

type QueueGetParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type QueueGetResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Queue                 `json:"result"`
	// Indicates if the API call was successful or not.
	Success QueueGetResponseEnvelopeSuccess `json:"success"`
	JSON    queueGetResponseEnvelopeJSON    `json:"-"`
}

type QueueGetResponseEnvelopeSuccess bool

type QueueListParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type QueueNewParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	QueueName param.Field[string] `json:"queue_name,required"`
}

type QueueNewResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Queue                 `json:"result"`
	// Indicates if the API call was successful or not.
	Success QueueNewResponseEnvelopeSuccess `json:"success"`
	JSON    queueNewResponseEnvelopeJSON    `json:"-"`
}

type QueueNewResponseEnvelopeSuccess bool

type QueueParam struct {
	QueueName param.Field[string]             `json:"queue_name"`
	Settings  param.Field[QueueSettingsParam] `json:"settings"`
}

type QueueProducer struct {
	BucketName string             `json:"bucket_name"`
	Script     string             `json:"script"`
	Type       QueueProducersType `json:"type"`
	JSON       queueProducerJSON  `json:"-"`
	// contains filtered or unexported fields
}

type QueueProducerParam struct {
	BucketName param.Field[string]             `json:"bucket_name"`
	Script     param.Field[string]             `json:"script"`
	Type       param.Field[QueueProducersType] `json:"type"`
}

type QueueProducersMqR2Producer struct {
	BucketName string                         `json:"bucket_name"`
	Type       QueueProducersMqR2ProducerType `json:"type"`
	JSON       queueProducersMqR2ProducerJSON `json:"-"`
}

type QueueProducersMqR2ProducerParam struct {
	BucketName param.Field[string]                         `json:"bucket_name"`
	Type       param.Field[QueueProducersMqR2ProducerType] `json:"type"`
}

type QueueProducersMqR2ProducerType string

type QueueProducersMqWorkerProducer struct {
	Script string                             `json:"script"`
	Type   QueueProducersMqWorkerProducerType `json:"type"`
	JSON   queueProducersMqWorkerProducerJSON `json:"-"`
}

type QueueProducersMqWorkerProducerParam struct {
	Script param.Field[string]                             `json:"script"`
	Type   param.Field[QueueProducersMqWorkerProducerType] `json:"type"`
}

type QueueProducersMqWorkerProducerType string

type QueueProducersType string

type QueueProducersUnion interface {
	// contains filtered or unexported methods
}

type QueueProducersUnionParam interface {
	// contains filtered or unexported methods
}

type QueueService struct {
	Options       []option.RequestOption
	Messages      *MessageService
	Purge         *PurgeService
	Consumers     *ConsumerService
	Subscriptions *SubscriptionService
}

type QueueSettings struct {
	// Number of seconds to delay delivery of all messages to consumers.
	DeliveryDelay float64 `json:"delivery_delay"`
	// Indicates if message delivery to consumers is currently paused.
	DeliveryPaused bool `json:"delivery_paused"`
	// Number of seconds after which an unconsumed message will be delayed.
	MessageRetentionPeriod float64           `json:"message_retention_period"`
	JSON                   queueSettingsJSON `json:"-"`
}

type QueueSettingsParam struct {
	// Number of seconds to delay delivery of all messages to consumers.
	DeliveryDelay param.Field[float64] `json:"delivery_delay"`
	// Indicates if message delivery to consumers is currently paused.
	DeliveryPaused param.Field[bool] `json:"delivery_paused"`
	// Number of seconds after which an unconsumed message will be delayed.
	MessageRetentionPeriod param.Field[float64] `json:"message_retention_period"`
}

type QueueUpdateParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	Queue     QueueParam          `json:"queue"`
}

type QueueUpdateResponseEnvelope struct {
	Errors   []shared.ResponseInfo `json:"errors"`
	Messages []string              `json:"messages"`
	Result   Queue                 `json:"result"`
	// Indicates if the API call was successful or not.
	Success QueueUpdateResponseEnvelopeSuccess `json:"success"`
	JSON    queueUpdateResponseEnvelopeJSON    `json:"-"`
}

type QueueUpdateResponseEnvelopeSuccess bool

type RatePlan = shared.RatePlan

type RatePlanID = shared.RatePlanID

type RatePlanParam = shared.RatePlanParam

type ResponseInfo = shared.ResponseInfo

type ResponseInfoSource = shared.ResponseInfoSource

type Role = shared.Role

type RoleParam = shared.RoleParam

type RolePermissions = shared.RolePermissions

type RolePermissionsParam = shared.RolePermissionsParam

type SortDirection = shared.SortDirection

type Subscription = shared.Subscription

type SubscriptionDeleteParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
}

type SubscriptionDeleteResponse struct {
	// Unique identifier for the subscription
	ID string `json:"id,required"`
	// When the subscription was created
	CreatedAt time.Time `json:"created_at,required" format:"date-time"`
	// Destination configuration for the subscription
	Destination SubscriptionDeleteResponseDestination `json:"destination,required"`
	// Whether the subscription is active
	Enabled bool `json:"enabled,required"`
	// List of event types this subscription handles
	Events []string `json:"events,required"`
	// When the subscription was last modified
	ModifiedAt time.Time `json:"modified_at,required" format:"date-time"`
	// Name of the subscription
	Name string `json:"name,required"`
	// Source configuration for the subscription
	Source SubscriptionDeleteResponseSource `json:"source,required"`
	JSON   subscriptionDeleteResponseJSON   `json:"-"`
}

type SubscriptionDeleteResponseDestination struct {
	// ID of the target queue
	QueueID string `json:"queue_id,required"`
	// Type of destination
	Type SubscriptionDeleteResponseDestinationType `json:"type,required"`
	JSON subscriptionDeleteResponseDestinationJSON `json:"-"`
}

type SubscriptionDeleteResponseDestinationType string

type SubscriptionDeleteResponseEnvelope struct {
	Errors   []shared.ResponseInfo      `json:"errors"`
	Messages []string                   `json:"messages"`
	Result   SubscriptionDeleteResponse `json:"result"`
	// Indicates if the API call was successful or not.
	Success SubscriptionDeleteResponseEnvelopeSuccess `json:"success"`
	JSON    subscriptionDeleteResponseEnvelopeJSON    `json:"-"`
}

type SubscriptionDeleteResponseEnvelopeSuccess bool

type SubscriptionDeleteResponseSource struct {
	// Name of the Workers AI model
	ModelName string `json:"model_name"`
	// Type of source
	Type SubscriptionDeleteResponseSourceType `json:"type"`
	// Name of the worker
	WorkerName string `json:"worker_name"`
	// Name of the workflow
	WorkflowName string                               `json:"workflow_name"`
	JSON         subscriptionDeleteResponseSourceJSON `json:"-"`
	// contains filtered or unexported fields
}

type SubscriptionDeleteResponseSourceMqEventSourceImages struct {
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceImagesType `json:"type"`
	JSON subscriptionDeleteResponseSourceMqEventSourceImagesJSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceImagesType string

type SubscriptionDeleteResponseSourceMqEventSourceKV struct {
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceKVType `json:"type"`
	JSON subscriptionDeleteResponseSourceMqEventSourceKVJSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceKVType string

type SubscriptionDeleteResponseSourceMqEventSourceR2 struct {
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceR2Type `json:"type"`
	JSON subscriptionDeleteResponseSourceMqEventSourceR2JSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceR2Type string

type SubscriptionDeleteResponseSourceMqEventSourceSuperSlurper struct {
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceSuperSlurperType `json:"type"`
	JSON subscriptionDeleteResponseSourceMqEventSourceSuperSlurperJSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceSuperSlurperType string

type SubscriptionDeleteResponseSourceMqEventSourceVectorize struct {
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceVectorizeType `json:"type"`
	JSON subscriptionDeleteResponseSourceMqEventSourceVectorizeJSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceVectorizeType string

type SubscriptionDeleteResponseSourceMqEventSourceWorkersAIModel struct {
	// Name of the Workers AI model
	ModelName string `json:"model_name"`
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceWorkersAIModelType `json:"type"`
	JSON subscriptionDeleteResponseSourceMqEventSourceWorkersAIModelJSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceWorkersAIModelType string

type SubscriptionDeleteResponseSourceMqEventSourceWorkersBuildsWorker struct {
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceWorkersBuildsWorkerType `json:"type"`
	// Name of the worker
	WorkerName string                                                               `json:"worker_name"`
	JSON       subscriptionDeleteResponseSourceMqEventSourceWorkersBuildsWorkerJSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceWorkersBuildsWorkerType string

type SubscriptionDeleteResponseSourceMqEventSourceWorkflowsWorkflow struct {
	// Type of source
	Type SubscriptionDeleteResponseSourceMqEventSourceWorkflowsWorkflowType `json:"type"`
	// Name of the workflow
	WorkflowName string                                                             `json:"workflow_name"`
	JSON         subscriptionDeleteResponseSourceMqEventSourceWorkflowsWorkflowJSON `json:"-"`
}

type SubscriptionDeleteResponseSourceMqEventSourceWorkflowsWorkflowType string

type SubscriptionDeleteResponseSourceType string

type SubscriptionDeleteResponseSourceUnion interface {
	// contains filtered or unexported methods
}

type SubscriptionFrequency = shared.SubscriptionFrequency

type SubscriptionListParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	// Sort direction
	Direction param.Field[SubscriptionListParamsDirection] `query:"direction"`
	// Field to sort by
	Order param.Field[SubscriptionListParamsOrder] `query:"order"`
	// Page number for pagination
	Page param.Field[int64] `query:"page"`
	// Number of items per page
	PerPage param.Field[int64] `query:"per_page"`
}

type SubscriptionListParamsDirection string

type SubscriptionListParamsOrder string

type SubscriptionListResponse struct {
	// Unique identifier for the subscription
	ID string `json:"id,required"`
	// When the subscription was created
	CreatedAt time.Time `json:"created_at,required" format:"date-time"`
	// Destination configuration for the subscription
	Destination SubscriptionListResponseDestination `json:"destination,required"`
	// Whether the subscription is active
	Enabled bool `json:"enabled,required"`
	// List of event types this subscription handles
	Events []string `json:"events,required"`
	// When the subscription was last modified
	ModifiedAt time.Time `json:"modified_at,required" format:"date-time"`
	// Name of the subscription
	Name string `json:"name,required"`
	// Source configuration for the subscription
	Source SubscriptionListResponseSource `json:"source,required"`
	JSON   subscriptionListResponseJSON   `json:"-"`
}

type SubscriptionListResponseDestination struct {
	// ID of the target queue
	QueueID string `json:"queue_id,required"`
	// Type of destination
	Type SubscriptionListResponseDestinationType `json:"type,required"`
	JSON subscriptionListResponseDestinationJSON `json:"-"`
}

type SubscriptionListResponseDestinationType string

type SubscriptionListResponseSource struct {
	// Name of the Workers AI model
	ModelName string `json:"model_name"`
	// Type of source
	Type SubscriptionListResponseSourceType `json:"type"`
	// Name of the worker
	WorkerName string `json:"worker_name"`
	// Name of the workflow
	WorkflowName string                             `json:"workflow_name"`
	JSON         subscriptionListResponseSourceJSON `json:"-"`
	// contains filtered or unexported fields
}

type SubscriptionListResponseSourceMqEventSourceImages struct {
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceImagesType `json:"type"`
	JSON subscriptionListResponseSourceMqEventSourceImagesJSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceImagesType string

type SubscriptionListResponseSourceMqEventSourceKV struct {
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceKVType `json:"type"`
	JSON subscriptionListResponseSourceMqEventSourceKVJSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceKVType string

type SubscriptionListResponseSourceMqEventSourceR2 struct {
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceR2Type `json:"type"`
	JSON subscriptionListResponseSourceMqEventSourceR2JSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceR2Type string

type SubscriptionListResponseSourceMqEventSourceSuperSlurper struct {
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceSuperSlurperType `json:"type"`
	JSON subscriptionListResponseSourceMqEventSourceSuperSlurperJSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceSuperSlurperType string

type SubscriptionListResponseSourceMqEventSourceVectorize struct {
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceVectorizeType `json:"type"`
	JSON subscriptionListResponseSourceMqEventSourceVectorizeJSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceVectorizeType string

type SubscriptionListResponseSourceMqEventSourceWorkersAIModel struct {
	// Name of the Workers AI model
	ModelName string `json:"model_name"`
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceWorkersAIModelType `json:"type"`
	JSON subscriptionListResponseSourceMqEventSourceWorkersAIModelJSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceWorkersAIModelType string

type SubscriptionListResponseSourceMqEventSourceWorkersBuildsWorker struct {
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceWorkersBuildsWorkerType `json:"type"`
	// Name of the worker
	WorkerName string                                                             `json:"worker_name"`
	JSON       subscriptionListResponseSourceMqEventSourceWorkersBuildsWorkerJSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceWorkersBuildsWorkerType string

type SubscriptionListResponseSourceMqEventSourceWorkflowsWorkflow struct {
	// Type of source
	Type SubscriptionListResponseSourceMqEventSourceWorkflowsWorkflowType `json:"type"`
	// Name of the workflow
	WorkflowName string                                                           `json:"workflow_name"`
	JSON         subscriptionListResponseSourceMqEventSourceWorkflowsWorkflowJSON `json:"-"`
}

type SubscriptionListResponseSourceMqEventSourceWorkflowsWorkflowType string

type SubscriptionListResponseSourceType string

type SubscriptionListResponseSourceUnion interface {
	// contains filtered or unexported methods
}

type SubscriptionNewParams struct {
	// A Resource identifier.
	AccountID param.Field[string] `path:"account_id,required"`
	// Destination configuration for the subscription
	Destination param.Field[SubscriptionNewParamsDestination] `json:"destination"`
	// Whether the subscription is active
	Enabled param.Field[bool] `json:"enabled"`
	// List of event types this subscription handles
	Events param.Field[[]string] `json:"events"`
	// Name of the subscription
	Name param.Field[string] `json:"name"`
	// Source configuration for the subscription
	Source param.Field[SubscriptionNewParamsSourceUnion] `json:"source"`
}

type SubscriptionNewParamsDestination struct {
	// ID of the target queue
	QueueID param.Field[string] `json:"queue_id,required"`
	// Type of destination
	Type param.Field[SubscriptionNewParamsDestinationType] `json:"type,required"`
}

type SubscriptionNewParamsDestinationType string

type SubscriptionNewParamsSource struct {
	// Name of the Workers AI model
	ModelName param.Field[string] `json:"model_name"`
	// Type of source
	Type param.Field[SubscriptionNewParamsSourceType] `json:"type"`
	// Name of the worker
	WorkerName param.Field[string] `json:"worker_name"`
	// Name of the workflow
	WorkflowName param.Field[string] `json:"workflow_name"`
}

type SubscriptionNewParamsSourceMqEventSourceImages struct {
	// Type of source
	Type param.Field[SubscriptionNewParamsSourceMqEventSourceImagesType] `json:"type"`
}

type SubscriptionNewParamsSourceMqEventSourceImagesType string

type SubscriptionNewParamsSourceMqEventSourceKV struct {
	// Type of source
	Type param.Field[SubscriptionNewParamsSourceMqEventSourceKVType] `json:"type"`
}

type SubscriptionNewParamsSourceMqEventSourceKVType string

type SubscriptionNewParamsSourceMqEventSourceR2 struct {
	// Type of source
	Type param.Field[SubscriptionNewParamsSourceMqEventSourceR2Type] `json:"type"`
}

type SubscriptionNewParamsSourceMqEventSourceR2Type string

type SubscriptionNewParamsSourceMqEventSourceSuperSlurper struct {
	// Type of source
	Type param.Field[SubscriptionNewParamsSourceMqEventSourceSuperSlurperType] `json:"type"`
}

type SubscriptionNewParamsSourceMqEventSourceSuperSlurperType string

type SubscriptionNewParamsSourceMqEventSourceVectorize struct {
	// Type of source
	Type param.Field[SubscriptionNewParamsSourceMqEventSourceVectorizeType] `json:"type"`
}

type SubscriptionNewParamsSourceMqEventSourceVectorizeType string