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

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

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)

更新topic