Versions in this module Expand all Collapse all v0 v0.2.2 Aug 16, 2021 v0.2.1 Aug 16, 2021 Changes in this version + const BatchSizeKey + const BatchTimeoutKey + const ChannelRestrictionsKey + const ConsensusStateMaintenance + const ConsensusStateNormal + const ConsensusTypeEtcdRaft + const ConsensusTypeKafka + const ConsensusTypeKey + const ConsensusTypeSolo + const KafkaBrokersKey + type BatchSize struct + AbsoluteMaxBytes uint32 + MaxMessageCount uint32 + PreferredMaxBytes uint32 + type ConsensusState string + type Consenter struct + Address EtcdAddress + ClientTLSCert *x509.Certificate + ServerTLSCert *x509.Certificate + type EtcdAddress struct + Host string + Port int + type EtcdRaft struct + Consenters []Consenter + Options EtcdRaftOptions + type EtcdRaftOptions struct + ElectionTick uint32 + HeartbeatTick uint32 + MaxInflightBlocks uint32 + SnapshotIntervalSize uint32 + TickInterval string + type Kafka struct + Brokers []string