mraft

package
v0.0.0-...-a9a2a47 Latest Latest
Warning

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

Go to latest
Published: Jun 22, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL