raft_serverpb

package
v0.0.0-...-98b0a12 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaftServerpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftServerpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var PeerState_name = map[int32]string{
	0: "Normal",
	1: "Applying",
	2: "Tombstone",
	3: "Merging",
}
View Source 
var PeerState_value = map[string]int32{
	"Normal":    0,
	"Applying":  1,
	"Tombstone": 2,
	"Merging":   3,
}

Functions

This section is empty.

Types

type Done 

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

func (*Done) Descriptor 

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

func (*Done) Marshal 

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

func (*Done) MarshalTo 

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

func (*Done) ProtoMessage 

func (*Done) ProtoMessage()

func (*Done) Reset 

func (m *Done) Reset()

func (*Done) Size 

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

func (*Done) String 

func (m *Done) String() string

func (*Done) Unmarshal 

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

func (*Done) XXX_DiscardUnknown 

func (m *Done) XXX_DiscardUnknown()

func (*Done) XXX_Marshal 

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

func (*Done) XXX_Merge 

func (dst *Done) XXX_Merge(src proto.Message)

func (*Done) XXX_Size 

func (m *Done) XXX_Size() int

func (*Done) XXX_Unmarshal 

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

type KeyValue 

type KeyValue struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() []byte

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() []byte

func (*KeyValue) Marshal 

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

func (*KeyValue) MarshalTo 

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

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) Size 

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

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal 

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

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

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

func (*KeyValue) XXX_Merge 

func (dst *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

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

type MergeState 

type MergeState struct {
	MinIndex             uint64         `protobuf:"varint,1,opt,name=min_index,json=minIndex,proto3" json:"min_index,omitempty"`
	Target               *metapb.Region `protobuf:"bytes,2,opt,name=target" json:"target,omitempty"`
	Commit               uint64         `protobuf:"varint,3,opt,name=commit,proto3" json:"commit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*MergeState) Descriptor 

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

func (*MergeState) GetCommit 

func (m *MergeState) GetCommit() uint64

func (*MergeState) GetMinIndex 

func (m *MergeState) GetMinIndex() uint64

func (*MergeState) GetTarget 

func (m *MergeState) GetTarget() *metapb.Region

func (*MergeState) Marshal 

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

func (*MergeState) MarshalTo 

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

func (*MergeState) ProtoMessage 

func (*MergeState) ProtoMessage()

func (*MergeState) Reset 

func (m *MergeState) Reset()

func (*MergeState) Size 

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

func (*MergeState) String 

func (m *MergeState) String() string

func (*MergeState) Unmarshal 

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

func (*MergeState) XXX_DiscardUnknown 

func (m *MergeState) XXX_DiscardUnknown()

func (*MergeState) XXX_Marshal 

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

func (*MergeState) XXX_Merge 

func (dst *MergeState) XXX_Merge(src proto.Message)

func (*MergeState) XXX_Size 

func (m *MergeState) XXX_Size() int

func (*MergeState) XXX_Unmarshal 

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

type PeerState 

type PeerState int32
const (
	PeerState_Normal    PeerState = 0
	PeerState_Applying  PeerState = 1
	PeerState_Tombstone PeerState = 2
	PeerState_Merging   PeerState = 3
)

func (PeerState) EnumDescriptor 

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

func (PeerState) String 

func (x PeerState) String() string

type RaftApplyState 

type RaftApplyState struct {
	AppliedIndex         uint64              `protobuf:"varint,1,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	TruncatedState       *RaftTruncatedState `protobuf:"bytes,2,opt,name=truncated_state,json=truncatedState" json:"truncated_state,omitempty"`
	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) 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 (dst *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            *eraftpb.HardState `protobuf:"bytes,1,opt,name=hard_state,json=hardState" json:"hard_state,omitempty"`
	LastIndex            uint64             `protobuf:"varint,2,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"`
	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() *eraftpb.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

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 (dst *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 {
	RegionId    uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	FromPeer    *metapb.Peer        `protobuf:"bytes,2,opt,name=from_peer,json=fromPeer" json:"from_peer,omitempty"`
	ToPeer      *metapb.Peer        `protobuf:"bytes,3,opt,name=to_peer,json=toPeer" json:"to_peer,omitempty"`
	Message     *eraftpb.Message    `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"`
	// true means to_peer is a tombstone peer and it should remove itself.
	IsTombstone bool `protobuf:"varint,6,opt,name=is_tombstone,json=isTombstone,proto3" json:"is_tombstone,omitempty"`
	// Region key range [start_key, end_key).
	StartKey []byte `protobuf:"bytes,7,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,8,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// If it has value, to_peer should be removed if merge is never going to complete.
	MergeTarget          *metapb.Region `protobuf:"bytes,9,opt,name=merge_target,json=mergeTarget" json:"merge_target,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RaftMessage) Descriptor 

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

func (*RaftMessage) GetEndKey 

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

func (*RaftMessage) GetFromPeer 

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

func (*RaftMessage) GetIsTombstone 

func (m *RaftMessage) GetIsTombstone() bool

func (*RaftMessage) GetMergeTarget 

func (m *RaftMessage) GetMergeTarget() *metapb.Region

func (*RaftMessage) GetMessage 

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

func (*RaftMessage) GetRegionEpoch 

func (m *RaftMessage) GetRegionEpoch() *metapb.RegionEpoch

func (*RaftMessage) GetRegionId 

func (m *RaftMessage) GetRegionId() uint64

func (*RaftMessage) GetStartKey 

func (m *RaftMessage) GetStartKey() []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) 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 (dst *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 RaftSnapshotData 

type RaftSnapshotData struct {
	Region               *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	FileSize             uint64         `protobuf:"varint,2,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Data                 []*KeyValue    `protobuf:"bytes,3,rep,name=data" json:"data,omitempty"`
	Version              uint64         `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	Meta                 *SnapshotMeta  `protobuf:"bytes,5,opt,name=meta" json:"meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RaftSnapshotData) Descriptor 

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

func (*RaftSnapshotData) GetData 

func (m *RaftSnapshotData) GetData() []*KeyValue

func (*RaftSnapshotData) GetFileSize 

func (m *RaftSnapshotData) GetFileSize() uint64

func (*RaftSnapshotData) GetMeta 

func (m *RaftSnapshotData) GetMeta() *SnapshotMeta

func (*RaftSnapshotData) GetRegion 

func (m *RaftSnapshotData) GetRegion() *metapb.Region

func (*RaftSnapshotData) GetVersion 

func (m *RaftSnapshotData) GetVersion() uint64

func (*RaftSnapshotData) Marshal 

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

func (*RaftSnapshotData) MarshalTo 

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

func (*RaftSnapshotData) ProtoMessage 

func (*RaftSnapshotData) ProtoMessage()

func (*RaftSnapshotData) Reset 

func (m *RaftSnapshotData) Reset()

func (*RaftSnapshotData) Size 

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

func (*RaftSnapshotData) String 

func (m *RaftSnapshotData) String() string

func (*RaftSnapshotData) Unmarshal 

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

func (*RaftSnapshotData) XXX_DiscardUnknown 

func (m *RaftSnapshotData) XXX_DiscardUnknown()

func (*RaftSnapshotData) XXX_Marshal 

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

func (*RaftSnapshotData) XXX_Merge 

func (dst *RaftSnapshotData) XXX_Merge(src proto.Message)

func (*RaftSnapshotData) XXX_Size 

func (m *RaftSnapshotData) XXX_Size() int

func (*RaftSnapshotData) XXX_Unmarshal 

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

type RaftTruncatedState 

type RaftTruncatedState struct {
	Index                uint64   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Term                 uint64   `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	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) 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 (dst *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 RegionLocalState 

type RegionLocalState struct {
	State                PeerState      `protobuf:"varint,1,opt,name=state,proto3,enum=raft_serverpb.PeerState" json:"state,omitempty"`
	Region               *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	MergeState           *MergeState    `protobuf:"bytes,3,opt,name=merge_state,json=mergeState" json:"merge_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RegionLocalState) Descriptor 

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

func (*RegionLocalState) GetMergeState 

func (m *RegionLocalState) GetMergeState() *MergeState

func (*RegionLocalState) GetRegion 

func (m *RegionLocalState) GetRegion() *metapb.Region

func (*RegionLocalState) GetState 

func (m *RegionLocalState) GetState() PeerState

func (*RegionLocalState) Marshal 

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

func (*RegionLocalState) MarshalTo 

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

func (*RegionLocalState) ProtoMessage 

func (*RegionLocalState) ProtoMessage()

func (*RegionLocalState) Reset 

func (m *RegionLocalState) Reset()

func (*RegionLocalState) Size 

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

func (*RegionLocalState) String 

func (m *RegionLocalState) String() string

func (*RegionLocalState) Unmarshal 

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

func (*RegionLocalState) XXX_DiscardUnknown 

func (m *RegionLocalState) XXX_DiscardUnknown()

func (*RegionLocalState) XXX_Marshal 

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

func (*RegionLocalState) XXX_Merge 

func (dst *RegionLocalState) XXX_Merge(src proto.Message)

func (*RegionLocalState) XXX_Size 

func (m *RegionLocalState) XXX_Size() int

func (*RegionLocalState) XXX_Unmarshal 

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

type SnapshotCFFile 

type SnapshotCFFile struct {
	Cf                   string   `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	Size_                uint64   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Checksum             uint32   `protobuf:"varint,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SnapshotCFFile) Descriptor 

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

func (*SnapshotCFFile) GetCf 

func (m *SnapshotCFFile) GetCf() string

func (*SnapshotCFFile) GetChecksum 

func (m *SnapshotCFFile) GetChecksum() uint32

func (*SnapshotCFFile) GetSize_ 

func (m *SnapshotCFFile) GetSize_() uint64

func (*SnapshotCFFile) Marshal 

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

func (*SnapshotCFFile) MarshalTo 

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

func (*SnapshotCFFile) ProtoMessage 

func (*SnapshotCFFile) ProtoMessage()

func (*SnapshotCFFile) Reset 

func (m *SnapshotCFFile) Reset()

func (*SnapshotCFFile) Size 

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

func (*SnapshotCFFile) String 

func (m *SnapshotCFFile) String() string

func (*SnapshotCFFile) Unmarshal 

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

func (*SnapshotCFFile) XXX_DiscardUnknown 

func (m *SnapshotCFFile) XXX_DiscardUnknown()

func (*SnapshotCFFile) XXX_Marshal 

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

func (*SnapshotCFFile) XXX_Merge 

func (dst *SnapshotCFFile) XXX_Merge(src proto.Message)

func (*SnapshotCFFile) XXX_Size 

func (m *SnapshotCFFile) XXX_Size() int

func (*SnapshotCFFile) XXX_Unmarshal 

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

type SnapshotChunk 

type SnapshotChunk struct {
	Message              *RaftMessage `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	Data                 []byte       `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SnapshotChunk) Descriptor 

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

func (*SnapshotChunk) GetData 

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

func (*SnapshotChunk) GetMessage 

func (m *SnapshotChunk) GetMessage() *RaftMessage

func (*SnapshotChunk) Marshal 

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

func (*SnapshotChunk) MarshalTo 

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

func (*SnapshotChunk) ProtoMessage 

func (*SnapshotChunk) ProtoMessage()

func (*SnapshotChunk) Reset 

func (m *SnapshotChunk) Reset()

func (*SnapshotChunk) Size 

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

func (*SnapshotChunk) String 

func (m *SnapshotChunk) String() string

func (*SnapshotChunk) Unmarshal 

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

func (*SnapshotChunk) XXX_DiscardUnknown 

func (m *SnapshotChunk) XXX_DiscardUnknown()

func (*SnapshotChunk) XXX_Marshal 

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

func (*SnapshotChunk) XXX_Merge 

func (dst *SnapshotChunk) XXX_Merge(src proto.Message)

func (*SnapshotChunk) XXX_Size 

func (m *SnapshotChunk) XXX_Size() int

func (*SnapshotChunk) XXX_Unmarshal 

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

type SnapshotMeta 

type SnapshotMeta struct {
	CfFiles              []*SnapshotCFFile `protobuf:"bytes,1,rep,name=cf_files,json=cfFiles" json:"cf_files,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SnapshotMeta) Descriptor 

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

func (*SnapshotMeta) GetCfFiles 

func (m *SnapshotMeta) GetCfFiles() []*SnapshotCFFile

func (*SnapshotMeta) Marshal 

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

func (*SnapshotMeta) MarshalTo 

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

func (*SnapshotMeta) ProtoMessage 

func (*SnapshotMeta) ProtoMessage()

func (*SnapshotMeta) Reset 

func (m *SnapshotMeta) Reset()

func (*SnapshotMeta) Size 

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

func (*SnapshotMeta) String 

func (m *SnapshotMeta) String() string

func (*SnapshotMeta) Unmarshal 

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

func (*SnapshotMeta) XXX_DiscardUnknown 

func (m *SnapshotMeta) XXX_DiscardUnknown()

func (*SnapshotMeta) XXX_Marshal 

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

func (*SnapshotMeta) XXX_Merge 

func (dst *SnapshotMeta) XXX_Merge(src proto.Message)

func (*SnapshotMeta) XXX_Size 

func (m *SnapshotMeta) XXX_Size() int

func (*SnapshotMeta) XXX_Unmarshal 

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

type StoreIdent 

type StoreIdent struct {
	ClusterId            uint64   `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	StoreId              uint64   `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	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) 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 (dst *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.