Versions in this module Expand all Collapse all v1 v1.0.0 Jul 16, 2021 Changes in this version + type DataNode struct + func NewDataNode(config *DataNodeConfig) (*DataNode, error) + func (d *DataNode) Run() error + func (d *DataNode) RunAsPrimary() error + func (d *DataNode) RunAsSecondary() error + type DataNodeConfig struct + DataDirPath string + ElectionAck string + ElectionPrefix string + ElectionZnode string + ForClientAddr string + KafkaServer string + KafkaTopic string + NodeID string + Port uint + ZookeeperServers []string + ZookeeperTimeout time.Duration