model

package
v0.0.74 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 10, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchCreateOrDeleteQueueTagRequest

type BatchCreateOrDeleteQueueTagRequest struct {
	QueueId string `json:"queue_id"`

	Body *BatchCreateOrDeleteTagReq `json:"body,omitempty"`
}

Request Object

func (BatchCreateOrDeleteQueueTagRequest) String

type BatchCreateOrDeleteQueueTagResponse

type BatchCreateOrDeleteQueueTagResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (BatchCreateOrDeleteQueueTagResponse) String

type BatchCreateOrDeleteTagReq

type BatchCreateOrDeleteTagReq struct {
	Action *BatchCreateOrDeleteTagReqAction `json:"action,omitempty"`

	Tags *[]BatchCreateOrDeleteTagReqTags `json:"tags,omitempty"`
}

func (BatchCreateOrDeleteTagReq) String

func (o BatchCreateOrDeleteTagReq) String() string

type BatchCreateOrDeleteTagReqAction

type BatchCreateOrDeleteTagReqAction struct {
	// contains filtered or unexported fields
}

func (BatchCreateOrDeleteTagReqAction) MarshalJSON

func (c BatchCreateOrDeleteTagReqAction) MarshalJSON() ([]byte, error)

func (*BatchCreateOrDeleteTagReqAction) UnmarshalJSON

func (c *BatchCreateOrDeleteTagReqAction) UnmarshalJSON(b []byte) error

type BatchCreateOrDeleteTagReqActionEnum

type BatchCreateOrDeleteTagReqActionEnum struct {
	CREATE BatchCreateOrDeleteTagReqAction
	DELETE BatchCreateOrDeleteTagReqAction
}

func GetBatchCreateOrDeleteTagReqActionEnum

func GetBatchCreateOrDeleteTagReqActionEnum() BatchCreateOrDeleteTagReqActionEnum

type BatchCreateOrDeleteTagReqTags

type BatchCreateOrDeleteTagReqTags struct {
	Key *string `json:"key,omitempty"`

	Value *string `json:"value,omitempty"`
}

func (BatchCreateOrDeleteTagReqTags) String

type ConfirmConsumptionMessagesReq

type ConfirmConsumptionMessagesReq struct {
	Message *[]ConfirmDeadLettersMessagesReqMessage `json:"message,omitempty"`
}

func (ConfirmConsumptionMessagesReq) String

type ConfirmConsumptionMessagesRequest

type ConfirmConsumptionMessagesRequest struct {
	QueueId string `json:"queue_id"`

	ConsumerGroupId string `json:"consumer_group_id"`

	Body *ConfirmConsumptionMessagesReq `json:"body,omitempty"`
}

Request Object

func (ConfirmConsumptionMessagesRequest) String

type ConfirmConsumptionMessagesResponse

type ConfirmConsumptionMessagesResponse struct {
	Success *int32 `json:"success,omitempty"`

	Fail           *int32 `json:"fail,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ConfirmConsumptionMessagesResponse) String

type ConfirmDeadLettersMessagesReq

type ConfirmDeadLettersMessagesReq struct {
	Message *[]ConfirmDeadLettersMessagesReqMessage `json:"message,omitempty"`
}

func (ConfirmDeadLettersMessagesReq) String

type ConfirmDeadLettersMessagesReqMessage

type ConfirmDeadLettersMessagesReqMessage struct {
	Handler *string `json:"handler,omitempty"`

	Status *ConfirmDeadLettersMessagesReqMessageStatus `json:"status,omitempty"`
}

func (ConfirmDeadLettersMessagesReqMessage) String

type ConfirmDeadLettersMessagesReqMessageStatus

type ConfirmDeadLettersMessagesReqMessageStatus struct {
	// contains filtered or unexported fields
}

func (ConfirmDeadLettersMessagesReqMessageStatus) MarshalJSON

func (*ConfirmDeadLettersMessagesReqMessageStatus) UnmarshalJSON

type ConfirmDeadLettersMessagesRequest

type ConfirmDeadLettersMessagesRequest struct {
	QueueId string `json:"queue_id"`

	ConsumerGroupId string `json:"consumer_group_id"`

	Body *ConfirmDeadLettersMessagesReq `json:"body,omitempty"`
}

Request Object

func (ConfirmDeadLettersMessagesRequest) String

type ConfirmDeadLettersMessagesResponse

type ConfirmDeadLettersMessagesResponse struct {
	Success *int32 `json:"success,omitempty"`

	Fail           *int32 `json:"fail,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ConfirmDeadLettersMessagesResponse) String

type ConsumeDeadlettersMessage

type ConsumeDeadlettersMessage struct {
	Message *ConsumeDeadlettersMessageMessage `json:"message,omitempty"`

	Handler *string `json:"handler,omitempty"`
}

func (ConsumeDeadlettersMessage) String

func (o ConsumeDeadlettersMessage) String() string

type ConsumeDeadlettersMessageMessage

type ConsumeDeadlettersMessageMessage struct {
	Body *interface{} `json:"body,omitempty"`

	Attributes *interface{} `json:"attributes,omitempty"`
}

消息的内容。

func (ConsumeDeadlettersMessageMessage) String

type ConsumeDeadlettersMessageRequest

type ConsumeDeadlettersMessageRequest struct {
	QueueId string `json:"queue_id"`

	ConsumerGroupId string `json:"consumer_group_id"`

	MaxMsgs *int32 `json:"max_msgs,omitempty"`

	TimeWait *int32 `json:"time_wait,omitempty"`

	AckWait *int32 `json:"ack_wait,omitempty"`
}

Request Object

func (ConsumeDeadlettersMessageRequest) String

type ConsumeDeadlettersMessageResponse

type ConsumeDeadlettersMessageResponse struct {
	Body           *[]ConsumeDeadlettersMessage `json:"body,omitempty"`
	HttpStatusCode int                          `json:"-"`
}

Response Object

func (ConsumeDeadlettersMessageResponse) String

type ConsumeMessage

type ConsumeMessage struct {
	Message *ConsumeMessageMessage `json:"message,omitempty"`

	Handler *string `json:"handler,omitempty"`
}

func (ConsumeMessage) String

func (o ConsumeMessage) String() string

type ConsumeMessageMessage

type ConsumeMessageMessage struct {
	Body *interface{} `json:"body,omitempty"`

	Attributes *interface{} `json:"attributes,omitempty"`

	Tags *[]string `json:"tags,omitempty"`
}

消息的内容。

func (ConsumeMessageMessage) String

func (o ConsumeMessageMessage) String() string

type ConsumeMessagesRequest

type ConsumeMessagesRequest struct {
	QueueId string `json:"queue_id"`

	ConsumerGroupId string `json:"consumer_group_id"`

	MaxMsgs *int32 `json:"max_msgs,omitempty"`

	TimeWait *int32 `json:"time_wait,omitempty"`

	AckWait *int32 `json:"ack_wait,omitempty"`

	Tag *string `json:"tag,omitempty"`

	TagType *string `json:"tag_type,omitempty"`
}

Request Object

func (ConsumeMessagesRequest) String

func (o ConsumeMessagesRequest) String() string

type ConsumeMessagesResponse

type ConsumeMessagesResponse struct {
	Body           *[]ConsumeMessage `json:"body,omitempty"`
	HttpStatusCode int               `json:"-"`
}

Response Object

func (ConsumeMessagesResponse) String

func (o ConsumeMessagesResponse) String() string

type CreateConsumerGroupReq

type CreateConsumerGroupReq struct {
	Groups []GroupEntity `json:"groups"`
}

func (CreateConsumerGroupReq) String

func (o CreateConsumerGroupReq) String() string

type CreateConsumerGroupRequest

type CreateConsumerGroupRequest struct {
	QueueId string `json:"queue_id"`

	Body *CreateConsumerGroupReq `json:"body,omitempty"`
}

Request Object

func (CreateConsumerGroupRequest) String

type CreateConsumerGroupRespGroups

type CreateConsumerGroupRespGroups struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`
}

func (CreateConsumerGroupRespGroups) String

type CreateConsumerGroupResponse

type CreateConsumerGroupResponse struct {
	Groups         *[]CreateConsumerGroupRespGroups `json:"groups,omitempty"`
	HttpStatusCode int                              `json:"-"`
}

Response Object

func (CreateConsumerGroupResponse) String

type CreateQueueReq

type CreateQueueReq struct {
	Name string `json:"name"`

	QueueMode *CreateQueueReqQueueMode `json:"queue_mode,omitempty"`

	Description *string `json:"description,omitempty"`

	RedrivePolicy *CreateQueueReqRedrivePolicy `json:"redrive_policy,omitempty"`

	MaxConsumeCount *int32 `json:"max_consume_count,omitempty"`

	RetentionHours *int32 `json:"retention_hours,omitempty"`
}

func (CreateQueueReq) String

func (o CreateQueueReq) String() string

type CreateQueueReqQueueMode

type CreateQueueReqQueueMode struct {
	// contains filtered or unexported fields
}

func (CreateQueueReqQueueMode) MarshalJSON

func (c CreateQueueReqQueueMode) MarshalJSON() ([]byte, error)

func (*CreateQueueReqQueueMode) UnmarshalJSON

func (c *CreateQueueReqQueueMode) UnmarshalJSON(b []byte) error

type CreateQueueReqQueueModeEnum

type CreateQueueReqQueueModeEnum struct {
	NORMAL   CreateQueueReqQueueMode
	FIFO     CreateQueueReqQueueMode
	KAFKA_HA CreateQueueReqQueueMode
	KAFKA_HT CreateQueueReqQueueMode
}

func GetCreateQueueReqQueueModeEnum

func GetCreateQueueReqQueueModeEnum() CreateQueueReqQueueModeEnum

type CreateQueueReqRedrivePolicy

type CreateQueueReqRedrivePolicy struct {
	// contains filtered or unexported fields
}

func (CreateQueueReqRedrivePolicy) MarshalJSON

func (c CreateQueueReqRedrivePolicy) MarshalJSON() ([]byte, error)

func (*CreateQueueReqRedrivePolicy) UnmarshalJSON

func (c *CreateQueueReqRedrivePolicy) UnmarshalJSON(b []byte) error

type CreateQueueReqRedrivePolicyEnum

type CreateQueueReqRedrivePolicyEnum struct {
	ENABLE  CreateQueueReqRedrivePolicy
	DISABLE CreateQueueReqRedrivePolicy
}

func GetCreateQueueReqRedrivePolicyEnum

func GetCreateQueueReqRedrivePolicyEnum() CreateQueueReqRedrivePolicyEnum

type CreateQueueRequest

type CreateQueueRequest struct {
	Body *CreateQueueReq `json:"body,omitempty"`
}

Request Object

func (CreateQueueRequest) String

func (o CreateQueueRequest) String() string

type CreateQueueResponse

type CreateQueueResponse struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	KafkaTopic     *string `json:"kafka_topic,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateQueueResponse) String

func (o CreateQueueResponse) String() string

type DeleteQueueRequest

type DeleteQueueRequest struct {
	QueueId string `json:"queue_id"`
}

Request Object

func (DeleteQueueRequest) String

func (o DeleteQueueRequest) String() string

type DeleteQueueResponse

type DeleteQueueResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteQueueResponse) String

func (o DeleteQueueResponse) String() string

type DeleteSpecifiedConsumerGroupRequest

type DeleteSpecifiedConsumerGroupRequest struct {
	QueueId string `json:"queue_id"`

	GroupId string `json:"group_id"`
}

Request Object

func (DeleteSpecifiedConsumerGroupRequest) String

type DeleteSpecifiedConsumerGroupResponse

type DeleteSpecifiedConsumerGroupResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteSpecifiedConsumerGroupResponse) String

type GroupEntity

type GroupEntity struct {
	Name string `json:"name"`
}

func (GroupEntity) String

func (o GroupEntity) String() string

type ListConsumerGroupsRequest

type ListConsumerGroupsRequest struct {
	QueueId string `json:"queue_id"`

	IncludeDeadletter *bool `json:"include_deadletter,omitempty"`

	IncludeMessagesNum *bool `json:"include_messages_num,omitempty"`

	PageSize *int32 `json:"page_size,omitempty"`

	CurrentPage *int32 `json:"current_page,omitempty"`
}

Request Object

func (ListConsumerGroupsRequest) String

func (o ListConsumerGroupsRequest) String() string

type ListConsumerGroupsResponse

type ListConsumerGroupsResponse struct {
	QueueId *string `json:"queue_id,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	Groups *[]ListQueueGroupsRespGroups `json:"groups,omitempty"`

	RedrivePolicy  *ListConsumerGroupsResponseRedrivePolicy `json:"redrive_policy,omitempty"`
	HttpStatusCode int                                      `json:"-"`
}

Response Object

func (ListConsumerGroupsResponse) String

type ListConsumerGroupsResponseRedrivePolicy

type ListConsumerGroupsResponseRedrivePolicy struct {
	// contains filtered or unexported fields
}

func (ListConsumerGroupsResponseRedrivePolicy) MarshalJSON

func (c ListConsumerGroupsResponseRedrivePolicy) MarshalJSON() ([]byte, error)

func (*ListConsumerGroupsResponseRedrivePolicy) UnmarshalJSON

func (c *ListConsumerGroupsResponseRedrivePolicy) UnmarshalJSON(b []byte) error

type ListConsumerGroupsResponseRedrivePolicyEnum

type ListConsumerGroupsResponseRedrivePolicyEnum struct {
	ENABLE  ListConsumerGroupsResponseRedrivePolicy
	DISABLE ListConsumerGroupsResponseRedrivePolicy
}

func GetListConsumerGroupsResponseRedrivePolicyEnum

func GetListConsumerGroupsResponseRedrivePolicyEnum() ListConsumerGroupsResponseRedrivePolicyEnum

type ListQueueGroupsRespGroups

type ListQueueGroupsRespGroups struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	ProducedMessages *int32 `json:"produced_messages,omitempty"`

	ConsumedMessages *int32 `json:"consumed_messages,omitempty"`

	AvailableMessages *int32 `json:"available_messages,omitempty"`

	ProducedDeadletters *int32 `json:"produced_deadletters,omitempty"`

	AvailableDeadletters *int32 `json:"available_deadletters,omitempty"`
}

消费组信息

func (ListQueueGroupsRespGroups) String

func (o ListQueueGroupsRespGroups) String() string

type ListQueuesRequest

type ListQueuesRequest struct {
	IncludeDeadletter *bool `json:"include_deadletter,omitempty"`
}

Request Object

func (ListQueuesRequest) String

func (o ListQueuesRequest) String() string

type ListQueuesRespQueues

type ListQueuesRespQueues struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Created *int64 `json:"created,omitempty"`

	Description *string `json:"description,omitempty"`

	QueueMode *string `json:"queue_mode,omitempty"`

	Reservation *int32 `json:"reservation,omitempty"`

	MaxMsgSizeByte *int32 `json:"max_msg_size_byte,omitempty"`

	ProducedMessages *int32 `json:"produced_messages,omitempty"`

	RedrivePolicy *string `json:"redrive_policy,omitempty"`

	MaxConsumeCount *int32 `json:"max_consume_count,omitempty"`

	GroupCount *int32 `json:"group_count,omitempty"`

	EffDate *int64 `json:"eff_date,omitempty"`
}

func (ListQueuesRespQueues) String

func (o ListQueuesRespQueues) String() string

type ListQueuesResponse

type ListQueuesResponse struct {
	Total *int32 `json:"total,omitempty"`

	Queues         *[]ListQueuesRespQueues `json:"queues,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

Response Object

func (ListQueuesResponse) String

func (o ListQueuesResponse) String() string

type SendMessageEntity

type SendMessageEntity struct {
	Body *interface{} `json:"body"`

	Attributes *interface{} `json:"attributes,omitempty"`

	Tags *interface{} `json:"tags,omitempty"`

	DelayTime *interface{} `json:"delay_time,omitempty"`
}

func (SendMessageEntity) String

func (o SendMessageEntity) String() string

type SendMessagesReq

type SendMessagesReq struct {
	ReturnId *bool `json:"return_id,omitempty"`

	Messages []SendMessageEntity `json:"messages"`
}

func (SendMessagesReq) String

func (o SendMessagesReq) String() string

type SendMessagesRequest

type SendMessagesRequest struct {
	QueueId string `json:"queue_id"`

	Body *SendMessagesReq `json:"body,omitempty"`
}

Request Object

func (SendMessagesRequest) String

func (o SendMessagesRequest) String() string

type SendMessagesRespMessages

type SendMessagesRespMessages struct {
	Error *string `json:"error,omitempty"`

	ErrorCode *int32 `json:"error_code,omitempty"`

	State *int32 `json:"state,omitempty"`

	Id *string `json:"id,omitempty"`
}

func (SendMessagesRespMessages) String

func (o SendMessagesRespMessages) String() string

type SendMessagesResponse

type SendMessagesResponse struct {
	Messages       *[]SendMessagesRespMessages `json:"messages,omitempty"`
	HttpStatusCode int                         `json:"-"`
}

Response Object

func (SendMessagesResponse) String

func (o SendMessagesResponse) String() string

type ShowProjectTagsRespTags

type ShowProjectTagsRespTags struct {
	Key *string `json:"key,omitempty"`

	Values *[]string `json:"values,omitempty"`
}

func (ShowProjectTagsRespTags) String

func (o ShowProjectTagsRespTags) String() string

type ShowQueueProjectTagsRequest

type ShowQueueProjectTagsRequest struct {
}

Request Object

func (ShowQueueProjectTagsRequest) String

type ShowQueueProjectTagsResponse

type ShowQueueProjectTagsResponse struct {
	Tags           *[]ShowProjectTagsRespTags `json:"tags,omitempty"`
	HttpStatusCode int                        `json:"-"`
}

Response Object

func (ShowQueueProjectTagsResponse) String

type ShowQueueRequest

type ShowQueueRequest struct {
	QueueId string `json:"queue_id"`

	IncludeDeadletter *bool `json:"include_deadletter,omitempty"`
}

Request Object

func (ShowQueueRequest) String

func (o ShowQueueRequest) String() string

type ShowQueueResponse

type ShowQueueResponse struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Created *int64 `json:"created,omitempty"`

	Description *string `json:"description,omitempty"`

	QueueMode *ShowQueueResponseQueueMode `json:"queue_mode,omitempty"`

	Reservation *int32 `json:"reservation,omitempty"`

	MaxMsgSizeByte *int32 `json:"max_msg_size_byte,omitempty"`

	ProducedMessages *int32 `json:"produced_messages,omitempty"`

	RedrivePolicy *ShowQueueResponseRedrivePolicy `json:"redrive_policy,omitempty"`

	MaxConsumeCount *int32 `json:"max_consume_count,omitempty"`

	GroupCount *int32 `json:"group_count,omitempty"`

	KafkaTopic *string `json:"kafka_topic,omitempty"`

	EffDate        *int64 `json:"eff_date,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowQueueResponse) String

func (o ShowQueueResponse) String() string

type ShowQueueResponseQueueMode

type ShowQueueResponseQueueMode struct {
	// contains filtered or unexported fields
}

func (ShowQueueResponseQueueMode) MarshalJSON

func (c ShowQueueResponseQueueMode) MarshalJSON() ([]byte, error)

func (*ShowQueueResponseQueueMode) UnmarshalJSON

func (c *ShowQueueResponseQueueMode) UnmarshalJSON(b []byte) error

type ShowQueueResponseQueueModeEnum

type ShowQueueResponseQueueModeEnum struct {
	NORMAL   ShowQueueResponseQueueMode
	FIFO     ShowQueueResponseQueueMode
	KAFKA_HA ShowQueueResponseQueueMode
	KAFKA_HT ShowQueueResponseQueueMode
}

func GetShowQueueResponseQueueModeEnum

func GetShowQueueResponseQueueModeEnum() ShowQueueResponseQueueModeEnum

type ShowQueueResponseRedrivePolicy

type ShowQueueResponseRedrivePolicy struct {
	// contains filtered or unexported fields
}

func (ShowQueueResponseRedrivePolicy) MarshalJSON

func (c ShowQueueResponseRedrivePolicy) MarshalJSON() ([]byte, error)

func (*ShowQueueResponseRedrivePolicy) UnmarshalJSON

func (c *ShowQueueResponseRedrivePolicy) UnmarshalJSON(b []byte) error

type ShowQueueResponseRedrivePolicyEnum

type ShowQueueResponseRedrivePolicyEnum struct {
	ENABLE  ShowQueueResponseRedrivePolicy
	DISABLE ShowQueueResponseRedrivePolicy
}

func GetShowQueueResponseRedrivePolicyEnum

func GetShowQueueResponseRedrivePolicyEnum() ShowQueueResponseRedrivePolicyEnum

type ShowQueueTagsRequest

type ShowQueueTagsRequest struct {
	QueueId string `json:"queue_id"`
}

Request Object

func (ShowQueueTagsRequest) String

func (o ShowQueueTagsRequest) String() string

type ShowQueueTagsResponse

type ShowQueueTagsResponse struct {
	Tags           *[]BatchCreateOrDeleteTagReqTags `json:"tags,omitempty"`
	HttpStatusCode int                              `json:"-"`
}

Response Object

func (ShowQueueTagsResponse) String

func (o ShowQueueTagsResponse) String() string

type ShowQuotasRequest

type ShowQuotasRequest struct {
}

Request Object

func (ShowQuotasRequest) String

func (o ShowQuotasRequest) String() string

type ShowQuotasRespQuotas

type ShowQuotasRespQuotas struct {
	Resources *[]ShowQuotasRespQuotasResources `json:"resources,omitempty"`
}

配额信息。

func (ShowQuotasRespQuotas) String

func (o ShowQuotasRespQuotas) String() string

type ShowQuotasRespQuotasResources

type ShowQuotasRespQuotasResources struct {
	Type *string `json:"type,omitempty"`

	Quota *int32 `json:"quota,omitempty"`

	Used *int32 `json:"used,omitempty"`

	Min *int32 `json:"min,omitempty"`

	Max *int32 `json:"max,omitempty"`
}

func (ShowQuotasRespQuotasResources) String

type ShowQuotasResponse

type ShowQuotasResponse struct {
	Quotas         *ShowQuotasRespQuotas `json:"quotas,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (ShowQuotasResponse) String

func (o ShowQuotasResponse) String() string

Source Files

Jump to

Keyboard shortcuts

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