model

package
v0.0.61 Latest Latest
Warning

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

Go to latest
Published: Sep 24, 2021 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchCreateOrDeleteKafkaTagRequest

type BatchCreateOrDeleteKafkaTagRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (BatchCreateOrDeleteKafkaTagRequest) String

type BatchCreateOrDeleteKafkaTagResponse

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

Response Object

func (BatchCreateOrDeleteKafkaTagResponse) String

type BatchCreateOrDeleteTagReq

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

	Tags *[]CreatePostPaidInstanceReqTags `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 BatchDeleteInstanceTopicReq

type BatchDeleteInstanceTopicReq struct {
	Topics *[]string `json:"topics,omitempty"`
}

func (BatchDeleteInstanceTopicReq) String

type BatchDeleteInstanceTopicRequest

type BatchDeleteInstanceTopicRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (BatchDeleteInstanceTopicRequest) String

type BatchDeleteInstanceTopicRespTopics

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

	Success *bool `json:"success,omitempty"`
}

func (BatchDeleteInstanceTopicRespTopics) String

type BatchDeleteInstanceTopicResponse

type BatchDeleteInstanceTopicResponse struct {
	Topics         *[]BatchDeleteInstanceTopicRespTopics `json:"topics,omitempty"`
	HttpStatusCode int                                   `json:"-"`
}

Response Object

func (BatchDeleteInstanceTopicResponse) String

type BatchDeleteInstanceUsersReq

type BatchDeleteInstanceUsersReq struct {
	Action *BatchDeleteInstanceUsersReqAction `json:"action,omitempty"`

	Users *[]string `json:"users,omitempty"`
}

func (BatchDeleteInstanceUsersReq) String

type BatchDeleteInstanceUsersReqAction

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

func (BatchDeleteInstanceUsersReqAction) MarshalJSON

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

func (*BatchDeleteInstanceUsersReqAction) UnmarshalJSON

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

type BatchDeleteInstanceUsersReqActionEnum

type BatchDeleteInstanceUsersReqActionEnum struct {
	DELETE BatchDeleteInstanceUsersReqAction
}

func GetBatchDeleteInstanceUsersReqActionEnum

func GetBatchDeleteInstanceUsersReqActionEnum() BatchDeleteInstanceUsersReqActionEnum

type BatchDeleteInstanceUsersRequest

type BatchDeleteInstanceUsersRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (BatchDeleteInstanceUsersRequest) String

type BatchDeleteInstanceUsersResponse

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

Response Object

func (BatchDeleteInstanceUsersResponse) String

type BatchRestartOrDeleteInstanceReq

type BatchRestartOrDeleteInstanceReq struct {
	Instances *[]string `json:"instances,omitempty"`

	Action BatchRestartOrDeleteInstanceReqAction `json:"action"`

	AllFailure *BatchRestartOrDeleteInstanceReqAllFailure `json:"all_failure,omitempty"`
}

func (BatchRestartOrDeleteInstanceReq) String

type BatchRestartOrDeleteInstanceReqAction

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

func (BatchRestartOrDeleteInstanceReqAction) MarshalJSON

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

func (*BatchRestartOrDeleteInstanceReqAction) UnmarshalJSON

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

type BatchRestartOrDeleteInstanceReqActionEnum

type BatchRestartOrDeleteInstanceReqActionEnum struct {
	RESTART BatchRestartOrDeleteInstanceReqAction
	DELETE  BatchRestartOrDeleteInstanceReqAction
}

func GetBatchRestartOrDeleteInstanceReqActionEnum

func GetBatchRestartOrDeleteInstanceReqActionEnum() BatchRestartOrDeleteInstanceReqActionEnum

type BatchRestartOrDeleteInstanceReqAllFailure

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

func (BatchRestartOrDeleteInstanceReqAllFailure) MarshalJSON

func (*BatchRestartOrDeleteInstanceReqAllFailure) UnmarshalJSON

type BatchRestartOrDeleteInstanceRespResults

type BatchRestartOrDeleteInstanceRespResults struct {
	Result *string `json:"result,omitempty"`

	Instance *string `json:"instance,omitempty"`
}

func (BatchRestartOrDeleteInstanceRespResults) String

type BatchRestartOrDeleteInstancesRequest

type BatchRestartOrDeleteInstancesRequest struct {
	Body *BatchRestartOrDeleteInstanceReq `json:"body,omitempty"`
}

Request Object

func (BatchRestartOrDeleteInstancesRequest) String

type BatchRestartOrDeleteInstancesResponse

type BatchRestartOrDeleteInstancesResponse struct {
	Results        *[]BatchRestartOrDeleteInstanceRespResults `json:"results,omitempty"`
	HttpStatusCode int                                        `json:"-"`
}

Response Object

func (BatchRestartOrDeleteInstancesResponse) String

type CreateConnectorReq

type CreateConnectorReq struct {
	Specification *CreateConnectorReqSpecification `json:"specification,omitempty"`

	NodeCnt *string `json:"node_cnt,omitempty"`

	SpecCode string `json:"spec_code"`
}

func (CreateConnectorReq) String

func (o CreateConnectorReq) String() string

type CreateConnectorReqSpecification

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

func (CreateConnectorReqSpecification) MarshalJSON

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

func (*CreateConnectorReqSpecification) UnmarshalJSON

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

type CreateConnectorRequest

type CreateConnectorRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (CreateConnectorRequest) String

func (o CreateConnectorRequest) String() string

type CreateConnectorResponse

type CreateConnectorResponse struct {
	JobId *string `json:"job_id,omitempty"`

	ConnectorId    *string `json:"connector_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateConnectorResponse) String

func (o CreateConnectorResponse) String() string

type CreateInstanceTopicReq

type CreateInstanceTopicReq struct {
	Id string `json:"id"`

	Replication *int32 `json:"replication,omitempty"`

	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`

	Partition *int32 `json:"partition,omitempty"`

	SyncReplication *bool `json:"sync_replication,omitempty"`

	RetentionTime *int32 `json:"retention_time,omitempty"`
}

func (CreateInstanceTopicReq) String

func (o CreateInstanceTopicReq) String() string

type CreateInstanceTopicRequest

type CreateInstanceTopicRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (CreateInstanceTopicRequest) String

type CreateInstanceTopicResponse

type CreateInstanceTopicResponse struct {
	Name           *string `json:"name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateInstanceTopicResponse) String

type CreateInstanceUserReq

type CreateInstanceUserReq struct {
	UserName *string `json:"user_name,omitempty"`

	UserPasswd *string `json:"user_passwd,omitempty"`
}

func (CreateInstanceUserReq) String

func (o CreateInstanceUserReq) String() string

type CreateInstanceUserRequest

type CreateInstanceUserRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (CreateInstanceUserRequest) String

func (o CreateInstanceUserRequest) String() string

type CreateInstanceUserResponse

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

Response Object

func (CreateInstanceUserResponse) String

type CreatePartitionReq

type CreatePartitionReq struct {
	Partition *int32 `json:"partition,omitempty"`
}

func (CreatePartitionReq) String

func (o CreatePartitionReq) String() string

type CreatePartitionRequest

type CreatePartitionRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`

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

Request Object

func (CreatePartitionRequest) String

func (o CreatePartitionRequest) String() string

type CreatePartitionResponse

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

Response Object

func (CreatePartitionResponse) String

func (o CreatePartitionResponse) String() string

type CreatePostPaidInstanceReq

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

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

	Engine CreatePostPaidInstanceReqEngine `json:"engine"`

	EngineVersion CreatePostPaidInstanceReqEngineVersion `json:"engine_version"`

	Specification CreatePostPaidInstanceReqSpecification `json:"specification"`

	StorageSpace int32 `json:"storage_space"`

	PartitionNum int32 `json:"partition_num"`

	AccessUser *string `json:"access_user,omitempty"`

	Password *string `json:"password,omitempty"`

	VpcId string `json:"vpc_id"`

	SecurityGroupId string `json:"security_group_id"`

	SubnetId string `json:"subnet_id"`

	AvailableZones []string `json:"available_zones"`

	ProductId string `json:"product_id"`

	KafkaManagerUser string `json:"kafka_manager_user"`

	KafkaManagerPassword string `json:"kafka_manager_password"`

	MaintainBegin *string `json:"maintain_begin,omitempty"`

	MaintainEnd *string `json:"maintain_end,omitempty"`

	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`

	PublicipId *string `json:"publicip_id,omitempty"`

	SslEnable *bool `json:"ssl_enable,omitempty"`

	RetentionPolicy *CreatePostPaidInstanceReqRetentionPolicy `json:"retention_policy,omitempty"`

	ConnectorEnable *bool `json:"connector_enable,omitempty"`

	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`

	StorageSpecCode CreatePostPaidInstanceReqStorageSpecCode `json:"storage_spec_code"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

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

创建实例请求体。

func (CreatePostPaidInstanceReq) String

func (o CreatePostPaidInstanceReq) String() string

type CreatePostPaidInstanceReqEngine

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

func (CreatePostPaidInstanceReqEngine) MarshalJSON

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

func (*CreatePostPaidInstanceReqEngine) UnmarshalJSON

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

type CreatePostPaidInstanceReqEngineEnum

type CreatePostPaidInstanceReqEngineEnum struct {
	KAFKA CreatePostPaidInstanceReqEngine
}

func GetCreatePostPaidInstanceReqEngineEnum

func GetCreatePostPaidInstanceReqEngineEnum() CreatePostPaidInstanceReqEngineEnum

type CreatePostPaidInstanceReqEngineVersion

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

func (CreatePostPaidInstanceReqEngineVersion) MarshalJSON

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

func (*CreatePostPaidInstanceReqEngineVersion) UnmarshalJSON

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

type CreatePostPaidInstanceReqEngineVersionEnum

type CreatePostPaidInstanceReqEngineVersionEnum struct {
	E_1_1_0 CreatePostPaidInstanceReqEngineVersion
	E_2_3_0 CreatePostPaidInstanceReqEngineVersion
}

func GetCreatePostPaidInstanceReqEngineVersionEnum

func GetCreatePostPaidInstanceReqEngineVersionEnum() CreatePostPaidInstanceReqEngineVersionEnum

type CreatePostPaidInstanceReqRetentionPolicy

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

func (CreatePostPaidInstanceReqRetentionPolicy) MarshalJSON

func (*CreatePostPaidInstanceReqRetentionPolicy) UnmarshalJSON

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

type CreatePostPaidInstanceReqRetentionPolicyEnum

type CreatePostPaidInstanceReqRetentionPolicyEnum struct {
	TIME_BASE      CreatePostPaidInstanceReqRetentionPolicy
	PRODUCE_REJECT CreatePostPaidInstanceReqRetentionPolicy
}

func GetCreatePostPaidInstanceReqRetentionPolicyEnum

func GetCreatePostPaidInstanceReqRetentionPolicyEnum() CreatePostPaidInstanceReqRetentionPolicyEnum

type CreatePostPaidInstanceReqSpecification

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

func (CreatePostPaidInstanceReqSpecification) MarshalJSON

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

func (*CreatePostPaidInstanceReqSpecification) UnmarshalJSON

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

type CreatePostPaidInstanceReqStorageSpecCode

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

func (CreatePostPaidInstanceReqStorageSpecCode) MarshalJSON

func (*CreatePostPaidInstanceReqStorageSpecCode) UnmarshalJSON

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

type CreatePostPaidInstanceReqStorageSpecCodeEnum

type CreatePostPaidInstanceReqStorageSpecCodeEnum struct {
	DMS_PHYSICAL_STORAGE_NORMAL CreatePostPaidInstanceReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_HIGH   CreatePostPaidInstanceReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_ULTRA  CreatePostPaidInstanceReqStorageSpecCode
}

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum() CreatePostPaidInstanceReqStorageSpecCodeEnum

type CreatePostPaidInstanceReqTags

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

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

func (CreatePostPaidInstanceReqTags) String

type CreatePostPaidInstanceRequest

type CreatePostPaidInstanceRequest struct {
	Body *CreatePostPaidInstanceReq `json:"body,omitempty"`
}

Request Object

func (CreatePostPaidInstanceRequest) String

type CreatePostPaidInstanceResponse

type CreatePostPaidInstanceResponse struct {
	InstanceId     *string `json:"instance_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreatePostPaidInstanceResponse) String

type CreateSinkTaskReq

type CreateSinkTaskReq struct {
	SourceType CreateSinkTaskReqSourceType `json:"source_type"`

	TaskName string `json:"task_name"`

	DestinationType CreateSinkTaskReqDestinationType `json:"destination_type"`

	ObsDestinationDescriptor *ObsDestinationDescriptor `json:"obs_destination_descriptor"`
}

func (CreateSinkTaskReq) String

func (o CreateSinkTaskReq) String() string

type CreateSinkTaskReqDestinationType

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

func (CreateSinkTaskReqDestinationType) MarshalJSON

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

func (*CreateSinkTaskReqDestinationType) UnmarshalJSON

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

type CreateSinkTaskReqDestinationTypeEnum

type CreateSinkTaskReqDestinationTypeEnum struct {
	OBS CreateSinkTaskReqDestinationType
}

func GetCreateSinkTaskReqDestinationTypeEnum

func GetCreateSinkTaskReqDestinationTypeEnum() CreateSinkTaskReqDestinationTypeEnum

type CreateSinkTaskReqSourceType

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

func (CreateSinkTaskReqSourceType) MarshalJSON

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

func (*CreateSinkTaskReqSourceType) UnmarshalJSON

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

type CreateSinkTaskReqSourceTypeEnum

type CreateSinkTaskReqSourceTypeEnum struct {
	BLOB CreateSinkTaskReqSourceType
}

func GetCreateSinkTaskReqSourceTypeEnum

func GetCreateSinkTaskReqSourceTypeEnum() CreateSinkTaskReqSourceTypeEnum

type CreateSinkTaskRequest

type CreateSinkTaskRequest struct {
	ConnectorId string `json:"connector_id"`

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

Request Object

func (CreateSinkTaskRequest) String

func (o CreateSinkTaskRequest) String() string

type CreateSinkTaskResponse

type CreateSinkTaskResponse struct {
	TaskId         *string `json:"task_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateSinkTaskResponse) String

func (o CreateSinkTaskResponse) String() string

type DeleteBackgroundTaskRequest

type DeleteBackgroundTaskRequest struct {
	InstanceId string `json:"instance_id"`

	TaskId string `json:"task_id"`
}

Request Object

func (DeleteBackgroundTaskRequest) String

type DeleteBackgroundTaskResponse

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

Response Object

func (DeleteBackgroundTaskResponse) String

type DeleteInstanceRequest

type DeleteInstanceRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (DeleteInstanceRequest) String

func (o DeleteInstanceRequest) String() string

type DeleteInstanceResponse

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

Response Object

func (DeleteInstanceResponse) String

func (o DeleteInstanceResponse) String() string

type DeleteSinkTaskRequest

type DeleteSinkTaskRequest struct {
	ConnectorId string `json:"connector_id"`

	TaskId string `json:"task_id"`
}

Request Object

func (DeleteSinkTaskRequest) String

func (o DeleteSinkTaskRequest) String() string

type DeleteSinkTaskResponse

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

Response Object

func (DeleteSinkTaskResponse) String

func (o DeleteSinkTaskResponse) String() string

type ListAvailableZonesRequest

type ListAvailableZonesRequest struct {
}

Request Object

func (ListAvailableZonesRequest) String

func (o ListAvailableZonesRequest) String() string

type ListAvailableZonesRespAvailableZones

type ListAvailableZonesRespAvailableZones struct {
	SoldOut *bool `json:"soldOut,omitempty"`

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

	Code *string `json:"code,omitempty"`

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

	Port *string `json:"port,omitempty"`

	ResourceAvailability *string `json:"resource_availability,omitempty"`

	DefaultAz *bool `json:"default_az,omitempty"`

	RemainTime *int64 `json:"remain_time,omitempty"`

	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`
}

func (ListAvailableZonesRespAvailableZones) String

type ListAvailableZonesResponse

type ListAvailableZonesResponse struct {
	RegionId *string `json:"region_id,omitempty"`

	AvailableZones *[]ListAvailableZonesRespAvailableZones `json:"available_zones,omitempty"`
	HttpStatusCode int                                     `json:"-"`
}

Response Object

func (ListAvailableZonesResponse) String

type ListBackgroundTasksRequest

type ListBackgroundTasksRequest struct {
	InstanceId string `json:"instance_id"`

	Start *int32 `json:"start,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	BeginTime *string `json:"begin_time,omitempty"`

	EndTime *string `json:"end_time,omitempty"`
}

Request Object

func (ListBackgroundTasksRequest) String

type ListBackgroundTasksRespTasks

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

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

	UserName *string `json:"user_name,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	Params *string `json:"params,omitempty"`

	Status *string `json:"status,omitempty"`

	CreatedAt *string `json:"created_at,omitempty"`

	UpdatedAt *string `json:"updated_at,omitempty"`
}

func (ListBackgroundTasksRespTasks) String

type ListBackgroundTasksResponse

type ListBackgroundTasksResponse struct {
	TaskCount *string `json:"task_count,omitempty"`

	Tasks          *[]ListBackgroundTasksRespTasks `json:"tasks,omitempty"`
	HttpStatusCode int                             `json:"-"`
}

Response Object

func (ListBackgroundTasksResponse) String

type ListInstanceTopicsRequest

type ListInstanceTopicsRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (ListInstanceTopicsRequest) String

func (o ListInstanceTopicsRequest) String() string

type ListInstanceTopicsRespTopics

type ListInstanceTopicsRespTopics struct {
	PoliciesOnly *bool `json:"policiesOnly,omitempty"`

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

	Replication *int32 `json:"replication,omitempty"`

	Partition *int32 `json:"partition,omitempty"`

	RetentionTime *int32 `json:"retention_time,omitempty"`

	SyncReplication *bool `json:"sync_replication,omitempty"`

	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`

	ExternalConfigs *interface{} `json:"external_configs,omitempty"`

	TopicType *int32 `json:"topic_type,omitempty"`
}

func (ListInstanceTopicsRespTopics) String

type ListInstanceTopicsResponse

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

	Size *int32 `json:"size,omitempty"`

	RemainPartitions *int32 `json:"remain_partitions,omitempty"`

	MaxPartitions *int32 `json:"max_partitions,omitempty"`

	Topics         *[]ListInstanceTopicsRespTopics `json:"topics,omitempty"`
	HttpStatusCode int                             `json:"-"`
}

Response Object

func (ListInstanceTopicsResponse) String

type ListInstancesRequest

type ListInstancesRequest struct {
	Engine *string `json:"engine,omitempty"`

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

	InstanceId *string `json:"instance_id,omitempty"`

	Status *ListInstancesRequestStatus `json:"status,omitempty"`

	IncludeFailure *ListInstancesRequestIncludeFailure `json:"include_failure,omitempty"`

	ExactMatchName *ListInstancesRequestExactMatchName `json:"exact_match_name,omitempty"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`
}

Request Object

func (ListInstancesRequest) String

func (o ListInstancesRequest) String() string

type ListInstancesRequestExactMatchName

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

func (ListInstancesRequestExactMatchName) MarshalJSON

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

func (*ListInstancesRequestExactMatchName) UnmarshalJSON

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

type ListInstancesRequestExactMatchNameEnum

type ListInstancesRequestExactMatchNameEnum struct {
	TRUE  ListInstancesRequestExactMatchName
	FALSE ListInstancesRequestExactMatchName
}

func GetListInstancesRequestExactMatchNameEnum

func GetListInstancesRequestExactMatchNameEnum() ListInstancesRequestExactMatchNameEnum

type ListInstancesRequestIncludeFailure

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

func (ListInstancesRequestIncludeFailure) MarshalJSON

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

func (*ListInstancesRequestIncludeFailure) UnmarshalJSON

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

type ListInstancesRequestIncludeFailureEnum

type ListInstancesRequestIncludeFailureEnum struct {
	TRUE  ListInstancesRequestIncludeFailure
	FALSE ListInstancesRequestIncludeFailure
}

func GetListInstancesRequestIncludeFailureEnum

func GetListInstancesRequestIncludeFailureEnum() ListInstancesRequestIncludeFailureEnum

type ListInstancesRequestStatus

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

func (ListInstancesRequestStatus) MarshalJSON

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

func (*ListInstancesRequestStatus) UnmarshalJSON

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

type ListInstancesRespInstances

type ListInstancesRespInstances struct {
	Name *string `json:"name,omitempty"`

	Engine *string `json:"engine,omitempty"`

	EngineVersion *string `json:"engine_version,omitempty"`

	Specification *string `json:"specification,omitempty"`

	StorageSpace *int32 `json:"storage_space,omitempty"`

	PartitionNum *string `json:"partition_num,omitempty"`

	UsedStorageSpace *int32 `json:"used_storage_space,omitempty"`

	ConnectAddress *string `json:"connect_address,omitempty"`

	Port *int32 `json:"port,omitempty"`

	Status *string `json:"status,omitempty"`

	InstanceId *string `json:"instance_id,omitempty"`

	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`

	ChargingMode *int32 `json:"charging_mode,omitempty"`

	VpcId *string `json:"vpc_id,omitempty"`

	VpcName *string `json:"vpc_name,omitempty"`

	CreatedAt *string `json:"created_at,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	UserName *string `json:"user_name,omitempty"`

	OrderId *string `json:"order_id,omitempty"`

	MaintainBegin *string `json:"maintain_begin,omitempty"`

	MaintainEnd *string `json:"maintain_end,omitempty"`

	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	ManagementConnectAddress *string `json:"management_connect_address,omitempty"`

	SslEnable *bool `json:"ssl_enable,omitempty"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	IsLogicalVolume *bool `json:"is_logical_volume,omitempty"`

	ExtendTimes *int32 `json:"extend_times,omitempty"`

	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`

	Type *ListInstancesRespInstancesType `json:"type,omitempty"`

	ProductId *string `json:"product_id,omitempty"`

	SecurityGroupId *string `json:"security_group_id,omitempty"`

	SecurityGroupName *string `json:"security_group_name,omitempty"`

	SubnetId *string `json:"subnet_id,omitempty"`

	AvailableZones *[]string `json:"available_zones,omitempty"`

	TotalStorageSpace *int32 `json:"total_storage_space,omitempty"`

	PublicConnectAddress *string `json:"public_connect_address,omitempty"`

	StorageResourceId *string `json:"storage_resource_id,omitempty"`

	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	ServiceType *string `json:"service_type,omitempty"`

	StorageType *string `json:"storage_type,omitempty"`

	RetentionPolicy *ListInstancesRespInstancesRetentionPolicy `json:"retention_policy,omitempty"`

	KafkaPublicStatus *string `json:"kafka_public_status,omitempty"`

	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`

	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`

	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`

	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`

	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	Ipv6ConnectAddresses *[]string `json:"ipv6_connect_addresses,omitempty"`

	ConnectorEnable *bool `json:"connector_enable,omitempty"`

	ConnectorId *string `json:"connector_id,omitempty"`

	RestEnable *bool `json:"rest_enable,omitempty"`

	RestConnectAddress *string `json:"rest_connect_address,omitempty"`

	MessageQueryInstEnable *bool `json:"message_query_inst_enable,omitempty"`

	VpcClientPlain *bool `json:"vpc_client_plain,omitempty"`

	SupportFeatures *string `json:"support_features,omitempty"`

	TraceEnable *bool `json:"trace_enable,omitempty"`

	PodConnectAddress *string `json:"pod_connect_address,omitempty"`

	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`

	KafkaPrivateConnectAddress *string `json:"kafka_private_connect_address,omitempty"`

	CesVersion *string `json:"ces_version,omitempty"`

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

func (ListInstancesRespInstances) String

type ListInstancesRespInstancesRetentionPolicy

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

func (ListInstancesRespInstancesRetentionPolicy) MarshalJSON

func (*ListInstancesRespInstancesRetentionPolicy) UnmarshalJSON

type ListInstancesRespInstancesRetentionPolicyEnum

type ListInstancesRespInstancesRetentionPolicyEnum struct {
	TIME_BASE      ListInstancesRespInstancesRetentionPolicy
	PRODUCE_REJECT ListInstancesRespInstancesRetentionPolicy
}

func GetListInstancesRespInstancesRetentionPolicyEnum

func GetListInstancesRespInstancesRetentionPolicyEnum() ListInstancesRespInstancesRetentionPolicyEnum

type ListInstancesRespInstancesType

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

func (ListInstancesRespInstancesType) MarshalJSON

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

func (*ListInstancesRespInstancesType) UnmarshalJSON

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

type ListInstancesRespInstancesTypeEnum

type ListInstancesRespInstancesTypeEnum struct {
	SINGLE  ListInstancesRespInstancesType
	CLUSTER ListInstancesRespInstancesType
}

func GetListInstancesRespInstancesTypeEnum

func GetListInstancesRespInstancesTypeEnum() ListInstancesRespInstancesTypeEnum

type ListInstancesRespTags

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

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

标签。

func (ListInstancesRespTags) String

func (o ListInstancesRespTags) String() string

type ListInstancesResponse

type ListInstancesResponse struct {
	Instances *[]ListInstancesRespInstances `json:"instances,omitempty"`

	InstanceNum    *int32 `json:"instance_num,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListInstancesResponse) String

func (o ListInstancesResponse) String() string

type ListProductsRequest

type ListProductsRequest struct {
	Engine string `json:"engine"`
}

Request Object

func (ListProductsRequest) String

func (o ListProductsRequest) String() string

type ListProductsRespDetail

type ListProductsRespDetail struct {
	Tps *string `json:"tps,omitempty"`

	Storage *string `json:"storage,omitempty"`

	PartitionNum *string `json:"partition_num,omitempty"`

	ProductId *string `json:"product_id,omitempty"`

	SpecCode *string `json:"spec_code,omitempty"`

	Io *[]ListProductsRespIo `json:"io,omitempty"`

	Bandwidth *string `json:"bandwidth,omitempty"`

	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	AvailableZones *[]string `json:"available_zones,omitempty"`

	EcsFlavorId *string `json:"ecs_flavor_id,omitempty"`

	ArchType *string `json:"arch_type,omitempty"`
}

func (ListProductsRespDetail) String

func (o ListProductsRespDetail) String() string

type ListProductsRespHourly

type ListProductsRespHourly struct {
	Name *string `json:"name,omitempty"`

	Version *string `json:"version,omitempty"`

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

func (ListProductsRespHourly) String

func (o ListProductsRespHourly) String() string

type ListProductsRespIo

type ListProductsRespIo struct {
	IoType *string `json:"io_type,omitempty"`

	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	AvailableZones *[]string `json:"available_zones,omitempty"`

	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	VolumeType *string `json:"volume_type,omitempty"`
}

func (ListProductsRespIo) String

func (o ListProductsRespIo) String() string

type ListProductsRespValues

type ListProductsRespValues struct {
	Detail *[]ListProductsRespDetail `json:"detail,omitempty"`

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

	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	AvailableZones *[]string `json:"available_zones,omitempty"`
}

func (ListProductsRespValues) String

func (o ListProductsRespValues) String() string

type ListProductsResponse

type ListProductsResponse struct {
	Hourly *[]ListProductsRespHourly `json:"Hourly,omitempty"`

	Monthly        *[]ListProductsRespHourly `json:"Monthly,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

Response Object

func (ListProductsResponse) String

func (o ListProductsResponse) String() string

type ListSinkTasksRequest

type ListSinkTasksRequest struct {
	ConnectorId string `json:"connector_id"`
}

Request Object

func (ListSinkTasksRequest) String

func (o ListSinkTasksRequest) String() string

type ListSinkTasksRespTasks

type ListSinkTasksRespTasks struct {
	TaskId *string `json:"task_id,omitempty"`

	TaskName *string `json:"task_name,omitempty"`

	DestinationType *string `json:"destination_type,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	Status *string `json:"status,omitempty"`

	Topics *string `json:"topics,omitempty"`
}

func (ListSinkTasksRespTasks) String

func (o ListSinkTasksRespTasks) String() string

type ListSinkTasksResponse

type ListSinkTasksResponse struct {
	Tasks *[]ListSinkTasksRespTasks `json:"tasks,omitempty"`

	TotalNumber *int32 `json:"total_number,omitempty"`

	MaxTasks *int32 `json:"max_tasks,omitempty"`

	QuotaTasks     *int32 `json:"quota_tasks,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListSinkTasksResponse) String

func (o ListSinkTasksResponse) String() string

type MaintainWindowsEntity

type MaintainWindowsEntity struct {
	Default *bool `json:"default,omitempty"`

	End *string `json:"end,omitempty"`

	Begin *string `json:"begin,omitempty"`

	Seq *int32 `json:"seq,omitempty"`
}

func (MaintainWindowsEntity) String

func (o MaintainWindowsEntity) String() string

type ObsDestinationDescriptor

type ObsDestinationDescriptor struct {
	Topics string `json:"topics"`

	TopicsRegex *string `json:"topics_regex,omitempty"`

	ConsumerStrategy ObsDestinationDescriptorConsumerStrategy `json:"consumer_strategy"`

	DestinationFileType ObsDestinationDescriptorDestinationFileType `json:"destination_file_type"`

	AccessKey string `json:"access_key"`

	SecretKey string `json:"secret_key"`

	ObsBucketName string `json:"obs_bucket_name"`

	ObsPath *string `json:"obs_path,omitempty"`

	PartitionFormat *string `json:"partition_format,omitempty"`

	RecordDelimiter *string `json:"record_delimiter,omitempty"`

	DeliverTimeInterval int32 `json:"deliver_time_interval"`
}

转存目标的描述。

func (ObsDestinationDescriptor) String

func (o ObsDestinationDescriptor) String() string

type ObsDestinationDescriptorConsumerStrategy

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

func (ObsDestinationDescriptorConsumerStrategy) MarshalJSON

func (*ObsDestinationDescriptorConsumerStrategy) UnmarshalJSON

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

type ObsDestinationDescriptorConsumerStrategyEnum

type ObsDestinationDescriptorConsumerStrategyEnum struct {
	LATEST   ObsDestinationDescriptorConsumerStrategy
	EARLIEST ObsDestinationDescriptorConsumerStrategy
}

func GetObsDestinationDescriptorConsumerStrategyEnum

func GetObsDestinationDescriptorConsumerStrategyEnum() ObsDestinationDescriptorConsumerStrategyEnum

type ObsDestinationDescriptorDestinationFileType

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

func (ObsDestinationDescriptorDestinationFileType) MarshalJSON

func (*ObsDestinationDescriptorDestinationFileType) UnmarshalJSON

type ObsDestinationDescriptorDestinationFileTypeEnum

type ObsDestinationDescriptorDestinationFileTypeEnum struct {
	TEXT ObsDestinationDescriptorDestinationFileType
}

func GetObsDestinationDescriptorDestinationFileTypeEnum

func GetObsDestinationDescriptorDestinationFileTypeEnum() ObsDestinationDescriptorDestinationFileTypeEnum

type ResetManagerPasswordReq

type ResetManagerPasswordReq struct {
	NewPassword *string `json:"new_password,omitempty"`
}

func (ResetManagerPasswordReq) String

func (o ResetManagerPasswordReq) String() string

type ResetManagerPasswordRequest

type ResetManagerPasswordRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (ResetManagerPasswordRequest) String

type ResetManagerPasswordResponse

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

Response Object

func (ResetManagerPasswordResponse) String

type ResetMessageOffsetReq

type ResetMessageOffsetReq struct {
	Topic string `json:"topic"`

	Partition *int32 `json:"partition,omitempty"`

	MessageOffset *int32 `json:"message_offset,omitempty"`

	Timestamp *int32 `json:"timestamp,omitempty"`
}

func (ResetMessageOffsetReq) String

func (o ResetMessageOffsetReq) String() string

type ResetMessageOffsetRequest

type ResetMessageOffsetRequest struct {
	InstanceId string `json:"instance_id"`

	Group string `json:"group"`

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

Request Object

func (ResetMessageOffsetRequest) String

func (o ResetMessageOffsetRequest) String() string

type ResetMessageOffsetResponse

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

Response Object

func (ResetMessageOffsetResponse) String

type ResetPasswordReq

type ResetPasswordReq struct {
	NewPassword *string `json:"new_password,omitempty"`
}

func (ResetPasswordReq) String

func (o ResetPasswordReq) String() string

type ResetPasswordRequest

type ResetPasswordRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (ResetPasswordRequest) String

func (o ResetPasswordRequest) String() string

type ResetPasswordResponse

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

Response Object

func (ResetPasswordResponse) String

func (o ResetPasswordResponse) String() string

type ResetReplicaReq

type ResetReplicaReq struct {
	Partitions *[]ResetReplicaReqPartitions `json:"partitions,omitempty"`
}

期望调整的分区副本分配情况。

func (ResetReplicaReq) String

func (o ResetReplicaReq) String() string

type ResetReplicaReqPartitions

type ResetReplicaReqPartitions struct {
	Partition *int32 `json:"partition,omitempty"`

	Replicas *[]int32 `json:"replicas,omitempty"`
}

func (ResetReplicaReqPartitions) String

func (o ResetReplicaReqPartitions) String() string

type ResetUserPasswrodReq

type ResetUserPasswrodReq struct {
	NewPassword *string `json:"new_password,omitempty"`
}

func (ResetUserPasswrodReq) String

func (o ResetUserPasswrodReq) String() string

type ResetUserPasswrodRequest

type ResetUserPasswrodRequest struct {
	InstanceId string `json:"instance_id"`

	UserName string `json:"user_name"`

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

Request Object

func (ResetUserPasswrodRequest) String

func (o ResetUserPasswrodRequest) String() string

type ResetUserPasswrodResponse

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

Response Object

func (ResetUserPasswrodResponse) String

func (o ResetUserPasswrodResponse) String() string

type ResizeInstanceReq

type ResizeInstanceReq struct {
	NewSpecCode *string `json:"new_spec_code,omitempty"`

	NewStorageSpace *int32 `json:"new_storage_space,omitempty"`
}

func (ResizeInstanceReq) String

func (o ResizeInstanceReq) String() string

type ResizeInstanceRequest

type ResizeInstanceRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (ResizeInstanceRequest) String

func (o ResizeInstanceRequest) String() string

type ResizeInstanceResponse

type ResizeInstanceResponse struct {
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ResizeInstanceResponse) String

func (o ResizeInstanceResponse) String() string

type RestartManagerRequest

type RestartManagerRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (RestartManagerRequest) String

func (o RestartManagerRequest) String() string

type RestartManagerResponse

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

Response Object

func (RestartManagerResponse) String

func (o RestartManagerResponse) String() string

type ShowBackgroundTaskRequest

type ShowBackgroundTaskRequest struct {
	InstanceId string `json:"instance_id"`

	TaskId string `json:"task_id"`
}

Request Object

func (ShowBackgroundTaskRequest) String

func (o ShowBackgroundTaskRequest) String() string

type ShowBackgroundTaskResponse

type ShowBackgroundTaskResponse struct {
	TaskCount *string `json:"task_count,omitempty"`

	Tasks          *[]ListBackgroundTasksRespTasks `json:"tasks,omitempty"`
	HttpStatusCode int                             `json:"-"`
}

Response Object

func (ShowBackgroundTaskResponse) String

type ShowCesHierarchyRequest

type ShowCesHierarchyRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowCesHierarchyRequest) String

func (o ShowCesHierarchyRequest) String() string

type ShowCesHierarchyResponse

type ShowCesHierarchyResponse struct {
	Dimensions *[]ShowCeshierarchyRespDimensions `json:"dimensions,omitempty"`

	InstanceIds *[]ShowCeshierarchyRespInstanceIds `json:"instance_ids,omitempty"`

	Nodes *[]ShowCeshierarchyRespNodes `json:"nodes,omitempty"`

	Queues *[]ShowCeshierarchyRespQueues `json:"queues,omitempty"`

	Groups         *[]ShowCeshierarchyRespGroups `json:"groups,omitempty"`
	HttpStatusCode int                           `json:"-"`
}

Response Object

func (ShowCesHierarchyResponse) String

func (o ShowCesHierarchyResponse) String() string

type ShowCeshierarchyRespChildren

type ShowCeshierarchyRespChildren struct {
	Name *string `json:"name,omitempty"`

	Metrics *[]string `json:"metrics,omitempty"`

	KeyName *[]string `json:"key_name,omitempty"`

	DimRouter *[]string `json:"dim_router,omitempty"`
}

子维度信息。

func (ShowCeshierarchyRespChildren) String

type ShowCeshierarchyRespDimensions

type ShowCeshierarchyRespDimensions struct {
	Name *string `json:"name,omitempty"`

	Metrics *[]string `json:"metrics,omitempty"`

	KeyName *[]string `json:"key_name,omitempty"`

	DimRouter *[]string `json:"dim_router,omitempty"`

	Children *[]ShowCeshierarchyRespChildren `json:"children,omitempty"`
}

func (ShowCeshierarchyRespDimensions) String

type ShowCeshierarchyRespGroups

type ShowCeshierarchyRespGroups struct {
	Name *string `json:"name,omitempty"`

	Queues *[]ShowCeshierarchyRespQueues1 `json:"queues,omitempty"`
}

func (ShowCeshierarchyRespGroups) String

type ShowCeshierarchyRespInstanceIds

type ShowCeshierarchyRespInstanceIds struct {
	Name *string `json:"name,omitempty"`
}

func (ShowCeshierarchyRespInstanceIds) String

type ShowCeshierarchyRespNodes

type ShowCeshierarchyRespNodes struct {
	Name *string `json:"name,omitempty"`
}

func (ShowCeshierarchyRespNodes) String

func (o ShowCeshierarchyRespNodes) String() string

type ShowCeshierarchyRespPartitions

type ShowCeshierarchyRespPartitions struct {
	Name *string `json:"name,omitempty"`
}

func (ShowCeshierarchyRespPartitions) String

type ShowCeshierarchyRespQueues

type ShowCeshierarchyRespQueues struct {
	Name *string `json:"name,omitempty"`

	Partitions *[]ShowCeshierarchyRespPartitions `json:"partitions,omitempty"`
}

func (ShowCeshierarchyRespQueues) String

type ShowCeshierarchyRespQueues1

type ShowCeshierarchyRespQueues1 struct {
	Name *string `json:"name,omitempty"`

	Partitions *[]ShowCeshierarchyRespPartitions `json:"partitions,omitempty"`
}

func (ShowCeshierarchyRespQueues1) String

type ShowClusterRequest

type ShowClusterRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowClusterRequest) String

func (o ShowClusterRequest) String() string

type ShowClusterRespCluster

type ShowClusterRespCluster struct {
	Controller *string `json:"controller,omitempty"`

	Brokers *[]ShowClusterRespClusterBrokers `json:"brokers,omitempty"`

	TopicsCount *int32 `json:"topics_count,omitempty"`

	PartitionsCount *int32 `json:"partitions_count,omitempty"`

	OnlinePartitionsCount *int32 `json:"online_partitions_count,omitempty"`

	ReplicasCount *int32 `json:"replicas_count,omitempty"`

	IsrReplicasCount *int32 `json:"isr_replicas_count,omitempty"`

	ConsumersCount *int32 `json:"consumers_count,omitempty"`
}

集群基本信息。

func (ShowClusterRespCluster) String

func (o ShowClusterRespCluster) String() string

type ShowClusterRespClusterBrokers

type ShowClusterRespClusterBrokers struct {
	Host *string `json:"host,omitempty"`

	Port *int32 `json:"port,omitempty"`

	BrokerId *string `json:"broker_id,omitempty"`

	IsController *bool `json:"is_controller,omitempty"`

	Version *string `json:"version,omitempty"`

	RegisterTime *int64 `json:"register_time,omitempty"`

	IsHealth *bool `json:"is_health,omitempty"`
}

节点。

func (ShowClusterRespClusterBrokers) String

type ShowClusterResponse

type ShowClusterResponse struct {
	Cluster        *ShowClusterRespCluster `json:"cluster,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

Response Object

func (ShowClusterResponse) String

func (o ShowClusterResponse) String() string

type ShowCoordinatorsRequest

type ShowCoordinatorsRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowCoordinatorsRequest) String

func (o ShowCoordinatorsRequest) String() string

type ShowCoordinatorsRespCoordinators

type ShowCoordinatorsRespCoordinators struct {
	GroupId *string `json:"group_id,omitempty"`

	Id *int32 `json:"id,omitempty"`

	Host *string `json:"host,omitempty"`

	Port *int32 `json:"port,omitempty"`
}

协调器信息。

func (ShowCoordinatorsRespCoordinators) String

type ShowCoordinatorsResponse

type ShowCoordinatorsResponse struct {
	Coordinators   *[]ShowCoordinatorsRespCoordinators `json:"coordinators,omitempty"`
	HttpStatusCode int                                 `json:"-"`
}

Response Object

func (ShowCoordinatorsResponse) String

func (o ShowCoordinatorsResponse) String() string

type ShowGroupsRequest

type ShowGroupsRequest struct {
	InstanceId string `json:"instance_id"`

	Group string `json:"group"`
}

Request Object

func (ShowGroupsRequest) String

func (o ShowGroupsRequest) String() string

type ShowGroupsRespGroup

type ShowGroupsRespGroup struct {
	GroupId *string `json:"group_id,omitempty"`

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

	CoordinatorId *int32 `json:"coordinator_id,omitempty"`

	Members *[]ShowGroupsRespGroupMembers `json:"members,omitempty"`

	GroupMessageOffsets *[]ShowGroupsRespGroupGroupMessageOffsets `json:"group_message_offsets,omitempty"`

	AssignmentStrategy *string `json:"assignment_strategy,omitempty"`
}

消费组信息。

func (ShowGroupsRespGroup) String

func (o ShowGroupsRespGroup) String() string

type ShowGroupsRespGroupAssignment

type ShowGroupsRespGroupAssignment struct {
	Topic *string `json:"topic,omitempty"`

	Partitions *[]int32 `json:"partitions,omitempty"`
}

func (ShowGroupsRespGroupAssignment) String

type ShowGroupsRespGroupGroupMessageOffsets

type ShowGroupsRespGroupGroupMessageOffsets struct {
	Partition *int32 `json:"partition,omitempty"`

	Lag *int32 `json:"lag,omitempty"`

	Topic *string `json:"topic,omitempty"`

	MessageCurrentOffset *int32 `json:"message_current_offset,omitempty"`

	MessageLogEndOffset *int32 `json:"message_log_end_offset,omitempty"`
}

func (ShowGroupsRespGroupGroupMessageOffsets) String

type ShowGroupsRespGroupMembers

type ShowGroupsRespGroupMembers struct {
	Host *string `json:"host,omitempty"`

	Assignment *[]ShowGroupsRespGroupAssignment `json:"assignment,omitempty"`

	MemberId *string `json:"member_id,omitempty"`

	ClientId *string `json:"client_id,omitempty"`
}

func (ShowGroupsRespGroupMembers) String

type ShowGroupsResponse

type ShowGroupsResponse struct {
	Group          *ShowGroupsRespGroup `json:"group,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (ShowGroupsResponse) String

func (o ShowGroupsResponse) String() string

type ShowInstanceExtendProductInfoRequest

type ShowInstanceExtendProductInfoRequest struct {
	InstanceId string `json:"instance_id"`

	Type ShowInstanceExtendProductInfoRequestType `json:"type"`

	Engine *string `json:"engine,omitempty"`
}

Request Object

func (ShowInstanceExtendProductInfoRequest) String

type ShowInstanceExtendProductInfoRequestType

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

func (ShowInstanceExtendProductInfoRequestType) MarshalJSON

func (*ShowInstanceExtendProductInfoRequestType) UnmarshalJSON

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

type ShowInstanceExtendProductInfoResponse

type ShowInstanceExtendProductInfoResponse struct {
	Hourly *[]ListProductsRespHourly `json:"hourly,omitempty"`

	Monthly        *[]ListProductsRespHourly `json:"monthly,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

Response Object

func (ShowInstanceExtendProductInfoResponse) String

type ShowInstanceMessagesRequest

type ShowInstanceMessagesRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`

	Asc *bool `json:"asc,omitempty"`

	StartTime *string `json:"start_time,omitempty"`

	EndTime *string `json:"end_time,omitempty"`

	Limit *string `json:"limit,omitempty"`

	Offset *string `json:"offset,omitempty"`

	Download *bool `json:"download,omitempty"`

	MessageOffset *string `json:"message_offset,omitempty"`

	Partition *string `json:"partition,omitempty"`
}

Request Object

func (ShowInstanceMessagesRequest) String

type ShowInstanceMessagesRespMessages

type ShowInstanceMessagesRespMessages struct {
	Topic *string `json:"topic,omitempty"`

	Partition *int32 `json:"partition,omitempty"`

	Key *string `json:"key,omitempty"`

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

	Size *int32 `json:"size,omitempty"`

	Timestamp *int64 `json:"timestamp,omitempty"`

	HugeMessage *bool `json:"huge_message,omitempty"`

	MessageOffset *int32 `json:"message_offset,omitempty"`

	MessageId *string `json:"message_id,omitempty"`

	AppId *string `json:"app_id,omitempty"`

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

func (ShowInstanceMessagesRespMessages) String

type ShowInstanceMessagesResponse

type ShowInstanceMessagesResponse struct {
	Messages *[]ShowInstanceMessagesRespMessages `json:"messages,omitempty"`

	Total *int64 `json:"total,omitempty"`

	Size           *int64 `json:"size,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowInstanceMessagesResponse) String

type ShowInstanceRequest

type ShowInstanceRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowInstanceRequest) String

func (o ShowInstanceRequest) String() string

type ShowInstanceResponse

type ShowInstanceResponse struct {
	Name *string `json:"name,omitempty"`

	Engine *string `json:"engine,omitempty"`

	EngineVersion *string `json:"engine_version,omitempty"`

	Specification *string `json:"specification,omitempty"`

	StorageSpace *int32 `json:"storage_space,omitempty"`

	PartitionNum *string `json:"partition_num,omitempty"`

	UsedStorageSpace *int32 `json:"used_storage_space,omitempty"`

	ConnectAddress *string `json:"connect_address,omitempty"`

	Port *int32 `json:"port,omitempty"`

	Status *string `json:"status,omitempty"`

	InstanceId *string `json:"instance_id,omitempty"`

	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`

	ChargingMode *int32 `json:"charging_mode,omitempty"`

	VpcId *string `json:"vpc_id,omitempty"`

	VpcName *string `json:"vpc_name,omitempty"`

	CreatedAt *string `json:"created_at,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	UserName *string `json:"user_name,omitempty"`

	OrderId *string `json:"order_id,omitempty"`

	MaintainBegin *string `json:"maintain_begin,omitempty"`

	MaintainEnd *string `json:"maintain_end,omitempty"`

	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	ManagementConnectAddress *string `json:"management_connect_address,omitempty"`

	SslEnable *bool `json:"ssl_enable,omitempty"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	IsLogicalVolume *bool `json:"is_logical_volume,omitempty"`

	ExtendTimes *int32 `json:"extend_times,omitempty"`

	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`

	Type *ShowInstanceResponseType `json:"type,omitempty"`

	ProductId *string `json:"product_id,omitempty"`

	SecurityGroupId *string `json:"security_group_id,omitempty"`

	SecurityGroupName *string `json:"security_group_name,omitempty"`

	SubnetId *string `json:"subnet_id,omitempty"`

	AvailableZones *[]string `json:"available_zones,omitempty"`

	TotalStorageSpace *int32 `json:"total_storage_space,omitempty"`

	PublicConnectAddress *string `json:"public_connect_address,omitempty"`

	StorageResourceId *string `json:"storage_resource_id,omitempty"`

	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	ServiceType *string `json:"service_type,omitempty"`

	StorageType *string `json:"storage_type,omitempty"`

	RetentionPolicy *ShowInstanceResponseRetentionPolicy `json:"retention_policy,omitempty"`

	KafkaPublicStatus *string `json:"kafka_public_status,omitempty"`

	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`

	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`

	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`

	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`

	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	Ipv6ConnectAddresses *[]string `json:"ipv6_connect_addresses,omitempty"`

	ConnectorEnable *bool `json:"connector_enable,omitempty"`

	ConnectorId *string `json:"connector_id,omitempty"`

	RestEnable *bool `json:"rest_enable,omitempty"`

	RestConnectAddress *string `json:"rest_connect_address,omitempty"`

	MessageQueryInstEnable *bool `json:"message_query_inst_enable,omitempty"`

	VpcClientPlain *bool `json:"vpc_client_plain,omitempty"`

	SupportFeatures *string `json:"support_features,omitempty"`

	TraceEnable *bool `json:"trace_enable,omitempty"`

	PodConnectAddress *string `json:"pod_connect_address,omitempty"`

	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`

	KafkaPrivateConnectAddress *string `json:"kafka_private_connect_address,omitempty"`

	CesVersion *string `json:"ces_version,omitempty"`

	Tags           *[]ListInstancesRespTags `json:"tags,omitempty"`
	HttpStatusCode int                      `json:"-"`
}

Response Object

func (ShowInstanceResponse) String

func (o ShowInstanceResponse) String() string

type ShowInstanceResponseRetentionPolicy

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

func (ShowInstanceResponseRetentionPolicy) MarshalJSON

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

func (*ShowInstanceResponseRetentionPolicy) UnmarshalJSON

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

type ShowInstanceResponseRetentionPolicyEnum

type ShowInstanceResponseRetentionPolicyEnum struct {
	TIME_BASE      ShowInstanceResponseRetentionPolicy
	PRODUCE_REJECT ShowInstanceResponseRetentionPolicy
}

func GetShowInstanceResponseRetentionPolicyEnum

func GetShowInstanceResponseRetentionPolicyEnum() ShowInstanceResponseRetentionPolicyEnum

type ShowInstanceResponseType

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

func (ShowInstanceResponseType) MarshalJSON

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

func (*ShowInstanceResponseType) UnmarshalJSON

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

type ShowInstanceResponseTypeEnum

type ShowInstanceResponseTypeEnum struct {
	SINGLE  ShowInstanceResponseType
	CLUSTER ShowInstanceResponseType
}

func GetShowInstanceResponseTypeEnum

func GetShowInstanceResponseTypeEnum() ShowInstanceResponseTypeEnum

type ShowInstanceTopicDetailRequest

type ShowInstanceTopicDetailRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`
}

Request Object

func (ShowInstanceTopicDetailRequest) String

type ShowInstanceTopicDetailRespPartitions

type ShowInstanceTopicDetailRespPartitions struct {
	Partition *int32 `json:"partition,omitempty"`

	Leader *int32 `json:"leader,omitempty"`

	Leo *int32 `json:"leo,omitempty"`

	Hw *int32 `json:"hw,omitempty"`

	Lso *int32 `json:"lso,omitempty"`

	LastUpdateTimestamp *int64 `json:"last_update_timestamp,omitempty"`

	Replicas *[]ShowInstanceTopicDetailRespReplicas `json:"replicas,omitempty"`
}

func (ShowInstanceTopicDetailRespPartitions) String

type ShowInstanceTopicDetailRespReplicas

type ShowInstanceTopicDetailRespReplicas struct {
	Broker *int32 `json:"broker,omitempty"`

	Leader *bool `json:"leader,omitempty"`

	InSync *bool `json:"in_sync,omitempty"`

	Size *int32 `json:"size,omitempty"`

	Lag *int32 `json:"lag,omitempty"`
}

func (ShowInstanceTopicDetailRespReplicas) String

type ShowInstanceTopicDetailResponse

type ShowInstanceTopicDetailResponse struct {
	Topic *string `json:"topic,omitempty"`

	Partitions *[]ShowInstanceTopicDetailRespPartitions `json:"partitions,omitempty"`

	GroupSubscribed *[]string `json:"group_subscribed,omitempty"`
	HttpStatusCode  int       `json:"-"`
}

Response Object

func (ShowInstanceTopicDetailResponse) String

type ShowInstanceUsersRequest

type ShowInstanceUsersRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowInstanceUsersRequest) String

func (o ShowInstanceUsersRequest) String() string

type ShowInstanceUsersRespUsers

type ShowInstanceUsersRespUsers struct {
	UserName *string `json:"user_name,omitempty"`

	Role *string `json:"role,omitempty"`

	DefaultApp *bool `json:"default_app,omitempty"`

	CreatedTime *int64 `json:"created_time,omitempty"`
}

func (ShowInstanceUsersRespUsers) String

type ShowInstanceUsersResponse

type ShowInstanceUsersResponse struct {
	Users          *[]ShowInstanceUsersRespUsers `json:"users,omitempty"`
	HttpStatusCode int                           `json:"-"`
}

Response Object

func (ShowInstanceUsersResponse) String

func (o ShowInstanceUsersResponse) String() string

type ShowKafkaProjectTagsRequest

type ShowKafkaProjectTagsRequest struct {
}

Request Object

func (ShowKafkaProjectTagsRequest) String

type ShowKafkaProjectTagsResponse

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

Response Object

func (ShowKafkaProjectTagsResponse) String

type ShowKafkaTagsRequest

type ShowKafkaTagsRequest struct {
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowKafkaTagsRequest) String

func (o ShowKafkaTagsRequest) String() string

type ShowKafkaTagsResponse

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

Response Object

func (ShowKafkaTagsResponse) String

func (o ShowKafkaTagsResponse) String() string

type ShowKafkaTopicPartitionDiskusageRequest

type ShowKafkaTopicPartitionDiskusageRequest struct {
	InstanceId string `json:"instance_id"`

	MinSize *string `json:"minSize,omitempty"`

	Top *string `json:"top,omitempty"`

	Percentage *string `json:"percentage,omitempty"`
}

Request Object

func (ShowKafkaTopicPartitionDiskusageRequest) String

type ShowKafkaTopicPartitionDiskusageRespBrokerList

type ShowKafkaTopicPartitionDiskusageRespBrokerList struct {
	BrokerName *string `json:"broker_name,omitempty"`

	DataDiskSize *string `json:"data_disk_size,omitempty"`

	DataDiskUse *string `json:"data_disk_use,omitempty"`

	DataDiskFree *string `json:"data_disk_free,omitempty"`

	DataDiskUsePercentage *string `json:"data_disk_use_percentage,omitempty"`

	Status *string `json:"status,omitempty"`

	TopicList *[]ShowKafkaTopicPartitionDiskusageRespTopicList `json:"topic_list,omitempty"`
}

func (ShowKafkaTopicPartitionDiskusageRespBrokerList) String

type ShowKafkaTopicPartitionDiskusageRespTopicList

type ShowKafkaTopicPartitionDiskusageRespTopicList struct {
	Size *string `json:"size,omitempty"`

	TopicName *string `json:"topic_name,omitempty"`

	TopicPartition *string `json:"topic_partition,omitempty"`

	Percentage *float64 `json:"percentage,omitempty"`
}

func (ShowKafkaTopicPartitionDiskusageRespTopicList) String

type ShowKafkaTopicPartitionDiskusageResponse

type ShowKafkaTopicPartitionDiskusageResponse struct {
	BrokerList     *[]ShowKafkaTopicPartitionDiskusageRespBrokerList `json:"broker_list,omitempty"`
	HttpStatusCode int                                               `json:"-"`
}

Response Object

func (ShowKafkaTopicPartitionDiskusageResponse) String

type ShowMaintainWindowsRequest

type ShowMaintainWindowsRequest struct {
}

Request Object

func (ShowMaintainWindowsRequest) String

type ShowMaintainWindowsResponse

type ShowMaintainWindowsResponse struct {
	MaintainWindows *[]MaintainWindowsEntity `json:"maintain_windows,omitempty"`
	HttpStatusCode  int                      `json:"-"`
}

Response Object

func (ShowMaintainWindowsResponse) String

type ShowMessagesRequest

type ShowMessagesRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`

	StartTime *string `json:"start_time,omitempty"`

	EndTime *string `json:"end_time,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Partition *string `json:"partition,omitempty"`
}

Request Object

func (ShowMessagesRequest) String

func (o ShowMessagesRequest) String() string

type ShowMessagesRespMessages

type ShowMessagesRespMessages struct {
	Topic *string `json:"topic,omitempty"`

	Partition *int32 `json:"partition,omitempty"`

	MessageOffset *int32 `json:"message_offset,omitempty"`

	Size *int32 `json:"size,omitempty"`

	Timestamp *int64 `json:"timestamp,omitempty"`
}

func (ShowMessagesRespMessages) String

func (o ShowMessagesRespMessages) String() string

type ShowMessagesResponse

type ShowMessagesResponse struct {
	Messages *[]ShowMessagesRespMessages `json:"messages,omitempty"`

	MessagesCount *int32 `json:"messages_count,omitempty"`

	OffsetsCount *int32 `json:"offsets_count,omitempty"`

	Offset         *int32 `json:"offset,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowMessagesResponse) String

func (o ShowMessagesResponse) String() string

type ShowPartitionBeginningMessageRequest

type ShowPartitionBeginningMessageRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`

	Partition int32 `json:"partition"`
}

Request Object

func (ShowPartitionBeginningMessageRequest) String

type ShowPartitionBeginningMessageResponse

type ShowPartitionBeginningMessageResponse struct {
	Topic *string `json:"topic,omitempty"`

	Partition *int32 `json:"partition,omitempty"`

	MessageOffset *int32 `json:"message_offset,omitempty"`

	Timestamp      *int64 `json:"timestamp,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowPartitionBeginningMessageResponse) String

type ShowPartitionEndMessageRequest

type ShowPartitionEndMessageRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`

	Partition int32 `json:"partition"`
}

Request Object

func (ShowPartitionEndMessageRequest) String

type ShowPartitionEndMessageResponse

type ShowPartitionEndMessageResponse struct {
	Topic *string `json:"topic,omitempty"`

	Partition *int32 `json:"partition,omitempty"`

	MessageOffset *int32 `json:"message_offset,omitempty"`

	Timestamp      *int64 `json:"timestamp,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowPartitionEndMessageResponse) String

type ShowPartitionMessageRequest

type ShowPartitionMessageRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`

	Partition int32 `json:"partition"`

	MessageOffset string `json:"message_offset"`
}

Request Object

func (ShowPartitionMessageRequest) String

type ShowPartitionMessageRespMessage

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

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

	Topic *string `json:"topic,omitempty"`

	Partition *int32 `json:"partition,omitempty"`

	MessageOffset *int64 `json:"message_offset,omitempty"`

	Size *int32 `json:"size,omitempty"`

	Timestamp *int64 `json:"timestamp,omitempty"`
}

消息体。

func (ShowPartitionMessageRespMessage) String

type ShowPartitionMessageResponse

type ShowPartitionMessageResponse struct {
	Message        *[]ShowPartitionMessageRespMessage `json:"message,omitempty"`
	HttpStatusCode int                                `json:"-"`
}

Response Object

func (ShowPartitionMessageResponse) 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 ShowSinkTaskDetailRequest

type ShowSinkTaskDetailRequest struct {
	ConnectorId string `json:"connector_id"`

	TaskId string `json:"task_id"`
}

Request Object

func (ShowSinkTaskDetailRequest) String

func (o ShowSinkTaskDetailRequest) String() string

type ShowSinkTaskDetailRespObsDestinationDescriptor

type ShowSinkTaskDetailRespObsDestinationDescriptor struct {
	ConsumerStrategy *string `json:"consumer_strategy,omitempty"`

	DestinationFileType *string `json:"destination_file_type,omitempty"`

	ObsBucketName *string `json:"obs_bucket_name,omitempty"`

	ObsPath *string `json:"obs_path,omitempty"`

	PartitionFormat *string `json:"partition_format,omitempty"`

	RecordDelimiter *string `json:"record_delimiter,omitempty"`

	DeliverTimeInterval *int32 `json:"deliver_time_interval,omitempty"`

	ObsPartSize *int64 `json:"obs_part_size,omitempty"`
}

转存目标的描述。

func (ShowSinkTaskDetailRespObsDestinationDescriptor) String

type ShowSinkTaskDetailResponse

type ShowSinkTaskDetailResponse struct {
	TaskName *string `json:"task_name,omitempty"`

	DestinationType *string `json:"destination_type,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	Status *string `json:"status,omitempty"`

	Topics *string `json:"topics,omitempty"`

	ObsDestinationDescriptor *ShowSinkTaskDetailRespObsDestinationDescriptor `json:"obs_destination_descriptor,omitempty"`
	HttpStatusCode           int                                             `json:"-"`
}

Response Object

func (ShowSinkTaskDetailResponse) String

type ShowTopicAccessPolicyRequest

type ShowTopicAccessPolicyRequest struct {
	InstanceId string `json:"instance_id"`

	TopicName string `json:"topic_name"`
}

Request Object

func (ShowTopicAccessPolicyRequest) String

type ShowTopicAccessPolicyRespPolicies

type ShowTopicAccessPolicyRespPolicies struct {
	Owner *bool `json:"owner,omitempty"`

	UserName *string `json:"user_name,omitempty"`

	AccessPolicy *ShowTopicAccessPolicyRespPoliciesAccessPolicy `json:"access_policy,omitempty"`
}

func (ShowTopicAccessPolicyRespPolicies) String

type ShowTopicAccessPolicyRespPoliciesAccessPolicy

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

func (ShowTopicAccessPolicyRespPoliciesAccessPolicy) MarshalJSON

func (*ShowTopicAccessPolicyRespPoliciesAccessPolicy) UnmarshalJSON

type ShowTopicAccessPolicyResponse

type ShowTopicAccessPolicyResponse struct {
	Name *string `json:"name,omitempty"`

	TopicType *int32 `json:"topic_type,omitempty"`

	Policies       *[]ShowTopicAccessPolicyRespPolicies `json:"policies,omitempty"`
	HttpStatusCode int                                  `json:"-"`
}

Response Object

func (ShowTopicAccessPolicyResponse) String

type UpdateInstanceAutoCreateTopicReq

type UpdateInstanceAutoCreateTopicReq struct {
	EnableAutoTopic bool `json:"enable_auto_topic"`
}

func (UpdateInstanceAutoCreateTopicReq) String

type UpdateInstanceAutoCreateTopicRequest

type UpdateInstanceAutoCreateTopicRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (UpdateInstanceAutoCreateTopicRequest) String

type UpdateInstanceAutoCreateTopicResponse

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

Response Object

func (UpdateInstanceAutoCreateTopicResponse) String

type UpdateInstanceCrossVpcIpReq

type UpdateInstanceCrossVpcIpReq struct {
	AdvertisedIpContents map[string]string `json:"advertised_ip_contents"`
}

func (UpdateInstanceCrossVpcIpReq) String

type UpdateInstanceCrossVpcIpRequest

type UpdateInstanceCrossVpcIpRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (UpdateInstanceCrossVpcIpRequest) String

type UpdateInstanceCrossVpcIpRespResults

type UpdateInstanceCrossVpcIpRespResults struct {
	AdvertisedIp *string `json:"advertised_ip,omitempty"`

	Success *bool `json:"success,omitempty"`

	Ip *string `json:"ip,omitempty"`
}

修改broker跨VPC访问的结果。

func (UpdateInstanceCrossVpcIpRespResults) String

type UpdateInstanceCrossVpcIpResponse

type UpdateInstanceCrossVpcIpResponse struct {
	Success *bool `json:"success,omitempty"`

	Results        *[]UpdateInstanceCrossVpcIpRespResults `json:"results,omitempty"`
	HttpStatusCode int                                    `json:"-"`
}

Response Object

func (UpdateInstanceCrossVpcIpResponse) String

type UpdateInstanceReq

type UpdateInstanceReq struct {
	Name *string `json:"name,omitempty"`

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

	MaintainBegin *string `json:"maintain_begin,omitempty"`

	MaintainEnd *string `json:"maintain_end,omitempty"`

	SecurityGroupId *string `json:"security_group_id,omitempty"`

	RetentionPolicy *UpdateInstanceReqRetentionPolicy `json:"retention_policy,omitempty"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`
}

func (UpdateInstanceReq) String

func (o UpdateInstanceReq) String() string

type UpdateInstanceReqRetentionPolicy

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

func (UpdateInstanceReqRetentionPolicy) MarshalJSON

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

func (*UpdateInstanceReqRetentionPolicy) UnmarshalJSON

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

type UpdateInstanceReqRetentionPolicyEnum

type UpdateInstanceReqRetentionPolicyEnum struct {
	PRODUCE_REJECT UpdateInstanceReqRetentionPolicy
	TIME_BASE      UpdateInstanceReqRetentionPolicy
}

func GetUpdateInstanceReqRetentionPolicyEnum

func GetUpdateInstanceReqRetentionPolicyEnum() UpdateInstanceReqRetentionPolicyEnum

type UpdateInstanceRequest

type UpdateInstanceRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (UpdateInstanceRequest) String

func (o UpdateInstanceRequest) String() string

type UpdateInstanceResponse

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

Response Object

func (UpdateInstanceResponse) String

func (o UpdateInstanceResponse) String() string

type UpdateInstanceTopicReq

type UpdateInstanceTopicReq struct {
	Topics *[]UpdateInstanceTopicReqTopics `json:"topics,omitempty"`
}

修改的topic列表。

func (UpdateInstanceTopicReq) String

func (o UpdateInstanceTopicReq) String() string

type UpdateInstanceTopicReqTopics

type UpdateInstanceTopicReqTopics struct {
	Id string `json:"id"`

	RetentionTime *int32 `json:"retention_time,omitempty"`

	SyncReplication *bool `json:"sync_replication,omitempty"`

	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`

	NewPartitionNumbers *int32 `json:"new_partition_numbers,omitempty"`
}

修改的topic。

func (UpdateInstanceTopicReqTopics) String

type UpdateInstanceTopicRequest

type UpdateInstanceTopicRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (UpdateInstanceTopicRequest) String

type UpdateInstanceTopicResponse

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

Response Object

func (UpdateInstanceTopicResponse) String

type UpdateSinkTaskQuotaReq

type UpdateSinkTaskQuotaReq struct {
	SinkMaxTasks int32 `json:"sink_max_tasks"`
}

func (UpdateSinkTaskQuotaReq) String

func (o UpdateSinkTaskQuotaReq) String() string

type UpdateSinkTaskQuotaRequest

type UpdateSinkTaskQuotaRequest struct {
	ConnectorId string `json:"connector_id"`

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

Request Object

func (UpdateSinkTaskQuotaRequest) String

type UpdateSinkTaskQuotaResponse

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

Response Object

func (UpdateSinkTaskQuotaResponse) String

type UpdateTopicAccessPolicyReq

type UpdateTopicAccessPolicyReq struct {
	Topics *[]UpdateTopicAccessPolicyReqTopics `json:"topics,omitempty"`
}

func (UpdateTopicAccessPolicyReq) String

type UpdateTopicAccessPolicyReqPolicies

type UpdateTopicAccessPolicyReqPolicies struct {
	UserName *string `json:"user_name,omitempty"`

	AccessPolicy *UpdateTopicAccessPolicyReqPoliciesAccessPolicy `json:"access_policy,omitempty"`
}

权限实体。

func (UpdateTopicAccessPolicyReqPolicies) String

type UpdateTopicAccessPolicyReqPoliciesAccessPolicy

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

func (UpdateTopicAccessPolicyReqPoliciesAccessPolicy) MarshalJSON

func (*UpdateTopicAccessPolicyReqPoliciesAccessPolicy) UnmarshalJSON

type UpdateTopicAccessPolicyReqTopics

type UpdateTopicAccessPolicyReqTopics struct {
	Name *string `json:"name,omitempty"`

	Policies *[]UpdateTopicAccessPolicyReqPolicies `json:"policies,omitempty"`
}

权限实体。

func (UpdateTopicAccessPolicyReqTopics) String

type UpdateTopicAccessPolicyRequest

type UpdateTopicAccessPolicyRequest struct {
	InstanceId string `json:"instance_id"`

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

Request Object

func (UpdateTopicAccessPolicyRequest) String

type UpdateTopicAccessPolicyResponse

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

Response Object

func (UpdateTopicAccessPolicyResponse) String

type UpdateTopicReplicaRequest

type UpdateTopicReplicaRequest struct {
	InstanceId string `json:"instance_id"`

	Topic string `json:"topic"`

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

Request Object

func (UpdateTopicReplicaRequest) String

func (o UpdateTopicReplicaRequest) String() string

type UpdateTopicReplicaResponse

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

Response Object

func (UpdateTopicReplicaResponse) String

Source Files

Jump to

Keyboard shortcuts

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