kafka

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package kafkaiface provides an interface to enable mocking the KAFKA service client for testing your code.

It is important to note that this interface will have breaking changes when the service model is updated and adds new API operations, paginators, and waiters.

Index

Constants

View Source 
const (
	// EnumOfStorageTypeForCreateInstanceInputEssd is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssd = "ESSD"

	// EnumOfStorageTypeForCreateInstanceInputEssdFlexPl is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssdFlexPl = "ESSD_FlexPL"

	// EnumOfStorageTypeForCreateInstanceInputEssdFlexPlInner is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssdFlexPlInner = "ESSD_FlexPL_Inner"

	// EnumOfStorageTypeForCreateInstanceInputEssdPl0 is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssdPl0 = "ESSD_PL0"

	// EnumOfStorageTypeForCreateInstanceInputEssdPl1 is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssdPl1 = "ESSD_PL1"

	// EnumOfStorageTypeForCreateInstanceInputEssdPl2 is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssdPl2 = "ESSD_PL2"

	// EnumOfStorageTypeForCreateInstanceInputEssdPl3 is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssdPl3 = "ESSD_PL3"

	// EnumOfStorageTypeForCreateInstanceInputEssdPl4 is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputEssdPl4 = "ESSD_PL4"

	// EnumOfStorageTypeForCreateInstanceInputHighCapacity is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputHighCapacity = "HighCapacity"

	// EnumOfStorageTypeForCreateInstanceInputHighPerformance is a EnumOfStorageTypeForCreateInstanceInput enum value
	EnumOfStorageTypeForCreateInstanceInputHighPerformance = "HighPerformance"
)
View Source 
const (
	ServiceName = "kafka"     // Name of service.
	EndpointsID = ServiceName // ID to lookup a service endpoint with.
	ServiceID   = "kafka"     // ServiceID is a unique identifer of a specific service.
)

Service information constants

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessPolicyForCreateTopicInput 

type AccessPolicyForCreateTopicInput struct {
	AccessPolicy *string `type:"string"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (AccessPolicyForCreateTopicInput) GoString 

func (s AccessPolicyForCreateTopicInput) GoString() string

GoString returns the string representation

func (*AccessPolicyForCreateTopicInput) SetAccessPolicy 

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

SetAccessPolicy sets the AccessPolicy field's value.

func (*AccessPolicyForCreateTopicInput) SetUserName 

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

SetUserName sets the UserName field's value.

func (AccessPolicyForCreateTopicInput) String 

func (s AccessPolicyForCreateTopicInput) String() string

String returns the string representation

type AccessPolicyForDescribeTopicAccessPoliciesOutput 

type AccessPolicyForDescribeTopicAccessPoliciesOutput struct {
	AccessPolicy *string `type:"string"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (AccessPolicyForDescribeTopicAccessPoliciesOutput) GoString 

func (s AccessPolicyForDescribeTopicAccessPoliciesOutput) GoString() string

GoString returns the string representation

func (*AccessPolicyForDescribeTopicAccessPoliciesOutput) SetAccessPolicy 

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

SetAccessPolicy sets the AccessPolicy field's value.

func (*AccessPolicyForDescribeTopicAccessPoliciesOutput) SetUserName 

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

SetUserName sets the UserName field's value.

func (AccessPolicyForDescribeTopicAccessPoliciesOutput) String 

func (s AccessPolicyForDescribeTopicAccessPoliciesOutput) String() string

String returns the string representation

type AccessPolicyForModifyTopicAccessPoliciesInput 

type AccessPolicyForModifyTopicAccessPoliciesInput struct {
	AccessPolicy *string `type:"string"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (AccessPolicyForModifyTopicAccessPoliciesInput) GoString 

func (s AccessPolicyForModifyTopicAccessPoliciesInput) GoString() string

GoString returns the string representation

func (*AccessPolicyForModifyTopicAccessPoliciesInput) SetAccessPolicy 

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

SetAccessPolicy sets the AccessPolicy field's value.

func (*AccessPolicyForModifyTopicAccessPoliciesInput) SetUserName 

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

SetUserName sets the UserName field's value.

func (AccessPolicyForModifyTopicAccessPoliciesInput) String 

func (s AccessPolicyForModifyTopicAccessPoliciesInput) String() string

String returns the string representation

type AddTagsToResourceInput 

type AddTagsToResourceInput struct {
	InstanceIds []*string `type:"list"`

	Tags []*TagForAddTagsToResourceInput `type:"list"`
	// contains filtered or unexported fields
}

func (AddTagsToResourceInput) GoString 

func (s AddTagsToResourceInput) GoString() string

GoString returns the string representation

func (*AddTagsToResourceInput) SetInstanceIds 

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

SetInstanceIds sets the InstanceIds field's value.

func (*AddTagsToResourceInput) SetTags 

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

SetTags sets the Tags field's value.

func (AddTagsToResourceInput) String 

func (s AddTagsToResourceInput) String() string

String returns the string representation

type AddTagsToResourceOutput 

type AddTagsToResourceOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (AddTagsToResourceOutput) GoString 

func (s AddTagsToResourceOutput) GoString() string

GoString returns the string representation

func (AddTagsToResourceOutput) String 

func (s AddTagsToResourceOutput) String() string

String returns the string representation

type BasicInstanceInfoForDescribeInstanceDetailOutput 

type BasicInstanceInfoForDescribeInstanceDetailOutput struct {
	AccountId *string `type:"string"`

	ChargeDetail *ChargeDetailForDescribeInstanceDetailOutput `type:"structure"`

	ComputeSpec *string `type:"string"`

	CreateTime *string `type:"string"`

	EipId *string `type:"string"`

	InstanceDescription *string `type:"string"`

	InstanceId *string `type:"string"`

	InstanceName *string `type:"string"`

	InstanceStatus *string `type:"string"`

	PrivateDomainOnPublic *bool `type:"boolean"`

	ProjectName *string `type:"string"`

	RegionId *string `type:"string"`

	StorageSpace *int32 `type:"int32"`

	StorageType *string `type:"string"`

	SubnetId *string `type:"string"`

	Tags map[string]*string `type:"map"`

	UsableGroupNumber *int32 `type:"int32"`

	UsablePartitionNumber *int32 `type:"int32"`

	UsedGroupNumber *int32 `type:"int32"`

	UsedPartitionNumber *int32 `type:"int32"`

	UsedStorageSpace *int32 `type:"int32"`

	UsedTopicNumber *int32 `type:"int32"`

	Version *string `type:"string"`

	VpcId *string `type:"string"`

	ZoneId *string `type:"string"`
	// contains filtered or unexported fields
}

func (BasicInstanceInfoForDescribeInstanceDetailOutput) GoString 

func (s BasicInstanceInfoForDescribeInstanceDetailOutput) GoString() string

GoString returns the string representation

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetAccountId 

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

SetAccountId sets the AccountId field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetChargeDetail 

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

SetChargeDetail sets the ChargeDetail field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetComputeSpec 

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

SetComputeSpec sets the ComputeSpec field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetCreateTime 

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

SetCreateTime sets the CreateTime field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetEipId 

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

SetEipId sets the EipId field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceDescription 

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

SetInstanceDescription sets the InstanceDescription field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceName 

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

SetInstanceName sets the InstanceName field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetInstanceStatus 

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

SetInstanceStatus sets the InstanceStatus field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetPrivateDomainOnPublic 

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

SetPrivateDomainOnPublic sets the PrivateDomainOnPublic field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetProjectName 

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

SetProjectName sets the ProjectName field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetRegionId 

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

SetRegionId sets the RegionId field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetStorageSpace 

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

SetStorageSpace sets the StorageSpace field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetStorageType 

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

SetStorageType sets the StorageType field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetSubnetId 

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

SetSubnetId sets the SubnetId field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetTags 

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

SetTags sets the Tags field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsableGroupNumber 

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

SetUsableGroupNumber sets the UsableGroupNumber field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsablePartitionNumber 

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

SetUsablePartitionNumber sets the UsablePartitionNumber field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedGroupNumber 

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

SetUsedGroupNumber sets the UsedGroupNumber field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedPartitionNumber 

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

SetUsedPartitionNumber sets the UsedPartitionNumber field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedStorageSpace 

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

SetUsedStorageSpace sets the UsedStorageSpace field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetUsedTopicNumber 

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

SetUsedTopicNumber sets the UsedTopicNumber field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetVersion 

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

SetVersion sets the Version field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetVpcId 

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

SetVpcId sets the VpcId field's value.

func (*BasicInstanceInfoForDescribeInstanceDetailOutput) SetZoneId 

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

SetZoneId sets the ZoneId field's value.

func (BasicInstanceInfoForDescribeInstanceDetailOutput) String 

func (s BasicInstanceInfoForDescribeInstanceDetailOutput) String() string

String returns the string representation

type ChargeDetailForDescribeInstanceDetailOutput 

type ChargeDetailForDescribeInstanceDetailOutput struct {
	AutoRenew *bool `type:"boolean"`

	ChargeExpireTime *string `type:"string"`

	ChargeStartTime *string `type:"string"`

	ChargeStatus *string `type:"string"`

	ChargeType *string `type:"string"`

	OverdueReclaimTime *string `type:"string"`

	OverdueTime *string `type:"string"`

	PeriodUnit *string `type:"string"`
	// contains filtered or unexported fields
}

func (ChargeDetailForDescribeInstanceDetailOutput) GoString 

func (s ChargeDetailForDescribeInstanceDetailOutput) GoString() string

GoString returns the string representation

func (*ChargeDetailForDescribeInstanceDetailOutput) SetAutoRenew 

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

SetAutoRenew sets the AutoRenew field's value.

func (*ChargeDetailForDescribeInstanceDetailOutput) SetChargeExpireTime 

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

SetChargeExpireTime sets the ChargeExpireTime field's value.

func (*ChargeDetailForDescribeInstanceDetailOutput) SetChargeStartTime 

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

SetChargeStartTime sets the ChargeStartTime field's value.

func (*ChargeDetailForDescribeInstanceDetailOutput) SetChargeStatus 

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

SetChargeStatus sets the ChargeStatus field's value.

func (*ChargeDetailForDescribeInstanceDetailOutput) SetChargeType 

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

SetChargeType sets the ChargeType field's value.

func (*ChargeDetailForDescribeInstanceDetailOutput) SetOverdueReclaimTime 

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

SetOverdueReclaimTime sets the OverdueReclaimTime field's value.

func (*ChargeDetailForDescribeInstanceDetailOutput) SetOverdueTime 

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

SetOverdueTime sets the OverdueTime field's value.

func (*ChargeDetailForDescribeInstanceDetailOutput) SetPeriodUnit 

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

SetPeriodUnit sets the PeriodUnit field's value.

func (ChargeDetailForDescribeInstanceDetailOutput) String 

func (s ChargeDetailForDescribeInstanceDetailOutput) String() string

String returns the string representation

type ChargeDetailForDescribeInstancesOutput 

type ChargeDetailForDescribeInstancesOutput struct {
	AutoRenew *bool `type:"boolean"`

	ChargeExpireTime *string `type:"string"`

	ChargeStartTime *string `type:"string"`

	ChargeStatus *string `type:"string"`

	ChargeType *string `type:"string"`

	OverdueReclaimTime *string `type:"string"`

	OverdueTime *string `type:"string"`

	PeriodUnit *string `type:"string"`
	// contains filtered or unexported fields
}

func (ChargeDetailForDescribeInstancesOutput) GoString 

func (s ChargeDetailForDescribeInstancesOutput) GoString() string

GoString returns the string representation

func (*ChargeDetailForDescribeInstancesOutput) SetAutoRenew 

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

SetAutoRenew sets the AutoRenew field's value.

func (*ChargeDetailForDescribeInstancesOutput) SetChargeExpireTime 

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

SetChargeExpireTime sets the ChargeExpireTime field's value.

func (*ChargeDetailForDescribeInstancesOutput) SetChargeStartTime 

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

SetChargeStartTime sets the ChargeStartTime field's value.

func (*ChargeDetailForDescribeInstancesOutput) SetChargeStatus 

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

SetChargeStatus sets the ChargeStatus field's value.

func (*ChargeDetailForDescribeInstancesOutput) SetChargeType 

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

SetChargeType sets the ChargeType field's value.

func (*ChargeDetailForDescribeInstancesOutput) SetOverdueReclaimTime 

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

SetOverdueReclaimTime sets the OverdueReclaimTime field's value.

func (*ChargeDetailForDescribeInstancesOutput) SetOverdueTime 

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

SetOverdueTime sets the OverdueTime field's value.

func (*ChargeDetailForDescribeInstancesOutput) SetPeriodUnit 

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

SetPeriodUnit sets the PeriodUnit field's value.

func (ChargeDetailForDescribeInstancesOutput) String 

func (s ChargeDetailForDescribeInstancesOutput) String() string

String returns the string representation

type ChargeInfoForCreateInstanceInput 

type ChargeInfoForCreateInstanceInput struct {
	AutoRenew *bool `type:"boolean"`

	ChargeType *string `type:"string"`

	Period *int32 `type:"int32"`

	PeriodUnit *string `type:"string"`
	// contains filtered or unexported fields
}

func (ChargeInfoForCreateInstanceInput) GoString 

func (s ChargeInfoForCreateInstanceInput) GoString() string

GoString returns the string representation

func (*ChargeInfoForCreateInstanceInput) SetAutoRenew 

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

SetAutoRenew sets the AutoRenew field's value.

func (*ChargeInfoForCreateInstanceInput) SetChargeType 

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

SetChargeType sets the ChargeType field's value.

func (*ChargeInfoForCreateInstanceInput) SetPeriod 

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

SetPeriod sets the Period field's value.

func (*ChargeInfoForCreateInstanceInput) SetPeriodUnit 

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

SetPeriodUnit sets the PeriodUnit field's value.

func (ChargeInfoForCreateInstanceInput) String 

func (s ChargeInfoForCreateInstanceInput) String() string

String returns the string representation

type ChargeInfoForModifyInstanceChargeTypeInput 

type ChargeInfoForModifyInstanceChargeTypeInput struct {
	AutoRenew *bool `type:"boolean"`

	ChargeType *string `type:"string"`

	Period *int32 `type:"int32"`

	PeriodUnit *string `type:"string"`
	// contains filtered or unexported fields
}

func (ChargeInfoForModifyInstanceChargeTypeInput) GoString 

func (s ChargeInfoForModifyInstanceChargeTypeInput) GoString() string

GoString returns the string representation

func (*ChargeInfoForModifyInstanceChargeTypeInput) SetAutoRenew 

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

SetAutoRenew sets the AutoRenew field's value.

func (*ChargeInfoForModifyInstanceChargeTypeInput) SetChargeType 

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

SetChargeType sets the ChargeType field's value.

func (*ChargeInfoForModifyInstanceChargeTypeInput) SetPeriod 

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

SetPeriod sets the Period field's value.

func (*ChargeInfoForModifyInstanceChargeTypeInput) SetPeriodUnit 

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

SetPeriodUnit sets the PeriodUnit field's value.

func (ChargeInfoForModifyInstanceChargeTypeInput) String 

func (s ChargeInfoForModifyInstanceChargeTypeInput) String() string

String returns the string representation

type ConnectionInfoForDescribeInstanceDetailOutput 

type ConnectionInfoForDescribeInstanceDetailOutput struct {
	EndpointType *string `type:"string"`

	InternalEndpoint *string `type:"string"`

	NetworkType *string `type:"string"`

	PublicEndpoint *string `type:"string"`
	// contains filtered or unexported fields
}

func (ConnectionInfoForDescribeInstanceDetailOutput) GoString 

func (s ConnectionInfoForDescribeInstanceDetailOutput) GoString() string

GoString returns the string representation

func (*ConnectionInfoForDescribeInstanceDetailOutput) SetEndpointType 

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

SetEndpointType sets the EndpointType field's value.

func (*ConnectionInfoForDescribeInstanceDetailOutput) SetInternalEndpoint 

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

SetInternalEndpoint sets the InternalEndpoint field's value.

func (*ConnectionInfoForDescribeInstanceDetailOutput) SetNetworkType 

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

SetNetworkType sets the NetworkType field's value.

func (*ConnectionInfoForDescribeInstanceDetailOutput) SetPublicEndpoint 

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

SetPublicEndpoint sets the PublicEndpoint field's value.

func (ConnectionInfoForDescribeInstanceDetailOutput) String 

func (s ConnectionInfoForDescribeInstanceDetailOutput) String() string

String returns the string representation

type ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput 

type ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput struct {
	Accumulation *int64 `type:"int64"`

	ConsumedClient *string `type:"string"`

	ConsumedOffset *int64 `type:"int64"`

	EndOffset *int64 `type:"int64"`

	PartitionId *int32 `type:"int32"`

	StartOffset *int64 `type:"int64"`
	// contains filtered or unexported fields
}

func (ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) GoString 

func (s ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) GoString() string

GoString returns the string representation

func (*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetAccumulation 

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

SetAccumulation sets the Accumulation field's value.

func (*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetConsumedClient 

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

SetConsumedClient sets the ConsumedClient field's value.

func (*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetConsumedOffset 

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

SetConsumedOffset sets the ConsumedOffset field's value.

func (*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetEndOffset 

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

SetEndOffset sets the EndOffset field's value.

func (*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetPartitionId 

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

SetPartitionId sets the PartitionId field's value.

func (*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) SetStartOffset 

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

SetStartOffset sets the StartOffset field's value.

func (ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) String 

func (s ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput) String() string

String returns the string representation

type ConsumedTopicsInfoForDescribeConsumedTopicsOutput 

type ConsumedTopicsInfoForDescribeConsumedTopicsOutput struct {
	Accumulation *int64 `type:"int64"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ConsumedTopicsInfoForDescribeConsumedTopicsOutput) GoString 

func (s ConsumedTopicsInfoForDescribeConsumedTopicsOutput) GoString() string

GoString returns the string representation

func (*ConsumedTopicsInfoForDescribeConsumedTopicsOutput) SetAccumulation 

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

SetAccumulation sets the Accumulation field's value.

func (*ConsumedTopicsInfoForDescribeConsumedTopicsOutput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (ConsumedTopicsInfoForDescribeConsumedTopicsOutput) String 

func (s ConsumedTopicsInfoForDescribeConsumedTopicsOutput) String() string

String returns the string representation

type CreateInstanceInput 

type CreateInstanceInput struct {
	ChargeInfo *ChargeInfoForCreateInstanceInput `type:"structure"`

	ComputeSpec *string `type:"string"`

	EipId *string `type:"string"`

	InstanceDescription *string `type:"string"`

	InstanceName *string `type:"string"`

	IpWhiteList []*string `type:"list"`

	Parameters *string `type:"string"`

	PartitionNumber *int32 `type:"int32"`

	ProjectName *string `type:"string"`

	StorageSpace *int32 `type:"int32"`

	StorageType *string `type:"string" enum:"EnumOfStorageTypeForCreateInstanceInput"`

	SubnetId *string `type:"string"`

	Tags map[string]*string `type:"map"`

	UserName *string `type:"string"`

	UserPassword *string `type:"string"`

	Version *string `type:"string"`

	VpcId *string `type:"string"`

	ZoneId *string `type:"string"`
	// contains filtered or unexported fields
}

func (CreateInstanceInput) GoString 

func (s CreateInstanceInput) GoString() string

GoString returns the string representation

func (*CreateInstanceInput) SetChargeInfo 

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

SetChargeInfo sets the ChargeInfo field's value.

func (*CreateInstanceInput) SetComputeSpec 

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

SetComputeSpec sets the ComputeSpec field's value.

func (*CreateInstanceInput) SetEipId 

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

SetEipId sets the EipId field's value.

func (*CreateInstanceInput) SetInstanceDescription 

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

SetInstanceDescription sets the InstanceDescription field's value.

func (*CreateInstanceInput) SetInstanceName 

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

SetInstanceName sets the InstanceName field's value.

func (*CreateInstanceInput) SetIpWhiteList 

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

SetIpWhiteList sets the IpWhiteList field's value.

func (*CreateInstanceInput) SetParameters 

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

SetParameters sets the Parameters field's value.

func (*CreateInstanceInput) SetPartitionNumber 

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

SetPartitionNumber sets the PartitionNumber field's value.

func (*CreateInstanceInput) SetProjectName 

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

SetProjectName sets the ProjectName field's value.

func (*CreateInstanceInput) SetStorageSpace 

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

SetStorageSpace sets the StorageSpace field's value.

func (*CreateInstanceInput) SetStorageType 

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

SetStorageType sets the StorageType field's value.

func (*CreateInstanceInput) SetSubnetId 

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

SetSubnetId sets the SubnetId field's value.

func (*CreateInstanceInput) SetTags 

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

SetTags sets the Tags field's value.

func (*CreateInstanceInput) SetUserName 

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

SetUserName sets the UserName field's value.

func (*CreateInstanceInput) SetUserPassword 

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

SetUserPassword sets the UserPassword field's value.

func (*CreateInstanceInput) SetVersion 

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

SetVersion sets the Version field's value.

func (*CreateInstanceInput) SetVpcId 

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

SetVpcId sets the VpcId field's value.

func (*CreateInstanceInput) SetZoneId 

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

SetZoneId sets the ZoneId field's value.

func (CreateInstanceInput) String 

func (s CreateInstanceInput) String() string

String returns the string representation

type CreateInstanceOutput 

type CreateInstanceOutput struct {
	Metadata *response.ResponseMetadata

	InstanceId *string `type:"string"`

	OrderId *string `type:"string"`
	// contains filtered or unexported fields
}

func (CreateInstanceOutput) GoString 

func (s CreateInstanceOutput) GoString() string

GoString returns the string representation

func (*CreateInstanceOutput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*CreateInstanceOutput) SetOrderId 

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

SetOrderId sets the OrderId field's value.

func (CreateInstanceOutput) String 

func (s CreateInstanceOutput) String() string

String returns the string representation

type CreatePublicAddressInput 

type CreatePublicAddressInput struct {
	EipId *string `type:"string"`

	InstanceId *string `type:"string"`
	// contains filtered or unexported fields
}

func (CreatePublicAddressInput) GoString 

func (s CreatePublicAddressInput) GoString() string

GoString returns the string representation

func (*CreatePublicAddressInput) SetEipId 

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

SetEipId sets the EipId field's value.

func (*CreatePublicAddressInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (CreatePublicAddressInput) String 

func (s CreatePublicAddressInput) String() string

String returns the string representation

type CreatePublicAddressOutput 

type CreatePublicAddressOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (CreatePublicAddressOutput) GoString 

func (s CreatePublicAddressOutput) GoString() string

GoString returns the string representation

func (CreatePublicAddressOutput) String 

func (s CreatePublicAddressOutput) String() string

String returns the string representation

type CreateTopicInput 

type CreateTopicInput struct {
	AccessPolicies []*AccessPolicyForCreateTopicInput `type:"list"`

	AllAuthority *bool `type:"boolean"`

	Description *string `type:"string"`

	InstanceId *string `type:"string"`

	Parameters *string `type:"string"`

	PartitionNumber *int32 `type:"int32"`

	ReplicaNumber *int32 `type:"int32"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (CreateTopicInput) GoString 

func (s CreateTopicInput) GoString() string

GoString returns the string representation

func (*CreateTopicInput) SetAccessPolicies 

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

SetAccessPolicies sets the AccessPolicies field's value.

func (*CreateTopicInput) SetAllAuthority 

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

SetAllAuthority sets the AllAuthority field's value.

func (*CreateTopicInput) SetDescription 

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

SetDescription sets the Description field's value.

func (*CreateTopicInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*CreateTopicInput) SetParameters 

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

SetParameters sets the Parameters field's value.

func (*CreateTopicInput) SetPartitionNumber 

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

SetPartitionNumber sets the PartitionNumber field's value.

func (*CreateTopicInput) SetReplicaNumber 

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

SetReplicaNumber sets the ReplicaNumber field's value.

func (*CreateTopicInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (CreateTopicInput) String 

func (s CreateTopicInput) String() string

String returns the string representation

type CreateTopicOutput 

type CreateTopicOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (CreateTopicOutput) GoString 

func (s CreateTopicOutput) GoString() string

GoString returns the string representation

func (CreateTopicOutput) String 

func (s CreateTopicOutput) String() string

String returns the string representation

type CreateUserInput 

type CreateUserInput struct {
	AllAuthority *bool `type:"boolean"`

	Description *string `type:"string"`

	InstanceId *string `type:"string"`

	UserName *string `type:"string"`

	UserPassword *string `type:"string"`
	// contains filtered or unexported fields
}

func (CreateUserInput) GoString 

func (s CreateUserInput) GoString() string

GoString returns the string representation

func (*CreateUserInput) SetAllAuthority 

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

SetAllAuthority sets the AllAuthority field's value.

func (*CreateUserInput) SetDescription 

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

SetDescription sets the Description field's value.

func (*CreateUserInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*CreateUserInput) SetUserName 

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

SetUserName sets the UserName field's value.

func (*CreateUserInput) SetUserPassword 

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

SetUserPassword sets the UserPassword field's value.

func (CreateUserInput) String 

func (s CreateUserInput) String() string

String returns the string representation

type CreateUserOutput 

type CreateUserOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (CreateUserOutput) GoString 

func (s CreateUserOutput) GoString() string

GoString returns the string representation

func (CreateUserOutput) String 

func (s CreateUserOutput) String() string

String returns the string representation

type DeleteGroupInput 

type DeleteGroupInput struct {
	GroupId *string `type:"string"`

	InstanceId *string `type:"string"`
	// contains filtered or unexported fields
}

func (DeleteGroupInput) GoString 

func (s DeleteGroupInput) GoString() string

GoString returns the string representation

func (*DeleteGroupInput) SetGroupId 

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

SetGroupId sets the GroupId field's value.

func (*DeleteGroupInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (DeleteGroupInput) String 

func (s DeleteGroupInput) String() string

String returns the string representation

type DeleteGroupOutput 

type DeleteGroupOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (DeleteGroupOutput) GoString 

func (s DeleteGroupOutput) GoString() string

GoString returns the string representation

func (DeleteGroupOutput) String 

func (s DeleteGroupOutput) String() string

String returns the string representation

type DeleteInstanceInput 

type DeleteInstanceInput struct {
	InstanceId *string `type:"string"`
	// contains filtered or unexported fields
}

func (DeleteInstanceInput) GoString 

func (s DeleteInstanceInput) GoString() string

GoString returns the string representation

func (*DeleteInstanceInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (DeleteInstanceInput) String 

func (s DeleteInstanceInput) String() string

String returns the string representation

type DeleteInstanceOutput 

type DeleteInstanceOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (DeleteInstanceOutput) GoString 

func (s DeleteInstanceOutput) GoString() string

GoString returns the string representation

func (DeleteInstanceOutput) String 

func (s DeleteInstanceOutput) String() string

String returns the string representation

type DeletePublicAddressInput 

type DeletePublicAddressInput struct {
	InstanceId *string `type:"string"`
	// contains filtered or unexported fields
}

func (DeletePublicAddressInput) GoString 

func (s DeletePublicAddressInput) GoString() string

GoString returns the string representation

func (*DeletePublicAddressInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (DeletePublicAddressInput) String 

func (s DeletePublicAddressInput) String() string

String returns the string representation

type DeletePublicAddressOutput 

type DeletePublicAddressOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (DeletePublicAddressOutput) GoString 

func (s DeletePublicAddressOutput) GoString() string

GoString returns the string representation

func (DeletePublicAddressOutput) String 

func (s DeletePublicAddressOutput) String() string

String returns the string representation

type DeleteTopicInput 

type DeleteTopicInput struct {
	InstanceId *string `type:"string"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DeleteTopicInput) GoString 

func (s DeleteTopicInput) GoString() string

GoString returns the string representation

func (*DeleteTopicInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DeleteTopicInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (DeleteTopicInput) String 

func (s DeleteTopicInput) String() string

String returns the string representation

type DeleteTopicOutput 

type DeleteTopicOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (DeleteTopicOutput) GoString 

func (s DeleteTopicOutput) GoString() string

GoString returns the string representation

func (DeleteTopicOutput) String 

func (s DeleteTopicOutput) String() string

String returns the string representation

type DeleteUserInput 

type DeleteUserInput struct {
	InstanceId *string `type:"string"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DeleteUserInput) GoString 

func (s DeleteUserInput) GoString() string

GoString returns the string representation

func (*DeleteUserInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DeleteUserInput) SetUserName 

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

SetUserName sets the UserName field's value.

func (DeleteUserInput) String 

func (s DeleteUserInput) String() string

String returns the string representation

type DeleteUserOutput 

type DeleteUserOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (DeleteUserOutput) GoString 

func (s DeleteUserOutput) GoString() string

GoString returns the string representation

func (DeleteUserOutput) String 

func (s DeleteUserOutput) String() string

String returns the string representation

type DescribeAvailabilityZonesInput 

type DescribeAvailabilityZonesInput struct {
	RegionId *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeAvailabilityZonesInput) GoString 

func (s DescribeAvailabilityZonesInput) GoString() string

GoString returns the string representation

func (*DescribeAvailabilityZonesInput) SetRegionId 

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

SetRegionId sets the RegionId field's value.

func (DescribeAvailabilityZonesInput) String 

func (s DescribeAvailabilityZonesInput) String() string

String returns the string representation

type DescribeAvailabilityZonesOutput 

type DescribeAvailabilityZonesOutput struct {
	Metadata *response.ResponseMetadata

	RegionId *string `type:"string"`

	Zones []*ZoneForDescribeAvailabilityZonesOutput `type:"list"`
	// contains filtered or unexported fields
}

func (DescribeAvailabilityZonesOutput) GoString 

func (s DescribeAvailabilityZonesOutput) GoString() string

GoString returns the string representation

func (*DescribeAvailabilityZonesOutput) SetRegionId 

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

SetRegionId sets the RegionId field's value.

func (*DescribeAvailabilityZonesOutput) SetZones 

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

SetZones sets the Zones field's value.

func (DescribeAvailabilityZonesOutput) String 

func (s DescribeAvailabilityZonesOutput) String() string

String returns the string representation

type DescribeConsumedPartitionsInput 

type DescribeConsumedPartitionsInput struct {
	GroupId *string `type:"string"`

	InstanceId *string `type:"string"`

	PageNumber *int32 `type:"int32"`

	PageSize *int32 `type:"int32"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeConsumedPartitionsInput) GoString 

func (s DescribeConsumedPartitionsInput) GoString() string

GoString returns the string representation

func (*DescribeConsumedPartitionsInput) SetGroupId 

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

SetGroupId sets the GroupId field's value.

func (*DescribeConsumedPartitionsInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeConsumedPartitionsInput) SetPageNumber 

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

SetPageNumber sets the PageNumber field's value.

func (*DescribeConsumedPartitionsInput) SetPageSize 

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

SetPageSize sets the PageSize field's value.

func (*DescribeConsumedPartitionsInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (DescribeConsumedPartitionsInput) String 

func (s DescribeConsumedPartitionsInput) String() string

String returns the string representation

type DescribeConsumedPartitionsOutput 

type DescribeConsumedPartitionsOutput struct {
	Metadata *response.ResponseMetadata

	ConsumedPartitionsInfo []*ConsumedPartitionsInfoForDescribeConsumedPartitionsOutput `type:"list"`

	Total *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (DescribeConsumedPartitionsOutput) GoString 

func (s DescribeConsumedPartitionsOutput) GoString() string

GoString returns the string representation

func (*DescribeConsumedPartitionsOutput) SetConsumedPartitionsInfo 

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

SetConsumedPartitionsInfo sets the ConsumedPartitionsInfo field's value.

func (*DescribeConsumedPartitionsOutput) SetTotal 

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

SetTotal sets the Total field's value.

func (DescribeConsumedPartitionsOutput) String 

func (s DescribeConsumedPartitionsOutput) String() string

String returns the string representation

type DescribeConsumedTopicsInput 

type DescribeConsumedTopicsInput struct {
	GroupId *string `type:"string"`

	InstanceId *string `type:"string"`

	PageNumber *int32 `type:"int32"`

	PageSize *int32 `type:"int32"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeConsumedTopicsInput) GoString 

func (s DescribeConsumedTopicsInput) GoString() string

GoString returns the string representation

func (*DescribeConsumedTopicsInput) SetGroupId 

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

SetGroupId sets the GroupId field's value.

func (*DescribeConsumedTopicsInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeConsumedTopicsInput) SetPageNumber 

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

SetPageNumber sets the PageNumber field's value.

func (*DescribeConsumedTopicsInput) SetPageSize 

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

SetPageSize sets the PageSize field's value.

func (*DescribeConsumedTopicsInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (DescribeConsumedTopicsInput) String 

func (s DescribeConsumedTopicsInput) String() string

String returns the string representation

type DescribeConsumedTopicsOutput 

type DescribeConsumedTopicsOutput struct {
	Metadata *response.ResponseMetadata

	Accumulation *int64 `type:"int64"`

	ConsumedTopicsInfo []*ConsumedTopicsInfoForDescribeConsumedTopicsOutput `type:"list"`

	Total *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (DescribeConsumedTopicsOutput) GoString 

func (s DescribeConsumedTopicsOutput) GoString() string

GoString returns the string representation

func (*DescribeConsumedTopicsOutput) SetAccumulation 

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

SetAccumulation sets the Accumulation field's value.

func (*DescribeConsumedTopicsOutput) SetConsumedTopicsInfo 

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

SetConsumedTopicsInfo sets the ConsumedTopicsInfo field's value.

func (*DescribeConsumedTopicsOutput) SetTotal 

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

SetTotal sets the Total field's value.

func (DescribeConsumedTopicsOutput) String 

func (s DescribeConsumedTopicsOutput) String() string

String returns the string representation

type DescribeGroupsInput 

type DescribeGroupsInput struct {
	GroupId *string `type:"string"`

	InstanceId *string `type:"string"`

	PageNumber *int32 `type:"int32"`

	PageSize *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (DescribeGroupsInput) GoString 

func (s DescribeGroupsInput) GoString() string

GoString returns the string representation

func (*DescribeGroupsInput) SetGroupId 

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

SetGroupId sets the GroupId field's value.

func (*DescribeGroupsInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeGroupsInput) SetPageNumber 

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

SetPageNumber sets the PageNumber field's value.

func (*DescribeGroupsInput) SetPageSize 

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

SetPageSize sets the PageSize field's value.

func (DescribeGroupsInput) String 

func (s DescribeGroupsInput) String() string

String returns the string representation

type DescribeGroupsOutput 

type DescribeGroupsOutput struct {
	Metadata *response.ResponseMetadata

	GroupsInfo []*GroupsInfoForDescribeGroupsOutput `type:"list"`

	Total *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (DescribeGroupsOutput) GoString 

func (s DescribeGroupsOutput) GoString() string

GoString returns the string representation

func (*DescribeGroupsOutput) SetGroupsInfo 

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

SetGroupsInfo sets the GroupsInfo field's value.

func (*DescribeGroupsOutput) SetTotal 

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

SetTotal sets the Total field's value.

func (DescribeGroupsOutput) String 

func (s DescribeGroupsOutput) String() string

String returns the string representation

type DescribeInstanceDetailInput 

type DescribeInstanceDetailInput struct {
	InstanceId *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeInstanceDetailInput) GoString 

func (s DescribeInstanceDetailInput) GoString() string

GoString returns the string representation

func (*DescribeInstanceDetailInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (DescribeInstanceDetailInput) String 

func (s DescribeInstanceDetailInput) String() string

String returns the string representation

type DescribeInstanceDetailOutput 

type DescribeInstanceDetailOutput struct {
	Metadata *response.ResponseMetadata

	BasicInstanceInfo *BasicInstanceInfoForDescribeInstanceDetailOutput `type:"structure"`

	ChargeDetail *ChargeDetailForDescribeInstanceDetailOutput `type:"structure"`

	ConnectionInfo []*ConnectionInfoForDescribeInstanceDetailOutput `type:"list"`

	Parameters *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeInstanceDetailOutput) GoString 

func (s DescribeInstanceDetailOutput) GoString() string

GoString returns the string representation

func (*DescribeInstanceDetailOutput) SetBasicInstanceInfo 

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

SetBasicInstanceInfo sets the BasicInstanceInfo field's value.

func (*DescribeInstanceDetailOutput) SetChargeDetail 

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

SetChargeDetail sets the ChargeDetail field's value.

func (*DescribeInstanceDetailOutput) SetConnectionInfo 

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

SetConnectionInfo sets the ConnectionInfo field's value.

func (*DescribeInstanceDetailOutput) SetParameters 

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

SetParameters sets the Parameters field's value.

func (DescribeInstanceDetailOutput) String 

func (s DescribeInstanceDetailOutput) String() string

String returns the string representation

type DescribeInstancesInput 

type DescribeInstancesInput struct {
	InstanceId *string `type:"string"`

	InstanceName *string `type:"string"`

	InstanceStatus *string `type:"string"`

	PageNumber *int32 `type:"int32"`

	PageSize *int32 `type:"int32"`

	Tags map[string][]*string `type:"map"`

	ZoneId *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeInstancesInput) GoString 

func (s DescribeInstancesInput) GoString() string

GoString returns the string representation

func (*DescribeInstancesInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeInstancesInput) SetInstanceName 

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

SetInstanceName sets the InstanceName field's value.

func (*DescribeInstancesInput) SetInstanceStatus 

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

SetInstanceStatus sets the InstanceStatus field's value.

func (*DescribeInstancesInput) SetPageNumber 

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

SetPageNumber sets the PageNumber field's value.

func (*DescribeInstancesInput) SetPageSize 

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

SetPageSize sets the PageSize field's value.

func (*DescribeInstancesInput) SetTags 

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

SetTags sets the Tags field's value.

func (*DescribeInstancesInput) SetZoneId 

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

SetZoneId sets the ZoneId field's value.

func (DescribeInstancesInput) String 

func (s DescribeInstancesInput) String() string

String returns the string representation

type DescribeInstancesOutput 

type DescribeInstancesOutput struct {
	Metadata *response.ResponseMetadata

	InstancesInfo []*InstancesInfoForDescribeInstancesOutput `type:"list"`

	Total *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (DescribeInstancesOutput) GoString 

func (s DescribeInstancesOutput) GoString() string

GoString returns the string representation

func (*DescribeInstancesOutput) SetInstancesInfo 

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

SetInstancesInfo sets the InstancesInfo field's value.

func (*DescribeInstancesOutput) SetTotal 

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

SetTotal sets the Total field's value.

func (DescribeInstancesOutput) String 

func (s DescribeInstancesOutput) String() string

String returns the string representation

type DescribeTopicAccessPoliciesInput 

type DescribeTopicAccessPoliciesInput struct {
	InstanceId *string `type:"string"`

	TopicName *string `type:"string"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeTopicAccessPoliciesInput) GoString 

func (s DescribeTopicAccessPoliciesInput) GoString() string

GoString returns the string representation

func (*DescribeTopicAccessPoliciesInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeTopicAccessPoliciesInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (*DescribeTopicAccessPoliciesInput) SetUserName 

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

SetUserName sets the UserName field's value.

func (DescribeTopicAccessPoliciesInput) String 

func (s DescribeTopicAccessPoliciesInput) String() string

String returns the string representation

type DescribeTopicAccessPoliciesOutput 

type DescribeTopicAccessPoliciesOutput struct {
	Metadata *response.ResponseMetadata

	AccessPolicies []*AccessPolicyForDescribeTopicAccessPoliciesOutput `type:"list"`

	AllAuthority *bool `type:"boolean"`
	// contains filtered or unexported fields
}

func (DescribeTopicAccessPoliciesOutput) GoString 

func (s DescribeTopicAccessPoliciesOutput) GoString() string

GoString returns the string representation

func (*DescribeTopicAccessPoliciesOutput) SetAccessPolicies 

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

SetAccessPolicies sets the AccessPolicies field's value.

func (*DescribeTopicAccessPoliciesOutput) SetAllAuthority 

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

SetAllAuthority sets the AllAuthority field's value.

func (DescribeTopicAccessPoliciesOutput) String 

func (s DescribeTopicAccessPoliciesOutput) String() string

String returns the string representation

type DescribeTopicParametersInput 

type DescribeTopicParametersInput struct {
	InstanceId *string `type:"string"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeTopicParametersInput) GoString 

func (s DescribeTopicParametersInput) GoString() string

GoString returns the string representation

func (*DescribeTopicParametersInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeTopicParametersInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (DescribeTopicParametersInput) String 

func (s DescribeTopicParametersInput) String() string

String returns the string representation

type DescribeTopicParametersOutput 

type DescribeTopicParametersOutput struct {
	Metadata *response.ResponseMetadata

	Parameters *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeTopicParametersOutput) GoString 

func (s DescribeTopicParametersOutput) GoString() string

GoString returns the string representation

func (*DescribeTopicParametersOutput) SetParameters 

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

SetParameters sets the Parameters field's value.

func (DescribeTopicParametersOutput) String 

func (s DescribeTopicParametersOutput) String() string

String returns the string representation

type DescribeTopicPartitionsInput 

type DescribeTopicPartitionsInput struct {
	InstanceId *string `type:"string"`

	PageNumber *int32 `type:"int32"`

	PageSize *int32 `type:"int32"`

	PartitionIds []*int64 `type:"list"`

	TopicName *string `type:"string"`

	UnderInsyncOnly *bool `type:"boolean"`
	// contains filtered or unexported fields
}

func (DescribeTopicPartitionsInput) GoString 

func (s DescribeTopicPartitionsInput) GoString() string

GoString returns the string representation

func (*DescribeTopicPartitionsInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeTopicPartitionsInput) SetPageNumber 

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

SetPageNumber sets the PageNumber field's value.

func (*DescribeTopicPartitionsInput) SetPageSize 

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

SetPageSize sets the PageSize field's value.

func (*DescribeTopicPartitionsInput) SetPartitionIds 

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

SetPartitionIds sets the PartitionIds field's value.

func (*DescribeTopicPartitionsInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (*DescribeTopicPartitionsInput) SetUnderInsyncOnly 

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

SetUnderInsyncOnly sets the UnderInsyncOnly field's value.

func (DescribeTopicPartitionsInput) String 

func (s DescribeTopicPartitionsInput) String() string

String returns the string representation

type DescribeTopicPartitionsOutput 

type DescribeTopicPartitionsOutput struct {
	Metadata *response.ResponseMetadata

	PartitionsInfo []*PartitionsInfoForDescribeTopicPartitionsOutput `type:"list"`

	Total *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (DescribeTopicPartitionsOutput) GoString 

func (s DescribeTopicPartitionsOutput) GoString() string

GoString returns the string representation

func (*DescribeTopicPartitionsOutput) SetPartitionsInfo 

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

SetPartitionsInfo sets the PartitionsInfo field's value.

func (*DescribeTopicPartitionsOutput) SetTotal 

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

SetTotal sets the Total field's value.

func (DescribeTopicPartitionsOutput) String 

func (s DescribeTopicPartitionsOutput) String() string

String returns the string representation

type DescribeTopicsInput 

type DescribeTopicsInput struct {
	InstanceId *string `type:"string"`

	PageNumber *int32 `type:"int32"`

	PageSize *int32 `type:"int32"`

	PartitionNumber *int32 `type:"int32"`

	ReplicaNumber *int32 `type:"int32"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeTopicsInput) GoString 

func (s DescribeTopicsInput) GoString() string

GoString returns the string representation

func (*DescribeTopicsInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeTopicsInput) SetPageNumber 

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

SetPageNumber sets the PageNumber field's value.

func (*DescribeTopicsInput) SetPageSize 

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

SetPageSize sets the PageSize field's value.

func (*DescribeTopicsInput) SetPartitionNumber 

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

SetPartitionNumber sets the PartitionNumber field's value.

func (*DescribeTopicsInput) SetReplicaNumber 

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

SetReplicaNumber sets the ReplicaNumber field's value.

func (*DescribeTopicsInput) SetTopicName 

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

SetTopicName sets the TopicName field's value.

func (DescribeTopicsInput) String 

func (s DescribeTopicsInput) String() string

String returns the string representation

type DescribeTopicsOutput 

type DescribeTopicsOutput struct {
	Metadata *response.ResponseMetadata

	InstanceId *string `type:"string"`

	TopicsInfo []*TopicsInfoForDescribeTopicsOutput `type:"list"`

	Total *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (DescribeTopicsOutput) GoString 

func (s DescribeTopicsOutput) GoString() string

GoString returns the string representation

func (*DescribeTopicsOutput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeTopicsOutput) SetTopicsInfo 

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

SetTopicsInfo sets the TopicsInfo field's value.

func (*DescribeTopicsOutput) SetTotal 

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

SetTotal sets the Total field's value.

func (DescribeTopicsOutput) String 

func (s DescribeTopicsOutput) String() string

String returns the string representation

type DescribeUsersInput 

type DescribeUsersInput struct {
	InstanceId *string `type:"string"`

	PageNumber *int32 `type:"int32"`

	PageSize *int32 `type:"int32"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (DescribeUsersInput) GoString 

func (s DescribeUsersInput) GoString() string

GoString returns the string representation

func (*DescribeUsersInput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*DescribeUsersInput) SetPageNumber 

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

SetPageNumber sets the PageNumber field's value.

func (*DescribeUsersInput) SetPageSize 

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

SetPageSize sets the PageSize field's value.

func (*DescribeUsersInput) SetUserName 

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

SetUserName sets the UserName field's value.

func (DescribeUsersInput) String 

func (s DescribeUsersInput) String() string

String returns the string representation

type DescribeUsersOutput 

type DescribeUsersOutput struct {
	Metadata *response.ResponseMetadata

	Total *int32 `type:"int32"`

	UsersInfo []*UsersInfoForDescribeUsersOutput `type:"list"`
	// contains filtered or unexported fields
}

func (DescribeUsersOutput) GoString 

func (s DescribeUsersOutput) GoString() string

GoString returns the string representation

func (*DescribeUsersOutput) SetTotal 

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

SetTotal sets the Total field's value.

func (*DescribeUsersOutput) SetUsersInfo 

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

SetUsersInfo sets the UsersInfo field's value.

func (DescribeUsersOutput) String 

func (s DescribeUsersOutput) String() string

String returns the string representation

type GroupsInfoForDescribeGroupsOutput 

type GroupsInfoForDescribeGroupsOutput struct {
	GroupId *string `type:"string"`

	State *string `type:"string"`
	// contains filtered or unexported fields
}

func (GroupsInfoForDescribeGroupsOutput) GoString 

func (s GroupsInfoForDescribeGroupsOutput) GoString() string

GoString returns the string representation

func (*GroupsInfoForDescribeGroupsOutput) SetGroupId 

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

SetGroupId sets the GroupId field's value.

func (*GroupsInfoForDescribeGroupsOutput) SetState 

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

SetState sets the State field's value.

func (GroupsInfoForDescribeGroupsOutput) String 

func (s GroupsInfoForDescribeGroupsOutput) String() string

String returns the string representation

type InnerParametersForModifyTopicParametersInput 

type InnerParametersForModifyTopicParametersInput struct {
	LogRetentionHours *int32 `type:"int32"`

	MessageMaxByte *int32 `type:"int32"`

	MinInsyncReplicaNumber *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (InnerParametersForModifyTopicParametersInput) GoString 

func (s InnerParametersForModifyTopicParametersInput) GoString() string

GoString returns the string representation

func (*InnerParametersForModifyTopicParametersInput) SetLogRetentionHours 

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

SetLogRetentionHours sets the LogRetentionHours field's value.

func (*InnerParametersForModifyTopicParametersInput) SetMessageMaxByte 

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

SetMessageMaxByte sets the MessageMaxByte field's value.

func (*InnerParametersForModifyTopicParametersInput) SetMinInsyncReplicaNumber 

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

SetMinInsyncReplicaNumber sets the MinInsyncReplicaNumber field's value.

func (InnerParametersForModifyTopicParametersInput) String 

func (s InnerParametersForModifyTopicParametersInput) String() string

String returns the string representation

type InstancesInfoForDescribeInstancesOutput 

type InstancesInfoForDescribeInstancesOutput struct {
	AccountId *string `type:"string"`

	ChargeDetail *ChargeDetailForDescribeInstancesOutput `type:"structure"`

	ComputeSpec *string `type:"string"`

	CreateTime *string `type:"string"`

	EipId *string `type:"string"`

	InstanceDescription *string `type:"string"`

	InstanceId *string `type:"string"`

	InstanceName *string `type:"string"`

	InstanceStatus *string `type:"string"`

	PrivateDomainOnPublic *bool `type:"boolean"`

	ProjectName *string `type:"string"`

	RegionId *string `type:"string"`

	StorageSpace *int32 `type:"int32"`

	StorageType *string `type:"string"`

	SubnetId *string `type:"string"`

	Tags map[string]*string `type:"map"`

	UsableGroupNumber *int32 `type:"int32"`

	UsablePartitionNumber *int32 `type:"int32"`

	UsedGroupNumber *int32 `type:"int32"`

	UsedPartitionNumber *int32 `type:"int32"`

	UsedStorageSpace *int32 `type:"int32"`

	UsedTopicNumber *int32 `type:"int32"`

	Version *string `type:"string"`

	VpcId *string `type:"string"`

	ZoneId *string `type:"string"`
	// contains filtered or unexported fields
}

func (InstancesInfoForDescribeInstancesOutput) GoString 

func (s InstancesInfoForDescribeInstancesOutput) GoString() string

GoString returns the string representation

func (*InstancesInfoForDescribeInstancesOutput) SetAccountId 

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

SetAccountId sets the AccountId field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetChargeDetail 

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

SetChargeDetail sets the ChargeDetail field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetComputeSpec 

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

SetComputeSpec sets the ComputeSpec field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetCreateTime 

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

SetCreateTime sets the CreateTime field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetEipId 

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

SetEipId sets the EipId field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetInstanceDescription 

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

SetInstanceDescription sets the InstanceDescription field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetInstanceId 

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

SetInstanceId sets the InstanceId field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetInstanceName 

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

SetInstanceName sets the InstanceName field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetInstanceStatus 

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

SetInstanceStatus sets the InstanceStatus field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetPrivateDomainOnPublic 

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

SetPrivateDomainOnPublic sets the PrivateDomainOnPublic field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetProjectName 

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

SetProjectName sets the ProjectName field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetRegionId 

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

SetRegionId sets the RegionId field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetStorageSpace 

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

SetStorageSpace sets the StorageSpace field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetStorageType 

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

SetStorageType sets the StorageType field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetSubnetId 

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

SetSubnetId sets the SubnetId field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetTags 

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

SetTags sets the Tags field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetUsableGroupNumber 

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

SetUsableGroupNumber sets the UsableGroupNumber field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetUsablePartitionNumber 

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

SetUsablePartitionNumber sets the UsablePartitionNumber field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetUsedGroupNumber 

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

SetUsedGroupNumber sets the UsedGroupNumber field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetUsedPartitionNumber 

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

SetUsedPartitionNumber sets the UsedPartitionNumber field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetUsedStorageSpace 

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

SetUsedStorageSpace sets the UsedStorageSpace field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetUsedTopicNumber 

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

SetUsedTopicNumber sets the UsedTopicNumber field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetVersion 

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

SetVersion sets the Version field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetVpcId 

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

SetVpcId sets the VpcId field's value.

func (*InstancesInfoForDescribeInstancesOutput) SetZoneId 

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

SetZoneId sets the ZoneId field's value.

func (InstancesInfoForDescribeInstancesOutput) String 

func (s InstancesInfoForDescribeInstancesOutput) String() string

String returns the string representation

type KAFKA 

type KAFKA struct {
	*client.Client
}

KAFKA provides the API operation methods for making requests to KAFKA. See this package's package overview docs for details on the service.

KAFKA methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

func New 

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

New create int can support ssl or region locate set

func (*KAFKA) AddTagsToResource 

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

AddTagsToResource API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation AddTagsToResource for usage and error information.

func (*KAFKA) AddTagsToResourceCommon 

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

AddTagsToResourceCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation AddTagsToResourceCommon for usage and error information.

func (*KAFKA) AddTagsToResourceCommonRequest 

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

AddTagsToResourceCommonRequest generates a "volcengine/request.Request" representing the client's request for the AddTagsToResourceCommon operation. The "output" return value will be populated with the AddTagsToResourceCommon request's response once the request completes successfully.

Use "Send" method on the returned AddTagsToResourceCommon Request to send the API call to the service. the "output" return value is not valid until after AddTagsToResourceCommon Send returns without error.

See AddTagsToResourceCommon for more information on using the AddTagsToResourceCommon API call, and error handling. 

// Example sending a request using the AddTagsToResourceCommonRequest method.
req, resp := client.AddTagsToResourceCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) AddTagsToResourceCommonWithContext 

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

AddTagsToResourceCommonWithContext is the same as AddTagsToResourceCommon with the addition of the ability to pass a context and additional request options.

See AddTagsToResourceCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) AddTagsToResourceRequest 

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

AddTagsToResourceRequest generates a "volcengine/request.Request" representing the client's request for the AddTagsToResource operation. The "output" return value will be populated with the AddTagsToResourceCommon request's response once the request completes successfully.

Use "Send" method on the returned AddTagsToResourceCommon Request to send the API call to the service. the "output" return value is not valid until after AddTagsToResourceCommon Send returns without error.

See AddTagsToResource for more information on using the AddTagsToResource API call, and error handling. 

// Example sending a request using the AddTagsToResourceRequest method.
req, resp := client.AddTagsToResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) AddTagsToResourceWithContext 

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

AddTagsToResourceWithContext is the same as AddTagsToResource with the addition of the ability to pass a context and additional request options.

See AddTagsToResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreateInstance 

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

CreateInstance API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreateInstance for usage and error information.

func (*KAFKA) CreateInstanceCommon 

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

CreateInstanceCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreateInstanceCommon for usage and error information.

func (*KAFKA) CreateInstanceCommonRequest 

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

CreateInstanceCommonRequest generates a "volcengine/request.Request" representing the client's request for the CreateInstanceCommon operation. The "output" return value will be populated with the CreateInstanceCommon request's response once the request completes successfully.

Use "Send" method on the returned CreateInstanceCommon Request to send the API call to the service. the "output" return value is not valid until after CreateInstanceCommon Send returns without error.

See CreateInstanceCommon for more information on using the CreateInstanceCommon API call, and error handling. 

// Example sending a request using the CreateInstanceCommonRequest method.
req, resp := client.CreateInstanceCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreateInstanceCommonWithContext 

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

CreateInstanceCommonWithContext is the same as CreateInstanceCommon with the addition of the ability to pass a context and additional request options.

See CreateInstanceCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreateInstanceRequest 

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

CreateInstanceRequest generates a "volcengine/request.Request" representing the client's request for the CreateInstance operation. The "output" return value will be populated with the CreateInstanceCommon request's response once the request completes successfully.

Use "Send" method on the returned CreateInstanceCommon Request to send the API call to the service. the "output" return value is not valid until after CreateInstanceCommon Send returns without error.

See CreateInstance for more information on using the CreateInstance API call, and error handling. 

// Example sending a request using the CreateInstanceRequest method.
req, resp := client.CreateInstanceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreateInstanceWithContext 

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

CreateInstanceWithContext is the same as CreateInstance with the addition of the ability to pass a context and additional request options.

See CreateInstance for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreatePublicAddress 

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

CreatePublicAddress API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreatePublicAddress for usage and error information.

func (*KAFKA) CreatePublicAddressCommon 

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

CreatePublicAddressCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreatePublicAddressCommon for usage and error information.

func (*KAFKA) CreatePublicAddressCommonRequest 

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

CreatePublicAddressCommonRequest generates a "volcengine/request.Request" representing the client's request for the CreatePublicAddressCommon operation. The "output" return value will be populated with the CreatePublicAddressCommon request's response once the request completes successfully.

Use "Send" method on the returned CreatePublicAddressCommon Request to send the API call to the service. the "output" return value is not valid until after CreatePublicAddressCommon Send returns without error.

See CreatePublicAddressCommon for more information on using the CreatePublicAddressCommon API call, and error handling. 

// Example sending a request using the CreatePublicAddressCommonRequest method.
req, resp := client.CreatePublicAddressCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreatePublicAddressCommonWithContext 

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

CreatePublicAddressCommonWithContext is the same as CreatePublicAddressCommon with the addition of the ability to pass a context and additional request options.

See CreatePublicAddressCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreatePublicAddressRequest 

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

CreatePublicAddressRequest generates a "volcengine/request.Request" representing the client's request for the CreatePublicAddress operation. The "output" return value will be populated with the CreatePublicAddressCommon request's response once the request completes successfully.

Use "Send" method on the returned CreatePublicAddressCommon Request to send the API call to the service. the "output" return value is not valid until after CreatePublicAddressCommon Send returns without error.

See CreatePublicAddress for more information on using the CreatePublicAddress API call, and error handling. 

// Example sending a request using the CreatePublicAddressRequest method.
req, resp := client.CreatePublicAddressRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreatePublicAddressWithContext 

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

CreatePublicAddressWithContext is the same as CreatePublicAddress with the addition of the ability to pass a context and additional request options.

See CreatePublicAddress for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreateTopic 

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

CreateTopic API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreateTopic for usage and error information.

func (*KAFKA) CreateTopicCommon 

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

CreateTopicCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreateTopicCommon for usage and error information.

func (*KAFKA) CreateTopicCommonRequest 

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

CreateTopicCommonRequest generates a "volcengine/request.Request" representing the client's request for the CreateTopicCommon operation. The "output" return value will be populated with the CreateTopicCommon request's response once the request completes successfully.

Use "Send" method on the returned CreateTopicCommon Request to send the API call to the service. the "output" return value is not valid until after CreateTopicCommon Send returns without error.

See CreateTopicCommon for more information on using the CreateTopicCommon API call, and error handling. 

// Example sending a request using the CreateTopicCommonRequest method.
req, resp := client.CreateTopicCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreateTopicCommonWithContext 

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

CreateTopicCommonWithContext is the same as CreateTopicCommon with the addition of the ability to pass a context and additional request options.

See CreateTopicCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreateTopicRequest 

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

CreateTopicRequest generates a "volcengine/request.Request" representing the client's request for the CreateTopic operation. The "output" return value will be populated with the CreateTopicCommon request's response once the request completes successfully.

Use "Send" method on the returned CreateTopicCommon Request to send the API call to the service. the "output" return value is not valid until after CreateTopicCommon Send returns without error.

See CreateTopic for more information on using the CreateTopic API call, and error handling. 

// Example sending a request using the CreateTopicRequest method.
req, resp := client.CreateTopicRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreateTopicWithContext 

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

CreateTopicWithContext is the same as CreateTopic with the addition of the ability to pass a context and additional request options.

See CreateTopic for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreateUser 

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

CreateUser API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreateUser for usage and error information.

func (*KAFKA) CreateUserCommon 

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

CreateUserCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation CreateUserCommon for usage and error information.

func (*KAFKA) CreateUserCommonRequest 

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

CreateUserCommonRequest generates a "volcengine/request.Request" representing the client's request for the CreateUserCommon operation. The "output" return value will be populated with the CreateUserCommon request's response once the request completes successfully.

Use "Send" method on the returned CreateUserCommon Request to send the API call to the service. the "output" return value is not valid until after CreateUserCommon Send returns without error.

See CreateUserCommon for more information on using the CreateUserCommon API call, and error handling. 

// Example sending a request using the CreateUserCommonRequest method.
req, resp := client.CreateUserCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreateUserCommonWithContext 

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

CreateUserCommonWithContext is the same as CreateUserCommon with the addition of the ability to pass a context and additional request options.

See CreateUserCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) CreateUserRequest 

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

CreateUserRequest generates a "volcengine/request.Request" representing the client's request for the CreateUser operation. The "output" return value will be populated with the CreateUserCommon request's response once the request completes successfully.

Use "Send" method on the returned CreateUserCommon Request to send the API call to the service. the "output" return value is not valid until after CreateUserCommon Send returns without error.

See CreateUser for more information on using the CreateUser API call, and error handling. 

// Example sending a request using the CreateUserRequest method.
req, resp := client.CreateUserRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) CreateUserWithContext 

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

CreateUserWithContext is the same as CreateUser with the addition of the ability to pass a context and additional request options.

See CreateUser for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteGroup 

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

DeleteGroup API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteGroup for usage and error information.

func (*KAFKA) DeleteGroupCommon 

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

DeleteGroupCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteGroupCommon for usage and error information.

func (*KAFKA) DeleteGroupCommonRequest 

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

DeleteGroupCommonRequest generates a "volcengine/request.Request" representing the client's request for the DeleteGroupCommon operation. The "output" return value will be populated with the DeleteGroupCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteGroupCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteGroupCommon Send returns without error.

See DeleteGroupCommon for more information on using the DeleteGroupCommon API call, and error handling. 

// Example sending a request using the DeleteGroupCommonRequest method.
req, resp := client.DeleteGroupCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteGroupCommonWithContext 

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

DeleteGroupCommonWithContext is the same as DeleteGroupCommon with the addition of the ability to pass a context and additional request options.

See DeleteGroupCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteGroupRequest 

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

DeleteGroupRequest generates a "volcengine/request.Request" representing the client's request for the DeleteGroup operation. The "output" return value will be populated with the DeleteGroupCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteGroupCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteGroupCommon Send returns without error.

See DeleteGroup for more information on using the DeleteGroup API call, and error handling. 

// Example sending a request using the DeleteGroupRequest method.
req, resp := client.DeleteGroupRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteGroupWithContext 

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

DeleteGroupWithContext is the same as DeleteGroup with the addition of the ability to pass a context and additional request options.

See DeleteGroup for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteInstance 

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

DeleteInstance API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteInstance for usage and error information.

func (*KAFKA) DeleteInstanceCommon 

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

DeleteInstanceCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteInstanceCommon for usage and error information.

func (*KAFKA) DeleteInstanceCommonRequest 

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

DeleteInstanceCommonRequest generates a "volcengine/request.Request" representing the client's request for the DeleteInstanceCommon operation. The "output" return value will be populated with the DeleteInstanceCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteInstanceCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteInstanceCommon Send returns without error.

See DeleteInstanceCommon for more information on using the DeleteInstanceCommon API call, and error handling. 

// Example sending a request using the DeleteInstanceCommonRequest method.
req, resp := client.DeleteInstanceCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteInstanceCommonWithContext 

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

DeleteInstanceCommonWithContext is the same as DeleteInstanceCommon with the addition of the ability to pass a context and additional request options.

See DeleteInstanceCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteInstanceRequest 

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

DeleteInstanceRequest generates a "volcengine/request.Request" representing the client's request for the DeleteInstance operation. The "output" return value will be populated with the DeleteInstanceCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteInstanceCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteInstanceCommon Send returns without error.

See DeleteInstance for more information on using the DeleteInstance API call, and error handling. 

// Example sending a request using the DeleteInstanceRequest method.
req, resp := client.DeleteInstanceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteInstanceWithContext 

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

DeleteInstanceWithContext is the same as DeleteInstance with the addition of the ability to pass a context and additional request options.

See DeleteInstance for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeletePublicAddress 

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

DeletePublicAddress API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeletePublicAddress for usage and error information.

func (*KAFKA) DeletePublicAddressCommon 

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

DeletePublicAddressCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeletePublicAddressCommon for usage and error information.

func (*KAFKA) DeletePublicAddressCommonRequest 

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

DeletePublicAddressCommonRequest generates a "volcengine/request.Request" representing the client's request for the DeletePublicAddressCommon operation. The "output" return value will be populated with the DeletePublicAddressCommon request's response once the request completes successfully.

Use "Send" method on the returned DeletePublicAddressCommon Request to send the API call to the service. the "output" return value is not valid until after DeletePublicAddressCommon Send returns without error.

See DeletePublicAddressCommon for more information on using the DeletePublicAddressCommon API call, and error handling. 

// Example sending a request using the DeletePublicAddressCommonRequest method.
req, resp := client.DeletePublicAddressCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeletePublicAddressCommonWithContext 

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

DeletePublicAddressCommonWithContext is the same as DeletePublicAddressCommon with the addition of the ability to pass a context and additional request options.

See DeletePublicAddressCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeletePublicAddressRequest 

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

DeletePublicAddressRequest generates a "volcengine/request.Request" representing the client's request for the DeletePublicAddress operation. The "output" return value will be populated with the DeletePublicAddressCommon request's response once the request completes successfully.

Use "Send" method on the returned DeletePublicAddressCommon Request to send the API call to the service. the "output" return value is not valid until after DeletePublicAddressCommon Send returns without error.

See DeletePublicAddress for more information on using the DeletePublicAddress API call, and error handling. 

// Example sending a request using the DeletePublicAddressRequest method.
req, resp := client.DeletePublicAddressRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeletePublicAddressWithContext 

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

DeletePublicAddressWithContext is the same as DeletePublicAddress with the addition of the ability to pass a context and additional request options.

See DeletePublicAddress for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteTopic 

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

DeleteTopic API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteTopic for usage and error information.

func (*KAFKA) DeleteTopicCommon 

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

DeleteTopicCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteTopicCommon for usage and error information.

func (*KAFKA) DeleteTopicCommonRequest 

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

DeleteTopicCommonRequest generates a "volcengine/request.Request" representing the client's request for the DeleteTopicCommon operation. The "output" return value will be populated with the DeleteTopicCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteTopicCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteTopicCommon Send returns without error.

See DeleteTopicCommon for more information on using the DeleteTopicCommon API call, and error handling. 

// Example sending a request using the DeleteTopicCommonRequest method.
req, resp := client.DeleteTopicCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteTopicCommonWithContext 

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

DeleteTopicCommonWithContext is the same as DeleteTopicCommon with the addition of the ability to pass a context and additional request options.

See DeleteTopicCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteTopicRequest 

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

DeleteTopicRequest generates a "volcengine/request.Request" representing the client's request for the DeleteTopic operation. The "output" return value will be populated with the DeleteTopicCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteTopicCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteTopicCommon Send returns without error.

See DeleteTopic for more information on using the DeleteTopic API call, and error handling. 

// Example sending a request using the DeleteTopicRequest method.
req, resp := client.DeleteTopicRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteTopicWithContext 

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

DeleteTopicWithContext is the same as DeleteTopic with the addition of the ability to pass a context and additional request options.

See DeleteTopic for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteUser 

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

DeleteUser API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteUser for usage and error information.

func (*KAFKA) DeleteUserCommon 

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

DeleteUserCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DeleteUserCommon for usage and error information.

func (*KAFKA) DeleteUserCommonRequest 

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

DeleteUserCommonRequest generates a "volcengine/request.Request" representing the client's request for the DeleteUserCommon operation. The "output" return value will be populated with the DeleteUserCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteUserCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteUserCommon Send returns without error.

See DeleteUserCommon for more information on using the DeleteUserCommon API call, and error handling. 

// Example sending a request using the DeleteUserCommonRequest method.
req, resp := client.DeleteUserCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteUserCommonWithContext 

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

DeleteUserCommonWithContext is the same as DeleteUserCommon with the addition of the ability to pass a context and additional request options.

See DeleteUserCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DeleteUserRequest 

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

DeleteUserRequest generates a "volcengine/request.Request" representing the client's request for the DeleteUser operation. The "output" return value will be populated with the DeleteUserCommon request's response once the request completes successfully.

Use "Send" method on the returned DeleteUserCommon Request to send the API call to the service. the "output" return value is not valid until after DeleteUserCommon Send returns without error.

See DeleteUser for more information on using the DeleteUser API call, and error handling. 

// Example sending a request using the DeleteUserRequest method.
req, resp := client.DeleteUserRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DeleteUserWithContext 

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

DeleteUserWithContext is the same as DeleteUser with the addition of the ability to pass a context and additional request options.

See DeleteUser for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeAvailabilityZones 

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

DescribeAvailabilityZones API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeAvailabilityZones for usage and error information.

func (*KAFKA) DescribeAvailabilityZonesCommon 

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

DescribeAvailabilityZonesCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeAvailabilityZonesCommon for usage and error information.

func (*KAFKA) DescribeAvailabilityZonesCommonRequest 

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

DescribeAvailabilityZonesCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeAvailabilityZonesCommon operation. The "output" return value will be populated with the DescribeAvailabilityZonesCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeAvailabilityZonesCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeAvailabilityZonesCommon Send returns without error.

See DescribeAvailabilityZonesCommon for more information on using the DescribeAvailabilityZonesCommon API call, and error handling. 

// Example sending a request using the DescribeAvailabilityZonesCommonRequest method.
req, resp := client.DescribeAvailabilityZonesCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeAvailabilityZonesCommonWithContext 

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

DescribeAvailabilityZonesCommonWithContext is the same as DescribeAvailabilityZonesCommon with the addition of the ability to pass a context and additional request options.

See DescribeAvailabilityZonesCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeAvailabilityZonesRequest 

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

DescribeAvailabilityZonesRequest generates a "volcengine/request.Request" representing the client's request for the DescribeAvailabilityZones operation. The "output" return value will be populated with the DescribeAvailabilityZonesCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeAvailabilityZonesCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeAvailabilityZonesCommon Send returns without error.

See DescribeAvailabilityZones for more information on using the DescribeAvailabilityZones API call, and error handling. 

// Example sending a request using the DescribeAvailabilityZonesRequest method.
req, resp := client.DescribeAvailabilityZonesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeAvailabilityZonesWithContext 

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

DescribeAvailabilityZonesWithContext is the same as DescribeAvailabilityZones with the addition of the ability to pass a context and additional request options.

See DescribeAvailabilityZones for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeConsumedPartitions 

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

DescribeConsumedPartitions API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeConsumedPartitions for usage and error information.

func (*KAFKA) DescribeConsumedPartitionsCommon 

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

DescribeConsumedPartitionsCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeConsumedPartitionsCommon for usage and error information.

func (*KAFKA) DescribeConsumedPartitionsCommonRequest 

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

DescribeConsumedPartitionsCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeConsumedPartitionsCommon operation. The "output" return value will be populated with the DescribeConsumedPartitionsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeConsumedPartitionsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeConsumedPartitionsCommon Send returns without error.

See DescribeConsumedPartitionsCommon for more information on using the DescribeConsumedPartitionsCommon API call, and error handling. 

// Example sending a request using the DescribeConsumedPartitionsCommonRequest method.
req, resp := client.DescribeConsumedPartitionsCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeConsumedPartitionsCommonWithContext 

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

DescribeConsumedPartitionsCommonWithContext is the same as DescribeConsumedPartitionsCommon with the addition of the ability to pass a context and additional request options.

See DescribeConsumedPartitionsCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeConsumedPartitionsRequest 

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

DescribeConsumedPartitionsRequest generates a "volcengine/request.Request" representing the client's request for the DescribeConsumedPartitions operation. The "output" return value will be populated with the DescribeConsumedPartitionsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeConsumedPartitionsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeConsumedPartitionsCommon Send returns without error.

See DescribeConsumedPartitions for more information on using the DescribeConsumedPartitions API call, and error handling. 

// Example sending a request using the DescribeConsumedPartitionsRequest method.
req, resp := client.DescribeConsumedPartitionsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeConsumedPartitionsWithContext 

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

DescribeConsumedPartitionsWithContext is the same as DescribeConsumedPartitions with the addition of the ability to pass a context and additional request options.

See DescribeConsumedPartitions for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeConsumedTopics 

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

DescribeConsumedTopics API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeConsumedTopics for usage and error information.

func (*KAFKA) DescribeConsumedTopicsCommon 

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

DescribeConsumedTopicsCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeConsumedTopicsCommon for usage and error information.

func (*KAFKA) DescribeConsumedTopicsCommonRequest 

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

DescribeConsumedTopicsCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeConsumedTopicsCommon operation. The "output" return value will be populated with the DescribeConsumedTopicsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeConsumedTopicsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeConsumedTopicsCommon Send returns without error.

See DescribeConsumedTopicsCommon for more information on using the DescribeConsumedTopicsCommon API call, and error handling. 

// Example sending a request using the DescribeConsumedTopicsCommonRequest method.
req, resp := client.DescribeConsumedTopicsCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeConsumedTopicsCommonWithContext 

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

DescribeConsumedTopicsCommonWithContext is the same as DescribeConsumedTopicsCommon with the addition of the ability to pass a context and additional request options.

See DescribeConsumedTopicsCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeConsumedTopicsRequest 

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

DescribeConsumedTopicsRequest generates a "volcengine/request.Request" representing the client's request for the DescribeConsumedTopics operation. The "output" return value will be populated with the DescribeConsumedTopicsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeConsumedTopicsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeConsumedTopicsCommon Send returns without error.

See DescribeConsumedTopics for more information on using the DescribeConsumedTopics API call, and error handling. 

// Example sending a request using the DescribeConsumedTopicsRequest method.
req, resp := client.DescribeConsumedTopicsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeConsumedTopicsWithContext 

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

DescribeConsumedTopicsWithContext is the same as DescribeConsumedTopics with the addition of the ability to pass a context and additional request options.

See DescribeConsumedTopics for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeGroups 

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

DescribeGroups API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeGroups for usage and error information.

func (*KAFKA) DescribeGroupsCommon 

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

DescribeGroupsCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeGroupsCommon for usage and error information.

func (*KAFKA) DescribeGroupsCommonRequest 

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

DescribeGroupsCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeGroupsCommon operation. The "output" return value will be populated with the DescribeGroupsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeGroupsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeGroupsCommon Send returns without error.

See DescribeGroupsCommon for more information on using the DescribeGroupsCommon API call, and error handling. 

// Example sending a request using the DescribeGroupsCommonRequest method.
req, resp := client.DescribeGroupsCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeGroupsCommonWithContext 

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

DescribeGroupsCommonWithContext is the same as DescribeGroupsCommon with the addition of the ability to pass a context and additional request options.

See DescribeGroupsCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeGroupsRequest 

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

DescribeGroupsRequest generates a "volcengine/request.Request" representing the client's request for the DescribeGroups operation. The "output" return value will be populated with the DescribeGroupsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeGroupsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeGroupsCommon Send returns without error.

See DescribeGroups for more information on using the DescribeGroups API call, and error handling. 

// Example sending a request using the DescribeGroupsRequest method.
req, resp := client.DescribeGroupsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeGroupsWithContext 

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

DescribeGroupsWithContext is the same as DescribeGroups with the addition of the ability to pass a context and additional request options.

See DescribeGroups for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeInstanceDetail 

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

DescribeInstanceDetail API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeInstanceDetail for usage and error information.

func (*KAFKA) DescribeInstanceDetailCommon 

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

DescribeInstanceDetailCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeInstanceDetailCommon for usage and error information.

func (*KAFKA) DescribeInstanceDetailCommonRequest 

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

DescribeInstanceDetailCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeInstanceDetailCommon operation. The "output" return value will be populated with the DescribeInstanceDetailCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeInstanceDetailCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeInstanceDetailCommon Send returns without error.

See DescribeInstanceDetailCommon for more information on using the DescribeInstanceDetailCommon API call, and error handling. 

// Example sending a request using the DescribeInstanceDetailCommonRequest method.
req, resp := client.DescribeInstanceDetailCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeInstanceDetailCommonWithContext 

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

DescribeInstanceDetailCommonWithContext is the same as DescribeInstanceDetailCommon with the addition of the ability to pass a context and additional request options.

See DescribeInstanceDetailCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeInstanceDetailRequest 

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

DescribeInstanceDetailRequest generates a "volcengine/request.Request" representing the client's request for the DescribeInstanceDetail operation. The "output" return value will be populated with the DescribeInstanceDetailCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeInstanceDetailCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeInstanceDetailCommon Send returns without error.

See DescribeInstanceDetail for more information on using the DescribeInstanceDetail API call, and error handling. 

// Example sending a request using the DescribeInstanceDetailRequest method.
req, resp := client.DescribeInstanceDetailRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeInstanceDetailWithContext 

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

DescribeInstanceDetailWithContext is the same as DescribeInstanceDetail with the addition of the ability to pass a context and additional request options.

See DescribeInstanceDetail for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeInstances 

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

DescribeInstances API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeInstances for usage and error information.

func (*KAFKA) DescribeInstancesCommon 

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

DescribeInstancesCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeInstancesCommon for usage and error information.

func (*KAFKA) DescribeInstancesCommonRequest 

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

DescribeInstancesCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeInstancesCommon operation. The "output" return value will be populated with the DescribeInstancesCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeInstancesCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeInstancesCommon Send returns without error.

See DescribeInstancesCommon for more information on using the DescribeInstancesCommon API call, and error handling. 

// Example sending a request using the DescribeInstancesCommonRequest method.
req, resp := client.DescribeInstancesCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeInstancesCommonWithContext 

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

DescribeInstancesCommonWithContext is the same as DescribeInstancesCommon with the addition of the ability to pass a context and additional request options.

See DescribeInstancesCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeInstancesRequest 

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

DescribeInstancesRequest generates a "volcengine/request.Request" representing the client's request for the DescribeInstances operation. The "output" return value will be populated with the DescribeInstancesCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeInstancesCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeInstancesCommon Send returns without error.

See DescribeInstances for more information on using the DescribeInstances API call, and error handling. 

// Example sending a request using the DescribeInstancesRequest method.
req, resp := client.DescribeInstancesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeInstancesWithContext 

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

DescribeInstancesWithContext is the same as DescribeInstances with the addition of the ability to pass a context and additional request options.

See DescribeInstances for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopicAccessPolicies 

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

DescribeTopicAccessPolicies API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopicAccessPolicies for usage and error information.

func (*KAFKA) DescribeTopicAccessPoliciesCommon 

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

DescribeTopicAccessPoliciesCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopicAccessPoliciesCommon for usage and error information.

func (*KAFKA) DescribeTopicAccessPoliciesCommonRequest 

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

DescribeTopicAccessPoliciesCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopicAccessPoliciesCommon operation. The "output" return value will be populated with the DescribeTopicAccessPoliciesCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicAccessPoliciesCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicAccessPoliciesCommon Send returns without error.

See DescribeTopicAccessPoliciesCommon for more information on using the DescribeTopicAccessPoliciesCommon API call, and error handling. 

// Example sending a request using the DescribeTopicAccessPoliciesCommonRequest method.
req, resp := client.DescribeTopicAccessPoliciesCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicAccessPoliciesCommonWithContext 

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

DescribeTopicAccessPoliciesCommonWithContext is the same as DescribeTopicAccessPoliciesCommon with the addition of the ability to pass a context and additional request options.

See DescribeTopicAccessPoliciesCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopicAccessPoliciesRequest 

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

DescribeTopicAccessPoliciesRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopicAccessPolicies operation. The "output" return value will be populated with the DescribeTopicAccessPoliciesCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicAccessPoliciesCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicAccessPoliciesCommon Send returns without error.

See DescribeTopicAccessPolicies for more information on using the DescribeTopicAccessPolicies API call, and error handling. 

// Example sending a request using the DescribeTopicAccessPoliciesRequest method.
req, resp := client.DescribeTopicAccessPoliciesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicAccessPoliciesWithContext 

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

DescribeTopicAccessPoliciesWithContext is the same as DescribeTopicAccessPolicies with the addition of the ability to pass a context and additional request options.

See DescribeTopicAccessPolicies for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopicParameters 

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

DescribeTopicParameters API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopicParameters for usage and error information.

func (*KAFKA) DescribeTopicParametersCommon 

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

DescribeTopicParametersCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopicParametersCommon for usage and error information.

func (*KAFKA) DescribeTopicParametersCommonRequest 

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

DescribeTopicParametersCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopicParametersCommon operation. The "output" return value will be populated with the DescribeTopicParametersCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicParametersCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicParametersCommon Send returns without error.

See DescribeTopicParametersCommon for more information on using the DescribeTopicParametersCommon API call, and error handling. 

// Example sending a request using the DescribeTopicParametersCommonRequest method.
req, resp := client.DescribeTopicParametersCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicParametersCommonWithContext 

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

DescribeTopicParametersCommonWithContext is the same as DescribeTopicParametersCommon with the addition of the ability to pass a context and additional request options.

See DescribeTopicParametersCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopicParametersRequest 

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

DescribeTopicParametersRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopicParameters operation. The "output" return value will be populated with the DescribeTopicParametersCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicParametersCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicParametersCommon Send returns without error.

See DescribeTopicParameters for more information on using the DescribeTopicParameters API call, and error handling. 

// Example sending a request using the DescribeTopicParametersRequest method.
req, resp := client.DescribeTopicParametersRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicParametersWithContext 

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

DescribeTopicParametersWithContext is the same as DescribeTopicParameters with the addition of the ability to pass a context and additional request options.

See DescribeTopicParameters for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopicPartitions 

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

DescribeTopicPartitions API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopicPartitions for usage and error information.

func (*KAFKA) DescribeTopicPartitionsCommon 

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

DescribeTopicPartitionsCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopicPartitionsCommon for usage and error information.

func (*KAFKA) DescribeTopicPartitionsCommonRequest 

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

DescribeTopicPartitionsCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopicPartitionsCommon operation. The "output" return value will be populated with the DescribeTopicPartitionsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicPartitionsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicPartitionsCommon Send returns without error.

See DescribeTopicPartitionsCommon for more information on using the DescribeTopicPartitionsCommon API call, and error handling. 

// Example sending a request using the DescribeTopicPartitionsCommonRequest method.
req, resp := client.DescribeTopicPartitionsCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicPartitionsCommonWithContext 

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

DescribeTopicPartitionsCommonWithContext is the same as DescribeTopicPartitionsCommon with the addition of the ability to pass a context and additional request options.

See DescribeTopicPartitionsCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopicPartitionsRequest 

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

DescribeTopicPartitionsRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopicPartitions operation. The "output" return value will be populated with the DescribeTopicPartitionsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicPartitionsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicPartitionsCommon Send returns without error.

See DescribeTopicPartitions for more information on using the DescribeTopicPartitions API call, and error handling. 

// Example sending a request using the DescribeTopicPartitionsRequest method.
req, resp := client.DescribeTopicPartitionsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicPartitionsWithContext 

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

DescribeTopicPartitionsWithContext is the same as DescribeTopicPartitions with the addition of the ability to pass a context and additional request options.

See DescribeTopicPartitions for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopics 

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

DescribeTopics API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopics for usage and error information.

func (*KAFKA) DescribeTopicsCommon 

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

DescribeTopicsCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeTopicsCommon for usage and error information.

func (*KAFKA) DescribeTopicsCommonRequest 

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

DescribeTopicsCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopicsCommon operation. The "output" return value will be populated with the DescribeTopicsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicsCommon Send returns without error.

See DescribeTopicsCommon for more information on using the DescribeTopicsCommon API call, and error handling. 

// Example sending a request using the DescribeTopicsCommonRequest method.
req, resp := client.DescribeTopicsCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicsCommonWithContext 

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

DescribeTopicsCommonWithContext is the same as DescribeTopicsCommon with the addition of the ability to pass a context and additional request options.

See DescribeTopicsCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeTopicsRequest 

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

DescribeTopicsRequest generates a "volcengine/request.Request" representing the client's request for the DescribeTopics operation. The "output" return value will be populated with the DescribeTopicsCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeTopicsCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeTopicsCommon Send returns without error.

See DescribeTopics for more information on using the DescribeTopics API call, and error handling. 

// Example sending a request using the DescribeTopicsRequest method.
req, resp := client.DescribeTopicsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeTopicsWithContext 

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

DescribeTopicsWithContext is the same as DescribeTopics with the addition of the ability to pass a context and additional request options.

See DescribeTopics for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeUsers 

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

DescribeUsers API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeUsers for usage and error information.

func (*KAFKA) DescribeUsersCommon 

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

DescribeUsersCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation DescribeUsersCommon for usage and error information.

func (*KAFKA) DescribeUsersCommonRequest 

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

DescribeUsersCommonRequest generates a "volcengine/request.Request" representing the client's request for the DescribeUsersCommon operation. The "output" return value will be populated with the DescribeUsersCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeUsersCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeUsersCommon Send returns without error.

See DescribeUsersCommon for more information on using the DescribeUsersCommon API call, and error handling. 

// Example sending a request using the DescribeUsersCommonRequest method.
req, resp := client.DescribeUsersCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeUsersCommonWithContext 

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

DescribeUsersCommonWithContext is the same as DescribeUsersCommon with the addition of the ability to pass a context and additional request options.

See DescribeUsersCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) DescribeUsersRequest 

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

DescribeUsersRequest generates a "volcengine/request.Request" representing the client's request for the DescribeUsers operation. The "output" return value will be populated with the DescribeUsersCommon request's response once the request completes successfully.

Use "Send" method on the returned DescribeUsersCommon Request to send the API call to the service. the "output" return value is not valid until after DescribeUsersCommon Send returns without error.

See DescribeUsers for more information on using the DescribeUsers API call, and error handling. 

// Example sending a request using the DescribeUsersRequest method.
req, resp := client.DescribeUsersRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) DescribeUsersWithContext 

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

DescribeUsersWithContext is the same as DescribeUsers with the addition of the ability to pass a context and additional request options.

See DescribeUsers for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceAttributes 

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

ModifyInstanceAttributes API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceAttributes for usage and error information.

func (*KAFKA) ModifyInstanceAttributesCommon 

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

ModifyInstanceAttributesCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceAttributesCommon for usage and error information.

func (*KAFKA) ModifyInstanceAttributesCommonRequest 

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

ModifyInstanceAttributesCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceAttributesCommon operation. The "output" return value will be populated with the ModifyInstanceAttributesCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceAttributesCommon Send returns without error.

See ModifyInstanceAttributesCommon for more information on using the ModifyInstanceAttributesCommon API call, and error handling. 

// Example sending a request using the ModifyInstanceAttributesCommonRequest method.
req, resp := client.ModifyInstanceAttributesCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceAttributesCommonWithContext 

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

ModifyInstanceAttributesCommonWithContext is the same as ModifyInstanceAttributesCommon with the addition of the ability to pass a context and additional request options.

See ModifyInstanceAttributesCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceAttributesRequest 

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

ModifyInstanceAttributesRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceAttributes operation. The "output" return value will be populated with the ModifyInstanceAttributesCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceAttributesCommon Send returns without error.

See ModifyInstanceAttributes for more information on using the ModifyInstanceAttributes API call, and error handling. 

// Example sending a request using the ModifyInstanceAttributesRequest method.
req, resp := client.ModifyInstanceAttributesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceAttributesWithContext 

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

ModifyInstanceAttributesWithContext is the same as ModifyInstanceAttributes with the addition of the ability to pass a context and additional request options.

See ModifyInstanceAttributes for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceChargeType 

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

ModifyInstanceChargeType API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceChargeType for usage and error information.

func (*KAFKA) ModifyInstanceChargeTypeCommon 

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

ModifyInstanceChargeTypeCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceChargeTypeCommon for usage and error information.

func (*KAFKA) ModifyInstanceChargeTypeCommonRequest 

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

ModifyInstanceChargeTypeCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceChargeTypeCommon operation. The "output" return value will be populated with the ModifyInstanceChargeTypeCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceChargeTypeCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceChargeTypeCommon Send returns without error.

See ModifyInstanceChargeTypeCommon for more information on using the ModifyInstanceChargeTypeCommon API call, and error handling. 

// Example sending a request using the ModifyInstanceChargeTypeCommonRequest method.
req, resp := client.ModifyInstanceChargeTypeCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceChargeTypeCommonWithContext 

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

ModifyInstanceChargeTypeCommonWithContext is the same as ModifyInstanceChargeTypeCommon with the addition of the ability to pass a context and additional request options.

See ModifyInstanceChargeTypeCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceChargeTypeRequest 

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

ModifyInstanceChargeTypeRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceChargeType operation. The "output" return value will be populated with the ModifyInstanceChargeTypeCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceChargeTypeCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceChargeTypeCommon Send returns without error.

See ModifyInstanceChargeType for more information on using the ModifyInstanceChargeType API call, and error handling. 

// Example sending a request using the ModifyInstanceChargeTypeRequest method.
req, resp := client.ModifyInstanceChargeTypeRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceChargeTypeWithContext 

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

ModifyInstanceChargeTypeWithContext is the same as ModifyInstanceChargeType with the addition of the ability to pass a context and additional request options.

See ModifyInstanceChargeType for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceParameters 

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

ModifyInstanceParameters API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceParameters for usage and error information.

func (*KAFKA) ModifyInstanceParametersCommon 

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

ModifyInstanceParametersCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceParametersCommon for usage and error information.

func (*KAFKA) ModifyInstanceParametersCommonRequest 

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

ModifyInstanceParametersCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceParametersCommon operation. The "output" return value will be populated with the ModifyInstanceParametersCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceParametersCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceParametersCommon Send returns without error.

See ModifyInstanceParametersCommon for more information on using the ModifyInstanceParametersCommon API call, and error handling. 

// Example sending a request using the ModifyInstanceParametersCommonRequest method.
req, resp := client.ModifyInstanceParametersCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceParametersCommonWithContext 

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

ModifyInstanceParametersCommonWithContext is the same as ModifyInstanceParametersCommon with the addition of the ability to pass a context and additional request options.

See ModifyInstanceParametersCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceParametersRequest 

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

ModifyInstanceParametersRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceParameters operation. The "output" return value will be populated with the ModifyInstanceParametersCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceParametersCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceParametersCommon Send returns without error.

See ModifyInstanceParameters for more information on using the ModifyInstanceParameters API call, and error handling. 

// Example sending a request using the ModifyInstanceParametersRequest method.
req, resp := client.ModifyInstanceParametersRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceParametersWithContext 

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

ModifyInstanceParametersWithContext is the same as ModifyInstanceParameters with the addition of the ability to pass a context and additional request options.

See ModifyInstanceParameters for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceSpec 

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

ModifyInstanceSpec API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceSpec for usage and error information.

func (*KAFKA) ModifyInstanceSpecCommon 

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

ModifyInstanceSpecCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyInstanceSpecCommon for usage and error information.

func (*KAFKA) ModifyInstanceSpecCommonRequest 

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

ModifyInstanceSpecCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceSpecCommon operation. The "output" return value will be populated with the ModifyInstanceSpecCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceSpecCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceSpecCommon Send returns without error.

See ModifyInstanceSpecCommon for more information on using the ModifyInstanceSpecCommon API call, and error handling. 

// Example sending a request using the ModifyInstanceSpecCommonRequest method.
req, resp := client.ModifyInstanceSpecCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceSpecCommonWithContext 

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

ModifyInstanceSpecCommonWithContext is the same as ModifyInstanceSpecCommon with the addition of the ability to pass a context and additional request options.

See ModifyInstanceSpecCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyInstanceSpecRequest 

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

ModifyInstanceSpecRequest generates a "volcengine/request.Request" representing the client's request for the ModifyInstanceSpec operation. The "output" return value will be populated with the ModifyInstanceSpecCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyInstanceSpecCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyInstanceSpecCommon Send returns without error.

See ModifyInstanceSpec for more information on using the ModifyInstanceSpec API call, and error handling. 

// Example sending a request using the ModifyInstanceSpecRequest method.
req, resp := client.ModifyInstanceSpecRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyInstanceSpecWithContext 

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

ModifyInstanceSpecWithContext is the same as ModifyInstanceSpec with the addition of the ability to pass a context and additional request options.

See ModifyInstanceSpec for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyTopicAccessPolicies 

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

ModifyTopicAccessPolicies API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyTopicAccessPolicies for usage and error information.

func (*KAFKA) ModifyTopicAccessPoliciesCommon 

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

ModifyTopicAccessPoliciesCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyTopicAccessPoliciesCommon for usage and error information.

func (*KAFKA) ModifyTopicAccessPoliciesCommonRequest 

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

ModifyTopicAccessPoliciesCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyTopicAccessPoliciesCommon operation. The "output" return value will be populated with the ModifyTopicAccessPoliciesCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyTopicAccessPoliciesCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyTopicAccessPoliciesCommon Send returns without error.

See ModifyTopicAccessPoliciesCommon for more information on using the ModifyTopicAccessPoliciesCommon API call, and error handling. 

// Example sending a request using the ModifyTopicAccessPoliciesCommonRequest method.
req, resp := client.ModifyTopicAccessPoliciesCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyTopicAccessPoliciesCommonWithContext 

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

ModifyTopicAccessPoliciesCommonWithContext is the same as ModifyTopicAccessPoliciesCommon with the addition of the ability to pass a context and additional request options.

See ModifyTopicAccessPoliciesCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyTopicAccessPoliciesRequest 

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

ModifyTopicAccessPoliciesRequest generates a "volcengine/request.Request" representing the client's request for the ModifyTopicAccessPolicies operation. The "output" return value will be populated with the ModifyTopicAccessPoliciesCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyTopicAccessPoliciesCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyTopicAccessPoliciesCommon Send returns without error.

See ModifyTopicAccessPolicies for more information on using the ModifyTopicAccessPolicies API call, and error handling. 

// Example sending a request using the ModifyTopicAccessPoliciesRequest method.
req, resp := client.ModifyTopicAccessPoliciesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyTopicAccessPoliciesWithContext 

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

ModifyTopicAccessPoliciesWithContext is the same as ModifyTopicAccessPolicies with the addition of the ability to pass a context and additional request options.

See ModifyTopicAccessPolicies for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyTopicAttributes 

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

ModifyTopicAttributes API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyTopicAttributes for usage and error information.

func (*KAFKA) ModifyTopicAttributesCommon 

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

ModifyTopicAttributesCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyTopicAttributesCommon for usage and error information.

func (*KAFKA) ModifyTopicAttributesCommonRequest 

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

ModifyTopicAttributesCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyTopicAttributesCommon operation. The "output" return value will be populated with the ModifyTopicAttributesCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyTopicAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyTopicAttributesCommon Send returns without error.

See ModifyTopicAttributesCommon for more information on using the ModifyTopicAttributesCommon API call, and error handling. 

// Example sending a request using the ModifyTopicAttributesCommonRequest method.
req, resp := client.ModifyTopicAttributesCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyTopicAttributesCommonWithContext 

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

ModifyTopicAttributesCommonWithContext is the same as ModifyTopicAttributesCommon with the addition of the ability to pass a context and additional request options.

See ModifyTopicAttributesCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyTopicAttributesRequest 

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

ModifyTopicAttributesRequest generates a "volcengine/request.Request" representing the client's request for the ModifyTopicAttributes operation. The "output" return value will be populated with the ModifyTopicAttributesCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyTopicAttributesCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyTopicAttributesCommon Send returns without error.

See ModifyTopicAttributes for more information on using the ModifyTopicAttributes API call, and error handling. 

// Example sending a request using the ModifyTopicAttributesRequest method.
req, resp := client.ModifyTopicAttributesRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyTopicAttributesWithContext 

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

ModifyTopicAttributesWithContext is the same as ModifyTopicAttributes with the addition of the ability to pass a context and additional request options.

See ModifyTopicAttributes for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyTopicParameters 

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

ModifyTopicParameters API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyTopicParameters for usage and error information.

func (*KAFKA) ModifyTopicParametersCommon 

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

ModifyTopicParametersCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyTopicParametersCommon for usage and error information.

func (*KAFKA) ModifyTopicParametersCommonRequest 

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

ModifyTopicParametersCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyTopicParametersCommon operation. The "output" return value will be populated with the ModifyTopicParametersCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyTopicParametersCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyTopicParametersCommon Send returns without error.

See ModifyTopicParametersCommon for more information on using the ModifyTopicParametersCommon API call, and error handling. 

// Example sending a request using the ModifyTopicParametersCommonRequest method.
req, resp := client.ModifyTopicParametersCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyTopicParametersCommonWithContext 

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

ModifyTopicParametersCommonWithContext is the same as ModifyTopicParametersCommon with the addition of the ability to pass a context and additional request options.

See ModifyTopicParametersCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyTopicParametersRequest 

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

ModifyTopicParametersRequest generates a "volcengine/request.Request" representing the client's request for the ModifyTopicParameters operation. The "output" return value will be populated with the ModifyTopicParametersCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyTopicParametersCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyTopicParametersCommon Send returns without error.

See ModifyTopicParameters for more information on using the ModifyTopicParameters API call, and error handling. 

// Example sending a request using the ModifyTopicParametersRequest method.
req, resp := client.ModifyTopicParametersRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyTopicParametersWithContext 

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

ModifyTopicParametersWithContext is the same as ModifyTopicParameters with the addition of the ability to pass a context and additional request options.

See ModifyTopicParameters for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyUserAuthority 

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

ModifyUserAuthority API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyUserAuthority for usage and error information.

func (*KAFKA) ModifyUserAuthorityCommon 

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

ModifyUserAuthorityCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ModifyUserAuthorityCommon for usage and error information.

func (*KAFKA) ModifyUserAuthorityCommonRequest 

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

ModifyUserAuthorityCommonRequest generates a "volcengine/request.Request" representing the client's request for the ModifyUserAuthorityCommon operation. The "output" return value will be populated with the ModifyUserAuthorityCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyUserAuthorityCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyUserAuthorityCommon Send returns without error.

See ModifyUserAuthorityCommon for more information on using the ModifyUserAuthorityCommon API call, and error handling. 

// Example sending a request using the ModifyUserAuthorityCommonRequest method.
req, resp := client.ModifyUserAuthorityCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyUserAuthorityCommonWithContext 

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

ModifyUserAuthorityCommonWithContext is the same as ModifyUserAuthorityCommon with the addition of the ability to pass a context and additional request options.

See ModifyUserAuthorityCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ModifyUserAuthorityRequest 

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

ModifyUserAuthorityRequest generates a "volcengine/request.Request" representing the client's request for the ModifyUserAuthority operation. The "output" return value will be populated with the ModifyUserAuthorityCommon request's response once the request completes successfully.

Use "Send" method on the returned ModifyUserAuthorityCommon Request to send the API call to the service. the "output" return value is not valid until after ModifyUserAuthorityCommon Send returns without error.

See ModifyUserAuthority for more information on using the ModifyUserAuthority API call, and error handling. 

// Example sending a request using the ModifyUserAuthorityRequest method.
req, resp := client.ModifyUserAuthorityRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ModifyUserAuthorityWithContext 

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

ModifyUserAuthorityWithContext is the same as ModifyUserAuthority with the addition of the ability to pass a context and additional request options.

See ModifyUserAuthority for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) RemoveTagsFromResource 

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

RemoveTagsFromResource API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation RemoveTagsFromResource for usage and error information.

func (*KAFKA) RemoveTagsFromResourceCommon 

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

RemoveTagsFromResourceCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation RemoveTagsFromResourceCommon for usage and error information.

func (*KAFKA) RemoveTagsFromResourceCommonRequest 

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

RemoveTagsFromResourceCommonRequest generates a "volcengine/request.Request" representing the client's request for the RemoveTagsFromResourceCommon operation. The "output" return value will be populated with the RemoveTagsFromResourceCommon request's response once the request completes successfully.

Use "Send" method on the returned RemoveTagsFromResourceCommon Request to send the API call to the service. the "output" return value is not valid until after RemoveTagsFromResourceCommon Send returns without error.

See RemoveTagsFromResourceCommon for more information on using the RemoveTagsFromResourceCommon API call, and error handling. 

// Example sending a request using the RemoveTagsFromResourceCommonRequest method.
req, resp := client.RemoveTagsFromResourceCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) RemoveTagsFromResourceCommonWithContext 

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

RemoveTagsFromResourceCommonWithContext is the same as RemoveTagsFromResourceCommon with the addition of the ability to pass a context and additional request options.

See RemoveTagsFromResourceCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) RemoveTagsFromResourceRequest 

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

RemoveTagsFromResourceRequest generates a "volcengine/request.Request" representing the client's request for the RemoveTagsFromResource operation. The "output" return value will be populated with the RemoveTagsFromResourceCommon request's response once the request completes successfully.

Use "Send" method on the returned RemoveTagsFromResourceCommon Request to send the API call to the service. the "output" return value is not valid until after RemoveTagsFromResourceCommon Send returns without error.

See RemoveTagsFromResource for more information on using the RemoveTagsFromResource API call, and error handling. 

// Example sending a request using the RemoveTagsFromResourceRequest method.
req, resp := client.RemoveTagsFromResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) RemoveTagsFromResourceWithContext 

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

RemoveTagsFromResourceWithContext is the same as RemoveTagsFromResource with the addition of the ability to pass a context and additional request options.

See RemoveTagsFromResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ResetConsumedOffsets 

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

ResetConsumedOffsets API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ResetConsumedOffsets for usage and error information.

func (*KAFKA) ResetConsumedOffsetsCommon 

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

ResetConsumedOffsetsCommon API operation for KAFKA.

Returns volcengineerr.Error for service API and SDK errors. Use runtime type assertions with volcengineerr.Error's Code and Message methods to get detailed information about the error.

See the VOLCENGINE API reference guide for KAFKA's API operation ResetConsumedOffsetsCommon for usage and error information.

func (*KAFKA) ResetConsumedOffsetsCommonRequest 

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

ResetConsumedOffsetsCommonRequest generates a "volcengine/request.Request" representing the client's request for the ResetConsumedOffsetsCommon operation. The "output" return value will be populated with the ResetConsumedOffsetsCommon request's response once the request completes successfully.

Use "Send" method on the returned ResetConsumedOffsetsCommon Request to send the API call to the service. the "output" return value is not valid until after ResetConsumedOffsetsCommon Send returns without error.

See ResetConsumedOffsetsCommon for more information on using the ResetConsumedOffsetsCommon API call, and error handling. 

// Example sending a request using the ResetConsumedOffsetsCommonRequest method.
req, resp := client.ResetConsumedOffsetsCommonRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ResetConsumedOffsetsCommonWithContext 

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

ResetConsumedOffsetsCommonWithContext is the same as ResetConsumedOffsetsCommon with the addition of the ability to pass a context and additional request options.

See ResetConsumedOffsetsCommon for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*KAFKA) ResetConsumedOffsetsRequest 

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

ResetConsumedOffsetsRequest generates a "volcengine/request.Request" representing the client's request for the ResetConsumedOffsets operation. The "output" return value will be populated with the ResetConsumedOffsetsCommon request's response once the request completes successfully.

Use "Send" method on the returned ResetConsumedOffsetsCommon Request to send the API call to the service. the "output" return value is not valid until after ResetConsumedOffsetsCommon Send returns without error.

See ResetConsumedOffsets for more information on using the ResetConsumedOffsets API call, and error handling. 

// Example sending a request using the ResetConsumedOffsetsRequest method.
req, resp := client.ResetConsumedOffsetsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

func (*KAFKA) ResetConsumedOffsetsWithContext 

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

ResetConsumedOffsetsWithContext is the same as ResetConsumedOffsets with the addition of the ability to pass a context and additional request options.

See ResetConsumedOffsets for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. Ifthe context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

type KAFKAAPI 

type KAFKAAPI interface {
	AddTagsToResourceCommon(*map[string]interface{}) (*map[string]interface{}, error)
	AddTagsToResourceCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	AddTagsToResourceCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	AddTagsToResource(*AddTagsToResourceInput) (*AddTagsToResourceOutput, error)
	AddTagsToResourceWithContext(volcengine.Context, *AddTagsToResourceInput, ...request.Option) (*AddTagsToResourceOutput, error)
	AddTagsToResourceRequest(*AddTagsToResourceInput) (*request.Request, *AddTagsToResourceOutput)

	CreateInstanceCommon(*map[string]interface{}) (*map[string]interface{}, error)
	CreateInstanceCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	CreateInstanceCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	CreateInstance(*CreateInstanceInput) (*CreateInstanceOutput, error)
	CreateInstanceWithContext(volcengine.Context, *CreateInstanceInput, ...request.Option) (*CreateInstanceOutput, error)
	CreateInstanceRequest(*CreateInstanceInput) (*request.Request, *CreateInstanceOutput)

	CreatePublicAddressCommon(*map[string]interface{}) (*map[string]interface{}, error)
	CreatePublicAddressCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	CreatePublicAddressCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	CreatePublicAddress(*CreatePublicAddressInput) (*CreatePublicAddressOutput, error)
	CreatePublicAddressWithContext(volcengine.Context, *CreatePublicAddressInput, ...request.Option) (*CreatePublicAddressOutput, error)
	CreatePublicAddressRequest(*CreatePublicAddressInput) (*request.Request, *CreatePublicAddressOutput)

	CreateTopicCommon(*map[string]interface{}) (*map[string]interface{}, error)
	CreateTopicCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	CreateTopicCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	CreateTopic(*CreateTopicInput) (*CreateTopicOutput, error)
	CreateTopicWithContext(volcengine.Context, *CreateTopicInput, ...request.Option) (*CreateTopicOutput, error)
	CreateTopicRequest(*CreateTopicInput) (*request.Request, *CreateTopicOutput)

	CreateUserCommon(*map[string]interface{}) (*map[string]interface{}, error)
	CreateUserCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	CreateUserCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	CreateUser(*CreateUserInput) (*CreateUserOutput, error)
	CreateUserWithContext(volcengine.Context, *CreateUserInput, ...request.Option) (*CreateUserOutput, error)
	CreateUserRequest(*CreateUserInput) (*request.Request, *CreateUserOutput)

	DeleteGroupCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DeleteGroupCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DeleteGroupCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DeleteGroup(*DeleteGroupInput) (*DeleteGroupOutput, error)
	DeleteGroupWithContext(volcengine.Context, *DeleteGroupInput, ...request.Option) (*DeleteGroupOutput, error)
	DeleteGroupRequest(*DeleteGroupInput) (*request.Request, *DeleteGroupOutput)

	DeleteInstanceCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DeleteInstanceCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DeleteInstanceCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DeleteInstance(*DeleteInstanceInput) (*DeleteInstanceOutput, error)
	DeleteInstanceWithContext(volcengine.Context, *DeleteInstanceInput, ...request.Option) (*DeleteInstanceOutput, error)
	DeleteInstanceRequest(*DeleteInstanceInput) (*request.Request, *DeleteInstanceOutput)

	DeletePublicAddressCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DeletePublicAddressCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DeletePublicAddressCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DeletePublicAddress(*DeletePublicAddressInput) (*DeletePublicAddressOutput, error)
	DeletePublicAddressWithContext(volcengine.Context, *DeletePublicAddressInput, ...request.Option) (*DeletePublicAddressOutput, error)
	DeletePublicAddressRequest(*DeletePublicAddressInput) (*request.Request, *DeletePublicAddressOutput)

	DeleteTopicCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DeleteTopicCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DeleteTopicCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DeleteTopic(*DeleteTopicInput) (*DeleteTopicOutput, error)
	DeleteTopicWithContext(volcengine.Context, *DeleteTopicInput, ...request.Option) (*DeleteTopicOutput, error)
	DeleteTopicRequest(*DeleteTopicInput) (*request.Request, *DeleteTopicOutput)

	DeleteUserCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DeleteUserCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DeleteUserCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DeleteUser(*DeleteUserInput) (*DeleteUserOutput, error)
	DeleteUserWithContext(volcengine.Context, *DeleteUserInput, ...request.Option) (*DeleteUserOutput, error)
	DeleteUserRequest(*DeleteUserInput) (*request.Request, *DeleteUserOutput)

	DescribeAvailabilityZonesCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeAvailabilityZonesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeAvailabilityZonesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeAvailabilityZones(*DescribeAvailabilityZonesInput) (*DescribeAvailabilityZonesOutput, error)
	DescribeAvailabilityZonesWithContext(volcengine.Context, *DescribeAvailabilityZonesInput, ...request.Option) (*DescribeAvailabilityZonesOutput, error)
	DescribeAvailabilityZonesRequest(*DescribeAvailabilityZonesInput) (*request.Request, *DescribeAvailabilityZonesOutput)

	DescribeConsumedPartitionsCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeConsumedPartitionsCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeConsumedPartitionsCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeConsumedPartitions(*DescribeConsumedPartitionsInput) (*DescribeConsumedPartitionsOutput, error)
	DescribeConsumedPartitionsWithContext(volcengine.Context, *DescribeConsumedPartitionsInput, ...request.Option) (*DescribeConsumedPartitionsOutput, error)
	DescribeConsumedPartitionsRequest(*DescribeConsumedPartitionsInput) (*request.Request, *DescribeConsumedPartitionsOutput)

	DescribeConsumedTopicsCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeConsumedTopicsCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeConsumedTopicsCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeConsumedTopics(*DescribeConsumedTopicsInput) (*DescribeConsumedTopicsOutput, error)
	DescribeConsumedTopicsWithContext(volcengine.Context, *DescribeConsumedTopicsInput, ...request.Option) (*DescribeConsumedTopicsOutput, error)
	DescribeConsumedTopicsRequest(*DescribeConsumedTopicsInput) (*request.Request, *DescribeConsumedTopicsOutput)

	DescribeGroupsCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeGroupsCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeGroupsCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeGroups(*DescribeGroupsInput) (*DescribeGroupsOutput, error)
	DescribeGroupsWithContext(volcengine.Context, *DescribeGroupsInput, ...request.Option) (*DescribeGroupsOutput, error)
	DescribeGroupsRequest(*DescribeGroupsInput) (*request.Request, *DescribeGroupsOutput)

	DescribeInstanceDetailCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeInstanceDetailCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeInstanceDetailCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeInstanceDetail(*DescribeInstanceDetailInput) (*DescribeInstanceDetailOutput, error)
	DescribeInstanceDetailWithContext(volcengine.Context, *DescribeInstanceDetailInput, ...request.Option) (*DescribeInstanceDetailOutput, error)
	DescribeInstanceDetailRequest(*DescribeInstanceDetailInput) (*request.Request, *DescribeInstanceDetailOutput)

	DescribeInstancesCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeInstancesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeInstancesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeInstances(*DescribeInstancesInput) (*DescribeInstancesOutput, error)
	DescribeInstancesWithContext(volcengine.Context, *DescribeInstancesInput, ...request.Option) (*DescribeInstancesOutput, error)
	DescribeInstancesRequest(*DescribeInstancesInput) (*request.Request, *DescribeInstancesOutput)

	DescribeTopicAccessPoliciesCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeTopicAccessPoliciesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeTopicAccessPoliciesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeTopicAccessPolicies(*DescribeTopicAccessPoliciesInput) (*DescribeTopicAccessPoliciesOutput, error)
	DescribeTopicAccessPoliciesWithContext(volcengine.Context, *DescribeTopicAccessPoliciesInput, ...request.Option) (*DescribeTopicAccessPoliciesOutput, error)
	DescribeTopicAccessPoliciesRequest(*DescribeTopicAccessPoliciesInput) (*request.Request, *DescribeTopicAccessPoliciesOutput)

	DescribeTopicParametersCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeTopicParametersCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeTopicParametersCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeTopicParameters(*DescribeTopicParametersInput) (*DescribeTopicParametersOutput, error)
	DescribeTopicParametersWithContext(volcengine.Context, *DescribeTopicParametersInput, ...request.Option) (*DescribeTopicParametersOutput, error)
	DescribeTopicParametersRequest(*DescribeTopicParametersInput) (*request.Request, *DescribeTopicParametersOutput)

	DescribeTopicPartitionsCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeTopicPartitionsCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeTopicPartitionsCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeTopicPartitions(*DescribeTopicPartitionsInput) (*DescribeTopicPartitionsOutput, error)
	DescribeTopicPartitionsWithContext(volcengine.Context, *DescribeTopicPartitionsInput, ...request.Option) (*DescribeTopicPartitionsOutput, error)
	DescribeTopicPartitionsRequest(*DescribeTopicPartitionsInput) (*request.Request, *DescribeTopicPartitionsOutput)

	DescribeTopicsCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeTopicsCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeTopicsCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeTopics(*DescribeTopicsInput) (*DescribeTopicsOutput, error)
	DescribeTopicsWithContext(volcengine.Context, *DescribeTopicsInput, ...request.Option) (*DescribeTopicsOutput, error)
	DescribeTopicsRequest(*DescribeTopicsInput) (*request.Request, *DescribeTopicsOutput)

	DescribeUsersCommon(*map[string]interface{}) (*map[string]interface{}, error)
	DescribeUsersCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	DescribeUsersCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	DescribeUsers(*DescribeUsersInput) (*DescribeUsersOutput, error)
	DescribeUsersWithContext(volcengine.Context, *DescribeUsersInput, ...request.Option) (*DescribeUsersOutput, error)
	DescribeUsersRequest(*DescribeUsersInput) (*request.Request, *DescribeUsersOutput)

	ModifyInstanceAttributesCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyInstanceAttributesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyInstanceAttributesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyInstanceAttributes(*ModifyInstanceAttributesInput) (*ModifyInstanceAttributesOutput, error)
	ModifyInstanceAttributesWithContext(volcengine.Context, *ModifyInstanceAttributesInput, ...request.Option) (*ModifyInstanceAttributesOutput, error)
	ModifyInstanceAttributesRequest(*ModifyInstanceAttributesInput) (*request.Request, *ModifyInstanceAttributesOutput)

	ModifyInstanceChargeTypeCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyInstanceChargeTypeCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyInstanceChargeTypeCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyInstanceChargeType(*ModifyInstanceChargeTypeInput) (*ModifyInstanceChargeTypeOutput, error)
	ModifyInstanceChargeTypeWithContext(volcengine.Context, *ModifyInstanceChargeTypeInput, ...request.Option) (*ModifyInstanceChargeTypeOutput, error)
	ModifyInstanceChargeTypeRequest(*ModifyInstanceChargeTypeInput) (*request.Request, *ModifyInstanceChargeTypeOutput)

	ModifyInstanceParametersCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyInstanceParametersCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyInstanceParametersCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyInstanceParameters(*ModifyInstanceParametersInput) (*ModifyInstanceParametersOutput, error)
	ModifyInstanceParametersWithContext(volcengine.Context, *ModifyInstanceParametersInput, ...request.Option) (*ModifyInstanceParametersOutput, error)
	ModifyInstanceParametersRequest(*ModifyInstanceParametersInput) (*request.Request, *ModifyInstanceParametersOutput)

	ModifyInstanceSpecCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyInstanceSpecCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyInstanceSpecCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyInstanceSpec(*ModifyInstanceSpecInput) (*ModifyInstanceSpecOutput, error)
	ModifyInstanceSpecWithContext(volcengine.Context, *ModifyInstanceSpecInput, ...request.Option) (*ModifyInstanceSpecOutput, error)
	ModifyInstanceSpecRequest(*ModifyInstanceSpecInput) (*request.Request, *ModifyInstanceSpecOutput)

	ModifyTopicAccessPoliciesCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyTopicAccessPoliciesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyTopicAccessPoliciesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyTopicAccessPolicies(*ModifyTopicAccessPoliciesInput) (*ModifyTopicAccessPoliciesOutput, error)
	ModifyTopicAccessPoliciesWithContext(volcengine.Context, *ModifyTopicAccessPoliciesInput, ...request.Option) (*ModifyTopicAccessPoliciesOutput, error)
	ModifyTopicAccessPoliciesRequest(*ModifyTopicAccessPoliciesInput) (*request.Request, *ModifyTopicAccessPoliciesOutput)

	ModifyTopicAttributesCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyTopicAttributesCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyTopicAttributesCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyTopicAttributes(*ModifyTopicAttributesInput) (*ModifyTopicAttributesOutput, error)
	ModifyTopicAttributesWithContext(volcengine.Context, *ModifyTopicAttributesInput, ...request.Option) (*ModifyTopicAttributesOutput, error)
	ModifyTopicAttributesRequest(*ModifyTopicAttributesInput) (*request.Request, *ModifyTopicAttributesOutput)

	ModifyTopicParametersCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyTopicParametersCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyTopicParametersCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyTopicParameters(*ModifyTopicParametersInput) (*ModifyTopicParametersOutput, error)
	ModifyTopicParametersWithContext(volcengine.Context, *ModifyTopicParametersInput, ...request.Option) (*ModifyTopicParametersOutput, error)
	ModifyTopicParametersRequest(*ModifyTopicParametersInput) (*request.Request, *ModifyTopicParametersOutput)

	ModifyUserAuthorityCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ModifyUserAuthorityCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ModifyUserAuthorityCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ModifyUserAuthority(*ModifyUserAuthorityInput) (*ModifyUserAuthorityOutput, error)
	ModifyUserAuthorityWithContext(volcengine.Context, *ModifyUserAuthorityInput, ...request.Option) (*ModifyUserAuthorityOutput, error)
	ModifyUserAuthorityRequest(*ModifyUserAuthorityInput) (*request.Request, *ModifyUserAuthorityOutput)

	RemoveTagsFromResourceCommon(*map[string]interface{}) (*map[string]interface{}, error)
	RemoveTagsFromResourceCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	RemoveTagsFromResourceCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	RemoveTagsFromResource(*RemoveTagsFromResourceInput) (*RemoveTagsFromResourceOutput, error)
	RemoveTagsFromResourceWithContext(volcengine.Context, *RemoveTagsFromResourceInput, ...request.Option) (*RemoveTagsFromResourceOutput, error)
	RemoveTagsFromResourceRequest(*RemoveTagsFromResourceInput) (*request.Request, *RemoveTagsFromResourceOutput)

	ResetConsumedOffsetsCommon(*map[string]interface{}) (*map[string]interface{}, error)
	ResetConsumedOffsetsCommonWithContext(volcengine.Context, *map[string]interface{}, ...request.Option) (*map[string]interface{}, error)
	ResetConsumedOffsetsCommonRequest(*map[string]interface{}) (*request.Request, *map[string]interface{})

	ResetConsumedOffsets(*ResetConsumedOffsetsInput) (*ResetConsumedOffsetsOutput, error)
	ResetConsumedOffsetsWithContext(volcengine.Context, *ResetConsumedOffsetsInput, ...request.Option) (*ResetConsumedOffsetsOutput, error)
	ResetConsumedOffsetsRequest(*ResetConsumedOffsetsInput) (*request.Request, *ResetConsumedOffsetsOutput)
}

KAFKAAPI provides an interface to enable mocking the kafka.KAFKA service client's API operation, 

// volcengine sdk func uses an SDK service client to make a request to
// KAFKA.
func myFunc(svc KAFKAAPI) bool {
    // Make svc.AddTagsToResource request
}

func main() {
    sess := session.New()
    svc := kafka.New(sess)

    myFunc(svc)
}

type ModifyInstanceAttributesInput 

type ModifyInstanceAttributesInput struct {
	InstanceDescription *string `type:"string"`

	InstanceId *string `type:"string"`

	InstanceName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyInstanceAttributesInput) GoString 

func (s ModifyInstanceAttributesInput) GoString() string

GoString returns the string representation

func (*ModifyInstanceAttributesInput) SetInstanceDescription 

func (s *ModifyInstanceAttributesInput) SetInstanceDescription(v string) *ModifyInstanceAttributesInput

SetInstanceDescription sets the InstanceDescription field's value.

func (*ModifyInstanceAttributesInput) SetInstanceId 

func (s *ModifyInstanceAttributesInput) SetInstanceId(v string) *ModifyInstanceAttributesInput

SetInstanceId sets the InstanceId field's value.

func (*ModifyInstanceAttributesInput) SetInstanceName 

func (s *ModifyInstanceAttributesInput) SetInstanceName(v string) *ModifyInstanceAttributesInput

SetInstanceName sets the InstanceName field's value.

func (ModifyInstanceAttributesInput) String 

func (s ModifyInstanceAttributesInput) String() string

String returns the string representation

type ModifyInstanceAttributesOutput 

type ModifyInstanceAttributesOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (ModifyInstanceAttributesOutput) GoString 

func (s ModifyInstanceAttributesOutput) GoString() string

GoString returns the string representation

func (ModifyInstanceAttributesOutput) String 

func (s ModifyInstanceAttributesOutput) String() string

String returns the string representation

type ModifyInstanceChargeTypeInput 

type ModifyInstanceChargeTypeInput struct {
	ChargeInfo *ChargeInfoForModifyInstanceChargeTypeInput `type:"structure"`

	InstanceId *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyInstanceChargeTypeInput) GoString 

func (s ModifyInstanceChargeTypeInput) GoString() string

GoString returns the string representation

func (*ModifyInstanceChargeTypeInput) SetChargeInfo 

func (s *ModifyInstanceChargeTypeInput) SetChargeInfo(v *ChargeInfoForModifyInstanceChargeTypeInput) *ModifyInstanceChargeTypeInput

SetChargeInfo sets the ChargeInfo field's value.

func (*ModifyInstanceChargeTypeInput) SetInstanceId 

func (s *ModifyInstanceChargeTypeInput) SetInstanceId(v string) *ModifyInstanceChargeTypeInput

SetInstanceId sets the InstanceId field's value.

func (ModifyInstanceChargeTypeInput) String 

func (s ModifyInstanceChargeTypeInput) String() string

String returns the string representation

type ModifyInstanceChargeTypeOutput 

type ModifyInstanceChargeTypeOutput struct {
	Metadata *response.ResponseMetadata

	OrderId *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyInstanceChargeTypeOutput) GoString 

func (s ModifyInstanceChargeTypeOutput) GoString() string

GoString returns the string representation

func (*ModifyInstanceChargeTypeOutput) SetOrderId 

func (s *ModifyInstanceChargeTypeOutput) SetOrderId(v string) *ModifyInstanceChargeTypeOutput

SetOrderId sets the OrderId field's value.

func (ModifyInstanceChargeTypeOutput) String 

func (s ModifyInstanceChargeTypeOutput) String() string

String returns the string representation

type ModifyInstanceParametersInput 

type ModifyInstanceParametersInput struct {
	InstanceId *string `type:"string"`

	Parameters *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyInstanceParametersInput) GoString 

func (s ModifyInstanceParametersInput) GoString() string

GoString returns the string representation

func (*ModifyInstanceParametersInput) SetInstanceId 

func (s *ModifyInstanceParametersInput) SetInstanceId(v string) *ModifyInstanceParametersInput

SetInstanceId sets the InstanceId field's value.

func (*ModifyInstanceParametersInput) SetParameters 

func (s *ModifyInstanceParametersInput) SetParameters(v string) *ModifyInstanceParametersInput

SetParameters sets the Parameters field's value.

func (ModifyInstanceParametersInput) String 

func (s ModifyInstanceParametersInput) String() string

String returns the string representation

type ModifyInstanceParametersOutput 

type ModifyInstanceParametersOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (ModifyInstanceParametersOutput) GoString 

func (s ModifyInstanceParametersOutput) GoString() string

GoString returns the string representation

func (ModifyInstanceParametersOutput) String 

func (s ModifyInstanceParametersOutput) String() string

String returns the string representation

type ModifyInstanceSpecInput 

type ModifyInstanceSpecInput struct {
	ComputeSpec *string `type:"string"`

	InstanceId *string `type:"string"`

	NeedRebalance *bool `type:"boolean"`

	PartitionNumber *int32 `type:"int32"`

	RebalanceTime *string `type:"string"`

	StorageSpace *int32 `type:"int32"`
	// contains filtered or unexported fields
}

func (ModifyInstanceSpecInput) GoString 

func (s ModifyInstanceSpecInput) GoString() string

GoString returns the string representation

func (*ModifyInstanceSpecInput) SetComputeSpec 

func (s *ModifyInstanceSpecInput) SetComputeSpec(v string) *ModifyInstanceSpecInput

SetComputeSpec sets the ComputeSpec field's value.

func (*ModifyInstanceSpecInput) SetInstanceId 

func (s *ModifyInstanceSpecInput) SetInstanceId(v string) *ModifyInstanceSpecInput

SetInstanceId sets the InstanceId field's value.

func (*ModifyInstanceSpecInput) SetNeedRebalance 

func (s *ModifyInstanceSpecInput) SetNeedRebalance(v bool) *ModifyInstanceSpecInput

SetNeedRebalance sets the NeedRebalance field's value.

func (*ModifyInstanceSpecInput) SetPartitionNumber 

func (s *ModifyInstanceSpecInput) SetPartitionNumber(v int32) *ModifyInstanceSpecInput

SetPartitionNumber sets the PartitionNumber field's value.

func (*ModifyInstanceSpecInput) SetRebalanceTime 

func (s *ModifyInstanceSpecInput) SetRebalanceTime(v string) *ModifyInstanceSpecInput

SetRebalanceTime sets the RebalanceTime field's value.

func (*ModifyInstanceSpecInput) SetStorageSpace 

func (s *ModifyInstanceSpecInput) SetStorageSpace(v int32) *ModifyInstanceSpecInput

SetStorageSpace sets the StorageSpace field's value.

func (ModifyInstanceSpecInput) String 

func (s ModifyInstanceSpecInput) String() string

String returns the string representation

type ModifyInstanceSpecOutput 

type ModifyInstanceSpecOutput struct {
	Metadata *response.ResponseMetadata

	OrderId *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyInstanceSpecOutput) GoString 

func (s ModifyInstanceSpecOutput) GoString() string

GoString returns the string representation

func (*ModifyInstanceSpecOutput) SetOrderId 

func (s *ModifyInstanceSpecOutput) SetOrderId(v string) *ModifyInstanceSpecOutput

SetOrderId sets the OrderId field's value.

func (ModifyInstanceSpecOutput) String 

func (s ModifyInstanceSpecOutput) String() string

String returns the string representation

type ModifyTopicAccessPoliciesInput 

type ModifyTopicAccessPoliciesInput struct {
	AccessPolicies []*AccessPolicyForModifyTopicAccessPoliciesInput `type:"list"`

	AllAuthority *bool `type:"boolean"`

	DeletePolicies []*string `type:"list"`

	InstanceId *string `type:"string"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyTopicAccessPoliciesInput) GoString 

func (s ModifyTopicAccessPoliciesInput) GoString() string

GoString returns the string representation

func (*ModifyTopicAccessPoliciesInput) SetAccessPolicies 

func (s *ModifyTopicAccessPoliciesInput) SetAccessPolicies(v []*AccessPolicyForModifyTopicAccessPoliciesInput) *ModifyTopicAccessPoliciesInput

SetAccessPolicies sets the AccessPolicies field's value.

func (*ModifyTopicAccessPoliciesInput) SetAllAuthority 

func (s *ModifyTopicAccessPoliciesInput) SetAllAuthority(v bool) *ModifyTopicAccessPoliciesInput

SetAllAuthority sets the AllAuthority field's value.

func (*ModifyTopicAccessPoliciesInput) SetDeletePolicies 

func (s *ModifyTopicAccessPoliciesInput) SetDeletePolicies(v []*string) *ModifyTopicAccessPoliciesInput

SetDeletePolicies sets the DeletePolicies field's value.

func (*ModifyTopicAccessPoliciesInput) SetInstanceId 

func (s *ModifyTopicAccessPoliciesInput) SetInstanceId(v string) *ModifyTopicAccessPoliciesInput

SetInstanceId sets the InstanceId field's value.

func (*ModifyTopicAccessPoliciesInput) SetTopicName 

func (s *ModifyTopicAccessPoliciesInput) SetTopicName(v string) *ModifyTopicAccessPoliciesInput

SetTopicName sets the TopicName field's value.

func (ModifyTopicAccessPoliciesInput) String 

func (s ModifyTopicAccessPoliciesInput) String() string

String returns the string representation

type ModifyTopicAccessPoliciesOutput 

type ModifyTopicAccessPoliciesOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (ModifyTopicAccessPoliciesOutput) GoString 

func (s ModifyTopicAccessPoliciesOutput) GoString() string

GoString returns the string representation

func (ModifyTopicAccessPoliciesOutput) String 

func (s ModifyTopicAccessPoliciesOutput) String() string

String returns the string representation

type ModifyTopicAttributesInput 

type ModifyTopicAttributesInput struct {
	Description *string `type:"string"`

	InstanceId *string `type:"string"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyTopicAttributesInput) GoString 

func (s ModifyTopicAttributesInput) GoString() string

GoString returns the string representation

func (*ModifyTopicAttributesInput) SetDescription 

func (s *ModifyTopicAttributesInput) SetDescription(v string) *ModifyTopicAttributesInput

SetDescription sets the Description field's value.

func (*ModifyTopicAttributesInput) SetInstanceId 

func (s *ModifyTopicAttributesInput) SetInstanceId(v string) *ModifyTopicAttributesInput

SetInstanceId sets the InstanceId field's value.

func (*ModifyTopicAttributesInput) SetTopicName 

func (s *ModifyTopicAttributesInput) SetTopicName(v string) *ModifyTopicAttributesInput

SetTopicName sets the TopicName field's value.

func (ModifyTopicAttributesInput) String 

func (s ModifyTopicAttributesInput) String() string

String returns the string representation

type ModifyTopicAttributesOutput 

type ModifyTopicAttributesOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (ModifyTopicAttributesOutput) GoString 

func (s ModifyTopicAttributesOutput) GoString() string

GoString returns the string representation

func (ModifyTopicAttributesOutput) String 

func (s ModifyTopicAttributesOutput) String() string

String returns the string representation

type ModifyTopicParametersInput 

type ModifyTopicParametersInput struct {
	InnerParameters *InnerParametersForModifyTopicParametersInput `type:"structure"`

	InstanceId *string `type:"string"`

	Parameters *string `type:"string"`

	PartitionNumber *int32 `type:"int32"`

	ReplicaNumber *int32 `type:"int32"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyTopicParametersInput) GoString 

func (s ModifyTopicParametersInput) GoString() string

GoString returns the string representation

func (*ModifyTopicParametersInput) SetInnerParameters 

func (s *ModifyTopicParametersInput) SetInnerParameters(v *InnerParametersForModifyTopicParametersInput) *ModifyTopicParametersInput

SetInnerParameters sets the InnerParameters field's value.

func (*ModifyTopicParametersInput) SetInstanceId 

func (s *ModifyTopicParametersInput) SetInstanceId(v string) *ModifyTopicParametersInput

SetInstanceId sets the InstanceId field's value.

func (*ModifyTopicParametersInput) SetParameters 

func (s *ModifyTopicParametersInput) SetParameters(v string) *ModifyTopicParametersInput

SetParameters sets the Parameters field's value.

func (*ModifyTopicParametersInput) SetPartitionNumber 

func (s *ModifyTopicParametersInput) SetPartitionNumber(v int32) *ModifyTopicParametersInput

SetPartitionNumber sets the PartitionNumber field's value.

func (*ModifyTopicParametersInput) SetReplicaNumber 

func (s *ModifyTopicParametersInput) SetReplicaNumber(v int32) *ModifyTopicParametersInput

SetReplicaNumber sets the ReplicaNumber field's value.

func (*ModifyTopicParametersInput) SetTopicName 

func (s *ModifyTopicParametersInput) SetTopicName(v string) *ModifyTopicParametersInput

SetTopicName sets the TopicName field's value.

func (ModifyTopicParametersInput) String 

func (s ModifyTopicParametersInput) String() string

String returns the string representation

type ModifyTopicParametersOutput 

type ModifyTopicParametersOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (ModifyTopicParametersOutput) GoString 

func (s ModifyTopicParametersOutput) GoString() string

GoString returns the string representation

func (ModifyTopicParametersOutput) String 

func (s ModifyTopicParametersOutput) String() string

String returns the string representation

type ModifyUserAuthorityInput 

type ModifyUserAuthorityInput struct {
	AllAuthority *bool `type:"boolean"`

	InstanceId *string `type:"string"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ModifyUserAuthorityInput) GoString 

func (s ModifyUserAuthorityInput) GoString() string

GoString returns the string representation

func (*ModifyUserAuthorityInput) SetAllAuthority 

func (s *ModifyUserAuthorityInput) SetAllAuthority(v bool) *ModifyUserAuthorityInput

SetAllAuthority sets the AllAuthority field's value.

func (*ModifyUserAuthorityInput) SetInstanceId 

func (s *ModifyUserAuthorityInput) SetInstanceId(v string) *ModifyUserAuthorityInput

SetInstanceId sets the InstanceId field's value.

func (*ModifyUserAuthorityInput) SetUserName 

func (s *ModifyUserAuthorityInput) SetUserName(v string) *ModifyUserAuthorityInput

SetUserName sets the UserName field's value.

func (ModifyUserAuthorityInput) String 

func (s ModifyUserAuthorityInput) String() string

String returns the string representation

type ModifyUserAuthorityOutput 

type ModifyUserAuthorityOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (ModifyUserAuthorityOutput) GoString 

func (s ModifyUserAuthorityOutput) GoString() string

GoString returns the string representation

func (ModifyUserAuthorityOutput) String 

func (s ModifyUserAuthorityOutput) String() string

String returns the string representation

type PartitionsInfoForDescribeTopicPartitionsOutput 

type PartitionsInfoForDescribeTopicPartitionsOutput struct {
	EndOffset *int64 `type:"int64"`

	InsyncReplicas []*int64 `type:"list"`

	Leader *int32 `type:"int32"`

	MessageCount *int64 `type:"int64"`

	PartitionId *int32 `type:"int32"`

	Replicas []*int64 `type:"list"`

	StartOffset *int64 `type:"int64"`

	UnderInsyncReplicas []*int64 `type:"list"`
	// contains filtered or unexported fields
}

func (PartitionsInfoForDescribeTopicPartitionsOutput) GoString 

func (s PartitionsInfoForDescribeTopicPartitionsOutput) GoString() string

GoString returns the string representation

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetEndOffset 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetEndOffset(v int64) *PartitionsInfoForDescribeTopicPartitionsOutput

SetEndOffset sets the EndOffset field's value.

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetInsyncReplicas 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetInsyncReplicas(v []*int64) *PartitionsInfoForDescribeTopicPartitionsOutput

SetInsyncReplicas sets the InsyncReplicas field's value.

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetLeader 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetLeader(v int32) *PartitionsInfoForDescribeTopicPartitionsOutput

SetLeader sets the Leader field's value.

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetMessageCount 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetMessageCount(v int64) *PartitionsInfoForDescribeTopicPartitionsOutput

SetMessageCount sets the MessageCount field's value.

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetPartitionId 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetPartitionId(v int32) *PartitionsInfoForDescribeTopicPartitionsOutput

SetPartitionId sets the PartitionId field's value.

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetReplicas 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetReplicas(v []*int64) *PartitionsInfoForDescribeTopicPartitionsOutput

SetReplicas sets the Replicas field's value.

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetStartOffset 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetStartOffset(v int64) *PartitionsInfoForDescribeTopicPartitionsOutput

SetStartOffset sets the StartOffset field's value.

func (*PartitionsInfoForDescribeTopicPartitionsOutput) SetUnderInsyncReplicas 

func (s *PartitionsInfoForDescribeTopicPartitionsOutput) SetUnderInsyncReplicas(v []*int64) *PartitionsInfoForDescribeTopicPartitionsOutput

SetUnderInsyncReplicas sets the UnderInsyncReplicas field's value.

func (PartitionsInfoForDescribeTopicPartitionsOutput) String 

func (s PartitionsInfoForDescribeTopicPartitionsOutput) String() string

String returns the string representation

type RemoveTagsFromResourceInput 

type RemoveTagsFromResourceInput struct {
	All *bool `type:"boolean"`

	InstanceIds []*string `type:"list"`

	TagKeys []*string `type:"list"`
	// contains filtered or unexported fields
}

func (RemoveTagsFromResourceInput) GoString 

func (s RemoveTagsFromResourceInput) GoString() string

GoString returns the string representation

func (*RemoveTagsFromResourceInput) SetAll 

func (s *RemoveTagsFromResourceInput) SetAll(v bool) *RemoveTagsFromResourceInput

SetAll sets the All field's value.

func (*RemoveTagsFromResourceInput) SetInstanceIds 

func (s *RemoveTagsFromResourceInput) SetInstanceIds(v []*string) *RemoveTagsFromResourceInput

SetInstanceIds sets the InstanceIds field's value.

func (*RemoveTagsFromResourceInput) SetTagKeys 

func (s *RemoveTagsFromResourceInput) SetTagKeys(v []*string) *RemoveTagsFromResourceInput

SetTagKeys sets the TagKeys field's value.

func (RemoveTagsFromResourceInput) String 

func (s RemoveTagsFromResourceInput) String() string

String returns the string representation

type RemoveTagsFromResourceOutput 

type RemoveTagsFromResourceOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (RemoveTagsFromResourceOutput) GoString 

func (s RemoveTagsFromResourceOutput) GoString() string

GoString returns the string representation

func (RemoveTagsFromResourceOutput) String 

func (s RemoveTagsFromResourceOutput) String() string

String returns the string representation

type ResetConsumedOffsetsInput 

type ResetConsumedOffsetsInput struct {
	GroupId *string `type:"string"`

	InstanceId *string `type:"string"`

	ResetOffsetsInfo []*ResetOffsetsInfoForResetConsumedOffsetsInput `type:"list"`
	// contains filtered or unexported fields
}

func (ResetConsumedOffsetsInput) GoString 

func (s ResetConsumedOffsetsInput) GoString() string

GoString returns the string representation

func (*ResetConsumedOffsetsInput) SetGroupId 

func (s *ResetConsumedOffsetsInput) SetGroupId(v string) *ResetConsumedOffsetsInput

SetGroupId sets the GroupId field's value.

func (*ResetConsumedOffsetsInput) SetInstanceId 

func (s *ResetConsumedOffsetsInput) SetInstanceId(v string) *ResetConsumedOffsetsInput

SetInstanceId sets the InstanceId field's value.

func (*ResetConsumedOffsetsInput) SetResetOffsetsInfo 

func (s *ResetConsumedOffsetsInput) SetResetOffsetsInfo(v []*ResetOffsetsInfoForResetConsumedOffsetsInput) *ResetConsumedOffsetsInput

SetResetOffsetsInfo sets the ResetOffsetsInfo field's value.

func (ResetConsumedOffsetsInput) String 

func (s ResetConsumedOffsetsInput) String() string

String returns the string representation

type ResetConsumedOffsetsOutput 

type ResetConsumedOffsetsOutput struct {
	Metadata *response.ResponseMetadata
	// contains filtered or unexported fields
}

func (ResetConsumedOffsetsOutput) GoString 

func (s ResetConsumedOffsetsOutput) GoString() string

GoString returns the string representation

func (ResetConsumedOffsetsOutput) String 

func (s ResetConsumedOffsetsOutput) String() string

String returns the string representation

type ResetOffsetsInfoForResetConsumedOffsetsInput 

type ResetOffsetsInfoForResetConsumedOffsetsInput struct {
	PartitionId *int32 `type:"int32"`

	ResetOffset *int64 `type:"int64"`

	ResetTimestamp *int64 `type:"int64"`

	ResetType *string `type:"string"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ResetOffsetsInfoForResetConsumedOffsetsInput) GoString 

func (s ResetOffsetsInfoForResetConsumedOffsetsInput) GoString() string

GoString returns the string representation

func (*ResetOffsetsInfoForResetConsumedOffsetsInput) SetPartitionId 

func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetPartitionId(v int32) *ResetOffsetsInfoForResetConsumedOffsetsInput

SetPartitionId sets the PartitionId field's value.

func (*ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetOffset 

func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetOffset(v int64) *ResetOffsetsInfoForResetConsumedOffsetsInput

SetResetOffset sets the ResetOffset field's value.

func (*ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetTimestamp 

func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetTimestamp(v int64) *ResetOffsetsInfoForResetConsumedOffsetsInput

SetResetTimestamp sets the ResetTimestamp field's value.

func (*ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetType 

func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetResetType(v string) *ResetOffsetsInfoForResetConsumedOffsetsInput

SetResetType sets the ResetType field's value.

func (*ResetOffsetsInfoForResetConsumedOffsetsInput) SetTopicName 

func (s *ResetOffsetsInfoForResetConsumedOffsetsInput) SetTopicName(v string) *ResetOffsetsInfoForResetConsumedOffsetsInput

SetTopicName sets the TopicName field's value.

func (ResetOffsetsInfoForResetConsumedOffsetsInput) String 

func (s ResetOffsetsInfoForResetConsumedOffsetsInput) String() string

String returns the string representation

type TagForAddTagsToResourceInput 

type TagForAddTagsToResourceInput struct {
	Key *string `type:"string"`

	Value *string `type:"string"`
	// contains filtered or unexported fields
}

func (TagForAddTagsToResourceInput) GoString 

func (s TagForAddTagsToResourceInput) GoString() string

GoString returns the string representation

func (*TagForAddTagsToResourceInput) SetKey 

func (s *TagForAddTagsToResourceInput) SetKey(v string) *TagForAddTagsToResourceInput

SetKey sets the Key field's value.

func (*TagForAddTagsToResourceInput) SetValue 

func (s *TagForAddTagsToResourceInput) SetValue(v string) *TagForAddTagsToResourceInput

SetValue sets the Value field's value.

func (TagForAddTagsToResourceInput) String 

func (s TagForAddTagsToResourceInput) String() string

String returns the string representation

type TopicsInfoForDescribeTopicsOutput 

type TopicsInfoForDescribeTopicsOutput struct {
	CreateTime *string `type:"string"`

	Description *string `type:"string"`

	PartitionNumber *int32 `type:"int32"`

	ReplicaNumber *int32 `type:"int32"`

	Status *string `type:"string"`

	TopicName *string `type:"string"`
	// contains filtered or unexported fields
}

func (TopicsInfoForDescribeTopicsOutput) GoString 

func (s TopicsInfoForDescribeTopicsOutput) GoString() string

GoString returns the string representation

func (*TopicsInfoForDescribeTopicsOutput) SetCreateTime 

func (s *TopicsInfoForDescribeTopicsOutput) SetCreateTime(v string) *TopicsInfoForDescribeTopicsOutput

SetCreateTime sets the CreateTime field's value.

func (*TopicsInfoForDescribeTopicsOutput) SetDescription 

func (s *TopicsInfoForDescribeTopicsOutput) SetDescription(v string) *TopicsInfoForDescribeTopicsOutput

SetDescription sets the Description field's value.

func (*TopicsInfoForDescribeTopicsOutput) SetPartitionNumber 

func (s *TopicsInfoForDescribeTopicsOutput) SetPartitionNumber(v int32) *TopicsInfoForDescribeTopicsOutput

SetPartitionNumber sets the PartitionNumber field's value.

func (*TopicsInfoForDescribeTopicsOutput) SetReplicaNumber 

func (s *TopicsInfoForDescribeTopicsOutput) SetReplicaNumber(v int32) *TopicsInfoForDescribeTopicsOutput

SetReplicaNumber sets the ReplicaNumber field's value.

func (*TopicsInfoForDescribeTopicsOutput) SetStatus 

func (s *TopicsInfoForDescribeTopicsOutput) SetStatus(v string) *TopicsInfoForDescribeTopicsOutput

SetStatus sets the Status field's value.

func (*TopicsInfoForDescribeTopicsOutput) SetTopicName 

func (s *TopicsInfoForDescribeTopicsOutput) SetTopicName(v string) *TopicsInfoForDescribeTopicsOutput

SetTopicName sets the TopicName field's value.

func (TopicsInfoForDescribeTopicsOutput) String 

func (s TopicsInfoForDescribeTopicsOutput) String() string

String returns the string representation

type UsersInfoForDescribeUsersOutput 

type UsersInfoForDescribeUsersOutput struct {
	AllAuthority *bool `type:"boolean"`

	CreateTime *string `type:"string"`

	Description *string `type:"string"`

	PasswordType *string `type:"string"`

	UserName *string `type:"string"`
	// contains filtered or unexported fields
}

func (UsersInfoForDescribeUsersOutput) GoString 

func (s UsersInfoForDescribeUsersOutput) GoString() string

GoString returns the string representation

func (*UsersInfoForDescribeUsersOutput) SetAllAuthority 

func (s *UsersInfoForDescribeUsersOutput) SetAllAuthority(v bool) *UsersInfoForDescribeUsersOutput

SetAllAuthority sets the AllAuthority field's value.

func (*UsersInfoForDescribeUsersOutput) SetCreateTime 

func (s *UsersInfoForDescribeUsersOutput) SetCreateTime(v string) *UsersInfoForDescribeUsersOutput

SetCreateTime sets the CreateTime field's value.

func (*UsersInfoForDescribeUsersOutput) SetDescription 

func (s *UsersInfoForDescribeUsersOutput) SetDescription(v string) *UsersInfoForDescribeUsersOutput

SetDescription sets the Description field's value.

func (*UsersInfoForDescribeUsersOutput) SetPasswordType 

func (s *UsersInfoForDescribeUsersOutput) SetPasswordType(v string) *UsersInfoForDescribeUsersOutput

SetPasswordType sets the PasswordType field's value.

func (*UsersInfoForDescribeUsersOutput) SetUserName 

func (s *UsersInfoForDescribeUsersOutput) SetUserName(v string) *UsersInfoForDescribeUsersOutput

SetUserName sets the UserName field's value.

func (UsersInfoForDescribeUsersOutput) String 

func (s UsersInfoForDescribeUsersOutput) String() string

String returns the string representation

type ZoneForDescribeAvailabilityZonesOutput 

type ZoneForDescribeAvailabilityZonesOutput struct {
	Description *string `type:"string"`

	ZoneId *string `type:"string"`

	ZoneName *string `type:"string"`
	// contains filtered or unexported fields
}

func (ZoneForDescribeAvailabilityZonesOutput) GoString 

func (s ZoneForDescribeAvailabilityZonesOutput) GoString() string

GoString returns the string representation

func (*ZoneForDescribeAvailabilityZonesOutput) SetDescription 

func (s *ZoneForDescribeAvailabilityZonesOutput) SetDescription(v string) *ZoneForDescribeAvailabilityZonesOutput

SetDescription sets the Description field's value.

func (*ZoneForDescribeAvailabilityZonesOutput) SetZoneId 

func (s *ZoneForDescribeAvailabilityZonesOutput) SetZoneId(v string) *ZoneForDescribeAvailabilityZonesOutput

SetZoneId sets the ZoneId field's value.

func (*ZoneForDescribeAvailabilityZonesOutput) SetZoneName 

func (s *ZoneForDescribeAvailabilityZonesOutput) SetZoneName(v string) *ZoneForDescribeAvailabilityZonesOutput

SetZoneName sets the ZoneName field's value.

func (ZoneForDescribeAvailabilityZonesOutput) String 

func (s ZoneForDescribeAvailabilityZonesOutput) String() string

String returns the string representation

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.