client

Documentation

Index

• type KafkaClient
  • func NewKafkaClient(credential *core.Credential) *KafkaClient
  • func (c *KafkaClient) CreateInstance(request *kafka.CreateInstanceRequest) (*kafka.CreateInstanceResponse, error)
  • func (c *KafkaClient) DeleteInstance(request *kafka.DeleteInstanceRequest) (*kafka.DeleteInstanceResponse, error)
  • func (c *KafkaClient) DescribeInstance(request *kafka.DescribeInstanceRequest) (*kafka.DescribeInstanceResponse, error)
  • func (c *KafkaClient) DescribeInstances(request *kafka.DescribeInstancesRequest) (*kafka.DescribeInstancesResponse, error)
  • func (c *KafkaClient) DisableLogger()
  • func (c *KafkaClient) ModifyInstanceSpec(request *kafka.ModifyInstanceSpecRequest) (*kafka.ModifyInstanceSpecResponse, error)
  • func (c *KafkaClient) SetConfig(config *core.Config)
  • func (c *KafkaClient) SetLogger(logger core.Logger)

Types

type KafkaClient

type KafkaClient struct {
	core.JDCloudClient
}

func NewKafkaClient

func NewKafkaClient(credential *core.Credential) *KafkaClient

func (*KafkaClient) CreateInstance

func (c *KafkaClient) CreateInstance(request *kafka.CreateInstanceRequest) (*kafka.CreateInstanceResponse, error)

创建一个指定配置的kafka实例

func (*KafkaClient) DeleteInstance

func (c *KafkaClient) DeleteInstance(request *kafka.DeleteInstanceRequest) (*kafka.DeleteInstanceResponse, error)

删除按配置计费或包年包月已到期的kafka实例，包年包月未到期不可删除。

状态为创建中和变配中的不可删除。

func (*KafkaClient) DescribeInstance

func (c *KafkaClient) DescribeInstance(request *kafka.DescribeInstanceRequest) (*kafka.DescribeInstanceResponse, error)

查询kafka实例的详细信息

func (*KafkaClient) DescribeInstances

func (c *KafkaClient) DescribeInstances(request *kafka.DescribeInstancesRequest) (*kafka.DescribeInstancesResponse, error)

查询kafka实例列表

func (*KafkaClient) DisableLogger

func (c *KafkaClient) DisableLogger()

func (*KafkaClient) ModifyInstanceSpec

func (c *KafkaClient) ModifyInstanceSpec(request *kafka.ModifyInstanceSpecRequest) (*kafka.ModifyInstanceSpecResponse, error)

变更kafka实例的配置，实例为running状态才可变更配置

func (*KafkaClient) SetConfig

func (c *KafkaClient) SetConfig(config *core.Config)

func (*KafkaClient) SetLogger

func (c *KafkaClient) SetLogger(logger core.Logger)