Versions in this module Expand all Collapse all v0 v0.0.10 Jan 28, 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 v0.0.10-alpha Dec 21, 2020