client

Documentation

Index

• type StreambusClient
  • func NewStreambusClient(credential *core.Credential) *StreambusClient
  • func (c *StreambusClient) AddTopic(request *streambus.AddTopicRequest) (*streambus.AddTopicResponse, error)
  • func (c *StreambusClient) CreateConsumerGroup(request *streambus.CreateConsumerGroupRequest) (*streambus.CreateConsumerGroupResponse, error)
  • func (c *StreambusClient) DeleteConsumerGroup(request *streambus.DeleteConsumerGroupRequest) (*streambus.DeleteConsumerGroupResponse, error)
  • func (c *StreambusClient) DeleteTopic(request *streambus.DeleteTopicRequest) (*streambus.DeleteTopicResponse, error)
  • func (c *StreambusClient) DescribeTopic(request *streambus.DescribeTopicRequest) (*streambus.DescribeTopicResponse, error)
  • func (c *StreambusClient) GetConsumerGroupList(request *streambus.GetConsumerGroupListRequest) (*streambus.GetConsumerGroupListResponse, error)
  • func (c *StreambusClient) GetTopicList(request *streambus.GetTopicListRequest) (*streambus.GetTopicListResponse, error)
  • func (c *StreambusClient) SetConfig(config *core.Config)
  • func (c *StreambusClient) SetLogger(logger core.Logger)
  • func (c *StreambusClient) UpdateTopic(request *streambus.UpdateTopicRequest) (*streambus.UpdateTopicResponse, error)

Types

type StreambusClient

type StreambusClient struct {
	core.JDCloudClient
}

func NewStreambusClient

func NewStreambusClient(credential *core.Credential) *StreambusClient

func (*StreambusClient) AddTopic

func (c *StreambusClient) AddTopic(request *streambus.AddTopicRequest) (*streambus.AddTopicResponse, error)

创建topic时，topicModel中只需要传topic参数，另外两个参数可为空

func (*StreambusClient) CreateConsumerGroup

func (c *StreambusClient) CreateConsumerGroup(request *streambus.CreateConsumerGroupRequest) (*streambus.CreateConsumerGroupResponse, error)

创建consumerGroupName

func (*StreambusClient) DeleteConsumerGroup

func (c *StreambusClient) DeleteConsumerGroup(request *streambus.DeleteConsumerGroupRequest) (*streambus.DeleteConsumerGroupResponse, error)

删除consumerGroupName

func (*StreambusClient) DeleteTopic

func (c *StreambusClient) DeleteTopic(request *streambus.DeleteTopicRequest) (*streambus.DeleteTopicResponse, error)

删除topic

func (*StreambusClient) DescribeTopic

func (c *StreambusClient) DescribeTopic(request *streambus.DescribeTopicRequest) (*streambus.DescribeTopicResponse, error)

查询指定主题,如果已归档会返回归档信息

func (*StreambusClient) GetConsumerGroupList

func (c *StreambusClient) GetConsumerGroupList(request *streambus.GetConsumerGroupListRequest) (*streambus.GetConsumerGroupListResponse, error)

查看指定主题的所有消费组

func (*StreambusClient) GetTopicList

func (c *StreambusClient) GetTopicList(request *streambus.GetTopicListRequest) (*streambus.GetTopicListResponse, error)

查询topic列表，返回topic的集合

func (*StreambusClient) SetConfig

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

func (*StreambusClient) SetLogger

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

func (*StreambusClient) UpdateTopic

func (c *StreambusClient) UpdateTopic(request *streambus.UpdateTopicRequest) (*streambus.UpdateTopicResponse, error)

此接口可以用来更新主题，创建归档，修改归档，删除归档，传入不同的参数可以实现不同的功能。修改归档只需要修改相应归档的参数，删除归档只需要把归档参数置为空即可