raft

package
v0.0.0-...-388aa53 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2020 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Overview

Package raft is a generated protocol buffer package.

It is generated from these files: 

pb.proto

It has these top-level messages: 

DBLocalState
RaftLocalState
RaftApplyState
RaftTruncatedState
RaftMessage
SnapshotMessageHeader
SnapshotMessage
SnapshotChunkMessage
RaftRequestHeader
RaftCMDRequest
AdminRequest
AdminResponse
ChangePeerRequest
ChangePeerResponse
SplitRequest
SplitResponse
TransferLeaderRequest
TransferLeaderResponse
CompactLogRequest
CompactLogResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AdminCmdType_name = map[int32]string{
	0: "ChangePeer",
	1: "Split",
	2: "CompactLog",
	3: "TransferLeader",
}
View Source 
var AdminCmdType_value = map[string]int32{
	"ChangePeer":     0,
	"Split":          1,
	"CompactLog":     2,
	"TransferLeader": 3,
}
View Source 
var PeerState_name = map[int32]string{
	0: "Normal",
	1: "Applying",
	2: "Tombstone",
}
View Source 
var PeerState_value = map[string]int32{
	"Normal":    0,
	"Applying":  1,
	"Tombstone": 2,
}

Functions

This section is empty.

Types

type AdminCmdType 

type AdminCmdType int32

AdminCmdType raft cmd type 

const (
	ChangePeer     AdminCmdType = 0
	Split          AdminCmdType = 1
	CompactLog     AdminCmdType = 2
	TransferLeader AdminCmdType = 3
)

func (AdminCmdType) Enum 

func (x AdminCmdType) Enum() *AdminCmdType

func (AdminCmdType) EnumDescriptor 

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

func (AdminCmdType) String 

func (x AdminCmdType) String() string

func (*AdminCmdType) UnmarshalJSON 

func (x *AdminCmdType) UnmarshalJSON(data []byte) error

type AdminRequest 

type AdminRequest struct {
	Type             AdminCmdType           `protobuf:"varint,1,opt,name=type,enum=raft.AdminCmdType" json:"type"`
	ChangePeer       *ChangePeerRequest     `protobuf:"bytes,2,opt,name=changePeer" json:"changePeer,omitempty"`
	Split            *SplitRequest          `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"`
	TransferLeader   *TransferLeaderRequest `protobuf:"bytes,4,opt,name=transferLeader" json:"transferLeader,omitempty"`
	CompactLog       *CompactLogRequest     `protobuf:"bytes,5,opt,name=compactLog" json:"compactLog,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*AdminRequest) Descriptor 

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

func (*AdminRequest) GetChangePeer 

func (m *AdminRequest) GetChangePeer() *ChangePeerRequest

func (*AdminRequest) GetCompactLog 

func (m *AdminRequest) GetCompactLog() *CompactLogRequest

func (*AdminRequest) GetSplit 

func (m *AdminRequest) GetSplit() *SplitRequest

func (*AdminRequest) GetTransferLeader 

func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest

func (*AdminRequest) GetType 

func (m *AdminRequest) GetType() AdminCmdType

func (*AdminRequest) Marshal 

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

func (*AdminRequest) MarshalTo 

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

func (*AdminRequest) ProtoMessage 

func (*AdminRequest) ProtoMessage()

func (*AdminRequest) Reset 

func (m *AdminRequest) Reset()

func (*AdminRequest) Size 

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

func (*AdminRequest) String 

func (m *AdminRequest) String() string

func (*AdminRequest) Unmarshal 

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

type AdminResponse 

type AdminResponse struct {
	Type             AdminCmdType            `protobuf:"varint,1,opt,name=type,enum=raft.AdminCmdType" json:"type"`
	ChangePeer       *ChangePeerResponse     `protobuf:"bytes,2,opt,name=changePeer" json:"changePeer,omitempty"`
	Split            *SplitResponse          `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"`
	TransferLeader   *TransferLeaderResponse `protobuf:"bytes,4,opt,name=transferLeader" json:"transferLeader,omitempty"`
	CompactLog       *CompactLogResponse     `protobuf:"bytes,5,opt,name=compactLog" json:"compactLog,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*AdminResponse) Descriptor 

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

func (*AdminResponse) GetChangePeer 

func (m *AdminResponse) GetChangePeer() *ChangePeerResponse

func (*AdminResponse) GetCompactLog 

func (m *AdminResponse) GetCompactLog() *CompactLogResponse

func (*AdminResponse) GetSplit 

func (m *AdminResponse) GetSplit() *SplitResponse

func (*AdminResponse) GetTransferLeader 

func (m *AdminResponse) GetTransferLeader() *TransferLeaderResponse

func (*AdminResponse) GetType 

func (m *AdminResponse) GetType() AdminCmdType

func (*AdminResponse) Marshal 

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

func (*AdminResponse) MarshalTo 

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

func (*AdminResponse) ProtoMessage 

func (*AdminResponse) ProtoMessage()

func (*AdminResponse) Reset 

func (m *AdminResponse) Reset()

func (*AdminResponse) Size 

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

func (*AdminResponse) String 

func (m *AdminResponse) String() string

func (*AdminResponse) Unmarshal 

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

type ChangePeerRequest 

type ChangePeerRequest struct {
	ChangeType       raftpb.ConfChangeType `protobuf:"varint,1,opt,name=changeType,enum=raftpb.ConfChangeType" json:"changeType"`
	Peer             meta.Peer             `protobuf:"bytes,2,opt,name=peer" json:"peer"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*ChangePeerRequest) Descriptor 

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

func (*ChangePeerRequest) GetChangeType 

func (m *ChangePeerRequest) GetChangeType() raftpb.ConfChangeType

func (*ChangePeerRequest) GetPeer 

func (m *ChangePeerRequest) GetPeer() meta.Peer

func (*ChangePeerRequest) Marshal 

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

func (*ChangePeerRequest) MarshalTo 

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

func (*ChangePeerRequest) ProtoMessage 

func (*ChangePeerRequest) ProtoMessage()

func (*ChangePeerRequest) Reset 

func (m *ChangePeerRequest) Reset()

func (*ChangePeerRequest) Size 

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

func (*ChangePeerRequest) String 

func (m *ChangePeerRequest) String() string

func (*ChangePeerRequest) Unmarshal 

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

type ChangePeerResponse 

type ChangePeerResponse struct {
	DB               meta.VectorDB `protobuf:"bytes,1,opt,name=db" json:"db"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ChangePeerResponse) Descriptor 

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

func (*ChangePeerResponse) GetDB 

func (m *ChangePeerResponse) GetDB() meta.VectorDB

func (*ChangePeerResponse) Marshal 

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

func (*ChangePeerResponse) MarshalTo 

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

func (*ChangePeerResponse) ProtoMessage 

func (*ChangePeerResponse) ProtoMessage()

func (*ChangePeerResponse) Reset 

func (m *ChangePeerResponse) Reset()

func (*ChangePeerResponse) Size 

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

func (*ChangePeerResponse) String 

func (m *ChangePeerResponse) String() string

func (*ChangePeerResponse) Unmarshal 

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

type CompactLogRequest 

type CompactLogRequest struct {
	CompactIndex     uint64 `protobuf:"varint,1,opt,name=compactIndex" json:"compactIndex"`
	CompactTerm      uint64 `protobuf:"varint,2,opt,name=compactTerm" json:"compactTerm"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CompactLogRequest) Descriptor 

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

func (*CompactLogRequest) GetCompactIndex 

func (m *CompactLogRequest) GetCompactIndex() uint64

func (*CompactLogRequest) GetCompactTerm 

func (m *CompactLogRequest) GetCompactTerm() uint64

func (*CompactLogRequest) Marshal 

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

func (*CompactLogRequest) MarshalTo 

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

func (*CompactLogRequest) ProtoMessage 

func (*CompactLogRequest) ProtoMessage()

func (*CompactLogRequest) Reset 

func (m *CompactLogRequest) Reset()

func (*CompactLogRequest) Size 

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

func (*CompactLogRequest) String 

func (m *CompactLogRequest) String() string

func (*CompactLogRequest) Unmarshal 

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

type CompactLogResponse 

type CompactLogResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CompactLogResponse) Descriptor 

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

func (*CompactLogResponse) Marshal 

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

func (*CompactLogResponse) MarshalTo 

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

func (*CompactLogResponse) ProtoMessage 

func (*CompactLogResponse) ProtoMessage()

func (*CompactLogResponse) Reset 

func (m *CompactLogResponse) Reset()

func (*CompactLogResponse) Size 

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

func (*CompactLogResponse) String 

func (m *CompactLogResponse) String() string

func (*CompactLogResponse) Unmarshal 

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

type DBLocalState 

type DBLocalState struct {
	State            PeerState     `protobuf:"varint,1,opt,name=state,enum=raft.PeerState" json:"state"`
	DB               meta.VectorDB `protobuf:"bytes,2,opt,name=db" json:"db"`
	XXX_unrecognized []byte        `json:"-"`
}

DBLocalState vectordb local state

func (*DBLocalState) Descriptor 

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

func (*DBLocalState) GetDB 

func (m *DBLocalState) GetDB() meta.VectorDB

func (*DBLocalState) GetState 

func (m *DBLocalState) GetState() PeerState

func (*DBLocalState) Marshal 

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

func (*DBLocalState) MarshalTo 

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

func (*DBLocalState) ProtoMessage 

func (*DBLocalState) ProtoMessage()

func (*DBLocalState) Reset 

func (m *DBLocalState) Reset()

func (*DBLocalState) Size 

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

func (*DBLocalState) String 

func (m *DBLocalState) String() string

func (*DBLocalState) Unmarshal 

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

type PeerState 

type PeerState int32

PeerState peer state 

const (
	Normal    PeerState = 0
	Applying  PeerState = 1
	Tombstone PeerState = 2
)

func (PeerState) Enum 

func (x PeerState) Enum() *PeerState

func (PeerState) EnumDescriptor 

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

func (PeerState) String 

func (x PeerState) String() string

func (*PeerState) UnmarshalJSON 

func (x *PeerState) UnmarshalJSON(data []byte) error

type RaftApplyState 

type RaftApplyState struct {
	AppliedIndex     uint64             `protobuf:"varint,1,opt,name=appliedIndex" json:"appliedIndex"`
	TruncatedState   RaftTruncatedState `protobuf:"bytes,2,opt,name=truncatedState" json:"truncatedState"`
	CommittedOffset  int64              `protobuf:"varint,3,opt,name=committedOffset" json:"committedOffset"`
	CommittedIndex   int64              `protobuf:"varint,4,opt,name=committedIndex" json:"committedIndex"`
	XXX_unrecognized []byte             `json:"-"`
}

RaftApplyState raft apply state

func (*RaftApplyState) Descriptor 

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

func (*RaftApplyState) GetAppliedIndex 

func (m *RaftApplyState) GetAppliedIndex() uint64

func (*RaftApplyState) GetCommittedIndex 

func (m *RaftApplyState) GetCommittedIndex() int64

func (*RaftApplyState) GetCommittedOffset 

func (m *RaftApplyState) GetCommittedOffset() int64

func (*RaftApplyState) GetTruncatedState 

func (m *RaftApplyState) GetTruncatedState() RaftTruncatedState

func (*RaftApplyState) Marshal 

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

func (*RaftApplyState) MarshalTo 

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

func (*RaftApplyState) ProtoMessage 

func (*RaftApplyState) ProtoMessage()

func (*RaftApplyState) Reset 

func (m *RaftApplyState) Reset()

func (*RaftApplyState) Size 

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

func (*RaftApplyState) String 

func (m *RaftApplyState) String() string

func (*RaftApplyState) Unmarshal 

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

type RaftCMDRequest 

type RaftCMDRequest struct {
	Header           RaftRequestHeader    `protobuf:"bytes,1,opt,name=header" json:"header"`
	Inserts          []*rpc.InsertRequest `protobuf:"bytes,2,rep,name=inserts" json:"inserts,omitempty"`
	Updates          []*rpc.UpdateRequest `protobuf:"bytes,3,rep,name=updates" json:"updates,omitempty"`
	Admin            *AdminRequest        `protobuf:"bytes,4,opt,name=admin" json:"admin,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

RaftCMDRequest we can't include both normal requests and administrator request at same time.

func (*RaftCMDRequest) Descriptor 

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

func (*RaftCMDRequest) GetAdmin 

func (m *RaftCMDRequest) GetAdmin() *AdminRequest

func (*RaftCMDRequest) GetHeader 

func (m *RaftCMDRequest) GetHeader() RaftRequestHeader

func (*RaftCMDRequest) GetInserts 

func (m *RaftCMDRequest) GetInserts() []*rpc.InsertRequest

func (*RaftCMDRequest) GetUpdates 

func (m *RaftCMDRequest) GetUpdates() []*rpc.UpdateRequest

func (*RaftCMDRequest) Marshal 

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

func (*RaftCMDRequest) MarshalTo 

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

func (*RaftCMDRequest) ProtoMessage 

func (*RaftCMDRequest) ProtoMessage()

func (*RaftCMDRequest) Reset 

func (m *RaftCMDRequest) Reset()

func (*RaftCMDRequest) Size 

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

func (*RaftCMDRequest) String 

func (m *RaftCMDRequest) String() string

func (*RaftCMDRequest) Unmarshal 

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

type RaftLocalState 

type RaftLocalState struct {
	HardState        raftpb.HardState `protobuf:"bytes,1,opt,name=hardState" json:"hardState"`
	LastIndex        uint64           `protobuf:"varint,2,opt,name=lastIndex" json:"lastIndex"`
	XXX_unrecognized []byte           `json:"-"`
}

RaftLocalState raft local state

func (*RaftLocalState) Descriptor 

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

func (*RaftLocalState) GetHardState 

func (m *RaftLocalState) GetHardState() raftpb.HardState

func (*RaftLocalState) GetLastIndex 

func (m *RaftLocalState) GetLastIndex() uint64

func (*RaftLocalState) Marshal 

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

func (*RaftLocalState) MarshalTo 

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

func (*RaftLocalState) ProtoMessage 

func (*RaftLocalState) ProtoMessage()

func (*RaftLocalState) Reset 

func (m *RaftLocalState) Reset()

func (*RaftLocalState) Size 

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

func (*RaftLocalState) String 

func (m *RaftLocalState) String() string

func (*RaftLocalState) Unmarshal 

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

type RaftMessage 

type RaftMessage struct {
	ID               uint64         `protobuf:"varint,1,opt,name=id" json:"id"`
	From             meta.Peer      `protobuf:"bytes,2,opt,name=from" json:"from"`
	To               meta.Peer      `protobuf:"bytes,3,opt,name=to" json:"to"`
	Epoch            meta.Epoch     `protobuf:"bytes,4,opt,name=epoch" json:"epoch"`
	Start            uint64         `protobuf:"varint,5,opt,name=start" json:"start"`
	DBState          meta.DBState   `protobuf:"varint,6,opt,name=dbState,enum=meta.DBState" json:"dbState"`
	Tombstone        bool           `protobuf:"varint,7,opt,name=tombstone" json:"tombstone"`
	Message          raftpb.Message `protobuf:"bytes,8,opt,name=message" json:"message"`
	XXX_unrecognized []byte         `json:"-"`
}

RaftMessage wrapper etcd raft msg for multi-raft

func (*RaftMessage) Descriptor 

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

func (*RaftMessage) GetDBState 

func (m *RaftMessage) GetDBState() meta.DBState

func (*RaftMessage) GetEpoch 

func (m *RaftMessage) GetEpoch() meta.Epoch

func (*RaftMessage) GetFrom 

func (m *RaftMessage) GetFrom() meta.Peer

func (*RaftMessage) GetID 

func (m *RaftMessage) GetID() uint64

func (*RaftMessage) GetMessage 

func (m *RaftMessage) GetMessage() raftpb.Message

func (*RaftMessage) GetStart 

func (m *RaftMessage) GetStart() uint64

func (*RaftMessage) GetTo 

func (m *RaftMessage) GetTo() meta.Peer

func (*RaftMessage) GetTombstone 

func (m *RaftMessage) GetTombstone() bool

func (*RaftMessage) Marshal 

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

func (*RaftMessage) MarshalTo 

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

func (*RaftMessage) ProtoMessage 

func (*RaftMessage) ProtoMessage()

func (*RaftMessage) Reset 

func (m *RaftMessage) Reset()

func (*RaftMessage) Size 

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

func (*RaftMessage) String 

func (m *RaftMessage) String() string

func (*RaftMessage) Unmarshal 

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

type RaftRequestHeader 

type RaftRequestHeader struct {
	ID               uint64     `protobuf:"varint,1,opt,name=id" json:"id"`
	UUID             []byte     `protobuf:"bytes,2,opt,name=uuid" json:"uuid,omitempty"`
	Peer             meta.Peer  `protobuf:"bytes,3,opt,name=peer" json:"peer"`
	Epoch            meta.Epoch `protobuf:"bytes,4,opt,name=epoch" json:"epoch"`
	Term             uint64     `protobuf:"varint,5,opt,name=term" json:"term"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*RaftRequestHeader) Descriptor 

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

func (*RaftRequestHeader) GetEpoch 

func (m *RaftRequestHeader) GetEpoch() meta.Epoch

func (*RaftRequestHeader) GetID 

func (m *RaftRequestHeader) GetID() uint64

func (*RaftRequestHeader) GetPeer 

func (m *RaftRequestHeader) GetPeer() meta.Peer

func (*RaftRequestHeader) GetTerm 

func (m *RaftRequestHeader) GetTerm() uint64

func (*RaftRequestHeader) GetUUID 

func (m *RaftRequestHeader) GetUUID() []byte

func (*RaftRequestHeader) Marshal 

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

func (*RaftRequestHeader) MarshalTo 

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

func (*RaftRequestHeader) ProtoMessage 

func (*RaftRequestHeader) ProtoMessage()

func (*RaftRequestHeader) Reset 

func (m *RaftRequestHeader) Reset()

func (*RaftRequestHeader) Size 

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

func (*RaftRequestHeader) String 

func (m *RaftRequestHeader) String() string

func (*RaftRequestHeader) Unmarshal 

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

type RaftTruncatedState 

type RaftTruncatedState struct {
	Index            uint64 `protobuf:"varint,1,opt,name=index" json:"index"`
	Term             uint64 `protobuf:"varint,2,opt,name=term" json:"term"`
	XXX_unrecognized []byte `json:"-"`
}

RaftTruncatedState raft snapshot state

func (*RaftTruncatedState) Descriptor 

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

func (*RaftTruncatedState) GetIndex 

func (m *RaftTruncatedState) GetIndex() uint64

func (*RaftTruncatedState) GetTerm 

func (m *RaftTruncatedState) GetTerm() uint64

func (*RaftTruncatedState) Marshal 

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

func (*RaftTruncatedState) MarshalTo 

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

func (*RaftTruncatedState) ProtoMessage 

func (*RaftTruncatedState) ProtoMessage()

func (*RaftTruncatedState) Reset 

func (m *RaftTruncatedState) Reset()

func (*RaftTruncatedState) Size 

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

func (*RaftTruncatedState) String 

func (m *RaftTruncatedState) String() string

func (*RaftTruncatedState) Unmarshal 

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

type SnapshotChunkMessage 

type SnapshotChunkMessage struct {
	Data             []byte `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
	First            bool   `protobuf:"varint,2,opt,name=first" json:"first"`
	Last             bool   `protobuf:"varint,3,opt,name=last" json:"last"`
	FileSize         uint64 `protobuf:"varint,4,opt,name=fileSize" json:"fileSize"`
	CheckSum         uint64 `protobuf:"varint,5,opt,name=checkSum" json:"checkSum"`
	XXX_unrecognized []byte `json:"-"`
}

SnapshotChunkMessage chunk message

func (*SnapshotChunkMessage) Descriptor 

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

func (*SnapshotChunkMessage) GetCheckSum 

func (m *SnapshotChunkMessage) GetCheckSum() uint64

func (*SnapshotChunkMessage) GetData 

func (m *SnapshotChunkMessage) GetData() []byte

func (*SnapshotChunkMessage) GetFileSize 

func (m *SnapshotChunkMessage) GetFileSize() uint64

func (*SnapshotChunkMessage) GetFirst 

func (m *SnapshotChunkMessage) GetFirst() bool

func (*SnapshotChunkMessage) GetLast 

func (m *SnapshotChunkMessage) GetLast() bool

func (*SnapshotChunkMessage) Marshal 

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

func (*SnapshotChunkMessage) MarshalTo 

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

func (*SnapshotChunkMessage) ProtoMessage 

func (*SnapshotChunkMessage) ProtoMessage()

func (*SnapshotChunkMessage) Reset 

func (m *SnapshotChunkMessage) Reset()

func (*SnapshotChunkMessage) Size 

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

func (*SnapshotChunkMessage) String 

func (m *SnapshotChunkMessage) String() string

func (*SnapshotChunkMessage) Unmarshal 

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

type SnapshotMessage 

type SnapshotMessage struct {
	Header           SnapshotMessageHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	Chunk            *SnapshotChunkMessage `protobuf:"bytes,2,opt,name=chunk" json:"chunk,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

SnapshotMessage message

func (*SnapshotMessage) Descriptor 

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

func (*SnapshotMessage) GetChunk 

func (m *SnapshotMessage) GetChunk() *SnapshotChunkMessage

func (*SnapshotMessage) GetHeader 

func (m *SnapshotMessage) GetHeader() SnapshotMessageHeader

func (*SnapshotMessage) Marshal 

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

func (*SnapshotMessage) MarshalTo 

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

func (*SnapshotMessage) ProtoMessage 

func (*SnapshotMessage) ProtoMessage()

func (*SnapshotMessage) Reset 

func (m *SnapshotMessage) Reset()

func (*SnapshotMessage) Size 

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

func (*SnapshotMessage) String 

func (m *SnapshotMessage) String() string

func (*SnapshotMessage) Unmarshal 

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

type SnapshotMessageHeader 

type SnapshotMessageHeader struct {
	DB               meta.VectorDB `protobuf:"bytes,1,opt,name=db" json:"db"`
	From             meta.Peer     `protobuf:"bytes,2,opt,name=from" json:"from"`
	To               meta.Peer     `protobuf:"bytes,3,opt,name=to" json:"to"`
	Term             uint64        `protobuf:"varint,4,opt,name=term" json:"term"`
	Index            uint64        `protobuf:"varint,5,opt,name=index" json:"index"`
	Seq              uint64        `protobuf:"varint,6,opt,name=seq" json:"seq"`
	CommittedOffset  int64         `protobuf:"varint,7,opt,name=committedOffset" json:"committedOffset"`
	CommittedIndex   int64         `protobuf:"varint,8,opt,name=committedIndex" json:"committedIndex"`
	XXX_unrecognized []byte        `json:"-"`
}

SnapshotMessageHeader snapshot header

func (*SnapshotMessageHeader) Descriptor 

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

func (*SnapshotMessageHeader) GetCommittedIndex 

func (m *SnapshotMessageHeader) GetCommittedIndex() int64

func (*SnapshotMessageHeader) GetCommittedOffset 

func (m *SnapshotMessageHeader) GetCommittedOffset() int64

func (*SnapshotMessageHeader) GetDB 

func (m *SnapshotMessageHeader) GetDB() meta.VectorDB

func (*SnapshotMessageHeader) GetFrom 

func (m *SnapshotMessageHeader) GetFrom() meta.Peer

func (*SnapshotMessageHeader) GetIndex 

func (m *SnapshotMessageHeader) GetIndex() uint64

func (*SnapshotMessageHeader) GetSeq 

func (m *SnapshotMessageHeader) GetSeq() uint64

func (*SnapshotMessageHeader) GetTerm 

func (m *SnapshotMessageHeader) GetTerm() uint64

func (*SnapshotMessageHeader) GetTo 

func (m *SnapshotMessageHeader) GetTo() meta.Peer

func (*SnapshotMessageHeader) Marshal 

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

func (*SnapshotMessageHeader) MarshalTo 

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

func (*SnapshotMessageHeader) ProtoMessage 

func (*SnapshotMessageHeader) ProtoMessage()

func (*SnapshotMessageHeader) Reset 

func (m *SnapshotMessageHeader) Reset()

func (*SnapshotMessageHeader) Size 

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

func (*SnapshotMessageHeader) String 

func (m *SnapshotMessageHeader) String() string

func (*SnapshotMessageHeader) Unmarshal 

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

type SplitRequest 

type SplitRequest struct {
	// We split the vectordb into two, first uses the origin
	// parent db id, and the second uses the newID.
	// We must guarantee that the newID is global unique.
	NewID uint64 `protobuf:"varint,1,opt,name=newID" json:"newID"`
	// The peer ids for the new split vectordb.
	NewPeerIDs []uint64 `protobuf:"varint,2,rep,name=newPeerIDs" json:"newPeerIDs,omitempty"`
	// The committedOffset last committed offset in mq
	CommittedOffset  int64  `protobuf:"varint,3,opt,name=committedOffset" json:"committedOffset"`
	CommittedIndex   int64  `protobuf:"varint,4,opt,name=committedIndex" json:"committedIndex"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SplitRequest) Descriptor 

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

func (*SplitRequest) GetCommittedIndex 

func (m *SplitRequest) GetCommittedIndex() int64

func (*SplitRequest) GetCommittedOffset 

func (m *SplitRequest) GetCommittedOffset() int64

func (*SplitRequest) GetNewID 

func (m *SplitRequest) GetNewID() uint64

func (*SplitRequest) GetNewPeerIDs 

func (m *SplitRequest) GetNewPeerIDs() []uint64

func (*SplitRequest) Marshal 

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

func (*SplitRequest) MarshalTo 

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

func (*SplitRequest) ProtoMessage 

func (*SplitRequest) ProtoMessage()

func (*SplitRequest) Reset 

func (m *SplitRequest) Reset()

func (*SplitRequest) Size 

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

func (*SplitRequest) String 

func (m *SplitRequest) String() string

func (*SplitRequest) Unmarshal 

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

type SplitResponse 

type SplitResponse struct {
	OldDB            meta.VectorDB `protobuf:"bytes,1,opt,name=oldDB" json:"oldDB"`
	NewDB            meta.VectorDB `protobuf:"bytes,2,opt,name=newDB" json:"newDB"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*SplitResponse) Descriptor 

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

func (*SplitResponse) GetNewDB 

func (m *SplitResponse) GetNewDB() meta.VectorDB

func (*SplitResponse) GetOldDB 

func (m *SplitResponse) GetOldDB() meta.VectorDB

func (*SplitResponse) Marshal 

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

func (*SplitResponse) MarshalTo 

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

func (*SplitResponse) ProtoMessage 

func (*SplitResponse) ProtoMessage()

func (*SplitResponse) Reset 

func (m *SplitResponse) Reset()

func (*SplitResponse) Size 

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

func (*SplitResponse) String 

func (m *SplitResponse) String() string

func (*SplitResponse) Unmarshal 

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

type TransferLeaderRequest 

type TransferLeaderRequest struct {
	Peer             meta.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TransferLeaderRequest) Descriptor 

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

func (*TransferLeaderRequest) GetPeer 

func (m *TransferLeaderRequest) GetPeer() meta.Peer

func (*TransferLeaderRequest) Marshal 

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

func (*TransferLeaderRequest) MarshalTo 

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

func (*TransferLeaderRequest) ProtoMessage 

func (*TransferLeaderRequest) ProtoMessage()

func (*TransferLeaderRequest) Reset 

func (m *TransferLeaderRequest) Reset()

func (*TransferLeaderRequest) Size 

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

func (*TransferLeaderRequest) String 

func (m *TransferLeaderRequest) String() string

func (*TransferLeaderRequest) Unmarshal 

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

type TransferLeaderResponse 

type TransferLeaderResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TransferLeaderResponse) Descriptor 

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

func (*TransferLeaderResponse) Marshal 

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

func (*TransferLeaderResponse) MarshalTo 

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

func (*TransferLeaderResponse) ProtoMessage 

func (*TransferLeaderResponse) ProtoMessage()

func (*TransferLeaderResponse) Reset 

func (m *TransferLeaderResponse) Reset()

func (*TransferLeaderResponse) Size 

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

func (*TransferLeaderResponse) String 

func (m *TransferLeaderResponse) String() string

func (*TransferLeaderResponse) Unmarshal 

func (m *TransferLeaderResponse) Unmarshal(dAtA []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.