raft_serverpb

package
v0.0.0-...-cb7c7b8 Latest Latest
Warning

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

 Go to latest Published: May 12, 2017 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
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 KeyValue 

type KeyValue struct {
	Key              []byte `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value            []byte `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `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

type PeerState 

type PeerState int32
const (
	PeerState_Normal    PeerState = 0
	PeerState_Applying  PeerState = 1
	PeerState_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,omitempty"`
	TruncatedState   *RaftTruncatedState `protobuf:"bytes,2,opt,name=truncated_state,json=truncatedState" json:"truncated_state,omitempty"`
	XXX_unrecognized []byte              `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

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" json:"last_index,omitempty"`
	XXX_unrecognized []byte             `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

type RaftMessage 

type RaftMessage struct {
	RegionId    *uint64             `protobuf:"varint,1,opt,name=region_id,json=regionId" 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" json:"is_tombstone,omitempty"`
	// Region key range [start_key, end_key).
	StartKey         []byte `protobuf:"bytes,7,opt,name=start_key,json=startKey" json:"start_key,omitempty"`
	EndKey           []byte `protobuf:"bytes,8,opt,name=end_key,json=endKey" json:"end_key,omitempty"`
	XXX_unrecognized []byte `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) 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" json:"file_size,omitempty"`
	Data             []*KeyValue    `protobuf:"bytes,3,rep,name=data" json:"data,omitempty"`
	Version          *uint64        `protobuf:"varint,4,opt,name=version" json:"version,omitempty"`
	Meta             *SnapshotMeta  `protobuf:"bytes,5,opt,name=meta" json:"meta,omitempty"`
	XXX_unrecognized []byte         `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

type RaftTruncatedState 

type RaftTruncatedState struct {
	Index            *uint64 `protobuf:"varint,1,opt,name=index" json:"index,omitempty"`
	Term             *uint64 `protobuf:"varint,2,opt,name=term" json:"term,omitempty"`
	XXX_unrecognized []byte  `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

type RegionLocalState 

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

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" json:"cf,omitempty"`
	Size_            *uint64 `protobuf:"varint,2,opt,name=size" json:"size,omitempty"`
	Checksum         *uint32 `protobuf:"varint,3,opt,name=checksum" json:"checksum,omitempty"`
	XXX_unrecognized []byte  `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

type SnapshotMeta 

type SnapshotMeta struct {
	CfFiles          []*SnapshotCFFile `protobuf:"bytes,1,rep,name=cf_files,json=cfFiles" json:"cf_files,omitempty"`
	XXX_unrecognized []byte            `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

type StoreIdent 

type StoreIdent struct {
	ClusterId        *uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId" json:"cluster_id,omitempty"`
	StoreId          *uint64 `protobuf:"varint,2,opt,name=store_id,json=storeId" json:"store_id,omitempty"`
	XXX_unrecognized []byte  `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

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.