config

Documentation

Index

• Variables
• type ProtocolConfig
  • func NewPopulatedProtocolConfig(r randyConfig, easy bool) *ProtocolConfig
  • func (*ProtocolConfig) Descriptor() ([]byte, []int)
  • func (this *ProtocolConfig) Equal(that interface{}) bool
  • func (m *ProtocolConfig) GetCheckpointInterval() *time.Duration
  • func (c *ProtocolConfig) GetCheckpointIntervalOrDefault() time.Duration
  • func (m *ProtocolConfig) GetLeaderTimeout() *time.Duration
  • func (c *ProtocolConfig) GetLeaderTimeoutOrDefault() time.Duration
  • func (m *ProtocolConfig) GetMaxLogLength() uint32
  • func (c *ProtocolConfig) GetMaxLogLengthOrDefault() int
  • func (m *ProtocolConfig) GetPingInterval() *time.Duration
  • func (c *ProtocolConfig) GetPingIntervalOrDefault() time.Duration
  • func (m *ProtocolConfig) GetSyncInterval() *time.Duration
  • func (c *ProtocolConfig) GetSyncIntervalOrDefault() time.Duration
  • 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 (*ProtocolConfig) ProtoMessage()
  • 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

Variables

var (
	ErrInvalidLengthConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConfig = fmt.Errorf("proto: unexpected end of group")
)

Types

type ProtocolConfig

type ProtocolConfig struct {
	LeaderTimeout      *time.Duration `protobuf:"bytes,1,opt,name=leader_timeout,json=leaderTimeout,proto3,stdduration" json:"leader_timeout,omitempty"`
	PingInterval       *time.Duration `protobuf:"bytes,2,opt,name=ping_interval,json=pingInterval,proto3,stdduration" json:"ping_interval,omitempty"`
	CheckpointInterval *time.Duration `` /* 127-byte string literal not displayed */
	SyncInterval       *time.Duration `protobuf:"bytes,4,opt,name=sync_interval,json=syncInterval,proto3,stdduration" json:"sync_interval,omitempty"`
	MaxLogLength       uint32         `protobuf:"varint,5,opt,name=max_log_length,json=maxLogLength,proto3" json:"max_log_length,omitempty"`
}

func NewPopulatedProtocolConfig

func NewPopulatedProtocolConfig(r randyConfig, easy bool) *ProtocolConfig

func (*ProtocolConfig) Descriptor

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

func (*ProtocolConfig) Equal

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

func (*ProtocolConfig) GetCheckpointInterval

func (m *ProtocolConfig) GetCheckpointInterval() *time.Duration

func (*ProtocolConfig) GetCheckpointIntervalOrDefault

func (c *ProtocolConfig) GetCheckpointIntervalOrDefault() time.Duration

GetCheckpointIntervalOrDefault returns the configured checkpoint interval if set, otherwise the default interval

func (*ProtocolConfig) GetLeaderTimeout

func (m *ProtocolConfig) GetLeaderTimeout() *time.Duration

func (*ProtocolConfig) GetLeaderTimeoutOrDefault

func (c *ProtocolConfig) GetLeaderTimeoutOrDefault() time.Duration

GetLeaderTimeoutOrDefault returns the configured election timeout if set, otherwise the default election timeout

func (*ProtocolConfig) GetMaxLogLength

func (m *ProtocolConfig) GetMaxLogLength() uint32

func (*ProtocolConfig) GetMaxLogLengthOrDefault

func (c *ProtocolConfig) GetMaxLogLengthOrDefault() int

GetMaxLogLengthOrDefault returns the configured maximum log length, otherwise the default

func (*ProtocolConfig) GetPingInterval

func (m *ProtocolConfig) GetPingInterval() *time.Duration

func (*ProtocolConfig) GetPingIntervalOrDefault

func (c *ProtocolConfig) GetPingIntervalOrDefault() time.Duration

GetPingIntervalOrDefault returns the configured heartbeat interval if set, otherwise the default heartbeat interval

func (*ProtocolConfig) GetSyncInterval

func (m *ProtocolConfig) GetSyncInterval() *time.Duration

func (*ProtocolConfig) GetSyncIntervalOrDefault

func (c *ProtocolConfig) GetSyncIntervalOrDefault() time.Duration

GetSyncIntervalOrDefault returns the configured sync interval if set, otherwise the default interval

func (*ProtocolConfig) Marshal

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

func (*ProtocolConfig) MarshalTo

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

func (*ProtocolConfig) MarshalToSizedBuffer

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

func (*ProtocolConfig) ProtoMessage

func (*ProtocolConfig) ProtoMessage()

func (*ProtocolConfig) Reset

func (m *ProtocolConfig) Reset()

func (*ProtocolConfig) Size

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

func (*ProtocolConfig) String

func (m *ProtocolConfig) String() string

func (*ProtocolConfig) Unmarshal

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

func (*ProtocolConfig) XXX_DiscardUnknown

func (m *ProtocolConfig) XXX_DiscardUnknown()

func (*ProtocolConfig) XXX_Marshal

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

func (*ProtocolConfig) XXX_Merge

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

func (*ProtocolConfig) XXX_Size

func (m *ProtocolConfig) XXX_Size() int

func (*ProtocolConfig) XXX_Unmarshal

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