raft

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 23, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaft        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaft          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaft = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var MemberGroupStrategy_name = map[int32]string{
	0: "HOST_AWARE",
	1: "RACK_AWARE",
	2: "ZONE_AWARE",
}
View Source 
var MemberGroupStrategy_value = map[string]int32{
	"HOST_AWARE": 0,
	"RACK_AWARE": 1,
	"ZONE_AWARE": 2,
}
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 CompactionSpec 

type CompactionSpec struct {
	Dynamic        bool    `protobuf:"varint,1,opt,name=dynamic,proto3" json:"dynamic,omitempty"`
	FreeDiskBuffer float64 `protobuf:"fixed64,2,opt,name=free_disk_buffer,json=freeDiskBuffer,proto3" json:"free_disk_buffer,omitempty"`
}

Partition group compaction configuration

func (*CompactionSpec) Descriptor 

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

func (*CompactionSpec) GetDynamic 

func (m *CompactionSpec) GetDynamic() bool

func (*CompactionSpec) GetFreeDiskBuffer 

func (m *CompactionSpec) GetFreeDiskBuffer() float64

func (*CompactionSpec) Marshal 

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

func (*CompactionSpec) MarshalTo 

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

func (*CompactionSpec) MarshalToSizedBuffer 

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

func (*CompactionSpec) ProtoMessage 

func (*CompactionSpec) ProtoMessage()

func (*CompactionSpec) Reset 

func (m *CompactionSpec) Reset()

func (*CompactionSpec) Size 

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

func (*CompactionSpec) String 

func (m *CompactionSpec) String() string

func (*CompactionSpec) Unmarshal 

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

func (*CompactionSpec) XXX_DiscardUnknown 

func (m *CompactionSpec) XXX_DiscardUnknown()

func (*CompactionSpec) XXX_Marshal 

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

func (*CompactionSpec) XXX_Merge 

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

func (*CompactionSpec) XXX_Size 

func (m *CompactionSpec) XXX_Size() int

func (*CompactionSpec) XXX_Unmarshal 

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

type MemberGroupStrategy 

type MemberGroupStrategy int32

Member group strategy 

const (
	MemberGroupStrategy_HOST_AWARE MemberGroupStrategy = 0
	MemberGroupStrategy_RACK_AWARE MemberGroupStrategy = 1
	MemberGroupStrategy_ZONE_AWARE MemberGroupStrategy = 2
)

func (MemberGroupStrategy) EnumDescriptor 

func (MemberGroupStrategy) EnumDescriptor() ([]byte, []int)

func (MemberGroupStrategy) String 

func (x MemberGroupStrategy) String() string

type RaftProtocol 

type RaftProtocol 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           *StorageSpec    `protobuf:"bytes,3,opt,name=storage,proto3" json:"storage,omitempty"`
	Compaction        *CompactionSpec `protobuf:"bytes,4,opt,name=compaction,proto3" json:"compaction,omitempty"`
}

Raft protocol configuration

func (*RaftProtocol) Descriptor 

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

func (*RaftProtocol) GetCompaction 

func (m *RaftProtocol) GetCompaction() *CompactionSpec

func (*RaftProtocol) GetElectionTimeout 

func (m *RaftProtocol) GetElectionTimeout() *time.Duration

func (*RaftProtocol) GetHeartbeatInterval 

func (m *RaftProtocol) GetHeartbeatInterval() *time.Duration

func (*RaftProtocol) GetStorage 

func (m *RaftProtocol) GetStorage() *StorageSpec

func (*RaftProtocol) Marshal 

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

func (*RaftProtocol) MarshalTo 

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

func (*RaftProtocol) MarshalToSizedBuffer 

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

func (*RaftProtocol) ProtoMessage 

func (*RaftProtocol) ProtoMessage()

func (*RaftProtocol) Reset 

func (m *RaftProtocol) Reset()

func (*RaftProtocol) Size 

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

func (*RaftProtocol) String 

func (m *RaftProtocol) String() string

func (*RaftProtocol) Unmarshal 

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

func (*RaftProtocol) XXX_DiscardUnknown 

func (m *RaftProtocol) XXX_DiscardUnknown()

func (*RaftProtocol) XXX_Marshal 

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

func (*RaftProtocol) XXX_Merge 

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

func (*RaftProtocol) XXX_Size 

func (m *RaftProtocol) XXX_Size() int

func (*RaftProtocol) XXX_Unmarshal 

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

type StorageLevel 

type StorageLevel int32

Storage level 

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

type StorageSpec 

type StorageSpec struct {
	MaxEntrySize  uint32       `protobuf:"varint,1,opt,name=max_entry_size,json=maxEntrySize,proto3" json:"max_entry_size,omitempty"`
	SegmentSize   uint32       `protobuf:"varint,2,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	Level         StorageLevel `protobuf:"varint,3,opt,name=level,proto3,enum=atomix.protocols.raft.StorageLevel" json:"level,omitempty"`
	FlushOnCommit bool         `protobuf:"varint,4,opt,name=flush_on_commit,json=flushOnCommit,proto3" json:"flush_on_commit,omitempty"`
}

Partition group storage configuration

func (*StorageSpec) Descriptor 

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

func (*StorageSpec) GetFlushOnCommit 

func (m *StorageSpec) GetFlushOnCommit() bool

func (*StorageSpec) GetLevel 

func (m *StorageSpec) GetLevel() StorageLevel

func (*StorageSpec) GetMaxEntrySize 

func (m *StorageSpec) GetMaxEntrySize() uint32

func (*StorageSpec) GetSegmentSize 

func (m *StorageSpec) GetSegmentSize() uint32

func (*StorageSpec) Marshal 

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

func (*StorageSpec) MarshalTo 

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

func (*StorageSpec) MarshalToSizedBuffer 

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

func (*StorageSpec) ProtoMessage 

func (*StorageSpec) ProtoMessage()

func (*StorageSpec) Reset 

func (m *StorageSpec) Reset()

func (*StorageSpec) Size 

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

func (*StorageSpec) String 

func (m *StorageSpec) String() string

func (*StorageSpec) Unmarshal 

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

func (*StorageSpec) XXX_DiscardUnknown 

func (m *StorageSpec) XXX_DiscardUnknown()

func (*StorageSpec) XXX_Marshal 

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

func (*StorageSpec) XXX_Merge 

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

func (*StorageSpec) XXX_Size 

func (m *StorageSpec) XXX_Size() int

func (*StorageSpec) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.