mraft

package
v0.0.0-...-f0aa2c5 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMraft = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMraft   = fmt.Errorf("proto: integer overflow")
)
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,
}
View Source 
var SnapshotState_name = map[int32]string{
	0: "Accept",
	1: "Reject",
	2: "Received",
}
View Source 
var SnapshotState_value = map[string]int32{
	"Accept":   0,
	"Reject":   1,
	"Received": 2,
}

Functions

This section is empty.

Types

type ACKMessage 

type ACKMessage struct {
	Seq                  uint64   `protobuf:"varint,1,opt,name=seq" json:"seq"`
	To                   uint64   `protobuf:"varint,2,opt,name=to" json:"to"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACKMessage) Descriptor 

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

func (*ACKMessage) GetSeq 

func (m *ACKMessage) GetSeq() uint64

func (*ACKMessage) GetTo 

func (m *ACKMessage) GetTo() uint64

func (*ACKMessage) Marshal 

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

func (*ACKMessage) MarshalTo 

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

func (*ACKMessage) MarshalToSizedBuffer 

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

func (*ACKMessage) ProtoMessage 

func (*ACKMessage) ProtoMessage()

func (*ACKMessage) Reset 

func (m *ACKMessage) Reset()

func (*ACKMessage) Size 

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

func (*ACKMessage) String 

func (m *ACKMessage) String() string

func (*ACKMessage) Unmarshal 

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

func (*ACKMessage) XXX_DiscardUnknown 

func (m *ACKMessage) XXX_DiscardUnknown()

func (*ACKMessage) XXX_Marshal 

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

func (*ACKMessage) XXX_Merge 

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

func (*ACKMessage) XXX_Size 

func (m *ACKMessage) XXX_Size() int

func (*ACKMessage) XXX_Unmarshal 

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

type CellLocalState 

type CellLocalState struct {
	State                PeerState   `protobuf:"varint,1,opt,name=state,enum=mraft.PeerState" json:"state"`
	Cell                 metapb.Cell `protobuf:"bytes,2,opt,name=cell" json:"cell"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CellLocalState) Descriptor 

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

func (*CellLocalState) GetCell 

func (m *CellLocalState) GetCell() metapb.Cell

func (*CellLocalState) GetState 

func (m *CellLocalState) GetState() PeerState

func (*CellLocalState) Marshal 

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

func (*CellLocalState) MarshalTo 

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

func (*CellLocalState) MarshalToSizedBuffer 

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

func (*CellLocalState) ProtoMessage 

func (*CellLocalState) ProtoMessage()

func (*CellLocalState) Reset 

func (m *CellLocalState) Reset()

func (*CellLocalState) Size 

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

func (*CellLocalState) String 

func (m *CellLocalState) String() string

func (*CellLocalState) Unmarshal 

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

func (*CellLocalState) XXX_DiscardUnknown 

func (m *CellLocalState) XXX_DiscardUnknown()

func (*CellLocalState) XXX_Marshal 

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

func (*CellLocalState) XXX_Merge 

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

func (*CellLocalState) XXX_Size 

func (m *CellLocalState) XXX_Size() int

func (*CellLocalState) XXX_Unmarshal 

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

type PeerState 

type PeerState int32
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=applied_index,json=appliedIndex" json:"applied_index"`
	TruncatedState       RaftTruncatedState `protobuf:"bytes,2,opt,name=truncated_state,json=truncatedState" json:"truncated_state"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*RaftApplyState) Descriptor 

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

func (*RaftApplyState) GetAppliedIndex 

func (m *RaftApplyState) GetAppliedIndex() uint64

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) MarshalToSizedBuffer 

func (m *RaftApplyState) MarshalToSizedBuffer(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

func (*RaftApplyState) XXX_DiscardUnknown 

func (m *RaftApplyState) XXX_DiscardUnknown()

func (*RaftApplyState) XXX_Marshal 

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

func (*RaftApplyState) XXX_Merge 

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

func (*RaftApplyState) XXX_Size 

func (m *RaftApplyState) XXX_Size() int

func (*RaftApplyState) XXX_Unmarshal 

func (m *RaftApplyState) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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) MarshalToSizedBuffer 

func (m *RaftLocalState) MarshalToSizedBuffer(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

func (*RaftLocalState) XXX_DiscardUnknown 

func (m *RaftLocalState) XXX_DiscardUnknown()

func (*RaftLocalState) XXX_Marshal 

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

func (*RaftLocalState) XXX_Merge 

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

func (*RaftLocalState) XXX_Size 

func (m *RaftLocalState) XXX_Size() int

func (*RaftLocalState) XXX_Unmarshal 

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

type RaftMessage 

type RaftMessage struct {
	CellID    uint64           `protobuf:"varint,1,opt,name=cellID" json:"cellID"`
	FromPeer  metapb.Peer      `protobuf:"bytes,2,opt,name=fromPeer" json:"fromPeer"`
	ToPeer    metapb.Peer      `protobuf:"bytes,3,opt,name=toPeer" json:"toPeer"`
	Message   raftpb.Message   `protobuf:"bytes,4,opt,name=message" json:"message"`
	CellEpoch metapb.CellEpoch `protobuf:"bytes,5,opt,name=cellEpoch" json:"cellEpoch"`
	// true means to_peer is a tombstone peer and it should remove itself.
	IsTombstone bool `protobuf:"varint,6,opt,name=isTombstone" json:"isTombstone"`
	// Cell key range [start_key, end_key).
	Start                []byte   `protobuf:"bytes,7,opt,name=start" json:"start,omitempty"`
	End                  []byte   `protobuf:"bytes,8,opt,name=end" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RaftMessage) Descriptor 

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

func (*RaftMessage) GetCellEpoch 

func (m *RaftMessage) GetCellEpoch() metapb.CellEpoch

func (*RaftMessage) GetCellID 

func (m *RaftMessage) GetCellID() uint64

func (*RaftMessage) GetEnd 

func (m *RaftMessage) GetEnd() []byte

func (*RaftMessage) GetFromPeer 

func (m *RaftMessage) GetFromPeer() metapb.Peer

func (*RaftMessage) GetIsTombstone 

func (m *RaftMessage) GetIsTombstone() bool

func (*RaftMessage) GetMessage 

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

func (*RaftMessage) GetStart 

func (m *RaftMessage) GetStart() []byte

func (*RaftMessage) GetToPeer 

func (m *RaftMessage) GetToPeer() metapb.Peer

func (*RaftMessage) Marshal 

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

func (*RaftMessage) MarshalTo 

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

func (*RaftMessage) MarshalToSizedBuffer 

func (m *RaftMessage) MarshalToSizedBuffer(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

func (*RaftMessage) XXX_DiscardUnknown 

func (m *RaftMessage) XXX_DiscardUnknown()

func (*RaftMessage) XXX_Marshal 

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

func (*RaftMessage) XXX_Merge 

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

func (*RaftMessage) XXX_Size 

func (m *RaftMessage) XXX_Size() int

func (*RaftMessage) XXX_Unmarshal 

func (m *RaftMessage) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) MarshalToSizedBuffer 

func (m *RaftTruncatedState) MarshalToSizedBuffer(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

func (*RaftTruncatedState) XXX_DiscardUnknown 

func (m *RaftTruncatedState) XXX_DiscardUnknown()

func (*RaftTruncatedState) XXX_Marshal 

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

func (*RaftTruncatedState) XXX_Merge 

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

func (*RaftTruncatedState) XXX_Size 

func (m *RaftTruncatedState) XXX_Size() int

func (*RaftTruncatedState) XXX_Unmarshal 

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

type SnapshotAckMessage 

type SnapshotAckMessage struct {
	Ack                  SnapshotState `protobuf:"varint,1,opt,name=ack,enum=mraft.SnapshotState" json:"ack"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SnapshotAckMessage) Descriptor 

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

func (*SnapshotAckMessage) GetAck 

func (m *SnapshotAckMessage) GetAck() SnapshotState

func (*SnapshotAckMessage) Marshal 

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

func (*SnapshotAckMessage) MarshalTo 

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

func (*SnapshotAckMessage) MarshalToSizedBuffer 

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

func (*SnapshotAckMessage) ProtoMessage 

func (*SnapshotAckMessage) ProtoMessage()

func (*SnapshotAckMessage) Reset 

func (m *SnapshotAckMessage) Reset()

func (*SnapshotAckMessage) Size 

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

func (*SnapshotAckMessage) String 

func (m *SnapshotAckMessage) String() string

func (*SnapshotAckMessage) Unmarshal 

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

func (*SnapshotAckMessage) XXX_DiscardUnknown 

func (m *SnapshotAckMessage) XXX_DiscardUnknown()

func (*SnapshotAckMessage) XXX_Marshal 

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

func (*SnapshotAckMessage) XXX_Merge 

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

func (*SnapshotAckMessage) XXX_Size 

func (m *SnapshotAckMessage) XXX_Size() int

func (*SnapshotAckMessage) XXX_Unmarshal 

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

type SnapshotAskMessage 

type SnapshotAskMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SnapshotAskMessage) Descriptor 

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

func (*SnapshotAskMessage) Marshal 

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

func (*SnapshotAskMessage) MarshalTo 

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

func (*SnapshotAskMessage) MarshalToSizedBuffer 

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

func (*SnapshotAskMessage) ProtoMessage 

func (*SnapshotAskMessage) ProtoMessage()

func (*SnapshotAskMessage) Reset 

func (m *SnapshotAskMessage) Reset()

func (*SnapshotAskMessage) Size 

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

func (*SnapshotAskMessage) String 

func (m *SnapshotAskMessage) String() string

func (*SnapshotAskMessage) Unmarshal 

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

func (*SnapshotAskMessage) XXX_DiscardUnknown 

func (m *SnapshotAskMessage) XXX_DiscardUnknown()

func (*SnapshotAskMessage) XXX_Marshal 

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

func (*SnapshotAskMessage) XXX_Merge 

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

func (*SnapshotAskMessage) XXX_Size 

func (m *SnapshotAskMessage) XXX_Size() int

func (*SnapshotAskMessage) XXX_Unmarshal 

func (m *SnapshotAskMessage) XXX_Unmarshal(b []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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) MarshalToSizedBuffer 

func (m *SnapshotChunkMessage) MarshalToSizedBuffer(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

func (*SnapshotChunkMessage) XXX_DiscardUnknown 

func (m *SnapshotChunkMessage) XXX_DiscardUnknown()

func (*SnapshotChunkMessage) XXX_Marshal 

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

func (*SnapshotChunkMessage) XXX_Merge 

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

func (*SnapshotChunkMessage) XXX_Size 

func (m *SnapshotChunkMessage) XXX_Size() int

func (*SnapshotChunkMessage) XXX_Unmarshal 

func (m *SnapshotChunkMessage) XXX_Unmarshal(b []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"`
	Ack                  *SnapshotAckMessage   `protobuf:"bytes,3,opt,name=ack" json:"ack,omitempty"`
	Ask                  *SnapshotAskMessage   `protobuf:"bytes,4,opt,name=ask" json:"ask,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*SnapshotMessage) Descriptor 

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

func (*SnapshotMessage) GetAck 

func (m *SnapshotMessage) GetAck() *SnapshotAckMessage

func (*SnapshotMessage) GetAsk 

func (m *SnapshotMessage) GetAsk() *SnapshotAskMessage

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) MarshalToSizedBuffer 

func (m *SnapshotMessage) MarshalToSizedBuffer(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

func (*SnapshotMessage) XXX_DiscardUnknown 

func (m *SnapshotMessage) XXX_DiscardUnknown()

func (*SnapshotMessage) XXX_Marshal 

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

func (*SnapshotMessage) XXX_Merge 

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

func (*SnapshotMessage) XXX_Size 

func (m *SnapshotMessage) XXX_Size() int

func (*SnapshotMessage) XXX_Unmarshal 

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

type SnapshotMessageHeader 

type SnapshotMessageHeader struct {
	Cell                 metapb.Cell `protobuf:"bytes,1,opt,name=cell" json:"cell"`
	FromPeer             metapb.Peer `protobuf:"bytes,2,opt,name=fromPeer" json:"fromPeer"`
	ToPeer               metapb.Peer `protobuf:"bytes,3,opt,name=toPeer" json:"toPeer"`
	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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SnapshotMessageHeader) Descriptor 

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

func (*SnapshotMessageHeader) GetCell 

func (m *SnapshotMessageHeader) GetCell() metapb.Cell

func (*SnapshotMessageHeader) GetFromPeer 

func (m *SnapshotMessageHeader) GetFromPeer() metapb.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) GetToPeer 

func (m *SnapshotMessageHeader) GetToPeer() metapb.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) MarshalToSizedBuffer 

func (m *SnapshotMessageHeader) MarshalToSizedBuffer(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

func (*SnapshotMessageHeader) XXX_DiscardUnknown 

func (m *SnapshotMessageHeader) XXX_DiscardUnknown()

func (*SnapshotMessageHeader) XXX_Marshal 

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

func (*SnapshotMessageHeader) XXX_Merge 

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

func (*SnapshotMessageHeader) XXX_Size 

func (m *SnapshotMessageHeader) XXX_Size() int

func (*SnapshotMessageHeader) XXX_Unmarshal 

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

type SnapshotState 

type SnapshotState int32
const (
	Accept   SnapshotState = 0
	Reject   SnapshotState = 1
	Received SnapshotState = 2
)

func (SnapshotState) Enum 

func (x SnapshotState) Enum() *SnapshotState

func (SnapshotState) EnumDescriptor 

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

func (SnapshotState) String 

func (x SnapshotState) String() string

func (*SnapshotState) UnmarshalJSON 

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

type StoreIdent 

type StoreIdent struct {
	ClusterID            uint64   `protobuf:"varint,1,opt,name=clusterID" json:"clusterID"`
	StoreID              uint64   `protobuf:"varint,2,opt,name=storeID" json:"storeID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StoreIdent) Descriptor 

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

func (*StoreIdent) GetClusterID 

func (m *StoreIdent) GetClusterID() uint64

func (*StoreIdent) GetStoreID 

func (m *StoreIdent) GetStoreID() uint64

func (*StoreIdent) Marshal 

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

func (*StoreIdent) MarshalTo 

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

func (*StoreIdent) MarshalToSizedBuffer 

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

func (*StoreIdent) ProtoMessage 

func (*StoreIdent) ProtoMessage()

func (*StoreIdent) Reset 

func (m *StoreIdent) Reset()

func (*StoreIdent) Size 

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

func (*StoreIdent) String 

func (m *StoreIdent) String() string

func (*StoreIdent) Unmarshal 

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

func (*StoreIdent) XXX_DiscardUnknown 

func (m *StoreIdent) XXX_DiscardUnknown()

func (*StoreIdent) XXX_Marshal 

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

func (*StoreIdent) XXX_Merge 

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

func (*StoreIdent) XXX_Size 

func (m *StoreIdent) XXX_Size() int

func (*StoreIdent) XXX_Unmarshal 

func (m *StoreIdent) 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.