apis

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2022 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddTopicRequest 

type AddTopicRequest struct {
	core.JDCloudRequest

	/* 地域ID  */
	RegionId string `json:"regionId"`

	/* 示例：{"topicModel":{"topic":{"archived":0,"id":"","name":"create","remark":"备注","shardNum":1,"partitionNum":2,"lifecycle":3}}}  */
	TopicModel *streambus.TopicModel `json:"topicModel"`
}

func NewAddTopicRequest 

func NewAddTopicRequest(
	regionId string,
	topicModel *streambus.TopicModel,
) *AddTopicRequest

* param regionId: 地域ID (Required) * param topicModel: 示例：{"topicModel":{"topic":{"archived":0,"id":"","name":"create","remark":"备注","shardNum":1,"partitionNum":2,"lifecycle":3}}} (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewAddTopicRequestWithAllParams 

func NewAddTopicRequestWithAllParams(
	regionId string,
	topicModel *streambus.TopicModel,
) *AddTopicRequest

* param regionId: 地域ID (Required) * param topicModel: 示例：{"topicModel":{"topic":{"archived":0,"id":"","name":"create","remark":"备注","shardNum":1,"partitionNum":2,"lifecycle":3}}} (Required)

func NewAddTopicRequestWithoutParam 

func NewAddTopicRequestWithoutParam() *AddTopicRequest

This constructor has better compatible ability when API parameters changed

func (AddTopicRequest) GetRegionId 

func (r AddTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*AddTopicRequest) SetRegionId 

func (r *AddTopicRequest) SetRegionId(regionId string)

param regionId: 地域ID(Required)

func (*AddTopicRequest) SetTopicModel 

func (r *AddTopicRequest) SetTopicModel(topicModel *streambus.TopicModel)

param topicModel: 示例：{"topicModel":{"topic":{"archived":0,"id":"","name":"create","remark":"备注","shardNum":1,"partitionNum":2,"lifecycle":3}}}(Required)

type AddTopicResponse 

type AddTopicResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    AddTopicResult     `json:"result"`
}

type AddTopicResult 

type AddTopicResult struct {
	Status  bool   `json:"status"`
	Message string `json:"message"`
}

type CreateConsumerGroupRequest 

type CreateConsumerGroupRequest struct {
	core.JDCloudRequest

	/* Region ID  */
	RegionId string `json:"regionId"`

	/* 消费组对象 (Optional) */
	ConsumerGroupStr *streambus.ConsumerGroup `json:"consumerGroupStr"`
}

func NewCreateConsumerGroupRequest 

func NewCreateConsumerGroupRequest(
	regionId string,
) *CreateConsumerGroupRequest

* param regionId: Region ID (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewCreateConsumerGroupRequestWithAllParams 

func NewCreateConsumerGroupRequestWithAllParams(
	regionId string,
	consumerGroupStr *streambus.ConsumerGroup,
) *CreateConsumerGroupRequest

* param regionId: Region ID (Required) * param consumerGroupStr: 消费组对象 (Optional)

func NewCreateConsumerGroupRequestWithoutParam 

func NewCreateConsumerGroupRequestWithoutParam() *CreateConsumerGroupRequest

This constructor has better compatible ability when API parameters changed

func (CreateConsumerGroupRequest) GetRegionId 

func (r CreateConsumerGroupRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*CreateConsumerGroupRequest) SetConsumerGroupStr 

func (r *CreateConsumerGroupRequest) SetConsumerGroupStr(consumerGroupStr *streambus.ConsumerGroup)

param consumerGroupStr: 消费组对象(Optional)

func (*CreateConsumerGroupRequest) SetRegionId 

func (r *CreateConsumerGroupRequest) SetRegionId(regionId string)

param regionId: Region ID(Required)

type CreateConsumerGroupResponse 

type CreateConsumerGroupResponse struct {
	RequestID string                    `json:"requestId"`
	Error     core.ErrorResponse        `json:"error"`
	Result    CreateConsumerGroupResult `json:"result"`
}

type CreateConsumerGroupResult 

type CreateConsumerGroupResult struct {
	Message string `json:"message"`
	Status  bool   `json:"status"`
}

type DeleteConsumerGroupRequest 

type DeleteConsumerGroupRequest struct {
	core.JDCloudRequest

	/* Region ID  */
	RegionId string `json:"regionId"`

	/* 主题ID  */
	TopicId int `json:"topicId"`

	/* 消费组ID  */
	ConsumerGroupId int `json:"consumerGroupId"`
}

func NewDeleteConsumerGroupRequest 

func NewDeleteConsumerGroupRequest(
	regionId string,
	topicId int,
	consumerGroupId int,
) *DeleteConsumerGroupRequest

* param regionId: Region ID (Required) * param topicId: 主题ID (Required) * param consumerGroupId: 消费组ID (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDeleteConsumerGroupRequestWithAllParams 

func NewDeleteConsumerGroupRequestWithAllParams(
	regionId string,
	topicId int,
	consumerGroupId int,
) *DeleteConsumerGroupRequest

* param regionId: Region ID (Required) * param topicId: 主题ID (Required) * param consumerGroupId: 消费组ID (Required)

func NewDeleteConsumerGroupRequestWithoutParam 

func NewDeleteConsumerGroupRequestWithoutParam() *DeleteConsumerGroupRequest

This constructor has better compatible ability when API parameters changed

func (DeleteConsumerGroupRequest) GetRegionId 

func (r DeleteConsumerGroupRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DeleteConsumerGroupRequest) SetConsumerGroupId 

func (r *DeleteConsumerGroupRequest) SetConsumerGroupId(consumerGroupId int)

param consumerGroupId: 消费组ID(Required)

func (*DeleteConsumerGroupRequest) SetRegionId 

func (r *DeleteConsumerGroupRequest) SetRegionId(regionId string)

param regionId: Region ID(Required)

func (*DeleteConsumerGroupRequest) SetTopicId 

func (r *DeleteConsumerGroupRequest) SetTopicId(topicId int)

param topicId: 主题ID(Required)

type DeleteConsumerGroupResponse 

type DeleteConsumerGroupResponse struct {
	RequestID string                    `json:"requestId"`
	Error     core.ErrorResponse        `json:"error"`
	Result    DeleteConsumerGroupResult `json:"result"`
}

type DeleteConsumerGroupResult 

type DeleteConsumerGroupResult struct {
	Message string `json:"message"`
	Status  bool   `json:"status"`
}

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	core.JDCloudRequest

	/* 地域ID  */
	RegionId string `json:"regionId"`

	/*   */
	Name string `json:"name"`
}

func NewDeleteTopicRequest 

func NewDeleteTopicRequest(
	regionId string,
	name string,
) *DeleteTopicRequest

* param regionId: 地域ID (Required) * param name: (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDeleteTopicRequestWithAllParams 

func NewDeleteTopicRequestWithAllParams(
	regionId string,
	name string,
) *DeleteTopicRequest

* param regionId: 地域ID (Required) * param name: (Required)

func NewDeleteTopicRequestWithoutParam 

func NewDeleteTopicRequestWithoutParam() *DeleteTopicRequest

This constructor has better compatible ability when API parameters changed

func (DeleteTopicRequest) GetRegionId 

func (r DeleteTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DeleteTopicRequest) SetName 

func (r *DeleteTopicRequest) SetName(name string)

param name: (Required)

func (*DeleteTopicRequest) SetRegionId 

func (r *DeleteTopicRequest) SetRegionId(regionId string)

param regionId: 地域ID(Required)

type DeleteTopicResponse 

type DeleteTopicResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    DeleteTopicResult  `json:"result"`
}

type DeleteTopicResult 

type DeleteTopicResult struct {
	Status  bool   `json:"status"`
	Message string `json:"message"`
}

type DescribeTopicRequest 

type DescribeTopicRequest struct {
	core.JDCloudRequest

	/* 地域ID  */
	RegionId string `json:"regionId"`

	/*   */
	Name string `json:"name"`
}

func NewDescribeTopicRequest 

func NewDescribeTopicRequest(
	regionId string,
	name string,
) *DescribeTopicRequest

* param regionId: 地域ID (Required) * param name: (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeTopicRequestWithAllParams 

func NewDescribeTopicRequestWithAllParams(
	regionId string,
	name string,
) *DescribeTopicRequest

* param regionId: 地域ID (Required) * param name: (Required)

func NewDescribeTopicRequestWithoutParam 

func NewDescribeTopicRequestWithoutParam() *DescribeTopicRequest

This constructor has better compatible ability when API parameters changed

func (DescribeTopicRequest) GetRegionId 

func (r DescribeTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeTopicRequest) SetName 

func (r *DescribeTopicRequest) SetName(name string)

param name: (Required)

func (*DescribeTopicRequest) SetRegionId 

func (r *DescribeTopicRequest) SetRegionId(regionId string)

param regionId: 地域ID(Required)

type DescribeTopicResponse 

type DescribeTopicResponse struct {
	RequestID string              `json:"requestId"`
	Error     core.ErrorResponse  `json:"error"`
	Result    DescribeTopicResult `json:"result"`
}

type DescribeTopicResult 

type DescribeTopicResult struct {
	Topic streambus.TopicModel `json:"topic"`
}

type GetConsumerGroupListRequest 

type GetConsumerGroupListRequest struct {
	core.JDCloudRequest

	/* Region ID  */
	RegionId string `json:"regionId"`

	/* 主题id  */
	TopicId int `json:"topicId"`
}

func NewGetConsumerGroupListRequest 

func NewGetConsumerGroupListRequest(
	regionId string,
	topicId int,
) *GetConsumerGroupListRequest

* param regionId: Region ID (Required) * param topicId: 主题id (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewGetConsumerGroupListRequestWithAllParams 

func NewGetConsumerGroupListRequestWithAllParams(
	regionId string,
	topicId int,
) *GetConsumerGroupListRequest

* param regionId: Region ID (Required) * param topicId: 主题id (Required)

func NewGetConsumerGroupListRequestWithoutParam 

func NewGetConsumerGroupListRequestWithoutParam() *GetConsumerGroupListRequest

This constructor has better compatible ability when API parameters changed

func (GetConsumerGroupListRequest) GetRegionId 

func (r GetConsumerGroupListRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*GetConsumerGroupListRequest) SetRegionId 

func (r *GetConsumerGroupListRequest) SetRegionId(regionId string)

param regionId: Region ID(Required)

func (*GetConsumerGroupListRequest) SetTopicId 

func (r *GetConsumerGroupListRequest) SetTopicId(topicId int)

param topicId: 主题id(Required)

type GetConsumerGroupListResponse 

type GetConsumerGroupListResponse struct {
	RequestID string                     `json:"requestId"`
	Error     core.ErrorResponse         `json:"error"`
	Result    GetConsumerGroupListResult `json:"result"`
}

type GetConsumerGroupListResult 

type GetConsumerGroupListResult struct {
	ConsumerGroup []streambus.ConsumerGroup `json:"consumerGroup"`
}

type GetTopicListRequest 

type GetTopicListRequest struct {
	core.JDCloudRequest

	/* 地域ID  */
	RegionId string `json:"regionId"`

	/*  (Optional) */
	Keyword *string `json:"keyword"`
}

func NewGetTopicListRequest 

func NewGetTopicListRequest(
	regionId string,
) *GetTopicListRequest

* param regionId: 地域ID (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewGetTopicListRequestWithAllParams 

func NewGetTopicListRequestWithAllParams(
	regionId string,
	keyword *string,
) *GetTopicListRequest

* param regionId: 地域ID (Required) * param keyword: (Optional)

func NewGetTopicListRequestWithoutParam 

func NewGetTopicListRequestWithoutParam() *GetTopicListRequest

This constructor has better compatible ability when API parameters changed

func (GetTopicListRequest) GetRegionId 

func (r GetTopicListRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*GetTopicListRequest) SetKeyword 

func (r *GetTopicListRequest) SetKeyword(keyword string)

param keyword: (Optional)

func (*GetTopicListRequest) SetRegionId 

func (r *GetTopicListRequest) SetRegionId(regionId string)

param regionId: 地域ID(Required)

type GetTopicListResponse 

type GetTopicListResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    GetTopicListResult `json:"result"`
}

type GetTopicListResult 

type GetTopicListResult struct {
	Topic []streambus.TopicListInfo `json:"topic"`
}

type UpdateTopicRequest 

type UpdateTopicRequest struct {
	core.JDCloudRequest

	/* 地域ID  */
	RegionId string `json:"regionId"`

	/* 当更新主题时只需要修改topicModel中的topic中的属性即可；创建归档需要指定target以及归档的目的地(mysql,京东云 Elasticsearch,对象存储,数据计算服务)参数  */
	TopicModel *streambus.TopicModel `json:"topicModel"`
}

func NewUpdateTopicRequest 

func NewUpdateTopicRequest(
	regionId string,
	topicModel *streambus.TopicModel,
) *UpdateTopicRequest

* param regionId: 地域ID (Required) * param topicModel: 当更新主题时只需要修改topicModel中的topic中的属性即可；创建归档需要指定target以及归档的目的地(mysql,京东云 Elasticsearch,对象存储,数据计算服务)参数 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewUpdateTopicRequestWithAllParams 

func NewUpdateTopicRequestWithAllParams(
	regionId string,
	topicModel *streambus.TopicModel,
) *UpdateTopicRequest

* param regionId: 地域ID (Required) * param topicModel: 当更新主题时只需要修改topicModel中的topic中的属性即可；创建归档需要指定target以及归档的目的地(mysql,京东云 Elasticsearch,对象存储,数据计算服务)参数 (Required)

func NewUpdateTopicRequestWithoutParam 

func NewUpdateTopicRequestWithoutParam() *UpdateTopicRequest

This constructor has better compatible ability when API parameters changed

func (UpdateTopicRequest) GetRegionId 

func (r UpdateTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*UpdateTopicRequest) SetRegionId 

func (r *UpdateTopicRequest) SetRegionId(regionId string)

param regionId: 地域ID(Required)

func (*UpdateTopicRequest) SetTopicModel 

func (r *UpdateTopicRequest) SetTopicModel(topicModel *streambus.TopicModel)

param topicModel: 当更新主题时只需要修改topicModel中的topic中的属性即可；创建归档需要指定target以及归档的目的地(mysql,京东云 Elasticsearch,对象存储,数据计算服务)参数(Required)

type UpdateTopicResponse 

type UpdateTopicResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    UpdateTopicResult  `json:"result"`
}

type UpdateTopicResult 

type UpdateTopicResult struct {
	Status  bool   `json:"status"`
	Message string `json:"message"`
}

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.