config

Aug 6, 2021

Changes in this version

+ var NodeType_name = map[int32]string

+ var NodeType_value = map[string]int32

+ type NodeType int32

+ const NodeType_MEMBER

+ const NodeType_OBSERVER

+ func (NodeType) EnumDescriptor() ([]byte, []int)

+ func (x NodeType) String() string

type ProtocolConfig

+ CompactionRetainEntries uint64

+ HeartbeatPeriod *time.Duration

+ SessionTimeout *time.Duration

+ SnapshotEntryThreshold uint64

+ func (m *ProtocolConfig) GetCompactionRetainEntries() uint64

+ func (m *ProtocolConfig) GetHeartbeatPeriod() *time.Duration

+ func (m *ProtocolConfig) GetSessionTimeout() *time.Duration

+ func (m *ProtocolConfig) GetSnapshotEntryThreshold() uint64

May 27, 2021

Changes in this version

+ var ErrIntOverflowConfig = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthConfig = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupConfig = fmt.Errorf("proto: unexpected end of group")

+ type ProtocolConfig struct

+ ElectionTimeout *time.Duration

+ HeartbeatInterval *time.Duration

+ SnapshotInterval *time.Duration

+ SnapshotThreshold uint64

+ func NewPopulatedProtocolConfig(r randyConfig, easy bool) *ProtocolConfig

+ func (*ProtocolConfig) Descriptor() ([]byte, []int)

+ func (*ProtocolConfig) ProtoMessage()

+ func (c *ProtocolConfig) GetElectionTimeoutOrDefault() time.Duration

+ func (c *ProtocolConfig) GetHeartbeatIntervalOrDefault() time.Duration

+ func (c *ProtocolConfig) GetSnapshotIntervalOrDefault() time.Duration

+ func (c *ProtocolConfig) GetSnapshotThresholdOrDefault() uint64

+ func (m *ProtocolConfig) GetElectionTimeout() *time.Duration

+ func (m *ProtocolConfig) GetHeartbeatInterval() *time.Duration

+ func (m *ProtocolConfig) GetSnapshotInterval() *time.Duration

+ func (m *ProtocolConfig) GetSnapshotThreshold() uint64

+ func (m *ProtocolConfig) Marshal() (dAtA []byte, err error)

+ func (m *ProtocolConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProtocolConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProtocolConfig) Reset()

+ func (m *ProtocolConfig) Size() (n int)

+ func (m *ProtocolConfig) String() string

+ func (m *ProtocolConfig) Unmarshal(dAtA []byte) error

+ func (m *ProtocolConfig) XXX_DiscardUnknown()

+ func (m *ProtocolConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProtocolConfig) XXX_Merge(src proto.Message)

+ func (m *ProtocolConfig) XXX_Size() int

+ func (m *ProtocolConfig) XXX_Unmarshal(b []byte) error

+ func (this *ProtocolConfig) Equal(that interface{}) bool