blob: 3db3e420d0afe7edfe0e810082b8a9c6d32f9017 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
package utils
// Pipeline type represents a stucture of a general pipeline
type Pipeline struct{
KafkaConfiguration KafkaConfig `json:"kafkaConfig"`
HdfsConfiguration HdfsConfig `json:"hdfsConfig"`
}
// HdfsConfig type represents the config items of HDFS
type HdfsConfig struct {
HdfsURL string `json:"hdfs_url"`
}
// KafkaConfig type represents the config items of Kafka
type KafkaConfig struct {
Broker string `json:"broker"`
Group string `json:"group"`
Topic string `json:"topic"`
}
|