models

Documentation

Index

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

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 {

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

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

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

	/* 分区 (Optional) */
	PartitionNum *int `json:"partitionNum"`

	/* 流数据总线中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"`
}

type TopicModel

type TopicModel struct {

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

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

	/* 归档相关的具体参数，需要对归档进行新建，更新，删除，修改对应参数值即可。<br>ossFlag，bucketName，directory，objectName 这四个参数值与ossFlag有关，若ossFlag为false，后面三个可为空，若为true，后面三个为异常数据保存位置，按需要填写即可。<br> 1）如果归档到数据计算服务需要传database，table，type，example，delimiter，targetColumn，analysisColumn，partsTargetColumn，partsAnalysisColumn。<br>2）如果归档到JFS需要传bucket，prefix，infix。<br>3）如果归档到京东云 Elasticsearch需要传host，port，indexType，idType，indexName，indexReferField，timestampFieldFormat，timestampIndexFormat，typeName，idReferField，noResolve，username，password。<br> 4）如果归档到mysql，则需要传host，database，table，username，password，type，example，delimiter。 <br>5)如果要归档到京东云数据库则需要传rdsId，database，table，username，password，type，example，delimiter。 (Optional) */
	ParameterList []ParameterList `json:"parameterList"`
}