Documentation ¶
Index ¶
- Variables
- type CompactionConfig
- func (*CompactionConfig) Descriptor() ([]byte, []int)
- func (this *CompactionConfig) Equal(that interface{}) bool
- func (m *CompactionConfig) GetDynamic() bool
- func (m *CompactionConfig) GetFreeDiskBuffer() float32
- func (m *CompactionConfig) GetFreeMemoryBuffer() float32
- func (m *CompactionConfig) Marshal() (dAtA []byte, err error)
- func (m *CompactionConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *CompactionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CompactionConfig) ProtoMessage()
- func (m *CompactionConfig) Reset()
- func (m *CompactionConfig) Size() (n int)
- func (m *CompactionConfig) String() string
- func (m *CompactionConfig) Unmarshal(dAtA []byte) error
- func (m *CompactionConfig) XXX_DiscardUnknown()
- func (m *CompactionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CompactionConfig) XXX_Merge(src proto.Message)
- func (m *CompactionConfig) XXX_Size() int
- func (m *CompactionConfig) XXX_Unmarshal(b []byte) error
- type ProtocolConfig
- func (*ProtocolConfig) Descriptor() ([]byte, []int)
- func (this *ProtocolConfig) Equal(that interface{}) bool
- func (m *ProtocolConfig) GetCompaction() *CompactionConfig
- func (m *ProtocolConfig) GetElectionTimeout() *time.Duration
- func (c *ProtocolConfig) GetElectionTimeoutOrDefault() time.Duration
- func (m *ProtocolConfig) GetHeartbeatInterval() *time.Duration
- func (c *ProtocolConfig) GetHeartbeatIntervalOrDefault() time.Duration
- func (m *ProtocolConfig) GetStorage() *StorageConfig
- 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
- type StorageConfig
- func (*StorageConfig) Descriptor() ([]byte, []int)
- func (this *StorageConfig) Equal(that interface{}) bool
- func (m *StorageConfig) GetDirectory() string
- func (m *StorageConfig) GetFlushOnCommit() bool
- func (m *StorageConfig) GetLevel() StorageLevel
- func (m *StorageConfig) GetMaxEntrySize() uint32
- func (m *StorageConfig) GetSegmentSize() uint32
- func (m *StorageConfig) Marshal() (dAtA []byte, err error)
- func (m *StorageConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageConfig) ProtoMessage()
- func (m *StorageConfig) Reset()
- func (m *StorageConfig) Size() (n int)
- func (m *StorageConfig) String() string
- func (m *StorageConfig) Unmarshal(dAtA []byte) error
- func (m *StorageConfig) XXX_DiscardUnknown()
- func (m *StorageConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageConfig) XXX_Merge(src proto.Message)
- func (m *StorageConfig) XXX_Size() int
- func (m *StorageConfig) XXX_Unmarshal(b []byte) error
- type StorageLevel
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthConfig = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowConfig = fmt.Errorf("proto: integer overflow") )
View Source
var StorageLevel_name = map[int32]string{
0: "DISK",
1: "MAPPED",
}
View Source
var StorageLevel_value = map[string]int32{
"DISK": 0,
"MAPPED": 1,
}
Functions ¶
This section is empty.
Types ¶
type CompactionConfig ¶
type CompactionConfig struct { Dynamic bool `protobuf:"varint,1,opt,name=dynamic,proto3" json:"dynamic,omitempty"` FreeDiskBuffer float32 `protobuf:"fixed32,2,opt,name=free_disk_buffer,json=freeDiskBuffer,proto3" json:"free_disk_buffer,omitempty"` FreeMemoryBuffer float32 `protobuf:"fixed32,3,opt,name=free_memory_buffer,json=freeMemoryBuffer,proto3" json:"free_memory_buffer,omitempty"` }
func NewPopulatedCompactionConfig ¶
func NewPopulatedCompactionConfig(r randyConfig, easy bool) *CompactionConfig
func (*CompactionConfig) Descriptor ¶
func (*CompactionConfig) Descriptor() ([]byte, []int)
func (*CompactionConfig) Equal ¶
func (this *CompactionConfig) Equal(that interface{}) bool
func (*CompactionConfig) GetDynamic ¶
func (m *CompactionConfig) GetDynamic() bool
func (*CompactionConfig) GetFreeDiskBuffer ¶
func (m *CompactionConfig) GetFreeDiskBuffer() float32
func (*CompactionConfig) GetFreeMemoryBuffer ¶
func (m *CompactionConfig) GetFreeMemoryBuffer() float32
func (*CompactionConfig) Marshal ¶
func (m *CompactionConfig) Marshal() (dAtA []byte, err error)
func (*CompactionConfig) MarshalToSizedBuffer ¶
func (m *CompactionConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CompactionConfig) ProtoMessage ¶
func (*CompactionConfig) ProtoMessage()
func (*CompactionConfig) Reset ¶
func (m *CompactionConfig) Reset()
func (*CompactionConfig) Size ¶
func (m *CompactionConfig) Size() (n int)
func (*CompactionConfig) String ¶
func (m *CompactionConfig) String() string
func (*CompactionConfig) Unmarshal ¶
func (m *CompactionConfig) Unmarshal(dAtA []byte) error
func (*CompactionConfig) XXX_DiscardUnknown ¶
func (m *CompactionConfig) XXX_DiscardUnknown()
func (*CompactionConfig) XXX_Marshal ¶
func (m *CompactionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CompactionConfig) XXX_Merge ¶
func (m *CompactionConfig) XXX_Merge(src proto.Message)
func (*CompactionConfig) XXX_Size ¶
func (m *CompactionConfig) XXX_Size() int
func (*CompactionConfig) XXX_Unmarshal ¶
func (m *CompactionConfig) XXX_Unmarshal(b []byte) error
type ProtocolConfig ¶
type ProtocolConfig struct { ElectionTimeout *time.Duration `protobuf:"bytes,1,opt,name=election_timeout,json=electionTimeout,proto3,stdduration" json:"election_timeout,omitempty"` HeartbeatInterval *time.Duration `protobuf:"bytes,2,opt,name=heartbeat_interval,json=heartbeatInterval,proto3,stdduration" json:"heartbeat_interval,omitempty"` Storage *StorageConfig `protobuf:"bytes,3,opt,name=storage,proto3" json:"storage,omitempty"` Compaction *CompactionConfig `protobuf:"bytes,4,opt,name=compaction,proto3" json:"compaction,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) GetCompaction ¶
func (m *ProtocolConfig) GetCompaction() *CompactionConfig
func (*ProtocolConfig) GetElectionTimeout ¶
func (m *ProtocolConfig) GetElectionTimeout() *time.Duration
func (*ProtocolConfig) GetElectionTimeoutOrDefault ¶
func (c *ProtocolConfig) GetElectionTimeoutOrDefault() time.Duration
GetElectionTimeoutOrDefault returns the configured election timeout if set, otherwise the default election timeout
func (*ProtocolConfig) GetHeartbeatInterval ¶
func (m *ProtocolConfig) GetHeartbeatInterval() *time.Duration
func (*ProtocolConfig) GetHeartbeatIntervalOrDefault ¶
func (c *ProtocolConfig) GetHeartbeatIntervalOrDefault() time.Duration
GetHeartbeatIntervalOrDefault returns the configured heartbeat interval if set, otherwise the default heartbeat interval
func (*ProtocolConfig) GetStorage ¶
func (m *ProtocolConfig) GetStorage() *StorageConfig
func (*ProtocolConfig) Marshal ¶
func (m *ProtocolConfig) Marshal() (dAtA []byte, err 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
type StorageConfig ¶
type StorageConfig struct { Directory string `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"` Level StorageLevel `protobuf:"varint,2,opt,name=level,proto3,enum=atomix.raft.config.StorageLevel" json:"level,omitempty"` MaxEntrySize uint32 `protobuf:"varint,3,opt,name=max_entry_size,json=maxEntrySize,proto3" json:"max_entry_size,omitempty"` SegmentSize uint32 `protobuf:"varint,4,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"` FlushOnCommit bool `protobuf:"varint,5,opt,name=flush_on_commit,json=flushOnCommit,proto3" json:"flush_on_commit,omitempty"` }
func NewPopulatedStorageConfig ¶
func NewPopulatedStorageConfig(r randyConfig, easy bool) *StorageConfig
func (*StorageConfig) Descriptor ¶
func (*StorageConfig) Descriptor() ([]byte, []int)
func (*StorageConfig) Equal ¶
func (this *StorageConfig) Equal(that interface{}) bool
func (*StorageConfig) GetDirectory ¶
func (m *StorageConfig) GetDirectory() string
func (*StorageConfig) GetFlushOnCommit ¶
func (m *StorageConfig) GetFlushOnCommit() bool
func (*StorageConfig) GetLevel ¶
func (m *StorageConfig) GetLevel() StorageLevel
func (*StorageConfig) GetMaxEntrySize ¶
func (m *StorageConfig) GetMaxEntrySize() uint32
func (*StorageConfig) GetSegmentSize ¶
func (m *StorageConfig) GetSegmentSize() uint32
func (*StorageConfig) Marshal ¶
func (m *StorageConfig) Marshal() (dAtA []byte, err error)
func (*StorageConfig) MarshalToSizedBuffer ¶
func (m *StorageConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageConfig) ProtoMessage ¶
func (*StorageConfig) ProtoMessage()
func (*StorageConfig) Reset ¶
func (m *StorageConfig) Reset()
func (*StorageConfig) Size ¶
func (m *StorageConfig) Size() (n int)
func (*StorageConfig) String ¶
func (m *StorageConfig) String() string
func (*StorageConfig) Unmarshal ¶
func (m *StorageConfig) Unmarshal(dAtA []byte) error
func (*StorageConfig) XXX_DiscardUnknown ¶
func (m *StorageConfig) XXX_DiscardUnknown()
func (*StorageConfig) XXX_Marshal ¶
func (m *StorageConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageConfig) XXX_Merge ¶
func (m *StorageConfig) XXX_Merge(src proto.Message)
func (*StorageConfig) XXX_Size ¶
func (m *StorageConfig) XXX_Size() int
func (*StorageConfig) XXX_Unmarshal ¶
func (m *StorageConfig) XXX_Unmarshal(b []byte) error
type StorageLevel ¶
type StorageLevel int32
const ( StorageLevel_DISK StorageLevel = 0 StorageLevel_MAPPED StorageLevel = 1 )
func (StorageLevel) EnumDescriptor ¶
func (StorageLevel) EnumDescriptor() ([]byte, []int)
func (StorageLevel) String ¶
func (x StorageLevel) String() string
Click to show internal directories.
Click to hide internal directories.