client

Documentation

Index

• type StreambusClient
  • func NewStreambusClient(credential *core.Credential) *StreambusClient
  • func (c *StreambusClient) AddTopic(request *streambus.AddTopicRequest) (*streambus.AddTopicResponse, 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) 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