raft_serverpb

package
v1.0.9 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package raft_serverpb is a generated protocol buffer package.

It is generated from these files:

raft_serverpb.proto

It has these top-level messages:

RaftMessage
RaftTruncatedState
SnapshotCFFile
SnapshotMeta
SnapshotChunk
Done
KeyValue
RaftSnapshotData
StoreIdent
RaftLocalState
RaftApplyState
RegionLocalState

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",
}
View Source
var PeerState_value = map[string]int32{
	"Normal":    0,
	"Applying":  1,
	"Tombstone": 2,
}

Functions

This section is empty.

Types

type Done

type Done struct {
}

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

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"`
}

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

type PeerState

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

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"`
}

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

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"`
}

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

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"`
}

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

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"`
}

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

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"`
}

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 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"`
}

func (*RegionLocalState) Descriptor

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

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

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"`
}

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

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"`
}

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

type SnapshotMeta

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

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

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"`
}

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

Jump to

Keyboard shortcuts

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