models

Documentation

Index

• type AddTopic
• type ConsumerGroup
• type ParameterList
• type Target
• type Topic
• type TopicListInfo

Types

type AddTopic

type AddTopic struct {

	/*  (Optional) */
	Topic *Topic `json:"topic"`

	/*  (Optional) */
	Target *Target `json:"target"`

	/* 归档相关的具体参数 (Optional) */
	ParameterList []ParameterList `json:"parameterList"`
}

type ConsumerGroup

type ConsumerGroup struct {

	/*  (Optional) */
	Id *int `json:"id"`

	/*  (Optional) */
	Name *string `json:"name"`

	/*  (Optional) */
	CreatedTime *string `json:"createdTime"`

	/*  (Optional) */
	Delete *string `json:"delete"`

	/*  (Optional) */
	TopicId *int64 `json:"topicId"`
}

type ParameterList

type ParameterList struct {

	/*  (Optional) */
	PKey *string `json:"pKey"`

	/*  (Optional) */
	PValue *string `json:"pValue"`
}

type Target

type Target struct {

	/* 需要归档的目的 (Optional) */
	Name *string `json:"name"`

	/* 当达到这个数据量时开始归档 (Optional) */
	RecordSize *int `json:"recordSize"`

	/* 进行归档任务的时间周期 (Optional) */
	Cycle *int `json:"cycle"`
}

type Topic

type Topic struct {

	/* 是否归档（0：未归档，1：已归档） (Optional) */
	Archived *int `json:"archived"`

	/* 数据写入后的保留时间 (Optional) */
	Lifecycle *int `json:"lifecycle"`

	/* 流数据总线中topic的名字 (Optional) */
	Name *string `json:"name"`

	/* 流数据总线shard的数量 (Optional) */
	ShardNum *int `json:"shardNum"`

	/* 备注 (Optional) */
	Remark *string `json:"remark"`
}

type TopicListInfo

type TopicListInfo struct {

	/* 是否归档（0：未归档，1：已归档） (Optional) */
	Archived int `json:"archived"`

	/* 创建topic的时间戳 (Optional) */
	CreatedTime string `json:"createdTime"`

	/* topic是否已删除（0：未删除，1：删除） (Optional) */
	Deleted int `json:"deleted"`

	/* topic的id值 (Optional) */
	Id int `json:"id"`

	/* 数据写入后的保留时间 (Optional) */
	Lifecycle int `json:"lifecycle"`

	/* 流数据总线中topic的名字 (Optional) */
	Name string `json:"name"`

	/* 对应kafka中的分区数 (Optional) */
	PartitionNum string `json:"partitionNum"`

	/* 备注 (Optional) */
	Remark string `json:"remark"`

	/* 流数据总线shard的数量 (Optional) */
	ShardNum string `json:"shardNum"`

	/* 0: 已创建, 1: 创建中 (Optional) */
	Status int `json:"status"`

	/* 对应kafka中的topic名字 (Optional) */
	TopicName string `json:"topicName"`

	/* 对应kafka中的uid (Optional) */
	Uid string `json:"uid"`

	/* 更新topic的时间戳 (Optional) */
	UpdatedTime string `json:"updatedTime"`

	/* 用户的userPin (Optional) */
	UserPin string `json:"userPin"`

	/*  (Optional) */
	DataSize string `json:"dataSize"`
}