node

type MasterNode struct {
	// contains filtered or unexported fields
}

type MasterNodeConfig struct {
	NodeID             string
	Port               uint
	ForClientAddr      string
	ZookeeperServers   []string
	ZookeeperTimeout   time.Duration
	ElectionZnode      string
	ElectionPrefix     string
	ElectionAck        string
	KafkaServer        string
	KafkaTopic         string
	DB                 *gorm.DB
	CheckpointInterval time.Duration
	DataNodeGroups     []string
}