Versions in this module Expand all Collapse all v2 v2.0.0 Nov 7, 2024 Changes in this version + const AuditLogActorTypeAdmin + const AuditLogActorTypeCloudflare + const AuditLogActorTypeUser + const CertificateCADigicert + const CertificateCAGoogle + const CertificateCALetsEncrypt + const CertificateRequestTypeKeylessCertificate + const CertificateRequestTypeOriginECC + const CertificateRequestTypeOriginRSA + const CloudflareTunnelStatusDegraded + const CloudflareTunnelStatusDown + const CloudflareTunnelStatusHealthy + const CloudflareTunnelStatusInactive + const CloudflareTunnelTunTypeCNI + const CloudflareTunnelTunTypeCfdTunnel + const CloudflareTunnelTunTypeGRE + const CloudflareTunnelTunTypeIPSec + const CloudflareTunnelTunTypeWARPConnector + const MemberStatusAccepted + const MemberStatusPending + const SortDirectionAsc + const SortDirectionDesc + 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 CloudflareTunnelConnection = shared.CloudflareTunnelConnection + type CloudflareTunnelStatus = shared.CloudflareTunnelStatus + type CloudflareTunnelTunType = shared.CloudflareTunnelTunType + type Consumer struct + CreatedOn interface{} + Environment interface{} + JSON consumerJSON + QueueName interface{} + Service interface{} + Settings ConsumerSettings + func (r *Consumer) UnmarshalJSON(data []byte) (err error) + type ConsumerDeleteResponseArray []interface + func (r ConsumerDeleteResponseArray) ImplementsQueuesConsumerDeleteResponseUnion() + type ConsumerDeleteResponseEnvelope struct + Errors []shared.ResponseInfo + JSON consumerDeleteResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result ConsumerDeleteResponseUnion + ResultInfo ConsumerDeleteResponseEnvelopeResultInfo + Success ConsumerDeleteResponseEnvelopeSuccess + func (r *ConsumerDeleteResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type ConsumerDeleteResponseEnvelopeResultInfo struct + Count float64 + JSON consumerDeleteResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *ConsumerDeleteResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type ConsumerDeleteResponseEnvelopeSuccess bool + const ConsumerDeleteResponseEnvelopeSuccessTrue + func (r ConsumerDeleteResponseEnvelopeSuccess) IsKnown() bool + type ConsumerDeleteResponseUnion interface + ImplementsQueuesConsumerDeleteResponseUnion func() + type ConsumerGetResponseEnvelope struct + Errors []shared.ResponseInfo + JSON consumerGetResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result []Consumer + ResultInfo ConsumerGetResponseEnvelopeResultInfo + Success ConsumerGetResponseEnvelopeSuccess + func (r *ConsumerGetResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type ConsumerGetResponseEnvelopeResultInfo struct + Count float64 + JSON consumerGetResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + TotalPages float64 + func (r *ConsumerGetResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type ConsumerGetResponseEnvelopeSuccess bool + const ConsumerGetResponseEnvelopeSuccessTrue + func (r ConsumerGetResponseEnvelopeSuccess) IsKnown() bool + type ConsumerNewParams struct + Body interface{} + func (r ConsumerNewParams) MarshalJSON() (data []byte, err error) + type ConsumerNewResponse struct + CreatedOn interface{} + DeadLetterQueue string + Environment interface{} + JSON consumerNewResponseJSON + QueueName interface{} + ScriptName interface{} + Settings ConsumerNewResponseSettings + func (r *ConsumerNewResponse) UnmarshalJSON(data []byte) (err error) + type ConsumerNewResponseEnvelope struct + Errors []shared.ResponseInfo + JSON consumerNewResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result ConsumerNewResponse + ResultInfo ConsumerNewResponseEnvelopeResultInfo + Success ConsumerNewResponseEnvelopeSuccess + func (r *ConsumerNewResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type ConsumerNewResponseEnvelopeResultInfo struct + Count float64 + JSON consumerNewResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *ConsumerNewResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type ConsumerNewResponseEnvelopeSuccess bool + const ConsumerNewResponseEnvelopeSuccessTrue + func (r ConsumerNewResponseEnvelopeSuccess) IsKnown() bool + type ConsumerNewResponseSettings struct + BatchSize float64 + JSON consumerNewResponseSettingsJSON + MaxRetries float64 + MaxWaitTimeMs float64 + func (r *ConsumerNewResponseSettings) UnmarshalJSON(data []byte) (err error) + type ConsumerService struct + Options []option.RequestOption + func NewConsumerService(opts ...option.RequestOption) (r *ConsumerService) + func (r *ConsumerService) Delete(ctx context.Context, accountID string, queueID string, consumerID string, ...) (res *ConsumerDeleteResponseUnion, err error) + func (r *ConsumerService) Get(ctx context.Context, accountID string, queueID string, ...) (res *[]Consumer, err error) + func (r *ConsumerService) New(ctx context.Context, accountID string, queueID string, body ConsumerNewParams, ...) (res *ConsumerNewResponse, err error) + func (r *ConsumerService) Update(ctx context.Context, accountID string, queueID string, consumerID string, ...) (res *ConsumerUpdateResponse, err error) + type ConsumerSettings struct + BatchSize float64 + JSON consumerSettingsJSON + MaxRetries float64 + MaxWaitTimeMs float64 + func (r *ConsumerSettings) UnmarshalJSON(data []byte) (err error) + type ConsumerUpdateParams struct + Body interface{} + func (r ConsumerUpdateParams) MarshalJSON() (data []byte, err error) + type ConsumerUpdateResponse struct + CreatedOn interface{} + DeadLetterQueue string + Environment interface{} + JSON consumerUpdateResponseJSON + QueueName interface{} + ScriptName interface{} + Settings ConsumerUpdateResponseSettings + func (r *ConsumerUpdateResponse) UnmarshalJSON(data []byte) (err error) + type ConsumerUpdateResponseEnvelope struct + Errors []shared.ResponseInfo + JSON consumerUpdateResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result ConsumerUpdateResponse + ResultInfo ConsumerUpdateResponseEnvelopeResultInfo + Success ConsumerUpdateResponseEnvelopeSuccess + func (r *ConsumerUpdateResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type ConsumerUpdateResponseEnvelopeResultInfo struct + Count float64 + JSON consumerUpdateResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *ConsumerUpdateResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type ConsumerUpdateResponseEnvelopeSuccess bool + const ConsumerUpdateResponseEnvelopeSuccessTrue + func (r ConsumerUpdateResponseEnvelopeSuccess) IsKnown() bool + type ConsumerUpdateResponseSettings struct + BatchSize float64 + JSON consumerUpdateResponseSettingsJSON + MaxRetries float64 + MaxWaitTimeMs float64 + func (r *ConsumerUpdateResponseSettings) UnmarshalJSON(data []byte) (err error) + type Error = apierror.Error + type ErrorData = shared.ErrorData + type MemberParam = shared.MemberParam + type MemberRoleParam = shared.MemberRoleParam + type MemberRolesPermissionsParam = shared.MemberRolesPermissionsParam + type MemberStatus = shared.MemberStatus + type MemberUserParam = shared.MemberUserParam + type MessageAckParams struct + Acks param.Field[[]MessageAckParamsAck] + Retries param.Field[[]MessageAckParamsRetry] + func (r MessageAckParams) MarshalJSON() (data []byte, err error) + type MessageAckParamsAck struct + LeaseID param.Field[string] + func (r MessageAckParamsAck) MarshalJSON() (data []byte, err error) + type MessageAckParamsRetry struct + DelaySeconds param.Field[float64] + LeaseID param.Field[string] + func (r MessageAckParamsRetry) MarshalJSON() (data []byte, err error) + type MessageAckResponse struct + AckCount float64 + JSON messageAckResponseJSON + RetryCount float64 + Warnings []string + func (r *MessageAckResponse) UnmarshalJSON(data []byte) (err error) + type MessageAckResponseEnvelope struct + Errors []shared.ResponseInfo + JSON messageAckResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result MessageAckResponse + ResultInfo MessageAckResponseEnvelopeResultInfo + Success MessageAckResponseEnvelopeSuccess + func (r *MessageAckResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type MessageAckResponseEnvelopeResultInfo struct + Count float64 + JSON messageAckResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *MessageAckResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type MessageAckResponseEnvelopeSuccess bool + const MessageAckResponseEnvelopeSuccessTrue + func (r MessageAckResponseEnvelopeSuccess) IsKnown() bool + type MessagePullParams struct + BatchSize param.Field[float64] + VisibilityTimeoutMs param.Field[float64] + func (r MessagePullParams) MarshalJSON() (data []byte, err error) + type MessagePullResponse struct + Attempts float64 + Body string + ID string + JSON messagePullResponseJSON + LeaseID string + Metadata interface{} + TimestampMs float64 + func (r *MessagePullResponse) UnmarshalJSON(data []byte) (err error) + type MessagePullResponseEnvelope struct + Errors []shared.ResponseInfo + JSON messagePullResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result []MessagePullResponse + ResultInfo MessagePullResponseEnvelopeResultInfo + Success MessagePullResponseEnvelopeSuccess + func (r *MessagePullResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type MessagePullResponseEnvelopeResultInfo struct + Count float64 + JSON messagePullResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *MessagePullResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type MessagePullResponseEnvelopeSuccess bool + const MessagePullResponseEnvelopeSuccessTrue + func (r MessagePullResponseEnvelopeSuccess) IsKnown() bool + type MessageService struct + Options []option.RequestOption + func NewMessageService(opts ...option.RequestOption) (r *MessageService) + func (r *MessageService) Ack(ctx context.Context, accountID string, queueID string, body MessageAckParams, ...) (res *MessageAckResponse, err error) + func (r *MessageService) Pull(ctx context.Context, accountID string, queueID string, body MessagePullParams, ...) (res *[]MessagePullResponse, err error) + type Permission = shared.Permission + type PermissionGrant = shared.PermissionGrant + type PermissionGrantParam = shared.PermissionGrantParam + type Queue struct + Consumers interface{} + ConsumersTotalCount interface{} + CreatedOn interface{} + JSON queueJSON + ModifiedOn interface{} + Producers interface{} + ProducersTotalCount interface{} + QueueID string + QueueName string + func (r *Queue) UnmarshalJSON(data []byte) (err error) + type QueueCreated struct + CreatedOn interface{} + JSON queueCreatedJSON + ModifiedOn interface{} + QueueID string + QueueName string + func (r *QueueCreated) UnmarshalJSON(data []byte) (err error) + type QueueDeleteResponseArray []interface + func (r QueueDeleteResponseArray) ImplementsQueuesQueueDeleteResponseUnion() + type QueueDeleteResponseEnvelope struct + Errors []shared.ResponseInfo + JSON queueDeleteResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result QueueDeleteResponseUnion + ResultInfo QueueDeleteResponseEnvelopeResultInfo + Success QueueDeleteResponseEnvelopeSuccess + func (r *QueueDeleteResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type QueueDeleteResponseEnvelopeResultInfo struct + Count float64 + JSON queueDeleteResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *QueueDeleteResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type QueueDeleteResponseEnvelopeSuccess bool + const QueueDeleteResponseEnvelopeSuccessTrue + func (r QueueDeleteResponseEnvelopeSuccess) IsKnown() bool + type QueueDeleteResponseUnion interface + ImplementsQueuesQueueDeleteResponseUnion func() + type QueueGetResponseEnvelope struct + Errors []shared.ResponseInfo + JSON queueGetResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result Queue + ResultInfo QueueGetResponseEnvelopeResultInfo + Success QueueGetResponseEnvelopeSuccess + func (r *QueueGetResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type QueueGetResponseEnvelopeResultInfo struct + Count float64 + JSON queueGetResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *QueueGetResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type QueueGetResponseEnvelopeSuccess bool + const QueueGetResponseEnvelopeSuccessTrue + func (r QueueGetResponseEnvelopeSuccess) IsKnown() bool + type QueueNewParams struct + Body interface{} + func (r QueueNewParams) MarshalJSON() (data []byte, err error) + type QueueNewResponseEnvelope struct + Errors []shared.ResponseInfo + JSON queueNewResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result QueueCreated + ResultInfo QueueNewResponseEnvelopeResultInfo + Success QueueNewResponseEnvelopeSuccess + func (r *QueueNewResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type QueueNewResponseEnvelopeResultInfo struct + Count float64 + JSON queueNewResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *QueueNewResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type QueueNewResponseEnvelopeSuccess bool + const QueueNewResponseEnvelopeSuccessTrue + func (r QueueNewResponseEnvelopeSuccess) IsKnown() bool + type QueueService struct + Consumers *ConsumerService + Messages *MessageService + Options []option.RequestOption + func NewQueueService(opts ...option.RequestOption) (r *QueueService) + func (r *QueueService) Delete(ctx context.Context, accountID string, queueID string, ...) (res *QueueDeleteResponseUnion, err error) + func (r *QueueService) Get(ctx context.Context, accountID string, queueID string, ...) (res *Queue, err error) + func (r *QueueService) List(ctx context.Context, accountID string, opts ...option.RequestOption) (res *pagination.SinglePage[Queue], err error) + func (r *QueueService) ListAutoPaging(ctx context.Context, accountID string, opts ...option.RequestOption) *pagination.SinglePageAutoPager[Queue] + func (r *QueueService) New(ctx context.Context, accountID string, body QueueNewParams, ...) (res *QueueCreated, err error) + func (r *QueueService) Update(ctx context.Context, accountID string, queueID string, body QueueUpdateParams, ...) (res *QueueUpdated, err error) + type QueueUpdateParams struct + Body interface{} + func (r QueueUpdateParams) MarshalJSON() (data []byte, err error) + type QueueUpdateResponseEnvelope struct + Errors []shared.ResponseInfo + JSON queueUpdateResponseEnvelopeJSON + Messages []shared.ResponseInfo + Result QueueUpdated + ResultInfo QueueUpdateResponseEnvelopeResultInfo + Success QueueUpdateResponseEnvelopeSuccess + func (r *QueueUpdateResponseEnvelope) UnmarshalJSON(data []byte) (err error) + type QueueUpdateResponseEnvelopeResultInfo struct + Count float64 + JSON queueUpdateResponseEnvelopeResultInfoJSON + Page float64 + PerPage float64 + TotalCount float64 + func (r *QueueUpdateResponseEnvelopeResultInfo) UnmarshalJSON(data []byte) (err error) + type QueueUpdateResponseEnvelopeSuccess bool + const QueueUpdateResponseEnvelopeSuccessTrue + func (r QueueUpdateResponseEnvelopeSuccess) IsKnown() bool + type QueueUpdated struct + CreatedOn interface{} + JSON queueUpdatedJSON + ModifiedOn interface{} + QueueID string + QueueName string + func (r *QueueUpdated) UnmarshalJSON(data []byte) (err error) + type ResponseInfo = shared.ResponseInfo + type Role = shared.Role + type SortDirection = shared.SortDirection
Go to main page