vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/types.go


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"`
}