kafka

package

Go to main page

Versions in this module

v1

v1.0.179

Jan 23, 2025

v1.0.178

Jan 16, 2025

v1.0.177

Jan 9, 2025

v1.0.176

Jan 2, 2025

v1.0.175

Dec 26, 2024

v1.0.174

Dec 23, 2024

Changes in this version

+ const EnumOfCleanupPolicyListForCreateTopicInputCompact

+ const EnumOfCleanupPolicyListForCreateTopicInputDelete

type CreateGroupInput

+ Tags []*TagForCreateGroupInput

+ func (s *CreateGroupInput) SetTags(v []*TagForCreateGroupInput) *CreateGroupInput

type CreateInstanceInput

+ ClientToken *string

+ func (s *CreateInstanceInput) SetClientToken(v string) *CreateInstanceInput

+ type CreateMigrateSubTasksInput struct

+ Items []*ItemForCreateMigrateSubTasksInput

+ TaskId *string

+ func (s *CreateMigrateSubTasksInput) SetItems(v []*ItemForCreateMigrateSubTasksInput) *CreateMigrateSubTasksInput

+ func (s *CreateMigrateSubTasksInput) SetTaskId(v string) *CreateMigrateSubTasksInput

+ func (s *CreateMigrateSubTasksInput) Validate() error

+ func (s CreateMigrateSubTasksInput) GoString() string

+ func (s CreateMigrateSubTasksInput) String() string

+ type CreateMigrateSubTasksOutput struct

+ Metadata *response.ResponseMetadata

+ func (s CreateMigrateSubTasksOutput) GoString() string

+ func (s CreateMigrateSubTasksOutput) String() string

type CreateTopicInput

+ CleanupPolicy []*string

+ Tags []*TagForCreateTopicInput

+ func (s *CreateTopicInput) SetCleanupPolicy(v []*string) *CreateTopicInput

+ func (s *CreateTopicInput) SetTags(v []*TagForCreateTopicInput) *CreateTopicInput

type DescribeGroupsInput

+ TagFilters []*TagFilterForDescribeGroupsInput

+ func (s *DescribeGroupsInput) SetTagFilters(v []*TagFilterForDescribeGroupsInput) *DescribeGroupsInput

type DescribeTopicsInput

+ TagFilters []*TagFilterForDescribeTopicsInput

+ func (s *DescribeTopicsInput) SetTagFilters(v []*TagFilterForDescribeTopicsInput) *DescribeTopicsInput

type GroupsInfoForDescribeGroupsOutput

+ BalanceAlgorithm *string

+ Description *string

+ ProtocolType *string

+ Tags []*TagForDescribeGroupsOutput

+ func (s *GroupsInfoForDescribeGroupsOutput) SetBalanceAlgorithm(v string) *GroupsInfoForDescribeGroupsOutput

+ func (s *GroupsInfoForDescribeGroupsOutput) SetDescription(v string) *GroupsInfoForDescribeGroupsOutput

+ func (s *GroupsInfoForDescribeGroupsOutput) SetProtocolType(v string) *GroupsInfoForDescribeGroupsOutput

+ func (s *GroupsInfoForDescribeGroupsOutput) SetTags(v []*TagForDescribeGroupsOutput) *GroupsInfoForDescribeGroupsOutput

+ type ItemForCreateMigrateSubTasksInput struct

+ Config *string

+ Name *string

+ Type *string

+ func (s *ItemForCreateMigrateSubTasksInput) SetConfig(v string) *ItemForCreateMigrateSubTasksInput

+ func (s *ItemForCreateMigrateSubTasksInput) SetName(v string) *ItemForCreateMigrateSubTasksInput

+ func (s *ItemForCreateMigrateSubTasksInput) SetType(v string) *ItemForCreateMigrateSubTasksInput

+ func (s ItemForCreateMigrateSubTasksInput) GoString() string

+ func (s ItemForCreateMigrateSubTasksInput) String() string

+ type ItemForVerifyMigrateSubTasksInput struct

+ Config *string

+ Name *string

+ Type *string

+ func (s *ItemForVerifyMigrateSubTasksInput) SetConfig(v string) *ItemForVerifyMigrateSubTasksInput

+ func (s *ItemForVerifyMigrateSubTasksInput) SetName(v string) *ItemForVerifyMigrateSubTasksInput

+ func (s *ItemForVerifyMigrateSubTasksInput) SetType(v string) *ItemForVerifyMigrateSubTasksInput

+ func (s ItemForVerifyMigrateSubTasksInput) GoString() string

+ func (s ItemForVerifyMigrateSubTasksInput) String() string

type KAFKA

+ func (c *KAFKA) CreateMigrateSubTasks(input *CreateMigrateSubTasksInput) (*CreateMigrateSubTasksOutput, error)

+ func (c *KAFKA) CreateMigrateSubTasksCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateMigrateSubTasksCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreateMigrateSubTasksCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateMigrateSubTasksRequest(input *CreateMigrateSubTasksInput) (req *request.Request, output *CreateMigrateSubTasksOutput)

+ func (c *KAFKA) CreateMigrateSubTasksWithContext(ctx volcengine.Context, input *CreateMigrateSubTasksInput, ...) (*CreateMigrateSubTasksOutput, error)

+ func (c *KAFKA) QueryMessageByTimestamp(input *QueryMessageByTimestampInput) (*QueryMessageByTimestampOutput, error)

+ func (c *KAFKA) QueryMessageByTimestampCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) QueryMessageByTimestampCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) QueryMessageByTimestampCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) QueryMessageByTimestampRequest(input *QueryMessageByTimestampInput) (req *request.Request, output *QueryMessageByTimestampOutput)

+ func (c *KAFKA) QueryMessageByTimestampWithContext(ctx volcengine.Context, input *QueryMessageByTimestampInput, ...) (*QueryMessageByTimestampOutput, error)

+ func (c *KAFKA) UpdateMigrateTaskStatus(input *UpdateMigrateTaskStatusInput) (*UpdateMigrateTaskStatusOutput, error)

+ func (c *KAFKA) UpdateMigrateTaskStatusCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) UpdateMigrateTaskStatusCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) UpdateMigrateTaskStatusCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) UpdateMigrateTaskStatusRequest(input *UpdateMigrateTaskStatusInput) (req *request.Request, output *UpdateMigrateTaskStatusOutput)

+ func (c *KAFKA) UpdateMigrateTaskStatusWithContext(ctx volcengine.Context, input *UpdateMigrateTaskStatusInput, ...) (*UpdateMigrateTaskStatusOutput, error)

+ func (c *KAFKA) VerifyMigrateSubTasks(input *VerifyMigrateSubTasksInput) (*VerifyMigrateSubTasksOutput, error)

+ func (c *KAFKA) VerifyMigrateSubTasksCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) VerifyMigrateSubTasksCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) VerifyMigrateSubTasksCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) VerifyMigrateSubTasksRequest(input *VerifyMigrateSubTasksInput) (req *request.Request, output *VerifyMigrateSubTasksOutput)

+ func (c *KAFKA) VerifyMigrateSubTasksWithContext(ctx volcengine.Context, input *VerifyMigrateSubTasksInput, ...) (*VerifyMigrateSubTasksOutput, error)

type KAFKAAPI

+ CreateMigrateSubTasks func(*CreateMigrateSubTasksInput) (*CreateMigrateSubTasksOutput, error)

+ CreateMigrateSubTasksCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreateMigrateSubTasksCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreateMigrateSubTasksCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreateMigrateSubTasksRequest func(*CreateMigrateSubTasksInput) (*request.Request, *CreateMigrateSubTasksOutput)

+ CreateMigrateSubTasksWithContext func(volcengine.Context, *CreateMigrateSubTasksInput, ...request.Option) (*CreateMigrateSubTasksOutput, error)

+ QueryMessageByTimestamp func(*QueryMessageByTimestampInput) (*QueryMessageByTimestampOutput, error)

+ QueryMessageByTimestampCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ QueryMessageByTimestampCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ QueryMessageByTimestampCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ QueryMessageByTimestampRequest func(*QueryMessageByTimestampInput) (*request.Request, *QueryMessageByTimestampOutput)

+ QueryMessageByTimestampWithContext func(volcengine.Context, *QueryMessageByTimestampInput, ...request.Option) (*QueryMessageByTimestampOutput, error)

+ UpdateMigrateTaskStatus func(*UpdateMigrateTaskStatusInput) (*UpdateMigrateTaskStatusOutput, error)

+ UpdateMigrateTaskStatusCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ UpdateMigrateTaskStatusCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ UpdateMigrateTaskStatusCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ UpdateMigrateTaskStatusRequest func(*UpdateMigrateTaskStatusInput) (*request.Request, *UpdateMigrateTaskStatusOutput)

+ UpdateMigrateTaskStatusWithContext func(volcengine.Context, *UpdateMigrateTaskStatusInput, ...request.Option) (*UpdateMigrateTaskStatusOutput, error)

+ VerifyMigrateSubTasks func(*VerifyMigrateSubTasksInput) (*VerifyMigrateSubTasksOutput, error)

+ VerifyMigrateSubTasksCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ VerifyMigrateSubTasksCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ VerifyMigrateSubTasksCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ VerifyMigrateSubTasksRequest func(*VerifyMigrateSubTasksInput) (*request.Request, *VerifyMigrateSubTasksOutput)

+ VerifyMigrateSubTasksWithContext func(volcengine.Context, *VerifyMigrateSubTasksInput, ...request.Option) (*VerifyMigrateSubTasksOutput, error)

+ type MessageListForQueryMessageByTimestampOutput struct

+ CreateTime *int64

+ Key *string

+ Message *string

+ MessageOffset *int64

+ MessageSize *int32

+ PartitionId *int32

+ TopicName *string

+ func (s *MessageListForQueryMessageByTimestampOutput) SetCreateTime(v int64) *MessageListForQueryMessageByTimestampOutput

+ func (s *MessageListForQueryMessageByTimestampOutput) SetKey(v string) *MessageListForQueryMessageByTimestampOutput

+ func (s *MessageListForQueryMessageByTimestampOutput) SetMessage(v string) *MessageListForQueryMessageByTimestampOutput

+ func (s *MessageListForQueryMessageByTimestampOutput) SetMessageOffset(v int64) *MessageListForQueryMessageByTimestampOutput

+ func (s *MessageListForQueryMessageByTimestampOutput) SetMessageSize(v int32) *MessageListForQueryMessageByTimestampOutput

+ func (s *MessageListForQueryMessageByTimestampOutput) SetPartitionId(v int32) *MessageListForQueryMessageByTimestampOutput

+ func (s *MessageListForQueryMessageByTimestampOutput) SetTopicName(v string) *MessageListForQueryMessageByTimestampOutput

+ func (s MessageListForQueryMessageByTimestampOutput) GoString() string

+ func (s MessageListForQueryMessageByTimestampOutput) String() string

type ModifyInstanceSpecInput

+ ClientToken *string

+ func (s *ModifyInstanceSpecInput) SetClientToken(v string) *ModifyInstanceSpecInput

+ type QueryMessageByTimestampInput struct

+ InstanceId *string

+ PageNumber *int32

+ PageSize *int32

+ PartitionId *int32

+ QueryEndTimestamp *int64

+ QueryStartTimestamp *int64

+ Refresh *bool

+ SortOrder *string

+ TopicName *string

+ func (s *QueryMessageByTimestampInput) SetInstanceId(v string) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetPageNumber(v int32) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetPageSize(v int32) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetPartitionId(v int32) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetQueryEndTimestamp(v int64) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetQueryStartTimestamp(v int64) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetRefresh(v bool) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetSortOrder(v string) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) SetTopicName(v string) *QueryMessageByTimestampInput

+ func (s *QueryMessageByTimestampInput) Validate() error

+ func (s QueryMessageByTimestampInput) GoString() string

+ func (s QueryMessageByTimestampInput) String() string

+ type QueryMessageByTimestampOutput struct

+ HasMoreMessage *bool

+ MessageList []*MessageListForQueryMessageByTimestampOutput

+ Metadata *response.ResponseMetadata

+ func (s *QueryMessageByTimestampOutput) SetHasMoreMessage(v bool) *QueryMessageByTimestampOutput

+ func (s *QueryMessageByTimestampOutput) SetMessageList(v []*MessageListForQueryMessageByTimestampOutput) *QueryMessageByTimestampOutput

+ func (s QueryMessageByTimestampOutput) GoString() string

+ func (s QueryMessageByTimestampOutput) String() string

+ type SubTaskResultForVerifyMigrateSubTasksOutput struct

+ Code *string

+ Message *string

+ func (s *SubTaskResultForVerifyMigrateSubTasksOutput) SetCode(v string) *SubTaskResultForVerifyMigrateSubTasksOutput

+ func (s *SubTaskResultForVerifyMigrateSubTasksOutput) SetMessage(v string) *SubTaskResultForVerifyMigrateSubTasksOutput

+ func (s SubTaskResultForVerifyMigrateSubTasksOutput) GoString() string

+ func (s SubTaskResultForVerifyMigrateSubTasksOutput) String() string

+ type SummaryForVerifyMigrateSubTasksOutput struct

+ Code *string

+ Message *string

+ func (s *SummaryForVerifyMigrateSubTasksOutput) SetCode(v string) *SummaryForVerifyMigrateSubTasksOutput

+ func (s *SummaryForVerifyMigrateSubTasksOutput) SetMessage(v string) *SummaryForVerifyMigrateSubTasksOutput

+ func (s SummaryForVerifyMigrateSubTasksOutput) GoString() string

+ func (s SummaryForVerifyMigrateSubTasksOutput) String() string

+ type TagFilterForDescribeGroupsInput struct

+ Key *string

+ Value *string

+ func (s *TagFilterForDescribeGroupsInput) SetKey(v string) *TagFilterForDescribeGroupsInput

+ func (s *TagFilterForDescribeGroupsInput) SetValue(v string) *TagFilterForDescribeGroupsInput

+ func (s TagFilterForDescribeGroupsInput) GoString() string

+ func (s TagFilterForDescribeGroupsInput) String() string

+ type TagFilterForDescribeTopicsInput struct

+ Key *string

+ Value *string

+ func (s *TagFilterForDescribeTopicsInput) SetKey(v string) *TagFilterForDescribeTopicsInput

+ func (s *TagFilterForDescribeTopicsInput) SetValue(v string) *TagFilterForDescribeTopicsInput

+ func (s TagFilterForDescribeTopicsInput) GoString() string

+ func (s TagFilterForDescribeTopicsInput) String() string

+ type TagForCreateGroupInput struct

+ Key *string

+ Value *string

+ func (s *TagForCreateGroupInput) SetKey(v string) *TagForCreateGroupInput

+ func (s *TagForCreateGroupInput) SetValue(v string) *TagForCreateGroupInput

+ func (s TagForCreateGroupInput) GoString() string

+ func (s TagForCreateGroupInput) String() string

+ type TagForCreateTopicInput struct

+ Key *string

+ Value *string

+ func (s *TagForCreateTopicInput) SetKey(v string) *TagForCreateTopicInput

+ func (s *TagForCreateTopicInput) SetValue(v string) *TagForCreateTopicInput

+ func (s TagForCreateTopicInput) GoString() string

+ func (s TagForCreateTopicInput) String() string

+ type TagForDescribeGroupsOutput struct

+ Key *string

+ Value *string

+ func (s *TagForDescribeGroupsOutput) SetKey(v string) *TagForDescribeGroupsOutput

+ func (s *TagForDescribeGroupsOutput) SetValue(v string) *TagForDescribeGroupsOutput

+ func (s TagForDescribeGroupsOutput) GoString() string

+ func (s TagForDescribeGroupsOutput) String() string

+ type TagForDescribeTopicsOutput struct

+ Key *string

+ Value *string

+ func (s *TagForDescribeTopicsOutput) SetKey(v string) *TagForDescribeTopicsOutput

+ func (s *TagForDescribeTopicsOutput) SetValue(v string) *TagForDescribeTopicsOutput

+ func (s TagForDescribeTopicsOutput) GoString() string

+ func (s TagForDescribeTopicsOutput) String() string

type TopicsInfoForDescribeTopicsOutput

+ CleanupPolicy []*string

+ LogRetentionHours *int32

+ Tags []*TagForDescribeTopicsOutput

+ UsedStoragePercentageInInstance *float64

+ UsedStorageSpaceInBytes *int64

+ func (s *TopicsInfoForDescribeTopicsOutput) SetCleanupPolicy(v []*string) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetLogRetentionHours(v int32) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetTags(v []*TagForDescribeTopicsOutput) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetUsedStoragePercentageInInstance(v float64) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetUsedStorageSpaceInBytes(v int64) *TopicsInfoForDescribeTopicsOutput

+ type UpdateMigrateTaskStatusInput struct

+ Status *string

+ TaskId *string

+ func (s *UpdateMigrateTaskStatusInput) SetStatus(v string) *UpdateMigrateTaskStatusInput

+ func (s *UpdateMigrateTaskStatusInput) SetTaskId(v string) *UpdateMigrateTaskStatusInput

+ func (s *UpdateMigrateTaskStatusInput) Validate() error

+ func (s UpdateMigrateTaskStatusInput) GoString() string

+ func (s UpdateMigrateTaskStatusInput) String() string

+ type UpdateMigrateTaskStatusOutput struct

+ Metadata *response.ResponseMetadata

+ func (s UpdateMigrateTaskStatusOutput) GoString() string

+ func (s UpdateMigrateTaskStatusOutput) String() string

+ type VerifyMigrateSubTasksInput struct

+ Items []*ItemForVerifyMigrateSubTasksInput

+ TaskId *string

+ func (s *VerifyMigrateSubTasksInput) SetItems(v []*ItemForVerifyMigrateSubTasksInput) *VerifyMigrateSubTasksInput

+ func (s *VerifyMigrateSubTasksInput) SetTaskId(v string) *VerifyMigrateSubTasksInput

+ func (s *VerifyMigrateSubTasksInput) Validate() error

+ func (s VerifyMigrateSubTasksInput) GoString() string

+ func (s VerifyMigrateSubTasksInput) String() string

+ type VerifyMigrateSubTasksOutput struct

+ Metadata *response.ResponseMetadata

+ SubTaskResults []*SubTaskResultForVerifyMigrateSubTasksOutput

+ Summary *SummaryForVerifyMigrateSubTasksOutput

+ func (s *VerifyMigrateSubTasksOutput) SetSubTaskResults(v []*SubTaskResultForVerifyMigrateSubTasksOutput) *VerifyMigrateSubTasksOutput

+ func (s *VerifyMigrateSubTasksOutput) SetSummary(v *SummaryForVerifyMigrateSubTasksOutput) *VerifyMigrateSubTasksOutput

+ func (s VerifyMigrateSubTasksOutput) GoString() string

+ func (s VerifyMigrateSubTasksOutput) String() string

v1.0.173

Dec 20, 2024

v1.0.172

Dec 16, 2024

v1.0.171

Dec 11, 2024

v1.0.170

Dec 10, 2024

v1.0.169

Dec 5, 2024

v1.0.168

Dec 2, 2024

v1.0.167

Nov 28, 2024

v1.0.166

Nov 21, 2024

v1.0.165

Nov 14, 2024

v1.0.164

Nov 7, 2024

v1.0.163

Oct 31, 2024

v1.0.162

Oct 24, 2024

v1.0.161

Oct 17, 2024

v1.0.160

Oct 10, 2024

v1.0.159

Sep 26, 2024

v1.0.158

Sep 19, 2024

v1.0.157

Sep 12, 2024

v1.0.156

Sep 5, 2024

v1.0.155

Aug 29, 2024

v1.0.154

Aug 22, 2024

v1.0.153

Aug 19, 2024

v1.0.152

Aug 15, 2024

v1.0.151

Aug 8, 2024

v1.0.150

Jul 25, 2024

v1.0.149

Jul 18, 2024

v1.0.148

Jul 11, 2024

v1.0.147

Jul 10, 2024

v1.0.146

Jul 4, 2024

v1.0.145

Jun 27, 2024

v1.0.144

Jun 26, 2024

v1.0.143

Jun 25, 2024

v1.0.142

Jun 24, 2024

v1.0.141

Jun 13, 2024

v1.0.140

Jun 6, 2024

v1.0.139

Jun 3, 2024

v1.0.138

May 30, 2024

v1.0.137

May 23, 2024

v1.0.136

May 16, 2024

v1.0.135

May 10, 2024

v1.0.134

Apr 25, 2024

v1.0.133

Apr 25, 2024

v1.0.132

Apr 18, 2024

v1.0.131

Apr 11, 2024

v1.0.130

Apr 1, 2024

v1.0.129

Mar 25, 2024

v1.0.128

Mar 22, 2024

v1.0.127

Mar 21, 2024

v1.0.126

Mar 16, 2024

v1.0.125

Mar 14, 2024

v1.0.124

Mar 7, 2024

v1.0.123

Feb 29, 2024

Changes in this version

+ type AclForDescribeAclsOutput struct

+ AccessPolicy *string

+ Ip *string

+ PatternType *string

+ Resource *string

+ ResourceType *string

+ UserName *string

+ func (s *AclForDescribeAclsOutput) SetAccessPolicy(v string) *AclForDescribeAclsOutput

+ func (s *AclForDescribeAclsOutput) SetIp(v string) *AclForDescribeAclsOutput

+ func (s *AclForDescribeAclsOutput) SetPatternType(v string) *AclForDescribeAclsOutput

+ func (s *AclForDescribeAclsOutput) SetResource(v string) *AclForDescribeAclsOutput

+ func (s *AclForDescribeAclsOutput) SetResourceType(v string) *AclForDescribeAclsOutput

+ func (s *AclForDescribeAclsOutput) SetUserName(v string) *AclForDescribeAclsOutput

+ func (s AclForDescribeAclsOutput) GoString() string

+ func (s AclForDescribeAclsOutput) String() string

+ type AllowListForDescribeAllowListsOutput struct

+ AllowListDesc *string

+ AllowListId *string

+ AllowListIpNum *int32

+ AllowListName *string

+ AssociatedInstanceNum *int32

+ func (s *AllowListForDescribeAllowListsOutput) SetAllowListDesc(v string) *AllowListForDescribeAllowListsOutput

+ func (s *AllowListForDescribeAllowListsOutput) SetAllowListId(v string) *AllowListForDescribeAllowListsOutput

+ func (s *AllowListForDescribeAllowListsOutput) SetAllowListIpNum(v int32) *AllowListForDescribeAllowListsOutput

+ func (s *AllowListForDescribeAllowListsOutput) SetAllowListName(v string) *AllowListForDescribeAllowListsOutput

+ func (s *AllowListForDescribeAllowListsOutput) SetAssociatedInstanceNum(v int32) *AllowListForDescribeAllowListsOutput

+ func (s AllowListForDescribeAllowListsOutput) GoString() string

+ func (s AllowListForDescribeAllowListsOutput) String() string

+ type AssociateAllowListInput struct

+ AllowListIds []*string

+ InstanceIds []*string

+ func (s *AssociateAllowListInput) SetAllowListIds(v []*string) *AssociateAllowListInput

+ func (s *AssociateAllowListInput) SetInstanceIds(v []*string) *AssociateAllowListInput

+ func (s AssociateAllowListInput) GoString() string

+ func (s AssociateAllowListInput) String() string

+ type AssociateAllowListOutput struct

+ Metadata *response.ResponseMetadata

+ func (s AssociateAllowListOutput) GoString() string

+ func (s AssociateAllowListOutput) String() string

+ type AssociatedInstanceForDescribeAllowListDetailOutput struct

+ InstanceId *string

+ InstanceName *string

+ func (s *AssociatedInstanceForDescribeAllowListDetailOutput) SetInstanceId(v string) *AssociatedInstanceForDescribeAllowListDetailOutput

+ func (s *AssociatedInstanceForDescribeAllowListDetailOutput) SetInstanceName(v string) *AssociatedInstanceForDescribeAllowListDetailOutput

+ func (s AssociatedInstanceForDescribeAllowListDetailOutput) GoString() string

+ func (s AssociatedInstanceForDescribeAllowListDetailOutput) String() string

+ type CreateAclInput struct

+ AccessPolicy *string

+ InstanceId *string

+ Ip *string

+ PatternType *string

+ Resource *string

+ ResourceType *string

+ UserName *string

+ func (s *CreateAclInput) SetAccessPolicy(v string) *CreateAclInput

+ func (s *CreateAclInput) SetInstanceId(v string) *CreateAclInput

+ func (s *CreateAclInput) SetIp(v string) *CreateAclInput

+ func (s *CreateAclInput) SetPatternType(v string) *CreateAclInput

+ func (s *CreateAclInput) SetResource(v string) *CreateAclInput

+ func (s *CreateAclInput) SetResourceType(v string) *CreateAclInput

+ func (s *CreateAclInput) SetUserName(v string) *CreateAclInput

+ func (s *CreateAclInput) Validate() error

+ func (s CreateAclInput) GoString() string

+ func (s CreateAclInput) String() string

+ type CreateAclOutput struct

+ Metadata *response.ResponseMetadata

+ func (s CreateAclOutput) GoString() string

+ func (s CreateAclOutput) String() string

+ type CreateAllowListInput struct

+ AllowList *string

+ AllowListDesc *string

+ AllowListName *string

+ func (s *CreateAllowListInput) SetAllowList(v string) *CreateAllowListInput

+ func (s *CreateAllowListInput) SetAllowListDesc(v string) *CreateAllowListInput

+ func (s *CreateAllowListInput) SetAllowListName(v string) *CreateAllowListInput

+ func (s *CreateAllowListInput) Validate() error

+ func (s CreateAllowListInput) GoString() string

+ func (s CreateAllowListInput) String() string

+ type CreateAllowListOutput struct

+ AllowListId *string

+ Metadata *response.ResponseMetadata

+ func (s *CreateAllowListOutput) SetAllowListId(v string) *CreateAllowListOutput

+ func (s CreateAllowListOutput) GoString() string

+ func (s CreateAllowListOutput) String() string

+ type CreateGroupInput struct

+ Description *string

+ GroupId *string

+ InstanceId *string

+ func (s *CreateGroupInput) SetDescription(v string) *CreateGroupInput

+ func (s *CreateGroupInput) SetGroupId(v string) *CreateGroupInput

+ func (s *CreateGroupInput) SetInstanceId(v string) *CreateGroupInput

+ func (s *CreateGroupInput) Validate() error

+ func (s CreateGroupInput) GoString() string

+ func (s CreateGroupInput) String() string

+ type CreateGroupOutput struct

+ Metadata *response.ResponseMetadata

+ func (s CreateGroupOutput) GoString() string

+ func (s CreateGroupOutput) String() string

type CreateInstanceInput

+ func (s *CreateInstanceInput) Validate() error

type CreatePublicAddressInput

+ func (s *CreatePublicAddressInput) Validate() error

type CreateTopicInput

+ func (s *CreateTopicInput) Validate() error

type CreateUserInput

+ PasswordType *string

+ func (s *CreateUserInput) SetPasswordType(v string) *CreateUserInput

+ func (s *CreateUserInput) Validate() error

+ type DeleteAclInput struct

+ AccessPolicy *string

+ InstanceId *string

+ Ip *string

+ PatternType *string

+ Resource *string

+ ResourceType *string

+ UserName *string

+ func (s *DeleteAclInput) SetAccessPolicy(v string) *DeleteAclInput

+ func (s *DeleteAclInput) SetInstanceId(v string) *DeleteAclInput

+ func (s *DeleteAclInput) SetIp(v string) *DeleteAclInput

+ func (s *DeleteAclInput) SetPatternType(v string) *DeleteAclInput

+ func (s *DeleteAclInput) SetResource(v string) *DeleteAclInput

+ func (s *DeleteAclInput) SetResourceType(v string) *DeleteAclInput

+ func (s *DeleteAclInput) SetUserName(v string) *DeleteAclInput

+ func (s *DeleteAclInput) Validate() error

+ func (s DeleteAclInput) GoString() string

+ func (s DeleteAclInput) String() string

+ type DeleteAclOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DeleteAclOutput) GoString() string

+ func (s DeleteAclOutput) String() string

+ type DeleteAllowListInput struct

+ AllowListId *string

+ func (s *DeleteAllowListInput) SetAllowListId(v string) *DeleteAllowListInput

+ func (s *DeleteAllowListInput) Validate() error

+ func (s DeleteAllowListInput) GoString() string

+ func (s DeleteAllowListInput) String() string

+ type DeleteAllowListOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DeleteAllowListOutput) GoString() string

+ func (s DeleteAllowListOutput) String() string

type DeleteGroupInput

+ func (s *DeleteGroupInput) Validate() error

type DeleteInstanceInput

+ func (s *DeleteInstanceInput) Validate() error

type DeletePublicAddressInput

+ func (s *DeletePublicAddressInput) Validate() error

type DeleteTopicInput

+ func (s *DeleteTopicInput) Validate() error

type DeleteUserInput

+ func (s *DeleteUserInput) Validate() error

+ type DescribeAclsInput struct

+ AccessPolicy *string

+ InstanceId *string

+ Ip *string

+ PageNumber *int32

+ PageSize *int32

+ PatternType *string

+ Resource *string

+ ResourceType *string

+ UserName *string

+ func (s *DescribeAclsInput) SetAccessPolicy(v string) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetInstanceId(v string) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetIp(v string) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetPageNumber(v int32) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetPageSize(v int32) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetPatternType(v string) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetResource(v string) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetResourceType(v string) *DescribeAclsInput

+ func (s *DescribeAclsInput) SetUserName(v string) *DescribeAclsInput

+ func (s *DescribeAclsInput) Validate() error

+ func (s DescribeAclsInput) GoString() string

+ func (s DescribeAclsInput) String() string

+ type DescribeAclsOutput struct

+ Acls []*AclForDescribeAclsOutput

+ Metadata *response.ResponseMetadata

+ Total *int32

+ func (s *DescribeAclsOutput) SetAcls(v []*AclForDescribeAclsOutput) *DescribeAclsOutput

+ func (s *DescribeAclsOutput) SetTotal(v int32) *DescribeAclsOutput

+ func (s DescribeAclsOutput) GoString() string

+ func (s DescribeAclsOutput) String() string

+ type DescribeAllowListDetailInput struct

+ AllowListId *string

+ func (s *DescribeAllowListDetailInput) SetAllowListId(v string) *DescribeAllowListDetailInput

+ func (s *DescribeAllowListDetailInput) Validate() error

+ func (s DescribeAllowListDetailInput) GoString() string

+ func (s DescribeAllowListDetailInput) String() string

+ type DescribeAllowListDetailOutput struct

+ AllowList *string

+ AllowListDesc *string

+ AllowListId *string

+ AllowListName *string

+ AssociatedInstances []*AssociatedInstanceForDescribeAllowListDetailOutput

+ Metadata *response.ResponseMetadata

+ func (s *DescribeAllowListDetailOutput) SetAllowList(v string) *DescribeAllowListDetailOutput

+ func (s *DescribeAllowListDetailOutput) SetAllowListDesc(v string) *DescribeAllowListDetailOutput

+ func (s *DescribeAllowListDetailOutput) SetAllowListId(v string) *DescribeAllowListDetailOutput

+ func (s *DescribeAllowListDetailOutput) SetAllowListName(v string) *DescribeAllowListDetailOutput

+ func (s *DescribeAllowListDetailOutput) SetAssociatedInstances(v []*AssociatedInstanceForDescribeAllowListDetailOutput) *DescribeAllowListDetailOutput

+ func (s DescribeAllowListDetailOutput) GoString() string

+ func (s DescribeAllowListDetailOutput) String() string

+ type DescribeAllowListsInput struct

+ InstanceId *string

+ RegionId *string

+ func (s *DescribeAllowListsInput) SetInstanceId(v string) *DescribeAllowListsInput

+ func (s *DescribeAllowListsInput) SetRegionId(v string) *DescribeAllowListsInput

+ func (s *DescribeAllowListsInput) Validate() error

+ func (s DescribeAllowListsInput) GoString() string

+ func (s DescribeAllowListsInput) String() string

+ type DescribeAllowListsOutput struct

+ AllowLists []*AllowListForDescribeAllowListsOutput

+ Metadata *response.ResponseMetadata

+ func (s *DescribeAllowListsOutput) SetAllowLists(v []*AllowListForDescribeAllowListsOutput) *DescribeAllowListsOutput

+ func (s DescribeAllowListsOutput) GoString() string

+ func (s DescribeAllowListsOutput) String() string

type DescribeAvailabilityZonesInput

+ func (s *DescribeAvailabilityZonesInput) Validate() error

type DescribeConsumedPartitionsInput

+ func (s *DescribeConsumedPartitionsInput) Validate() error

type DescribeConsumedTopicsInput

+ func (s *DescribeConsumedTopicsInput) Validate() error

type DescribeGroupsInput

+ func (s *DescribeGroupsInput) Validate() error

type DescribeInstanceDetailInput

+ func (s *DescribeInstanceDetailInput) Validate() error

type DescribeInstancesInput

+ Project *string

+ func (s *DescribeInstancesInput) SetProject(v string) *DescribeInstancesInput

+ func (s *DescribeInstancesInput) Validate() error

+ type DescribeRegionsInput struct

+ func (s DescribeRegionsInput) GoString() string

+ func (s DescribeRegionsInput) String() string

+ type DescribeRegionsOutput struct

+ Metadata *response.ResponseMetadata

+ Regions []*RegionForDescribeRegionsOutput

+ func (s *DescribeRegionsOutput) SetRegions(v []*RegionForDescribeRegionsOutput) *DescribeRegionsOutput

+ func (s DescribeRegionsOutput) GoString() string

+ func (s DescribeRegionsOutput) String() string

+ type DescribeTagsByResourceInput struct

+ InstanceIds []*string

+ PageNumber *int32

+ PageSize *int32

+ TagFilters []*TagFilterForDescribeTagsByResourceInput

+ func (s *DescribeTagsByResourceInput) SetInstanceIds(v []*string) *DescribeTagsByResourceInput

+ func (s *DescribeTagsByResourceInput) SetPageNumber(v int32) *DescribeTagsByResourceInput

+ func (s *DescribeTagsByResourceInput) SetPageSize(v int32) *DescribeTagsByResourceInput

+ func (s *DescribeTagsByResourceInput) SetTagFilters(v []*TagFilterForDescribeTagsByResourceInput) *DescribeTagsByResourceInput

+ func (s *DescribeTagsByResourceInput) Validate() error

+ func (s DescribeTagsByResourceInput) GoString() string

+ func (s DescribeTagsByResourceInput) String() string

+ type DescribeTagsByResourceOutput struct

+ Metadata *response.ResponseMetadata

+ TagResources []*TagResourceForDescribeTagsByResourceOutput

+ Total *int32

+ func (s *DescribeTagsByResourceOutput) SetTagResources(v []*TagResourceForDescribeTagsByResourceOutput) *DescribeTagsByResourceOutput

+ func (s *DescribeTagsByResourceOutput) SetTotal(v int32) *DescribeTagsByResourceOutput

+ func (s DescribeTagsByResourceOutput) GoString() string

+ func (s DescribeTagsByResourceOutput) String() string

type DescribeTopicAccessPoliciesInput

+ func (s *DescribeTopicAccessPoliciesInput) Validate() error

type DescribeTopicParametersInput

+ func (s *DescribeTopicParametersInput) Validate() error

type DescribeTopicPartitionsInput

+ func (s *DescribeTopicPartitionsInput) Validate() error

type DescribeTopicsInput

+ func (s *DescribeTopicsInput) Validate() error

type DescribeUsersInput

+ func (s *DescribeUsersInput) Validate() error

+ type DisassociateAllowListInput struct

+ AllowListIds []*string

+ InstanceIds []*string

+ func (s *DisassociateAllowListInput) SetAllowListIds(v []*string) *DisassociateAllowListInput

+ func (s *DisassociateAllowListInput) SetInstanceIds(v []*string) *DisassociateAllowListInput

+ func (s DisassociateAllowListInput) GoString() string

+ func (s DisassociateAllowListInput) String() string

+ type DisassociateAllowListOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DisassociateAllowListOutput) GoString() string

+ func (s DisassociateAllowListOutput) String() string

type KAFKA

+ func (c *KAFKA) AssociateAllowList(input *AssociateAllowListInput) (*AssociateAllowListOutput, error)

+ func (c *KAFKA) AssociateAllowListCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) AssociateAllowListCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) AssociateAllowListCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) AssociateAllowListRequest(input *AssociateAllowListInput) (req *request.Request, output *AssociateAllowListOutput)

+ func (c *KAFKA) AssociateAllowListWithContext(ctx volcengine.Context, input *AssociateAllowListInput, opts ...request.Option) (*AssociateAllowListOutput, error)

+ func (c *KAFKA) CreateAcl(input *CreateAclInput) (*CreateAclOutput, error)

+ func (c *KAFKA) CreateAclCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateAclCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreateAclCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateAclRequest(input *CreateAclInput) (req *request.Request, output *CreateAclOutput)

+ func (c *KAFKA) CreateAclWithContext(ctx volcengine.Context, input *CreateAclInput, opts ...request.Option) (*CreateAclOutput, error)

+ func (c *KAFKA) CreateAllowList(input *CreateAllowListInput) (*CreateAllowListOutput, error)

+ func (c *KAFKA) CreateAllowListCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateAllowListCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreateAllowListCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateAllowListRequest(input *CreateAllowListInput) (req *request.Request, output *CreateAllowListOutput)

+ func (c *KAFKA) CreateAllowListWithContext(ctx volcengine.Context, input *CreateAllowListInput, opts ...request.Option) (*CreateAllowListOutput, error)

+ func (c *KAFKA) CreateGroup(input *CreateGroupInput) (*CreateGroupOutput, error)

+ func (c *KAFKA) CreateGroupCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateGroupCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreateGroupCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateGroupRequest(input *CreateGroupInput) (req *request.Request, output *CreateGroupOutput)

+ func (c *KAFKA) CreateGroupWithContext(ctx volcengine.Context, input *CreateGroupInput, opts ...request.Option) (*CreateGroupOutput, error)

+ func (c *KAFKA) DeleteAcl(input *DeleteAclInput) (*DeleteAclOutput, error)

+ func (c *KAFKA) DeleteAclCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteAclCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DeleteAclCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteAclRequest(input *DeleteAclInput) (req *request.Request, output *DeleteAclOutput)

+ func (c *KAFKA) DeleteAclWithContext(ctx volcengine.Context, input *DeleteAclInput, opts ...request.Option) (*DeleteAclOutput, error)

+ func (c *KAFKA) DeleteAllowList(input *DeleteAllowListInput) (*DeleteAllowListOutput, error)

+ func (c *KAFKA) DeleteAllowListCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteAllowListCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DeleteAllowListCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteAllowListRequest(input *DeleteAllowListInput) (req *request.Request, output *DeleteAllowListOutput)

+ func (c *KAFKA) DeleteAllowListWithContext(ctx volcengine.Context, input *DeleteAllowListInput, opts ...request.Option) (*DeleteAllowListOutput, error)

+ func (c *KAFKA) DescribeAcls(input *DescribeAclsInput) (*DescribeAclsOutput, error)

+ func (c *KAFKA) DescribeAclsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAclsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeAclsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAclsRequest(input *DescribeAclsInput) (req *request.Request, output *DescribeAclsOutput)

+ func (c *KAFKA) DescribeAclsWithContext(ctx volcengine.Context, input *DescribeAclsInput, opts ...request.Option) (*DescribeAclsOutput, error)

+ func (c *KAFKA) DescribeAllowListDetail(input *DescribeAllowListDetailInput) (*DescribeAllowListDetailOutput, error)

+ func (c *KAFKA) DescribeAllowListDetailCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAllowListDetailCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeAllowListDetailCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAllowListDetailRequest(input *DescribeAllowListDetailInput) (req *request.Request, output *DescribeAllowListDetailOutput)

+ func (c *KAFKA) DescribeAllowListDetailWithContext(ctx volcengine.Context, input *DescribeAllowListDetailInput, ...) (*DescribeAllowListDetailOutput, error)

+ func (c *KAFKA) DescribeAllowLists(input *DescribeAllowListsInput) (*DescribeAllowListsOutput, error)

+ func (c *KAFKA) DescribeAllowListsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAllowListsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeAllowListsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAllowListsRequest(input *DescribeAllowListsInput) (req *request.Request, output *DescribeAllowListsOutput)

+ func (c *KAFKA) DescribeAllowListsWithContext(ctx volcengine.Context, input *DescribeAllowListsInput, opts ...request.Option) (*DescribeAllowListsOutput, error)

+ func (c *KAFKA) DescribeRegions(input *DescribeRegionsInput) (*DescribeRegionsOutput, error)

+ func (c *KAFKA) DescribeRegionsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeRegionsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeRegionsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeRegionsRequest(input *DescribeRegionsInput) (req *request.Request, output *DescribeRegionsOutput)

+ func (c *KAFKA) DescribeRegionsWithContext(ctx volcengine.Context, input *DescribeRegionsInput, opts ...request.Option) (*DescribeRegionsOutput, error)

+ func (c *KAFKA) DescribeTagsByResource(input *DescribeTagsByResourceInput) (*DescribeTagsByResourceOutput, error)

+ func (c *KAFKA) DescribeTagsByResourceCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTagsByResourceCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeTagsByResourceCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTagsByResourceRequest(input *DescribeTagsByResourceInput) (req *request.Request, output *DescribeTagsByResourceOutput)

+ func (c *KAFKA) DescribeTagsByResourceWithContext(ctx volcengine.Context, input *DescribeTagsByResourceInput, ...) (*DescribeTagsByResourceOutput, error)

+ func (c *KAFKA) DisassociateAllowList(input *DisassociateAllowListInput) (*DisassociateAllowListOutput, error)

+ func (c *KAFKA) DisassociateAllowListCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DisassociateAllowListCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DisassociateAllowListCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DisassociateAllowListRequest(input *DisassociateAllowListInput) (req *request.Request, output *DisassociateAllowListOutput)

+ func (c *KAFKA) DisassociateAllowListWithContext(ctx volcengine.Context, input *DisassociateAllowListInput, ...) (*DisassociateAllowListOutput, error)

+ func (c *KAFKA) ModifyAllowList(input *ModifyAllowListInput) (*ModifyAllowListOutput, error)

+ func (c *KAFKA) ModifyAllowListCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyAllowListCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyAllowListCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyAllowListRequest(input *ModifyAllowListInput) (req *request.Request, output *ModifyAllowListOutput)

+ func (c *KAFKA) ModifyAllowListWithContext(ctx volcengine.Context, input *ModifyAllowListInput, opts ...request.Option) (*ModifyAllowListOutput, error)

+ func (c *KAFKA) ModifyGroup(input *ModifyGroupInput) (*ModifyGroupOutput, error)

+ func (c *KAFKA) ModifyGroupCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyGroupCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyGroupCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyGroupRequest(input *ModifyGroupInput) (req *request.Request, output *ModifyGroupOutput)

+ func (c *KAFKA) ModifyGroupWithContext(ctx volcengine.Context, input *ModifyGroupInput, opts ...request.Option) (*ModifyGroupOutput, error)

type KAFKAAPI

+ AssociateAllowList func(*AssociateAllowListInput) (*AssociateAllowListOutput, error)

+ AssociateAllowListCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ AssociateAllowListCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ AssociateAllowListCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ AssociateAllowListRequest func(*AssociateAllowListInput) (*request.Request, *AssociateAllowListOutput)

+ AssociateAllowListWithContext func(volcengine.Context, *AssociateAllowListInput, ...request.Option) (*AssociateAllowListOutput, error)

+ CreateAcl func(*CreateAclInput) (*CreateAclOutput, error)

+ CreateAclCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreateAclCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreateAclCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreateAclRequest func(*CreateAclInput) (*request.Request, *CreateAclOutput)

+ CreateAclWithContext func(volcengine.Context, *CreateAclInput, ...request.Option) (*CreateAclOutput, error)

+ CreateAllowList func(*CreateAllowListInput) (*CreateAllowListOutput, error)

+ CreateAllowListCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreateAllowListCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreateAllowListCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreateAllowListRequest func(*CreateAllowListInput) (*request.Request, *CreateAllowListOutput)

+ CreateAllowListWithContext func(volcengine.Context, *CreateAllowListInput, ...request.Option) (*CreateAllowListOutput, error)

+ CreateGroup func(*CreateGroupInput) (*CreateGroupOutput, error)

+ CreateGroupCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreateGroupCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreateGroupCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreateGroupRequest func(*CreateGroupInput) (*request.Request, *CreateGroupOutput)

+ CreateGroupWithContext func(volcengine.Context, *CreateGroupInput, ...request.Option) (*CreateGroupOutput, error)

+ DeleteAcl func(*DeleteAclInput) (*DeleteAclOutput, error)

+ DeleteAclCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DeleteAclCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DeleteAclCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DeleteAclRequest func(*DeleteAclInput) (*request.Request, *DeleteAclOutput)

+ DeleteAclWithContext func(volcengine.Context, *DeleteAclInput, ...request.Option) (*DeleteAclOutput, error)

+ DeleteAllowList func(*DeleteAllowListInput) (*DeleteAllowListOutput, error)

+ DeleteAllowListCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DeleteAllowListCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DeleteAllowListCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DeleteAllowListRequest func(*DeleteAllowListInput) (*request.Request, *DeleteAllowListOutput)

+ DeleteAllowListWithContext func(volcengine.Context, *DeleteAllowListInput, ...request.Option) (*DeleteAllowListOutput, error)

+ DescribeAcls func(*DescribeAclsInput) (*DescribeAclsOutput, error)

+ DescribeAclsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeAclsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeAclsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeAclsRequest func(*DescribeAclsInput) (*request.Request, *DescribeAclsOutput)

+ DescribeAclsWithContext func(volcengine.Context, *DescribeAclsInput, ...request.Option) (*DescribeAclsOutput, error)

+ DescribeAllowListDetail func(*DescribeAllowListDetailInput) (*DescribeAllowListDetailOutput, error)

+ DescribeAllowListDetailCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeAllowListDetailCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeAllowListDetailCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeAllowListDetailRequest func(*DescribeAllowListDetailInput) (*request.Request, *DescribeAllowListDetailOutput)

+ DescribeAllowListDetailWithContext func(volcengine.Context, *DescribeAllowListDetailInput, ...request.Option) (*DescribeAllowListDetailOutput, error)

+ DescribeAllowLists func(*DescribeAllowListsInput) (*DescribeAllowListsOutput, error)

+ DescribeAllowListsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeAllowListsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeAllowListsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeAllowListsRequest func(*DescribeAllowListsInput) (*request.Request, *DescribeAllowListsOutput)

+ DescribeAllowListsWithContext func(volcengine.Context, *DescribeAllowListsInput, ...request.Option) (*DescribeAllowListsOutput, error)

+ DescribeRegions func(*DescribeRegionsInput) (*DescribeRegionsOutput, error)

+ DescribeRegionsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeRegionsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeRegionsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeRegionsRequest func(*DescribeRegionsInput) (*request.Request, *DescribeRegionsOutput)

+ DescribeRegionsWithContext func(volcengine.Context, *DescribeRegionsInput, ...request.Option) (*DescribeRegionsOutput, error)

+ DescribeTagsByResource func(*DescribeTagsByResourceInput) (*DescribeTagsByResourceOutput, error)

+ DescribeTagsByResourceCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeTagsByResourceCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeTagsByResourceCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeTagsByResourceRequest func(*DescribeTagsByResourceInput) (*request.Request, *DescribeTagsByResourceOutput)

+ DescribeTagsByResourceWithContext func(volcengine.Context, *DescribeTagsByResourceInput, ...request.Option) (*DescribeTagsByResourceOutput, error)

+ DisassociateAllowList func(*DisassociateAllowListInput) (*DisassociateAllowListOutput, error)

+ DisassociateAllowListCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DisassociateAllowListCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DisassociateAllowListCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DisassociateAllowListRequest func(*DisassociateAllowListInput) (*request.Request, *DisassociateAllowListOutput)

+ DisassociateAllowListWithContext func(volcengine.Context, *DisassociateAllowListInput, ...request.Option) (*DisassociateAllowListOutput, error)

+ ModifyAllowList func(*ModifyAllowListInput) (*ModifyAllowListOutput, error)

+ ModifyAllowListCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyAllowListCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyAllowListCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyAllowListRequest func(*ModifyAllowListInput) (*request.Request, *ModifyAllowListOutput)

+ ModifyAllowListWithContext func(volcengine.Context, *ModifyAllowListInput, ...request.Option) (*ModifyAllowListOutput, error)

+ ModifyGroup func(*ModifyGroupInput) (*ModifyGroupOutput, error)

+ ModifyGroupCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyGroupCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyGroupCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyGroupRequest func(*ModifyGroupInput) (*request.Request, *ModifyGroupOutput)

+ ModifyGroupWithContext func(volcengine.Context, *ModifyGroupInput, ...request.Option) (*ModifyGroupOutput, error)

+ type ModifyAllowListInput struct

+ AllowList *string

+ AllowListDesc *string

+ AllowListId *string

+ AllowListName *string

+ ApplyInstanceNum *int32

+ func (s *ModifyAllowListInput) SetAllowList(v string) *ModifyAllowListInput

+ func (s *ModifyAllowListInput) SetAllowListDesc(v string) *ModifyAllowListInput

+ func (s *ModifyAllowListInput) SetAllowListId(v string) *ModifyAllowListInput

+ func (s *ModifyAllowListInput) SetAllowListName(v string) *ModifyAllowListInput

+ func (s *ModifyAllowListInput) SetApplyInstanceNum(v int32) *ModifyAllowListInput

+ func (s *ModifyAllowListInput) Validate() error

+ func (s ModifyAllowListInput) GoString() string

+ func (s ModifyAllowListInput) String() string

+ type ModifyAllowListOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyAllowListOutput) GoString() string

+ func (s ModifyAllowListOutput) String() string

+ type ModifyGroupInput struct

+ Description *string

+ GroupId *string

+ InstanceId *string

+ func (s *ModifyGroupInput) SetDescription(v string) *ModifyGroupInput

+ func (s *ModifyGroupInput) SetGroupId(v string) *ModifyGroupInput

+ func (s *ModifyGroupInput) SetInstanceId(v string) *ModifyGroupInput

+ func (s *ModifyGroupInput) Validate() error

+ func (s ModifyGroupInput) GoString() string

+ func (s ModifyGroupInput) String() string

+ type ModifyGroupOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyGroupOutput) GoString() string

+ func (s ModifyGroupOutput) String() string

type ModifyInstanceAttributesInput

+ func (s *ModifyInstanceAttributesInput) Validate() error

type ModifyInstanceChargeTypeInput

+ func (s *ModifyInstanceChargeTypeInput) Validate() error

type ModifyInstanceParametersInput

+ func (s *ModifyInstanceParametersInput) Validate() error

type ModifyInstanceSpecInput

+ func (s *ModifyInstanceSpecInput) Validate() error

type ModifyTopicAccessPoliciesInput

+ func (s *ModifyTopicAccessPoliciesInput) Validate() error

type ModifyTopicAttributesInput

+ func (s *ModifyTopicAttributesInput) Validate() error

type ModifyTopicParametersInput

+ func (s *ModifyTopicParametersInput) Validate() error

type ModifyUserAuthorityInput

+ func (s *ModifyUserAuthorityInput) Validate() error

+ type RegionForDescribeRegionsOutput struct

+ Description *string

+ RegionId *string

+ RegionName *string

+ Status *string

+ func (s *RegionForDescribeRegionsOutput) SetDescription(v string) *RegionForDescribeRegionsOutput

+ func (s *RegionForDescribeRegionsOutput) SetRegionId(v string) *RegionForDescribeRegionsOutput

+ func (s *RegionForDescribeRegionsOutput) SetRegionName(v string) *RegionForDescribeRegionsOutput

+ func (s *RegionForDescribeRegionsOutput) SetStatus(v string) *RegionForDescribeRegionsOutput

+ func (s RegionForDescribeRegionsOutput) GoString() string

+ func (s RegionForDescribeRegionsOutput) String() string

type ResetConsumedOffsetsInput

+ func (s *ResetConsumedOffsetsInput) Validate() error

+ type TagFilterForDescribeTagsByResourceInput struct

+ Key *string

+ Value *string

+ func (s *TagFilterForDescribeTagsByResourceInput) SetKey(v string) *TagFilterForDescribeTagsByResourceInput

+ func (s *TagFilterForDescribeTagsByResourceInput) SetValue(v string) *TagFilterForDescribeTagsByResourceInput

+ func (s TagFilterForDescribeTagsByResourceInput) GoString() string

+ func (s TagFilterForDescribeTagsByResourceInput) String() string

+ type TagResourceForDescribeTagsByResourceOutput struct

+ InstanceId *string

+ Key *string

+ Value *string

+ func (s *TagResourceForDescribeTagsByResourceOutput) SetInstanceId(v string) *TagResourceForDescribeTagsByResourceOutput

+ func (s *TagResourceForDescribeTagsByResourceOutput) SetKey(v string) *TagResourceForDescribeTagsByResourceOutput

+ func (s *TagResourceForDescribeTagsByResourceOutput) SetValue(v string) *TagResourceForDescribeTagsByResourceOutput

+ func (s TagResourceForDescribeTagsByResourceOutput) GoString() string

+ func (s TagResourceForDescribeTagsByResourceOutput) String() string

type ZoneForDescribeAvailabilityZonesOutput

+ Status *string

+ func (s *ZoneForDescribeAvailabilityZonesOutput) SetStatus(v string) *ZoneForDescribeAvailabilityZonesOutput

v1.0.122

Feb 22, 2024

v1.0.121

Feb 5, 2024

v1.0.120

Feb 1, 2024

v1.0.119

Jan 18, 2024

v1.0.118

Jan 4, 2024

v1.0.117

Dec 28, 2023

v1.0.116

Dec 14, 2023

v1.0.115

Dec 7, 2023

v1.0.114

Nov 30, 2023

v1.0.113

Nov 23, 2023

v1.0.112

Nov 16, 2023

v1.0.111

Nov 9, 2023

v1.0.110

Nov 6, 2023

v1.0.109

Nov 2, 2023

v1.0.108

Nov 1, 2023

v1.0.107

Oct 30, 2023

v1.0.106

Oct 20, 2023

v1.0.105

Oct 19, 2023

v1.0.104

Oct 12, 2023

v1.0.103

Oct 10, 2023

v1.0.102

Sep 28, 2023

v1.0.101

Sep 26, 2023

v1.0.100

Sep 21, 2023

v1.0.99

Sep 7, 2023

v1.0.98

Sep 7, 2023

v1.0.97

Aug 17, 2023

v1.0.96

Aug 16, 2023

v1.0.95

Aug 8, 2023

v1.0.94

Aug 1, 2023

v1.0.93

Jul 28, 2023

v1.0.92

Jul 27, 2023

v1.0.91

Jul 24, 2023

Changes in this version

+ const EndpointsID

+ const EnumOfStorageTypeForCreateInstanceInputEssd

+ const EnumOfStorageTypeForCreateInstanceInputEssdFlexPl

+ const EnumOfStorageTypeForCreateInstanceInputEssdFlexPlInner

+ const EnumOfStorageTypeForCreateInstanceInputEssdPl0

+ const EnumOfStorageTypeForCreateInstanceInputEssdPl1

+ const EnumOfStorageTypeForCreateInstanceInputEssdPl2

+ const EnumOfStorageTypeForCreateInstanceInputEssdPl3

+ const EnumOfStorageTypeForCreateInstanceInputEssdPl4

+ const EnumOfStorageTypeForCreateInstanceInputHighCapacity

+ const EnumOfStorageTypeForCreateInstanceInputHighPerformance

+ const ServiceID

+ const ServiceName

+ type AccessPolicyForCreateTopicInput struct

+ AccessPolicy *string

+ UserName *string

+ func (s *AccessPolicyForCreateTopicInput) SetAccessPolicy(v string) *AccessPolicyForCreateTopicInput

+ func (s *AccessPolicyForCreateTopicInput) SetUserName(v string) *AccessPolicyForCreateTopicInput

+ func (s AccessPolicyForCreateTopicInput) GoString() string

+ func (s AccessPolicyForCreateTopicInput) String() string

+ type AccessPolicyForDescribeTopicAccessPoliciesOutput struct

+ AccessPolicy *string

+ UserName *string

+ func (s *AccessPolicyForDescribeTopicAccessPoliciesOutput) SetAccessPolicy(v string) *AccessPolicyForDescribeTopicAccessPoliciesOutput

+ func (s *AccessPolicyForDescribeTopicAccessPoliciesOutput) SetUserName(v string) *AccessPolicyForDescribeTopicAccessPoliciesOutput

+ func (s AccessPolicyForDescribeTopicAccessPoliciesOutput) GoString() string

+ func (s AccessPolicyForDescribeTopicAccessPoliciesOutput) String() string

+ type AccessPolicyForModifyTopicAccessPoliciesInput struct

+ AccessPolicy *string

+ UserName *string

+ func (s *AccessPolicyForModifyTopicAccessPoliciesInput) SetAccessPolicy(v string) *AccessPolicyForModifyTopicAccessPoliciesInput

+ func (s *AccessPolicyForModifyTopicAccessPoliciesInput) SetUserName(v string) *AccessPolicyForModifyTopicAccessPoliciesInput

+ func (s AccessPolicyForModifyTopicAccessPoliciesInput) GoString() string

+ func (s AccessPolicyForModifyTopicAccessPoliciesInput) String() string

+ type AddTagsToResourceInput struct

+ InstanceIds []*string

+ Tags []*TagForAddTagsToResourceInput

+ func (s *AddTagsToResourceInput) SetInstanceIds(v []*string) *AddTagsToResourceInput

+ func (s *AddTagsToResourceInput) SetTags(v []*TagForAddTagsToResourceInput) *AddTagsToResourceInput

+ func (s AddTagsToResourceInput) GoString() string

+ func (s AddTagsToResourceInput) String() string

+ type AddTagsToResourceOutput struct

+ Metadata *response.ResponseMetadata

+ func (s AddTagsToResourceOutput) GoString() string

+ func (s AddTagsToResourceOutput) String() string

+ type BasicInstanceInfoForDescribeInstanceDetailOutput struct

+ AccountId *string

+ ChargeDetail *ChargeDetailForDescribeInstanceDetailOutput

+ ComputeSpec *string

+ CreateTime *string

+ EipId *string

+ InstanceDescription *string

+ InstanceId *string

+ InstanceName *string

+ InstanceStatus *string

+ PrivateDomainOnPublic *bool

+ ProjectName *string

+ RegionId *string

+ StorageSpace *int32

+ StorageType *string

+ SubnetId *string

+ Tags map[string]*string

+ UsableGroupNumber *int32

+ UsablePartitionNumber *int32

+ UsedGroupNumber *int32

+ UsedPartitionNumber *int32

+ UsedStorageSpace *int32

+ UsedTopicNumber *int32

+ Version *string

+ VpcId *string

+ ZoneId *string

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetAccountId(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetChargeDetail(v *ChargeDetailForDescribeInstanceDetailOutput) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetComputeSpec(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetCreateTime(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetEipId(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceDescription(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceId(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceName(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceStatus(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetPrivateDomainOnPublic(v bool) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetProjectName(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetRegionId(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetStorageSpace(v int32) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetStorageType(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetSubnetId(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetTags(v map[string]*string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsableGroupNumber(v int32) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsablePartitionNumber(v int32) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedGroupNumber(v int32) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedPartitionNumber(v int32) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedStorageSpace(v int32) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedTopicNumber(v int32) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetVersion(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetVpcId(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s *BasicInstanceInfoForDescribeInstanceDetailOutput) SetZoneId(v string) *BasicInstanceInfoForDescribeInstanceDetailOutput

+ func (s BasicInstanceInfoForDescribeInstanceDetailOutput) GoString() string

+ func (s BasicInstanceInfoForDescribeInstanceDetailOutput) String() string

+ type ChargeDetailForDescribeInstanceDetailOutput struct

+ AutoRenew *bool

+ ChargeExpireTime *string

+ ChargeStartTime *string

+ ChargeStatus *string

+ ChargeType *string

+ OverdueReclaimTime *string

+ OverdueTime *string

+ PeriodUnit *string

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetAutoRenew(v bool) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetChargeExpireTime(v string) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetChargeStartTime(v string) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetChargeStatus(v string) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetChargeType(v string) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetOverdueReclaimTime(v string) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetOverdueTime(v string) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s *ChargeDetailForDescribeInstanceDetailOutput) SetPeriodUnit(v string) *ChargeDetailForDescribeInstanceDetailOutput

+ func (s ChargeDetailForDescribeInstanceDetailOutput) GoString() string

+ func (s ChargeDetailForDescribeInstanceDetailOutput) String() string

+ type ChargeDetailForDescribeInstancesOutput struct

+ AutoRenew *bool

+ ChargeExpireTime *string

+ ChargeStartTime *string

+ ChargeStatus *string

+ ChargeType *string

+ OverdueReclaimTime *string

+ OverdueTime *string

+ PeriodUnit *string

+ func (s *ChargeDetailForDescribeInstancesOutput) SetAutoRenew(v bool) *ChargeDetailForDescribeInstancesOutput

+ func (s *ChargeDetailForDescribeInstancesOutput) SetChargeExpireTime(v string) *ChargeDetailForDescribeInstancesOutput

+ func (s *ChargeDetailForDescribeInstancesOutput) SetChargeStartTime(v string) *ChargeDetailForDescribeInstancesOutput

+ func (s *ChargeDetailForDescribeInstancesOutput) SetChargeStatus(v string) *ChargeDetailForDescribeInstancesOutput

+ func (s *ChargeDetailForDescribeInstancesOutput) SetChargeType(v string) *ChargeDetailForDescribeInstancesOutput

+ func (s *ChargeDetailForDescribeInstancesOutput) SetOverdueReclaimTime(v string) *ChargeDetailForDescribeInstancesOutput

+ func (s *ChargeDetailForDescribeInstancesOutput) SetOverdueTime(v string) *ChargeDetailForDescribeInstancesOutput

+ func (s *ChargeDetailForDescribeInstancesOutput) SetPeriodUnit(v string) *ChargeDetailForDescribeInstancesOutput

+ func (s ChargeDetailForDescribeInstancesOutput) GoString() string

+ func (s ChargeDetailForDescribeInstancesOutput) String() string

+ type ChargeInfoForCreateInstanceInput struct

+ AutoRenew *bool

+ ChargeType *string

+ Period *int32

+ PeriodUnit *string

+ func (s *ChargeInfoForCreateInstanceInput) SetAutoRenew(v bool) *ChargeInfoForCreateInstanceInput

+ func (s *ChargeInfoForCreateInstanceInput) SetChargeType(v string) *ChargeInfoForCreateInstanceInput

+ func (s *ChargeInfoForCreateInstanceInput) SetPeriod(v int32) *ChargeInfoForCreateInstanceInput

+ func (s *ChargeInfoForCreateInstanceInput) SetPeriodUnit(v string) *ChargeInfoForCreateInstanceInput

+ func (s ChargeInfoForCreateInstanceInput) GoString() string

+ func (s ChargeInfoForCreateInstanceInput) String() string

+ type ChargeInfoForModifyInstanceChargeTypeInput struct

+ AutoRenew *bool

+ ChargeType *string

+ Period *int32

+ PeriodUnit *string

+ func (s *ChargeInfoForModifyInstanceChargeTypeInput) SetAutoRenew(v bool) *ChargeInfoForModifyInstanceChargeTypeInput

+ func (s *ChargeInfoForModifyInstanceChargeTypeInput) SetChargeType(v string) *ChargeInfoForModifyInstanceChargeTypeInput

+ func (s *ChargeInfoForModifyInstanceChargeTypeInput) SetPeriod(v int32) *ChargeInfoForModifyInstanceChargeTypeInput

+ func (s *ChargeInfoForModifyInstanceChargeTypeInput) SetPeriodUnit(v string) *ChargeInfoForModifyInstanceChargeTypeInput

+ func (s ChargeInfoForModifyInstanceChargeTypeInput) GoString() string

+ func (s ChargeInfoForModifyInstanceChargeTypeInput) String() string

+ type ConnectionInfoForDescribeInstanceDetailOutput struct

+ EndpointType *string

+ InternalEndpoint *string

+ NetworkType *string

+ PublicEndpoint *string

+ func (s *ConnectionInfoForDescribeInstanceDetailOutput) SetEndpointType(v string) *ConnectionInfoForDescribeInstanceDetailOutput

+ func (s *ConnectionInfoForDescribeInstanceDetailOutput) SetInternalEndpoint(v string) *ConnectionInfoForDescribeInstanceDetailOutput

+ func (s *ConnectionInfoForDescribeInstanceDetailOutput) SetNetworkType(v string) *ConnectionInfoForDescribeInstanceDetailOutput

+ func (s *ConnectionInfoForDescribeInstanceDetailOutput) SetPublicEndpoint(v string) *ConnectionInfoForDescribeInstanceDetailOutput

+ func (s ConnectionInfoForDescribeInstanceDetailOutput) GoString() string

+ func (s ConnectionInfoForDescribeInstanceDetailOutput) String() string

+ type ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput struct

+ Accumulation *int64

+ ConsumedClient *string

+ ConsumedOffset *int64

+ EndOffset *int64

+ PartitionId *int32

+ StartOffset *int64

+ func (s *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetAccumulation(v int64) *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput

+ func (s *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetConsumedClient(v string) *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput

+ func (s *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetConsumedOffset(v int64) *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput

+ func (s *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetEndOffset(v int64) *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput

+ func (s *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetPartitionId(v int32) *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput

+ func (s *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetStartOffset(v int64) *ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput

+ func (s ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) GoString() string

+ func (s ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) String() string

+ type ConsumedTopicsInfoForDescribeConsumedTopicsOutput struct

+ Accumulation *int64

+ TopicName *string

+ func (s *ConsumedTopicsInfoForDescribeConsumedTopicsOutput) SetAccumulation(v int64) *ConsumedTopicsInfoForDescribeConsumedTopicsOutput

+ func (s *ConsumedTopicsInfoForDescribeConsumedTopicsOutput) SetTopicName(v string) *ConsumedTopicsInfoForDescribeConsumedTopicsOutput

+ func (s ConsumedTopicsInfoForDescribeConsumedTopicsOutput) GoString() string

+ func (s ConsumedTopicsInfoForDescribeConsumedTopicsOutput) String() string

+ type CreateInstanceInput struct

+ ChargeInfo *ChargeInfoForCreateInstanceInput

+ ComputeSpec *string

+ EipId *string

+ InstanceDescription *string

+ InstanceName *string

+ IpWhiteList []*string

+ Parameters *string

+ PartitionNumber *int32

+ ProjectName *string

+ StorageSpace *int32

+ StorageType *string

+ SubnetId *string

+ Tags map[string]*string

+ UserName *string

+ UserPassword *string

+ Version *string

+ VpcId *string

+ ZoneId *string

+ func (s *CreateInstanceInput) SetChargeInfo(v *ChargeInfoForCreateInstanceInput) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetComputeSpec(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetEipId(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetInstanceDescription(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetInstanceName(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetIpWhiteList(v []*string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetParameters(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetPartitionNumber(v int32) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetProjectName(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetStorageSpace(v int32) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetStorageType(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetSubnetId(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetTags(v map[string]*string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetUserName(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetUserPassword(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetVersion(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetVpcId(v string) *CreateInstanceInput

+ func (s *CreateInstanceInput) SetZoneId(v string) *CreateInstanceInput

+ func (s CreateInstanceInput) GoString() string

+ func (s CreateInstanceInput) String() string

+ type CreateInstanceOutput struct

+ InstanceId *string

+ Metadata *response.ResponseMetadata

+ OrderId *string

+ func (s *CreateInstanceOutput) SetInstanceId(v string) *CreateInstanceOutput

+ func (s *CreateInstanceOutput) SetOrderId(v string) *CreateInstanceOutput

+ func (s CreateInstanceOutput) GoString() string

+ func (s CreateInstanceOutput) String() string

+ type CreatePublicAddressInput struct

+ EipId *string

+ InstanceId *string

+ func (s *CreatePublicAddressInput) SetEipId(v string) *CreatePublicAddressInput

+ func (s *CreatePublicAddressInput) SetInstanceId(v string) *CreatePublicAddressInput

+ func (s CreatePublicAddressInput) GoString() string

+ func (s CreatePublicAddressInput) String() string

+ type CreatePublicAddressOutput struct

+ Metadata *response.ResponseMetadata

+ func (s CreatePublicAddressOutput) GoString() string

+ func (s CreatePublicAddressOutput) String() string

+ type CreateTopicInput struct

+ AccessPolicies []*AccessPolicyForCreateTopicInput

+ AllAuthority *bool

+ Description *string

+ InstanceId *string

+ Parameters *string

+ PartitionNumber *int32

+ ReplicaNumber *int32

+ TopicName *string

+ func (s *CreateTopicInput) SetAccessPolicies(v []*AccessPolicyForCreateTopicInput) *CreateTopicInput

+ func (s *CreateTopicInput) SetAllAuthority(v bool) *CreateTopicInput

+ func (s *CreateTopicInput) SetDescription(v string) *CreateTopicInput

+ func (s *CreateTopicInput) SetInstanceId(v string) *CreateTopicInput

+ func (s *CreateTopicInput) SetParameters(v string) *CreateTopicInput

+ func (s *CreateTopicInput) SetPartitionNumber(v int32) *CreateTopicInput

+ func (s *CreateTopicInput) SetReplicaNumber(v int32) *CreateTopicInput

+ func (s *CreateTopicInput) SetTopicName(v string) *CreateTopicInput

+ func (s CreateTopicInput) GoString() string

+ func (s CreateTopicInput) String() string

+ type CreateTopicOutput struct

+ Metadata *response.ResponseMetadata

+ func (s CreateTopicOutput) GoString() string

+ func (s CreateTopicOutput) String() string

+ type CreateUserInput struct

+ AllAuthority *bool

+ Description *string

+ InstanceId *string

+ UserName *string

+ UserPassword *string

+ func (s *CreateUserInput) SetAllAuthority(v bool) *CreateUserInput

+ func (s *CreateUserInput) SetDescription(v string) *CreateUserInput

+ func (s *CreateUserInput) SetInstanceId(v string) *CreateUserInput

+ func (s *CreateUserInput) SetUserName(v string) *CreateUserInput

+ func (s *CreateUserInput) SetUserPassword(v string) *CreateUserInput

+ func (s CreateUserInput) GoString() string

+ func (s CreateUserInput) String() string

+ type CreateUserOutput struct

+ Metadata *response.ResponseMetadata

+ func (s CreateUserOutput) GoString() string

+ func (s CreateUserOutput) String() string

+ type DeleteGroupInput struct

+ GroupId *string

+ InstanceId *string

+ func (s *DeleteGroupInput) SetGroupId(v string) *DeleteGroupInput

+ func (s *DeleteGroupInput) SetInstanceId(v string) *DeleteGroupInput

+ func (s DeleteGroupInput) GoString() string

+ func (s DeleteGroupInput) String() string

+ type DeleteGroupOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DeleteGroupOutput) GoString() string

+ func (s DeleteGroupOutput) String() string

+ type DeleteInstanceInput struct

+ InstanceId *string

+ func (s *DeleteInstanceInput) SetInstanceId(v string) *DeleteInstanceInput

+ func (s DeleteInstanceInput) GoString() string

+ func (s DeleteInstanceInput) String() string

+ type DeleteInstanceOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DeleteInstanceOutput) GoString() string

+ func (s DeleteInstanceOutput) String() string

+ type DeletePublicAddressInput struct

+ InstanceId *string

+ func (s *DeletePublicAddressInput) SetInstanceId(v string) *DeletePublicAddressInput

+ func (s DeletePublicAddressInput) GoString() string

+ func (s DeletePublicAddressInput) String() string

+ type DeletePublicAddressOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DeletePublicAddressOutput) GoString() string

+ func (s DeletePublicAddressOutput) String() string

+ type DeleteTopicInput struct

+ InstanceId *string

+ TopicName *string

+ func (s *DeleteTopicInput) SetInstanceId(v string) *DeleteTopicInput

+ func (s *DeleteTopicInput) SetTopicName(v string) *DeleteTopicInput

+ func (s DeleteTopicInput) GoString() string

+ func (s DeleteTopicInput) String() string

+ type DeleteTopicOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DeleteTopicOutput) GoString() string

+ func (s DeleteTopicOutput) String() string

+ type DeleteUserInput struct

+ InstanceId *string

+ UserName *string

+ func (s *DeleteUserInput) SetInstanceId(v string) *DeleteUserInput

+ func (s *DeleteUserInput) SetUserName(v string) *DeleteUserInput

+ func (s DeleteUserInput) GoString() string

+ func (s DeleteUserInput) String() string

+ type DeleteUserOutput struct

+ Metadata *response.ResponseMetadata

+ func (s DeleteUserOutput) GoString() string

+ func (s DeleteUserOutput) String() string

+ type DescribeAvailabilityZonesInput struct

+ RegionId *string

+ func (s *DescribeAvailabilityZonesInput) SetRegionId(v string) *DescribeAvailabilityZonesInput

+ func (s DescribeAvailabilityZonesInput) GoString() string

+ func (s DescribeAvailabilityZonesInput) String() string

+ type DescribeAvailabilityZonesOutput struct

+ Metadata *response.ResponseMetadata

+ RegionId *string

+ Zones []*ZoneForDescribeAvailabilityZonesOutput

+ func (s *DescribeAvailabilityZonesOutput) SetRegionId(v string) *DescribeAvailabilityZonesOutput

+ func (s *DescribeAvailabilityZonesOutput) SetZones(v []*ZoneForDescribeAvailabilityZonesOutput) *DescribeAvailabilityZonesOutput

+ func (s DescribeAvailabilityZonesOutput) GoString() string

+ func (s DescribeAvailabilityZonesOutput) String() string

+ type DescribeConsumedPartitionsInput struct

+ GroupId *string

+ InstanceId *string

+ PageNumber *int32

+ PageSize *int32

+ TopicName *string

+ func (s *DescribeConsumedPartitionsInput) SetGroupId(v string) *DescribeConsumedPartitionsInput

+ func (s *DescribeConsumedPartitionsInput) SetInstanceId(v string) *DescribeConsumedPartitionsInput

+ func (s *DescribeConsumedPartitionsInput) SetPageNumber(v int32) *DescribeConsumedPartitionsInput

+ func (s *DescribeConsumedPartitionsInput) SetPageSize(v int32) *DescribeConsumedPartitionsInput

+ func (s *DescribeConsumedPartitionsInput) SetTopicName(v string) *DescribeConsumedPartitionsInput

+ func (s DescribeConsumedPartitionsInput) GoString() string

+ func (s DescribeConsumedPartitionsInput) String() string

+ type DescribeConsumedPartitionsOutput struct

+ ConsumedPartitionsInfo []*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput

+ Metadata *response.ResponseMetadata

+ Total *int32

+ func (s *DescribeConsumedPartitionsOutput) SetConsumedPartitionsInfo(v []*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) *DescribeConsumedPartitionsOutput

+ func (s *DescribeConsumedPartitionsOutput) SetTotal(v int32) *DescribeConsumedPartitionsOutput

+ func (s DescribeConsumedPartitionsOutput) GoString() string

+ func (s DescribeConsumedPartitionsOutput) String() string

+ type DescribeConsumedTopicsInput struct

+ GroupId *string

+ InstanceId *string

+ PageNumber *int32

+ PageSize *int32

+ TopicName *string

+ func (s *DescribeConsumedTopicsInput) SetGroupId(v string) *DescribeConsumedTopicsInput

+ func (s *DescribeConsumedTopicsInput) SetInstanceId(v string) *DescribeConsumedTopicsInput

+ func (s *DescribeConsumedTopicsInput) SetPageNumber(v int32) *DescribeConsumedTopicsInput

+ func (s *DescribeConsumedTopicsInput) SetPageSize(v int32) *DescribeConsumedTopicsInput

+ func (s *DescribeConsumedTopicsInput) SetTopicName(v string) *DescribeConsumedTopicsInput

+ func (s DescribeConsumedTopicsInput) GoString() string

+ func (s DescribeConsumedTopicsInput) String() string

+ type DescribeConsumedTopicsOutput struct

+ Accumulation *int64

+ ConsumedTopicsInfo []*ConsumedTopicsInfoForDescribeConsumedTopicsOutput

+ Metadata *response.ResponseMetadata

+ Total *int32

+ func (s *DescribeConsumedTopicsOutput) SetAccumulation(v int64) *DescribeConsumedTopicsOutput

+ func (s *DescribeConsumedTopicsOutput) SetConsumedTopicsInfo(v []*ConsumedTopicsInfoForDescribeConsumedTopicsOutput) *DescribeConsumedTopicsOutput

+ func (s *DescribeConsumedTopicsOutput) SetTotal(v int32) *DescribeConsumedTopicsOutput

+ func (s DescribeConsumedTopicsOutput) GoString() string

+ func (s DescribeConsumedTopicsOutput) String() string

+ type DescribeGroupsInput struct

+ GroupId *string

+ InstanceId *string

+ PageNumber *int32

+ PageSize *int32

+ func (s *DescribeGroupsInput) SetGroupId(v string) *DescribeGroupsInput

+ func (s *DescribeGroupsInput) SetInstanceId(v string) *DescribeGroupsInput

+ func (s *DescribeGroupsInput) SetPageNumber(v int32) *DescribeGroupsInput

+ func (s *DescribeGroupsInput) SetPageSize(v int32) *DescribeGroupsInput

+ func (s DescribeGroupsInput) GoString() string

+ func (s DescribeGroupsInput) String() string

+ type DescribeGroupsOutput struct

+ GroupsInfo []*GroupsInfoForDescribeGroupsOutput

+ Metadata *response.ResponseMetadata

+ Total *int32

+ func (s *DescribeGroupsOutput) SetGroupsInfo(v []*GroupsInfoForDescribeGroupsOutput) *DescribeGroupsOutput

+ func (s *DescribeGroupsOutput) SetTotal(v int32) *DescribeGroupsOutput

+ func (s DescribeGroupsOutput) GoString() string

+ func (s DescribeGroupsOutput) String() string

+ type DescribeInstanceDetailInput struct

+ InstanceId *string

+ func (s *DescribeInstanceDetailInput) SetInstanceId(v string) *DescribeInstanceDetailInput

+ func (s DescribeInstanceDetailInput) GoString() string

+ func (s DescribeInstanceDetailInput) String() string

+ type DescribeInstanceDetailOutput struct

+ BasicInstanceInfo *BasicInstanceInfoForDescribeInstanceDetailOutput

+ ChargeDetail *ChargeDetailForDescribeInstanceDetailOutput

+ ConnectionInfo []*ConnectionInfoForDescribeInstanceDetailOutput

+ Metadata *response.ResponseMetadata

+ Parameters *string

+ func (s *DescribeInstanceDetailOutput) SetBasicInstanceInfo(v *BasicInstanceInfoForDescribeInstanceDetailOutput) *DescribeInstanceDetailOutput

+ func (s *DescribeInstanceDetailOutput) SetChargeDetail(v *ChargeDetailForDescribeInstanceDetailOutput) *DescribeInstanceDetailOutput

+ func (s *DescribeInstanceDetailOutput) SetConnectionInfo(v []*ConnectionInfoForDescribeInstanceDetailOutput) *DescribeInstanceDetailOutput

+ func (s *DescribeInstanceDetailOutput) SetParameters(v string) *DescribeInstanceDetailOutput

+ func (s DescribeInstanceDetailOutput) GoString() string

+ func (s DescribeInstanceDetailOutput) String() string

+ type DescribeInstancesInput struct

+ InstanceId *string

+ InstanceName *string

+ InstanceStatus *string

+ PageNumber *int32

+ PageSize *int32

+ Tags map[string][]*string

+ ZoneId *string

+ func (s *DescribeInstancesInput) SetInstanceId(v string) *DescribeInstancesInput

+ func (s *DescribeInstancesInput) SetInstanceName(v string) *DescribeInstancesInput

+ func (s *DescribeInstancesInput) SetInstanceStatus(v string) *DescribeInstancesInput

+ func (s *DescribeInstancesInput) SetPageNumber(v int32) *DescribeInstancesInput

+ func (s *DescribeInstancesInput) SetPageSize(v int32) *DescribeInstancesInput

+ func (s *DescribeInstancesInput) SetTags(v map[string][]*string) *DescribeInstancesInput

+ func (s *DescribeInstancesInput) SetZoneId(v string) *DescribeInstancesInput

+ func (s DescribeInstancesInput) GoString() string

+ func (s DescribeInstancesInput) String() string

+ type DescribeInstancesOutput struct

+ InstancesInfo []*InstancesInfoForDescribeInstancesOutput

+ Metadata *response.ResponseMetadata

+ Total *int32

+ func (s *DescribeInstancesOutput) SetInstancesInfo(v []*InstancesInfoForDescribeInstancesOutput) *DescribeInstancesOutput

+ func (s *DescribeInstancesOutput) SetTotal(v int32) *DescribeInstancesOutput

+ func (s DescribeInstancesOutput) GoString() string

+ func (s DescribeInstancesOutput) String() string

+ type DescribeTopicAccessPoliciesInput struct

+ InstanceId *string

+ TopicName *string

+ UserName *string

+ func (s *DescribeTopicAccessPoliciesInput) SetInstanceId(v string) *DescribeTopicAccessPoliciesInput

+ func (s *DescribeTopicAccessPoliciesInput) SetTopicName(v string) *DescribeTopicAccessPoliciesInput

+ func (s *DescribeTopicAccessPoliciesInput) SetUserName(v string) *DescribeTopicAccessPoliciesInput

+ func (s DescribeTopicAccessPoliciesInput) GoString() string

+ func (s DescribeTopicAccessPoliciesInput) String() string

+ type DescribeTopicAccessPoliciesOutput struct

+ AccessPolicies []*AccessPolicyForDescribeTopicAccessPoliciesOutput

+ AllAuthority *bool

+ Metadata *response.ResponseMetadata

+ func (s *DescribeTopicAccessPoliciesOutput) SetAccessPolicies(v []*AccessPolicyForDescribeTopicAccessPoliciesOutput) *DescribeTopicAccessPoliciesOutput

+ func (s *DescribeTopicAccessPoliciesOutput) SetAllAuthority(v bool) *DescribeTopicAccessPoliciesOutput

+ func (s DescribeTopicAccessPoliciesOutput) GoString() string

+ func (s DescribeTopicAccessPoliciesOutput) String() string

+ type DescribeTopicParametersInput struct

+ InstanceId *string

+ TopicName *string

+ func (s *DescribeTopicParametersInput) SetInstanceId(v string) *DescribeTopicParametersInput

+ func (s *DescribeTopicParametersInput) SetTopicName(v string) *DescribeTopicParametersInput

+ func (s DescribeTopicParametersInput) GoString() string

+ func (s DescribeTopicParametersInput) String() string

+ type DescribeTopicParametersOutput struct

+ Metadata *response.ResponseMetadata

+ Parameters *string

+ func (s *DescribeTopicParametersOutput) SetParameters(v string) *DescribeTopicParametersOutput

+ func (s DescribeTopicParametersOutput) GoString() string

+ func (s DescribeTopicParametersOutput) String() string

+ type DescribeTopicPartitionsInput struct

+ InstanceId *string

+ PageNumber *int32

+ PageSize *int32

+ PartitionIds []*int64

+ TopicName *string

+ UnderInsyncOnly *bool

+ func (s *DescribeTopicPartitionsInput) SetInstanceId(v string) *DescribeTopicPartitionsInput

+ func (s *DescribeTopicPartitionsInput) SetPageNumber(v int32) *DescribeTopicPartitionsInput

+ func (s *DescribeTopicPartitionsInput) SetPageSize(v int32) *DescribeTopicPartitionsInput

+ func (s *DescribeTopicPartitionsInput) SetPartitionIds(v []*int64) *DescribeTopicPartitionsInput

+ func (s *DescribeTopicPartitionsInput) SetTopicName(v string) *DescribeTopicPartitionsInput

+ func (s *DescribeTopicPartitionsInput) SetUnderInsyncOnly(v bool) *DescribeTopicPartitionsInput

+ func (s DescribeTopicPartitionsInput) GoString() string

+ func (s DescribeTopicPartitionsInput) String() string

+ type DescribeTopicPartitionsOutput struct

+ Metadata *response.ResponseMetadata

+ PartitionsInfo []*PartitionsInfoForDescribeTopicPartitionsOutput

+ Total *int32

+ func (s *DescribeTopicPartitionsOutput) SetPartitionsInfo(v []*PartitionsInfoForDescribeTopicPartitionsOutput) *DescribeTopicPartitionsOutput

+ func (s *DescribeTopicPartitionsOutput) SetTotal(v int32) *DescribeTopicPartitionsOutput

+ func (s DescribeTopicPartitionsOutput) GoString() string

+ func (s DescribeTopicPartitionsOutput) String() string

+ type DescribeTopicsInput struct

+ InstanceId *string

+ PageNumber *int32

+ PageSize *int32

+ PartitionNumber *int32

+ ReplicaNumber *int32

+ TopicName *string

+ func (s *DescribeTopicsInput) SetInstanceId(v string) *DescribeTopicsInput

+ func (s *DescribeTopicsInput) SetPageNumber(v int32) *DescribeTopicsInput

+ func (s *DescribeTopicsInput) SetPageSize(v int32) *DescribeTopicsInput

+ func (s *DescribeTopicsInput) SetPartitionNumber(v int32) *DescribeTopicsInput

+ func (s *DescribeTopicsInput) SetReplicaNumber(v int32) *DescribeTopicsInput

+ func (s *DescribeTopicsInput) SetTopicName(v string) *DescribeTopicsInput

+ func (s DescribeTopicsInput) GoString() string

+ func (s DescribeTopicsInput) String() string

+ type DescribeTopicsOutput struct

+ InstanceId *string

+ Metadata *response.ResponseMetadata

+ TopicsInfo []*TopicsInfoForDescribeTopicsOutput

+ Total *int32

+ func (s *DescribeTopicsOutput) SetInstanceId(v string) *DescribeTopicsOutput

+ func (s *DescribeTopicsOutput) SetTopicsInfo(v []*TopicsInfoForDescribeTopicsOutput) *DescribeTopicsOutput

+ func (s *DescribeTopicsOutput) SetTotal(v int32) *DescribeTopicsOutput

+ func (s DescribeTopicsOutput) GoString() string

+ func (s DescribeTopicsOutput) String() string

+ type DescribeUsersInput struct

+ InstanceId *string

+ PageNumber *int32

+ PageSize *int32

+ UserName *string

+ func (s *DescribeUsersInput) SetInstanceId(v string) *DescribeUsersInput

+ func (s *DescribeUsersInput) SetPageNumber(v int32) *DescribeUsersInput

+ func (s *DescribeUsersInput) SetPageSize(v int32) *DescribeUsersInput

+ func (s *DescribeUsersInput) SetUserName(v string) *DescribeUsersInput

+ func (s DescribeUsersInput) GoString() string

+ func (s DescribeUsersInput) String() string

+ type DescribeUsersOutput struct

+ Metadata *response.ResponseMetadata

+ Total *int32

+ UsersInfo []*UsersInfoForDescribeUsersOutput

+ func (s *DescribeUsersOutput) SetTotal(v int32) *DescribeUsersOutput

+ func (s *DescribeUsersOutput) SetUsersInfo(v []*UsersInfoForDescribeUsersOutput) *DescribeUsersOutput

+ func (s DescribeUsersOutput) GoString() string

+ func (s DescribeUsersOutput) String() string

+ type GroupsInfoForDescribeGroupsOutput struct

+ GroupId *string

+ State *string

+ func (s *GroupsInfoForDescribeGroupsOutput) SetGroupId(v string) *GroupsInfoForDescribeGroupsOutput

+ func (s *GroupsInfoForDescribeGroupsOutput) SetState(v string) *GroupsInfoForDescribeGroupsOutput

+ func (s GroupsInfoForDescribeGroupsOutput) GoString() string

+ func (s GroupsInfoForDescribeGroupsOutput) String() string

+ type InnerParametersForModifyTopicParametersInput struct

+ LogRetentionHours *int32

+ MessageMaxByte *int32

+ MinInsyncReplicaNumber *int32

+ func (s *InnerParametersForModifyTopicParametersInput) SetLogRetentionHours(v int32) *InnerParametersForModifyTopicParametersInput

+ func (s *InnerParametersForModifyTopicParametersInput) SetMessageMaxByte(v int32) *InnerParametersForModifyTopicParametersInput

+ func (s *InnerParametersForModifyTopicParametersInput) SetMinInsyncReplicaNumber(v int32) *InnerParametersForModifyTopicParametersInput

+ func (s InnerParametersForModifyTopicParametersInput) GoString() string

+ func (s InnerParametersForModifyTopicParametersInput) String() string

+ type InstancesInfoForDescribeInstancesOutput struct

+ AccountId *string

+ ChargeDetail *ChargeDetailForDescribeInstancesOutput

+ ComputeSpec *string

+ CreateTime *string

+ EipId *string

+ InstanceDescription *string

+ InstanceId *string

+ InstanceName *string

+ InstanceStatus *string

+ PrivateDomainOnPublic *bool

+ ProjectName *string

+ RegionId *string

+ StorageSpace *int32

+ StorageType *string

+ SubnetId *string

+ Tags map[string]*string

+ UsableGroupNumber *int32

+ UsablePartitionNumber *int32

+ UsedGroupNumber *int32

+ UsedPartitionNumber *int32

+ UsedStorageSpace *int32

+ UsedTopicNumber *int32

+ Version *string

+ VpcId *string

+ ZoneId *string

+ func (s *InstancesInfoForDescribeInstancesOutput) SetAccountId(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetChargeDetail(v *ChargeDetailForDescribeInstancesOutput) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetComputeSpec(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetCreateTime(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetEipId(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetInstanceDescription(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetInstanceId(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetInstanceName(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetInstanceStatus(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetPrivateDomainOnPublic(v bool) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetProjectName(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetRegionId(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetStorageSpace(v int32) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetStorageType(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetSubnetId(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetTags(v map[string]*string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetUsableGroupNumber(v int32) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetUsablePartitionNumber(v int32) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetUsedGroupNumber(v int32) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetUsedPartitionNumber(v int32) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetUsedStorageSpace(v int32) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetUsedTopicNumber(v int32) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetVersion(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetVpcId(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s *InstancesInfoForDescribeInstancesOutput) SetZoneId(v string) *InstancesInfoForDescribeInstancesOutput

+ func (s InstancesInfoForDescribeInstancesOutput) GoString() string

+ func (s InstancesInfoForDescribeInstancesOutput) String() string

+ type KAFKA struct

+ func New(p client.ConfigProvider, cfgs ...*volcengine.Config) *KAFKA

+ func (c *KAFKA) AddTagsToResource(input *AddTagsToResourceInput) (*AddTagsToResourceOutput, error)

+ func (c *KAFKA) AddTagsToResourceCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) AddTagsToResourceCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) AddTagsToResourceCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) AddTagsToResourceRequest(input *AddTagsToResourceInput) (req *request.Request, output *AddTagsToResourceOutput)

+ func (c *KAFKA) AddTagsToResourceWithContext(ctx volcengine.Context, input *AddTagsToResourceInput, opts ...request.Option) (*AddTagsToResourceOutput, error)

+ func (c *KAFKA) CreateInstance(input *CreateInstanceInput) (*CreateInstanceOutput, error)

+ func (c *KAFKA) CreateInstanceCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateInstanceCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreateInstanceCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateInstanceRequest(input *CreateInstanceInput) (req *request.Request, output *CreateInstanceOutput)

+ func (c *KAFKA) CreateInstanceWithContext(ctx volcengine.Context, input *CreateInstanceInput, opts ...request.Option) (*CreateInstanceOutput, error)

+ func (c *KAFKA) CreatePublicAddress(input *CreatePublicAddressInput) (*CreatePublicAddressOutput, error)

+ func (c *KAFKA) CreatePublicAddressCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreatePublicAddressCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreatePublicAddressCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreatePublicAddressRequest(input *CreatePublicAddressInput) (req *request.Request, output *CreatePublicAddressOutput)

+ func (c *KAFKA) CreatePublicAddressWithContext(ctx volcengine.Context, input *CreatePublicAddressInput, ...) (*CreatePublicAddressOutput, error)

+ func (c *KAFKA) CreateTopic(input *CreateTopicInput) (*CreateTopicOutput, error)

+ func (c *KAFKA) CreateTopicCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateTopicCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreateTopicCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateTopicRequest(input *CreateTopicInput) (req *request.Request, output *CreateTopicOutput)

+ func (c *KAFKA) CreateTopicWithContext(ctx volcengine.Context, input *CreateTopicInput, opts ...request.Option) (*CreateTopicOutput, error)

+ func (c *KAFKA) CreateUser(input *CreateUserInput) (*CreateUserOutput, error)

+ func (c *KAFKA) CreateUserCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateUserCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) CreateUserCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) CreateUserRequest(input *CreateUserInput) (req *request.Request, output *CreateUserOutput)

+ func (c *KAFKA) CreateUserWithContext(ctx volcengine.Context, input *CreateUserInput, opts ...request.Option) (*CreateUserOutput, error)

+ func (c *KAFKA) DeleteGroup(input *DeleteGroupInput) (*DeleteGroupOutput, error)

+ func (c *KAFKA) DeleteGroupCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteGroupCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DeleteGroupCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteGroupRequest(input *DeleteGroupInput) (req *request.Request, output *DeleteGroupOutput)

+ func (c *KAFKA) DeleteGroupWithContext(ctx volcengine.Context, input *DeleteGroupInput, opts ...request.Option) (*DeleteGroupOutput, error)

+ func (c *KAFKA) DeleteInstance(input *DeleteInstanceInput) (*DeleteInstanceOutput, error)

+ func (c *KAFKA) DeleteInstanceCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteInstanceCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DeleteInstanceCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteInstanceRequest(input *DeleteInstanceInput) (req *request.Request, output *DeleteInstanceOutput)

+ func (c *KAFKA) DeleteInstanceWithContext(ctx volcengine.Context, input *DeleteInstanceInput, opts ...request.Option) (*DeleteInstanceOutput, error)

+ func (c *KAFKA) DeletePublicAddress(input *DeletePublicAddressInput) (*DeletePublicAddressOutput, error)

+ func (c *KAFKA) DeletePublicAddressCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DeletePublicAddressCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DeletePublicAddressCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DeletePublicAddressRequest(input *DeletePublicAddressInput) (req *request.Request, output *DeletePublicAddressOutput)

+ func (c *KAFKA) DeletePublicAddressWithContext(ctx volcengine.Context, input *DeletePublicAddressInput, ...) (*DeletePublicAddressOutput, error)

+ func (c *KAFKA) DeleteTopic(input *DeleteTopicInput) (*DeleteTopicOutput, error)

+ func (c *KAFKA) DeleteTopicCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteTopicCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DeleteTopicCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteTopicRequest(input *DeleteTopicInput) (req *request.Request, output *DeleteTopicOutput)

+ func (c *KAFKA) DeleteTopicWithContext(ctx volcengine.Context, input *DeleteTopicInput, opts ...request.Option) (*DeleteTopicOutput, error)

+ func (c *KAFKA) DeleteUser(input *DeleteUserInput) (*DeleteUserOutput, error)

+ func (c *KAFKA) DeleteUserCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteUserCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DeleteUserCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DeleteUserRequest(input *DeleteUserInput) (req *request.Request, output *DeleteUserOutput)

+ func (c *KAFKA) DeleteUserWithContext(ctx volcengine.Context, input *DeleteUserInput, opts ...request.Option) (*DeleteUserOutput, error)

+ func (c *KAFKA) DescribeAvailabilityZones(input *DescribeAvailabilityZonesInput) (*DescribeAvailabilityZonesOutput, error)

+ func (c *KAFKA) DescribeAvailabilityZonesCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAvailabilityZonesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeAvailabilityZonesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeAvailabilityZonesRequest(input *DescribeAvailabilityZonesInput) (req *request.Request, output *DescribeAvailabilityZonesOutput)

+ func (c *KAFKA) DescribeAvailabilityZonesWithContext(ctx volcengine.Context, input *DescribeAvailabilityZonesInput, ...) (*DescribeAvailabilityZonesOutput, error)

+ func (c *KAFKA) DescribeConsumedPartitions(input *DescribeConsumedPartitionsInput) (*DescribeConsumedPartitionsOutput, error)

+ func (c *KAFKA) DescribeConsumedPartitionsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeConsumedPartitionsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeConsumedPartitionsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeConsumedPartitionsRequest(input *DescribeConsumedPartitionsInput) (req *request.Request, output *DescribeConsumedPartitionsOutput)

+ func (c *KAFKA) DescribeConsumedPartitionsWithContext(ctx volcengine.Context, input *DescribeConsumedPartitionsInput, ...) (*DescribeConsumedPartitionsOutput, error)

+ func (c *KAFKA) DescribeConsumedTopics(input *DescribeConsumedTopicsInput) (*DescribeConsumedTopicsOutput, error)

+ func (c *KAFKA) DescribeConsumedTopicsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeConsumedTopicsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeConsumedTopicsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeConsumedTopicsRequest(input *DescribeConsumedTopicsInput) (req *request.Request, output *DescribeConsumedTopicsOutput)

+ func (c *KAFKA) DescribeConsumedTopicsWithContext(ctx volcengine.Context, input *DescribeConsumedTopicsInput, ...) (*DescribeConsumedTopicsOutput, error)

+ func (c *KAFKA) DescribeGroups(input *DescribeGroupsInput) (*DescribeGroupsOutput, error)

+ func (c *KAFKA) DescribeGroupsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeGroupsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeGroupsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeGroupsRequest(input *DescribeGroupsInput) (req *request.Request, output *DescribeGroupsOutput)

+ func (c *KAFKA) DescribeGroupsWithContext(ctx volcengine.Context, input *DescribeGroupsInput, opts ...request.Option) (*DescribeGroupsOutput, error)

+ func (c *KAFKA) DescribeInstanceDetail(input *DescribeInstanceDetailInput) (*DescribeInstanceDetailOutput, error)

+ func (c *KAFKA) DescribeInstanceDetailCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeInstanceDetailCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeInstanceDetailCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeInstanceDetailRequest(input *DescribeInstanceDetailInput) (req *request.Request, output *DescribeInstanceDetailOutput)

+ func (c *KAFKA) DescribeInstanceDetailWithContext(ctx volcengine.Context, input *DescribeInstanceDetailInput, ...) (*DescribeInstanceDetailOutput, error)

+ func (c *KAFKA) DescribeInstances(input *DescribeInstancesInput) (*DescribeInstancesOutput, error)

+ func (c *KAFKA) DescribeInstancesCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeInstancesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeInstancesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeInstancesRequest(input *DescribeInstancesInput) (req *request.Request, output *DescribeInstancesOutput)

+ func (c *KAFKA) DescribeInstancesWithContext(ctx volcengine.Context, input *DescribeInstancesInput, opts ...request.Option) (*DescribeInstancesOutput, error)

+ func (c *KAFKA) DescribeTopicAccessPolicies(input *DescribeTopicAccessPoliciesInput) (*DescribeTopicAccessPoliciesOutput, error)

+ func (c *KAFKA) DescribeTopicAccessPoliciesCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicAccessPoliciesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeTopicAccessPoliciesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicAccessPoliciesRequest(input *DescribeTopicAccessPoliciesInput) (req *request.Request, output *DescribeTopicAccessPoliciesOutput)

+ func (c *KAFKA) DescribeTopicAccessPoliciesWithContext(ctx volcengine.Context, input *DescribeTopicAccessPoliciesInput, ...) (*DescribeTopicAccessPoliciesOutput, error)

+ func (c *KAFKA) DescribeTopicParameters(input *DescribeTopicParametersInput) (*DescribeTopicParametersOutput, error)

+ func (c *KAFKA) DescribeTopicParametersCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicParametersCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeTopicParametersCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicParametersRequest(input *DescribeTopicParametersInput) (req *request.Request, output *DescribeTopicParametersOutput)

+ func (c *KAFKA) DescribeTopicParametersWithContext(ctx volcengine.Context, input *DescribeTopicParametersInput, ...) (*DescribeTopicParametersOutput, error)

+ func (c *KAFKA) DescribeTopicPartitions(input *DescribeTopicPartitionsInput) (*DescribeTopicPartitionsOutput, error)

+ func (c *KAFKA) DescribeTopicPartitionsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicPartitionsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeTopicPartitionsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicPartitionsRequest(input *DescribeTopicPartitionsInput) (req *request.Request, output *DescribeTopicPartitionsOutput)

+ func (c *KAFKA) DescribeTopicPartitionsWithContext(ctx volcengine.Context, input *DescribeTopicPartitionsInput, ...) (*DescribeTopicPartitionsOutput, error)

+ func (c *KAFKA) DescribeTopics(input *DescribeTopicsInput) (*DescribeTopicsOutput, error)

+ func (c *KAFKA) DescribeTopicsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeTopicsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeTopicsRequest(input *DescribeTopicsInput) (req *request.Request, output *DescribeTopicsOutput)

+ func (c *KAFKA) DescribeTopicsWithContext(ctx volcengine.Context, input *DescribeTopicsInput, opts ...request.Option) (*DescribeTopicsOutput, error)

+ func (c *KAFKA) DescribeUsers(input *DescribeUsersInput) (*DescribeUsersOutput, error)

+ func (c *KAFKA) DescribeUsersCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeUsersCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) DescribeUsersCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) DescribeUsersRequest(input *DescribeUsersInput) (req *request.Request, output *DescribeUsersOutput)

+ func (c *KAFKA) DescribeUsersWithContext(ctx volcengine.Context, input *DescribeUsersInput, opts ...request.Option) (*DescribeUsersOutput, error)

+ func (c *KAFKA) ModifyInstanceAttributes(input *ModifyInstanceAttributesInput) (*ModifyInstanceAttributesOutput, error)

+ func (c *KAFKA) ModifyInstanceAttributesCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceAttributesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyInstanceAttributesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceAttributesRequest(input *ModifyInstanceAttributesInput) (req *request.Request, output *ModifyInstanceAttributesOutput)

+ func (c *KAFKA) ModifyInstanceAttributesWithContext(ctx volcengine.Context, input *ModifyInstanceAttributesInput, ...) (*ModifyInstanceAttributesOutput, error)

+ func (c *KAFKA) ModifyInstanceChargeType(input *ModifyInstanceChargeTypeInput) (*ModifyInstanceChargeTypeOutput, error)

+ func (c *KAFKA) ModifyInstanceChargeTypeCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceChargeTypeCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyInstanceChargeTypeCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceChargeTypeRequest(input *ModifyInstanceChargeTypeInput) (req *request.Request, output *ModifyInstanceChargeTypeOutput)

+ func (c *KAFKA) ModifyInstanceChargeTypeWithContext(ctx volcengine.Context, input *ModifyInstanceChargeTypeInput, ...) (*ModifyInstanceChargeTypeOutput, error)

+ func (c *KAFKA) ModifyInstanceParameters(input *ModifyInstanceParametersInput) (*ModifyInstanceParametersOutput, error)

+ func (c *KAFKA) ModifyInstanceParametersCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceParametersCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyInstanceParametersCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceParametersRequest(input *ModifyInstanceParametersInput) (req *request.Request, output *ModifyInstanceParametersOutput)

+ func (c *KAFKA) ModifyInstanceParametersWithContext(ctx volcengine.Context, input *ModifyInstanceParametersInput, ...) (*ModifyInstanceParametersOutput, error)

+ func (c *KAFKA) ModifyInstanceSpec(input *ModifyInstanceSpecInput) (*ModifyInstanceSpecOutput, error)

+ func (c *KAFKA) ModifyInstanceSpecCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceSpecCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyInstanceSpecCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyInstanceSpecRequest(input *ModifyInstanceSpecInput) (req *request.Request, output *ModifyInstanceSpecOutput)

+ func (c *KAFKA) ModifyInstanceSpecWithContext(ctx volcengine.Context, input *ModifyInstanceSpecInput, opts ...request.Option) (*ModifyInstanceSpecOutput, error)

+ func (c *KAFKA) ModifyTopicAccessPolicies(input *ModifyTopicAccessPoliciesInput) (*ModifyTopicAccessPoliciesOutput, error)

+ func (c *KAFKA) ModifyTopicAccessPoliciesCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyTopicAccessPoliciesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyTopicAccessPoliciesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyTopicAccessPoliciesRequest(input *ModifyTopicAccessPoliciesInput) (req *request.Request, output *ModifyTopicAccessPoliciesOutput)

+ func (c *KAFKA) ModifyTopicAccessPoliciesWithContext(ctx volcengine.Context, input *ModifyTopicAccessPoliciesInput, ...) (*ModifyTopicAccessPoliciesOutput, error)

+ func (c *KAFKA) ModifyTopicAttributes(input *ModifyTopicAttributesInput) (*ModifyTopicAttributesOutput, error)

+ func (c *KAFKA) ModifyTopicAttributesCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyTopicAttributesCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyTopicAttributesCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyTopicAttributesRequest(input *ModifyTopicAttributesInput) (req *request.Request, output *ModifyTopicAttributesOutput)

+ func (c *KAFKA) ModifyTopicAttributesWithContext(ctx volcengine.Context, input *ModifyTopicAttributesInput, ...) (*ModifyTopicAttributesOutput, error)

+ func (c *KAFKA) ModifyTopicParameters(input *ModifyTopicParametersInput) (*ModifyTopicParametersOutput, error)

+ func (c *KAFKA) ModifyTopicParametersCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyTopicParametersCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyTopicParametersCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyTopicParametersRequest(input *ModifyTopicParametersInput) (req *request.Request, output *ModifyTopicParametersOutput)

+ func (c *KAFKA) ModifyTopicParametersWithContext(ctx volcengine.Context, input *ModifyTopicParametersInput, ...) (*ModifyTopicParametersOutput, error)

+ func (c *KAFKA) ModifyUserAuthority(input *ModifyUserAuthorityInput) (*ModifyUserAuthorityOutput, error)

+ func (c *KAFKA) ModifyUserAuthorityCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyUserAuthorityCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ModifyUserAuthorityCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ModifyUserAuthorityRequest(input *ModifyUserAuthorityInput) (req *request.Request, output *ModifyUserAuthorityOutput)

+ func (c *KAFKA) ModifyUserAuthorityWithContext(ctx volcengine.Context, input *ModifyUserAuthorityInput, ...) (*ModifyUserAuthorityOutput, error)

+ func (c *KAFKA) RemoveTagsFromResource(input *RemoveTagsFromResourceInput) (*RemoveTagsFromResourceOutput, error)

+ func (c *KAFKA) RemoveTagsFromResourceCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) RemoveTagsFromResourceCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) RemoveTagsFromResourceCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) RemoveTagsFromResourceRequest(input *RemoveTagsFromResourceInput) (req *request.Request, output *RemoveTagsFromResourceOutput)

+ func (c *KAFKA) RemoveTagsFromResourceWithContext(ctx volcengine.Context, input *RemoveTagsFromResourceInput, ...) (*RemoveTagsFromResourceOutput, error)

+ func (c *KAFKA) ResetConsumedOffsets(input *ResetConsumedOffsetsInput) (*ResetConsumedOffsetsOutput, error)

+ func (c *KAFKA) ResetConsumedOffsetsCommon(input *map[string]interface{}) (*map[string]interface{}, error)

+ func (c *KAFKA) ResetConsumedOffsetsCommonRequest(input *map[string]interface{}) (req *request.Request, output *map[string]interface{})

+ func (c *KAFKA) ResetConsumedOffsetsCommonWithContext(ctx volcengine.Context, input *map[string]interface{}, opts ...request.Option) (*map[string]interface{}, error)

+ func (c *KAFKA) ResetConsumedOffsetsRequest(input *ResetConsumedOffsetsInput) (req *request.Request, output *ResetConsumedOffsetsOutput)

+ func (c *KAFKA) ResetConsumedOffsetsWithContext(ctx volcengine.Context, input *ResetConsumedOffsetsInput, ...) (*ResetConsumedOffsetsOutput, error)

+ type KAFKAAPI interface

+ AddTagsToResource func(*AddTagsToResourceInput) (*AddTagsToResourceOutput, error)

+ AddTagsToResourceCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ AddTagsToResourceCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ AddTagsToResourceCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ AddTagsToResourceRequest func(*AddTagsToResourceInput) (*request.Request, *AddTagsToResourceOutput)

+ AddTagsToResourceWithContext func(volcengine.Context, *AddTagsToResourceInput, ...request.Option) (*AddTagsToResourceOutput, error)

+ CreateInstance func(*CreateInstanceInput) (*CreateInstanceOutput, error)

+ CreateInstanceCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreateInstanceCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreateInstanceCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreateInstanceRequest func(*CreateInstanceInput) (*request.Request, *CreateInstanceOutput)

+ CreateInstanceWithContext func(volcengine.Context, *CreateInstanceInput, ...request.Option) (*CreateInstanceOutput, error)

+ CreatePublicAddress func(*CreatePublicAddressInput) (*CreatePublicAddressOutput, error)

+ CreatePublicAddressCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreatePublicAddressCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreatePublicAddressCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreatePublicAddressRequest func(*CreatePublicAddressInput) (*request.Request, *CreatePublicAddressOutput)

+ CreatePublicAddressWithContext func(volcengine.Context, *CreatePublicAddressInput, ...request.Option) (*CreatePublicAddressOutput, error)

+ CreateTopic func(*CreateTopicInput) (*CreateTopicOutput, error)

+ CreateTopicCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreateTopicCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreateTopicCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreateTopicRequest func(*CreateTopicInput) (*request.Request, *CreateTopicOutput)

+ CreateTopicWithContext func(volcengine.Context, *CreateTopicInput, ...request.Option) (*CreateTopicOutput, error)

+ CreateUser func(*CreateUserInput) (*CreateUserOutput, error)

+ CreateUserCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ CreateUserCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ CreateUserCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ CreateUserRequest func(*CreateUserInput) (*request.Request, *CreateUserOutput)

+ CreateUserWithContext func(volcengine.Context, *CreateUserInput, ...request.Option) (*CreateUserOutput, error)

+ DeleteGroup func(*DeleteGroupInput) (*DeleteGroupOutput, error)

+ DeleteGroupCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DeleteGroupCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DeleteGroupCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DeleteGroupRequest func(*DeleteGroupInput) (*request.Request, *DeleteGroupOutput)

+ DeleteGroupWithContext func(volcengine.Context, *DeleteGroupInput, ...request.Option) (*DeleteGroupOutput, error)

+ DeleteInstance func(*DeleteInstanceInput) (*DeleteInstanceOutput, error)

+ DeleteInstanceCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DeleteInstanceCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DeleteInstanceCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DeleteInstanceRequest func(*DeleteInstanceInput) (*request.Request, *DeleteInstanceOutput)

+ DeleteInstanceWithContext func(volcengine.Context, *DeleteInstanceInput, ...request.Option) (*DeleteInstanceOutput, error)

+ DeletePublicAddress func(*DeletePublicAddressInput) (*DeletePublicAddressOutput, error)

+ DeletePublicAddressCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DeletePublicAddressCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DeletePublicAddressCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DeletePublicAddressRequest func(*DeletePublicAddressInput) (*request.Request, *DeletePublicAddressOutput)

+ DeletePublicAddressWithContext func(volcengine.Context, *DeletePublicAddressInput, ...request.Option) (*DeletePublicAddressOutput, error)

+ DeleteTopic func(*DeleteTopicInput) (*DeleteTopicOutput, error)

+ DeleteTopicCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DeleteTopicCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DeleteTopicCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DeleteTopicRequest func(*DeleteTopicInput) (*request.Request, *DeleteTopicOutput)

+ DeleteTopicWithContext func(volcengine.Context, *DeleteTopicInput, ...request.Option) (*DeleteTopicOutput, error)

+ DeleteUser func(*DeleteUserInput) (*DeleteUserOutput, error)

+ DeleteUserCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DeleteUserCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DeleteUserCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DeleteUserRequest func(*DeleteUserInput) (*request.Request, *DeleteUserOutput)

+ DeleteUserWithContext func(volcengine.Context, *DeleteUserInput, ...request.Option) (*DeleteUserOutput, error)

+ DescribeAvailabilityZones func(*DescribeAvailabilityZonesInput) (*DescribeAvailabilityZonesOutput, error)

+ DescribeAvailabilityZonesCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeAvailabilityZonesCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeAvailabilityZonesCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeAvailabilityZonesRequest func(*DescribeAvailabilityZonesInput) (*request.Request, *DescribeAvailabilityZonesOutput)

+ DescribeAvailabilityZonesWithContext func(volcengine.Context, *DescribeAvailabilityZonesInput, ...request.Option) (*DescribeAvailabilityZonesOutput, error)

+ DescribeConsumedPartitions func(*DescribeConsumedPartitionsInput) (*DescribeConsumedPartitionsOutput, error)

+ DescribeConsumedPartitionsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeConsumedPartitionsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeConsumedPartitionsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeConsumedPartitionsRequest func(*DescribeConsumedPartitionsInput) (*request.Request, *DescribeConsumedPartitionsOutput)

+ DescribeConsumedPartitionsWithContext func(volcengine.Context, *DescribeConsumedPartitionsInput, ...request.Option) (*DescribeConsumedPartitionsOutput, error)

+ DescribeConsumedTopics func(*DescribeConsumedTopicsInput) (*DescribeConsumedTopicsOutput, error)

+ DescribeConsumedTopicsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeConsumedTopicsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeConsumedTopicsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeConsumedTopicsRequest func(*DescribeConsumedTopicsInput) (*request.Request, *DescribeConsumedTopicsOutput)

+ DescribeConsumedTopicsWithContext func(volcengine.Context, *DescribeConsumedTopicsInput, ...request.Option) (*DescribeConsumedTopicsOutput, error)

+ DescribeGroups func(*DescribeGroupsInput) (*DescribeGroupsOutput, error)

+ DescribeGroupsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeGroupsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeGroupsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeGroupsRequest func(*DescribeGroupsInput) (*request.Request, *DescribeGroupsOutput)

+ DescribeGroupsWithContext func(volcengine.Context, *DescribeGroupsInput, ...request.Option) (*DescribeGroupsOutput, error)

+ DescribeInstanceDetail func(*DescribeInstanceDetailInput) (*DescribeInstanceDetailOutput, error)

+ DescribeInstanceDetailCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeInstanceDetailCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeInstanceDetailCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeInstanceDetailRequest func(*DescribeInstanceDetailInput) (*request.Request, *DescribeInstanceDetailOutput)

+ DescribeInstanceDetailWithContext func(volcengine.Context, *DescribeInstanceDetailInput, ...request.Option) (*DescribeInstanceDetailOutput, error)

+ DescribeInstances func(*DescribeInstancesInput) (*DescribeInstancesOutput, error)

+ DescribeInstancesCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeInstancesCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeInstancesCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeInstancesRequest func(*DescribeInstancesInput) (*request.Request, *DescribeInstancesOutput)

+ DescribeInstancesWithContext func(volcengine.Context, *DescribeInstancesInput, ...request.Option) (*DescribeInstancesOutput, error)

+ DescribeTopicAccessPolicies func(*DescribeTopicAccessPoliciesInput) (*DescribeTopicAccessPoliciesOutput, error)

+ DescribeTopicAccessPoliciesCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeTopicAccessPoliciesCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeTopicAccessPoliciesCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeTopicAccessPoliciesRequest func(*DescribeTopicAccessPoliciesInput) (*request.Request, *DescribeTopicAccessPoliciesOutput)

+ DescribeTopicAccessPoliciesWithContext func(volcengine.Context, *DescribeTopicAccessPoliciesInput, ...request.Option) (*DescribeTopicAccessPoliciesOutput, error)

+ DescribeTopicParameters func(*DescribeTopicParametersInput) (*DescribeTopicParametersOutput, error)

+ DescribeTopicParametersCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeTopicParametersCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeTopicParametersCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeTopicParametersRequest func(*DescribeTopicParametersInput) (*request.Request, *DescribeTopicParametersOutput)

+ DescribeTopicParametersWithContext func(volcengine.Context, *DescribeTopicParametersInput, ...request.Option) (*DescribeTopicParametersOutput, error)

+ DescribeTopicPartitions func(*DescribeTopicPartitionsInput) (*DescribeTopicPartitionsOutput, error)

+ DescribeTopicPartitionsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeTopicPartitionsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeTopicPartitionsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeTopicPartitionsRequest func(*DescribeTopicPartitionsInput) (*request.Request, *DescribeTopicPartitionsOutput)

+ DescribeTopicPartitionsWithContext func(volcengine.Context, *DescribeTopicPartitionsInput, ...request.Option) (*DescribeTopicPartitionsOutput, error)

+ DescribeTopics func(*DescribeTopicsInput) (*DescribeTopicsOutput, error)

+ DescribeTopicsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeTopicsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeTopicsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeTopicsRequest func(*DescribeTopicsInput) (*request.Request, *DescribeTopicsOutput)

+ DescribeTopicsWithContext func(volcengine.Context, *DescribeTopicsInput, ...request.Option) (*DescribeTopicsOutput, error)

+ DescribeUsers func(*DescribeUsersInput) (*DescribeUsersOutput, error)

+ DescribeUsersCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ DescribeUsersCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ DescribeUsersCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ DescribeUsersRequest func(*DescribeUsersInput) (*request.Request, *DescribeUsersOutput)

+ DescribeUsersWithContext func(volcengine.Context, *DescribeUsersInput, ...request.Option) (*DescribeUsersOutput, error)

+ ModifyInstanceAttributes func(*ModifyInstanceAttributesInput) (*ModifyInstanceAttributesOutput, error)

+ ModifyInstanceAttributesCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyInstanceAttributesCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyInstanceAttributesCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyInstanceAttributesRequest func(*ModifyInstanceAttributesInput) (*request.Request, *ModifyInstanceAttributesOutput)

+ ModifyInstanceAttributesWithContext func(volcengine.Context, *ModifyInstanceAttributesInput, ...request.Option) (*ModifyInstanceAttributesOutput, error)

+ ModifyInstanceChargeType func(*ModifyInstanceChargeTypeInput) (*ModifyInstanceChargeTypeOutput, error)

+ ModifyInstanceChargeTypeCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyInstanceChargeTypeCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyInstanceChargeTypeCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyInstanceChargeTypeRequest func(*ModifyInstanceChargeTypeInput) (*request.Request, *ModifyInstanceChargeTypeOutput)

+ ModifyInstanceChargeTypeWithContext func(volcengine.Context, *ModifyInstanceChargeTypeInput, ...request.Option) (*ModifyInstanceChargeTypeOutput, error)

+ ModifyInstanceParameters func(*ModifyInstanceParametersInput) (*ModifyInstanceParametersOutput, error)

+ ModifyInstanceParametersCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyInstanceParametersCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyInstanceParametersCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyInstanceParametersRequest func(*ModifyInstanceParametersInput) (*request.Request, *ModifyInstanceParametersOutput)

+ ModifyInstanceParametersWithContext func(volcengine.Context, *ModifyInstanceParametersInput, ...request.Option) (*ModifyInstanceParametersOutput, error)

+ ModifyInstanceSpec func(*ModifyInstanceSpecInput) (*ModifyInstanceSpecOutput, error)

+ ModifyInstanceSpecCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyInstanceSpecCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyInstanceSpecCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyInstanceSpecRequest func(*ModifyInstanceSpecInput) (*request.Request, *ModifyInstanceSpecOutput)

+ ModifyInstanceSpecWithContext func(volcengine.Context, *ModifyInstanceSpecInput, ...request.Option) (*ModifyInstanceSpecOutput, error)

+ ModifyTopicAccessPolicies func(*ModifyTopicAccessPoliciesInput) (*ModifyTopicAccessPoliciesOutput, error)

+ ModifyTopicAccessPoliciesCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyTopicAccessPoliciesCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyTopicAccessPoliciesCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyTopicAccessPoliciesRequest func(*ModifyTopicAccessPoliciesInput) (*request.Request, *ModifyTopicAccessPoliciesOutput)

+ ModifyTopicAccessPoliciesWithContext func(volcengine.Context, *ModifyTopicAccessPoliciesInput, ...request.Option) (*ModifyTopicAccessPoliciesOutput, error)

+ ModifyTopicAttributes func(*ModifyTopicAttributesInput) (*ModifyTopicAttributesOutput, error)

+ ModifyTopicAttributesCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyTopicAttributesCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyTopicAttributesCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyTopicAttributesRequest func(*ModifyTopicAttributesInput) (*request.Request, *ModifyTopicAttributesOutput)

+ ModifyTopicAttributesWithContext func(volcengine.Context, *ModifyTopicAttributesInput, ...request.Option) (*ModifyTopicAttributesOutput, error)

+ ModifyTopicParameters func(*ModifyTopicParametersInput) (*ModifyTopicParametersOutput, error)

+ ModifyTopicParametersCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyTopicParametersCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyTopicParametersCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyTopicParametersRequest func(*ModifyTopicParametersInput) (*request.Request, *ModifyTopicParametersOutput)

+ ModifyTopicParametersWithContext func(volcengine.Context, *ModifyTopicParametersInput, ...request.Option) (*ModifyTopicParametersOutput, error)

+ ModifyUserAuthority func(*ModifyUserAuthorityInput) (*ModifyUserAuthorityOutput, error)

+ ModifyUserAuthorityCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ModifyUserAuthorityCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ModifyUserAuthorityCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ModifyUserAuthorityRequest func(*ModifyUserAuthorityInput) (*request.Request, *ModifyUserAuthorityOutput)

+ ModifyUserAuthorityWithContext func(volcengine.Context, *ModifyUserAuthorityInput, ...request.Option) (*ModifyUserAuthorityOutput, error)

+ RemoveTagsFromResource func(*RemoveTagsFromResourceInput) (*RemoveTagsFromResourceOutput, error)

+ RemoveTagsFromResourceCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ RemoveTagsFromResourceCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ RemoveTagsFromResourceCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ RemoveTagsFromResourceRequest func(*RemoveTagsFromResourceInput) (*request.Request, *RemoveTagsFromResourceOutput)

+ RemoveTagsFromResourceWithContext func(volcengine.Context, *RemoveTagsFromResourceInput, ...request.Option) (*RemoveTagsFromResourceOutput, error)

+ ResetConsumedOffsets func(*ResetConsumedOffsetsInput) (*ResetConsumedOffsetsOutput, error)

+ ResetConsumedOffsetsCommon func(*map[string]interface{}) (*map[string]interface{}, error)

+ ResetConsumedOffsetsCommonRequest func(*map[string]interface{}) (*request.Request, *map[string]interface{})

+ ResetConsumedOffsetsCommonWithContext func(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)

+ ResetConsumedOffsetsRequest func(*ResetConsumedOffsetsInput) (*request.Request, *ResetConsumedOffsetsOutput)

+ ResetConsumedOffsetsWithContext func(volcengine.Context, *ResetConsumedOffsetsInput, ...request.Option) (*ResetConsumedOffsetsOutput, error)

+ type ModifyInstanceAttributesInput struct

+ InstanceDescription *string

+ InstanceId *string

+ InstanceName *string

+ func (s *ModifyInstanceAttributesInput) SetInstanceDescription(v string) *ModifyInstanceAttributesInput

+ func (s *ModifyInstanceAttributesInput) SetInstanceId(v string) *ModifyInstanceAttributesInput

+ func (s *ModifyInstanceAttributesInput) SetInstanceName(v string) *ModifyInstanceAttributesInput

+ func (s ModifyInstanceAttributesInput) GoString() string

+ func (s ModifyInstanceAttributesInput) String() string

+ type ModifyInstanceAttributesOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyInstanceAttributesOutput) GoString() string

+ func (s ModifyInstanceAttributesOutput) String() string

+ type ModifyInstanceChargeTypeInput struct

+ ChargeInfo *ChargeInfoForModifyInstanceChargeTypeInput

+ InstanceId *string

+ func (s *ModifyInstanceChargeTypeInput) SetChargeInfo(v *ChargeInfoForModifyInstanceChargeTypeInput) *ModifyInstanceChargeTypeInput

+ func (s *ModifyInstanceChargeTypeInput) SetInstanceId(v string) *ModifyInstanceChargeTypeInput

+ func (s ModifyInstanceChargeTypeInput) GoString() string

+ func (s ModifyInstanceChargeTypeInput) String() string

+ type ModifyInstanceChargeTypeOutput struct

+ Metadata *response.ResponseMetadata

+ OrderId *string

+ func (s *ModifyInstanceChargeTypeOutput) SetOrderId(v string) *ModifyInstanceChargeTypeOutput

+ func (s ModifyInstanceChargeTypeOutput) GoString() string

+ func (s ModifyInstanceChargeTypeOutput) String() string

+ type ModifyInstanceParametersInput struct

+ InstanceId *string

+ Parameters *string

+ func (s *ModifyInstanceParametersInput) SetInstanceId(v string) *ModifyInstanceParametersInput

+ func (s *ModifyInstanceParametersInput) SetParameters(v string) *ModifyInstanceParametersInput

+ func (s ModifyInstanceParametersInput) GoString() string

+ func (s ModifyInstanceParametersInput) String() string

+ type ModifyInstanceParametersOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyInstanceParametersOutput) GoString() string

+ func (s ModifyInstanceParametersOutput) String() string

+ type ModifyInstanceSpecInput struct

+ ComputeSpec *string

+ InstanceId *string

+ NeedRebalance *bool

+ PartitionNumber *int32

+ RebalanceTime *string

+ StorageSpace *int32

+ func (s *ModifyInstanceSpecInput) SetComputeSpec(v string) *ModifyInstanceSpecInput

+ func (s *ModifyInstanceSpecInput) SetInstanceId(v string) *ModifyInstanceSpecInput

+ func (s *ModifyInstanceSpecInput) SetNeedRebalance(v bool) *ModifyInstanceSpecInput

+ func (s *ModifyInstanceSpecInput) SetPartitionNumber(v int32) *ModifyInstanceSpecInput

+ func (s *ModifyInstanceSpecInput) SetRebalanceTime(v string) *ModifyInstanceSpecInput

+ func (s *ModifyInstanceSpecInput) SetStorageSpace(v int32) *ModifyInstanceSpecInput

+ func (s ModifyInstanceSpecInput) GoString() string

+ func (s ModifyInstanceSpecInput) String() string

+ type ModifyInstanceSpecOutput struct

+ Metadata *response.ResponseMetadata

+ OrderId *string

+ func (s *ModifyInstanceSpecOutput) SetOrderId(v string) *ModifyInstanceSpecOutput

+ func (s ModifyInstanceSpecOutput) GoString() string

+ func (s ModifyInstanceSpecOutput) String() string

+ type ModifyTopicAccessPoliciesInput struct

+ AccessPolicies []*AccessPolicyForModifyTopicAccessPoliciesInput

+ AllAuthority *bool

+ DeletePolicies []*string

+ InstanceId *string

+ TopicName *string

+ func (s *ModifyTopicAccessPoliciesInput) SetAccessPolicies(v []*AccessPolicyForModifyTopicAccessPoliciesInput) *ModifyTopicAccessPoliciesInput

+ func (s *ModifyTopicAccessPoliciesInput) SetAllAuthority(v bool) *ModifyTopicAccessPoliciesInput

+ func (s *ModifyTopicAccessPoliciesInput) SetDeletePolicies(v []*string) *ModifyTopicAccessPoliciesInput

+ func (s *ModifyTopicAccessPoliciesInput) SetInstanceId(v string) *ModifyTopicAccessPoliciesInput

+ func (s *ModifyTopicAccessPoliciesInput) SetTopicName(v string) *ModifyTopicAccessPoliciesInput

+ func (s ModifyTopicAccessPoliciesInput) GoString() string

+ func (s ModifyTopicAccessPoliciesInput) String() string

+ type ModifyTopicAccessPoliciesOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyTopicAccessPoliciesOutput) GoString() string

+ func (s ModifyTopicAccessPoliciesOutput) String() string

+ type ModifyTopicAttributesInput struct

+ Description *string

+ InstanceId *string

+ TopicName *string

+ func (s *ModifyTopicAttributesInput) SetDescription(v string) *ModifyTopicAttributesInput

+ func (s *ModifyTopicAttributesInput) SetInstanceId(v string) *ModifyTopicAttributesInput

+ func (s *ModifyTopicAttributesInput) SetTopicName(v string) *ModifyTopicAttributesInput

+ func (s ModifyTopicAttributesInput) GoString() string

+ func (s ModifyTopicAttributesInput) String() string

+ type ModifyTopicAttributesOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyTopicAttributesOutput) GoString() string

+ func (s ModifyTopicAttributesOutput) String() string

+ type ModifyTopicParametersInput struct

+ InnerParameters *InnerParametersForModifyTopicParametersInput

+ InstanceId *string

+ Parameters *string

+ PartitionNumber *int32

+ ReplicaNumber *int32

+ TopicName *string

+ func (s *ModifyTopicParametersInput) SetInnerParameters(v *InnerParametersForModifyTopicParametersInput) *ModifyTopicParametersInput

+ func (s *ModifyTopicParametersInput) SetInstanceId(v string) *ModifyTopicParametersInput

+ func (s *ModifyTopicParametersInput) SetParameters(v string) *ModifyTopicParametersInput

+ func (s *ModifyTopicParametersInput) SetPartitionNumber(v int32) *ModifyTopicParametersInput

+ func (s *ModifyTopicParametersInput) SetReplicaNumber(v int32) *ModifyTopicParametersInput

+ func (s *ModifyTopicParametersInput) SetTopicName(v string) *ModifyTopicParametersInput

+ func (s ModifyTopicParametersInput) GoString() string

+ func (s ModifyTopicParametersInput) String() string

+ type ModifyTopicParametersOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyTopicParametersOutput) GoString() string

+ func (s ModifyTopicParametersOutput) String() string

+ type ModifyUserAuthorityInput struct

+ AllAuthority *bool

+ InstanceId *string

+ UserName *string

+ func (s *ModifyUserAuthorityInput) SetAllAuthority(v bool) *ModifyUserAuthorityInput

+ func (s *ModifyUserAuthorityInput) SetInstanceId(v string) *ModifyUserAuthorityInput

+ func (s *ModifyUserAuthorityInput) SetUserName(v string) *ModifyUserAuthorityInput

+ func (s ModifyUserAuthorityInput) GoString() string

+ func (s ModifyUserAuthorityInput) String() string

+ type ModifyUserAuthorityOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ModifyUserAuthorityOutput) GoString() string

+ func (s ModifyUserAuthorityOutput) String() string

+ type PartitionsInfoForDescribeTopicPartitionsOutput struct

+ EndOffset *int64

+ InsyncReplicas []*int64

+ Leader *int32

+ MessageCount *int64

+ PartitionId *int32

+ Replicas []*int64

+ StartOffset *int64

+ UnderInsyncReplicas []*int64

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetEndOffset(v int64) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetInsyncReplicas(v []*int64) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetLeader(v int32) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetMessageCount(v int64) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetPartitionId(v int32) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetReplicas(v []*int64) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetStartOffset(v int64) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetUnderInsyncReplicas(v []*int64) *PartitionsInfoForDescribeTopicPartitionsOutput

+ func (s PartitionsInfoForDescribeTopicPartitionsOutput) GoString() string

+ func (s PartitionsInfoForDescribeTopicPartitionsOutput) String() string

+ type RemoveTagsFromResourceInput struct

+ All *bool

+ InstanceIds []*string

+ TagKeys []*string

+ func (s *RemoveTagsFromResourceInput) SetAll(v bool) *RemoveTagsFromResourceInput

+ func (s *RemoveTagsFromResourceInput) SetInstanceIds(v []*string) *RemoveTagsFromResourceInput

+ func (s *RemoveTagsFromResourceInput) SetTagKeys(v []*string) *RemoveTagsFromResourceInput

+ func (s RemoveTagsFromResourceInput) GoString() string

+ func (s RemoveTagsFromResourceInput) String() string

+ type RemoveTagsFromResourceOutput struct

+ Metadata *response.ResponseMetadata

+ func (s RemoveTagsFromResourceOutput) GoString() string

+ func (s RemoveTagsFromResourceOutput) String() string

+ type ResetConsumedOffsetsInput struct

+ GroupId *string

+ InstanceId *string

+ ResetOffsetsInfo []*ResetOffsetsInfoForResetConsumedOffsetsInput

+ func (s *ResetConsumedOffsetsInput) SetGroupId(v string) *ResetConsumedOffsetsInput

+ func (s *ResetConsumedOffsetsInput) SetInstanceId(v string) *ResetConsumedOffsetsInput

+ func (s *ResetConsumedOffsetsInput) SetResetOffsetsInfo(v []*ResetOffsetsInfoForResetConsumedOffsetsInput) *ResetConsumedOffsetsInput

+ func (s ResetConsumedOffsetsInput) GoString() string

+ func (s ResetConsumedOffsetsInput) String() string

+ type ResetConsumedOffsetsOutput struct

+ Metadata *response.ResponseMetadata

+ func (s ResetConsumedOffsetsOutput) GoString() string

+ func (s ResetConsumedOffsetsOutput) String() string

+ type ResetOffsetsInfoForResetConsumedOffsetsInput struct

+ PartitionId *int32

+ ResetOffset *int64

+ ResetTimestamp *int64

+ ResetType *string

+ TopicName *string

+ func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetPartitionId(v int32) *ResetOffsetsInfoForResetConsumedOffsetsInput

+ func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetOffset(v int64) *ResetOffsetsInfoForResetConsumedOffsetsInput

+ func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetTimestamp(v int64) *ResetOffsetsInfoForResetConsumedOffsetsInput

+ func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetType(v string) *ResetOffsetsInfoForResetConsumedOffsetsInput

+ func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetTopicName(v string) *ResetOffsetsInfoForResetConsumedOffsetsInput

+ func (s ResetOffsetsInfoForResetConsumedOffsetsInput) GoString() string

+ func (s ResetOffsetsInfoForResetConsumedOffsetsInput) String() string

+ type TagForAddTagsToResourceInput struct

+ Key *string

+ Value *string

+ func (s *TagForAddTagsToResourceInput) SetKey(v string) *TagForAddTagsToResourceInput

+ func (s *TagForAddTagsToResourceInput) SetValue(v string) *TagForAddTagsToResourceInput

+ func (s TagForAddTagsToResourceInput) GoString() string

+ func (s TagForAddTagsToResourceInput) String() string

+ type TopicsInfoForDescribeTopicsOutput struct

+ CreateTime *string

+ Description *string

+ PartitionNumber *int32

+ ReplicaNumber *int32

+ Status *string

+ TopicName *string

+ func (s *TopicsInfoForDescribeTopicsOutput) SetCreateTime(v string) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetDescription(v string) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetPartitionNumber(v int32) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetReplicaNumber(v int32) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetStatus(v string) *TopicsInfoForDescribeTopicsOutput

+ func (s *TopicsInfoForDescribeTopicsOutput) SetTopicName(v string) *TopicsInfoForDescribeTopicsOutput

+ func (s TopicsInfoForDescribeTopicsOutput) GoString() string

+ func (s TopicsInfoForDescribeTopicsOutput) String() string

+ type UsersInfoForDescribeUsersOutput struct

+ AllAuthority *bool

+ CreateTime *string

+ Description *string

+ PasswordType *string

+ UserName *string

+ func (s *UsersInfoForDescribeUsersOutput) SetAllAuthority(v bool) *UsersInfoForDescribeUsersOutput

+ func (s *UsersInfoForDescribeUsersOutput) SetCreateTime(v string) *UsersInfoForDescribeUsersOutput

+ func (s *UsersInfoForDescribeUsersOutput) SetDescription(v string) *UsersInfoForDescribeUsersOutput

+ func (s *UsersInfoForDescribeUsersOutput) SetPasswordType(v string) *UsersInfoForDescribeUsersOutput

+ func (s *UsersInfoForDescribeUsersOutput) SetUserName(v string) *UsersInfoForDescribeUsersOutput

+ func (s UsersInfoForDescribeUsersOutput) GoString() string

+ func (s UsersInfoForDescribeUsersOutput) String() string

+ type ZoneForDescribeAvailabilityZonesOutput struct

+ Description *string

+ ZoneId *string

+ ZoneName *string

+ func (s *ZoneForDescribeAvailabilityZonesOutput) SetDescription(v string) *ZoneForDescribeAvailabilityZonesOutput

+ func (s *ZoneForDescribeAvailabilityZonesOutput) SetZoneId(v string) *ZoneForDescribeAvailabilityZonesOutput

+ func (s *ZoneForDescribeAvailabilityZonesOutput) SetZoneName(v string) *ZoneForDescribeAvailabilityZonesOutput

+ func (s ZoneForDescribeAvailabilityZonesOutput) GoString() string

+ func (s ZoneForDescribeAvailabilityZonesOutput) String() string

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