Documentation ¶
Index ¶
Constants ¶
View Source
const ( BLOCK_SIZE = 2 << 10 DIR_DATA_PATH = "../data/" ElectionZnodePrefix = "/datanode_election_" ElectionAckPrefix = "/datanode_election_ack_" MasterAck = "/master_election_ack" ElectionTimeout = 1 * time.Second ElectionPrefix = "16d8a690-2c5e-484a-b794-e015a0e436d5-n_" )
Variables ¶
View Source
var KafkaServer = "127.0.0.1:9093"
View Source
var KafkaTopicPrefix = "datanode_journal_"
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.