bhraftpb

package
v0.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBhraftpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBhraftpb   = 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 PeerState 

type PeerState int32

PeerState the state of the shard peer 

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

RaftApplyState raft log applied state

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 (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,proto3" json:"hardState"`
	LastIndex            uint64           `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

RaftLocalState raft local state about raft log

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) 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 {
	ShardID              uint64               `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"`
	Group                uint64               `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"`
	From                 metapb.Peer          `protobuf:"bytes,3,opt,name=from,proto3" json:"from"`
	To                   metapb.Peer          `protobuf:"bytes,4,opt,name=to,proto3" json:"to"`
	Message              raftpb.Message       `protobuf:"bytes,5,opt,name=message,proto3" json:"message"`
	ShardEpoch           metapb.ResourceEpoch `protobuf:"bytes,6,opt,name=shardEpoch,proto3" json:"shardEpoch"`
	IsTombstone          bool                 `protobuf:"varint,7,opt,name=isTombstone,proto3" json:"isTombstone,omitempty"`
	Start                []byte               `protobuf:"bytes,8,opt,name=start,proto3" json:"start,omitempty"`
	End                  []byte               `protobuf:"bytes,9,opt,name=end,proto3" json:"end,omitempty"`
	DisableSplit         bool                 `protobuf:"varint,10,opt,name=disableSplit,proto3" json:"disableSplit,omitempty"`
	Unique               string               `protobuf:"bytes,11,opt,name=unique,proto3" json:"unique,omitempty"`
	RuleGroups           []string             `protobuf:"bytes,12,rep,name=ruleGroups,proto3" json:"ruleGroups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

RaftMessage the message wrapped raft msg with shard info

func (*RaftMessage) Descriptor 

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

func (*RaftMessage) GetDisableSplit 

func (m *RaftMessage) GetDisableSplit() bool

func (*RaftMessage) GetEnd 

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

func (*RaftMessage) GetFrom 

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

func (*RaftMessage) GetGroup 

func (m *RaftMessage) GetGroup() uint64

func (*RaftMessage) GetIsTombstone 

func (m *RaftMessage) GetIsTombstone() bool

func (*RaftMessage) GetMessage 

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

func (*RaftMessage) GetRuleGroups 

func (m *RaftMessage) GetRuleGroups() []string

func (*RaftMessage) GetShardEpoch 

func (m *RaftMessage) GetShardEpoch() metapb.ResourceEpoch

func (*RaftMessage) GetShardID 

func (m *RaftMessage) GetShardID() uint64

func (*RaftMessage) GetStart 

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

func (*RaftMessage) GetTo 

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

func (*RaftMessage) GetUnique 

func (m *RaftMessage) GetUnique() string

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 (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,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:"-"`
}

RaftTruncatedState raft log truncated state

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 (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 ShardLocalState 

type ShardLocalState struct {
	State                PeerState      `protobuf:"varint,1,opt,name=state,proto3,enum=bhraftpb.PeerState" json:"state,omitempty"`
	Shard                bhmetapb.Shard `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

ShardLocalState the shard state on the store

func (*ShardLocalState) Descriptor 

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

func (*ShardLocalState) GetShard 

func (m *ShardLocalState) GetShard() bhmetapb.Shard

func (*ShardLocalState) GetState 

func (m *ShardLocalState) GetState() PeerState

func (*ShardLocalState) Marshal 

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

func (*ShardLocalState) MarshalTo 

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

func (*ShardLocalState) ProtoMessage 

func (*ShardLocalState) ProtoMessage()

func (*ShardLocalState) Reset 

func (m *ShardLocalState) Reset()

func (*ShardLocalState) Size 

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

func (*ShardLocalState) String 

func (m *ShardLocalState) String() string

func (*ShardLocalState) Unmarshal 

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

func (*ShardLocalState) XXX_DiscardUnknown 

func (m *ShardLocalState) XXX_DiscardUnknown()

func (*ShardLocalState) XXX_Marshal 

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

func (*ShardLocalState) XXX_Merge 

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

func (*ShardLocalState) XXX_Size 

func (m *ShardLocalState) XXX_Size() int

func (*ShardLocalState) XXX_Unmarshal 

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

type SnapshotMessage 

type SnapshotMessage struct {
	Header               SnapshotMessageHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	Data                 []byte                `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	First                bool                  `protobuf:"varint,3,opt,name=first,proto3" json:"first,omitempty"`
	Last                 bool                  `protobuf:"varint,4,opt,name=last,proto3" json:"last,omitempty"`
	FileSize             uint64                `protobuf:"varint,5,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
	CheckSum             uint64                `protobuf:"varint,6,opt,name=checkSum,proto3" json:"checkSum,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

SnapshotMessage snapshot message

func (*SnapshotMessage) Descriptor 

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

func (*SnapshotMessage) GetCheckSum 

func (m *SnapshotMessage) GetCheckSum() uint64

func (*SnapshotMessage) GetData 

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

func (*SnapshotMessage) GetFileSize 

func (m *SnapshotMessage) GetFileSize() uint64

func (*SnapshotMessage) GetFirst 

func (m *SnapshotMessage) GetFirst() bool

func (*SnapshotMessage) GetHeader 

func (m *SnapshotMessage) GetHeader() SnapshotMessageHeader

func (*SnapshotMessage) GetLast 

func (m *SnapshotMessage) GetLast() bool

func (*SnapshotMessage) Marshal 

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

func (*SnapshotMessage) MarshalTo 

func (m *SnapshotMessage) MarshalTo(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 {
	Shard                bhmetapb.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard"`
	From                 metapb.Peer    `protobuf:"bytes,2,opt,name=from,proto3" json:"from"`
	To                   metapb.Peer    `protobuf:"bytes,3,opt,name=to,proto3" json:"to"`
	Term                 uint64         `protobuf:"varint,4,opt,name=term,proto3" json:"term,omitempty"`
	Index                uint64         `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

SnapshotMessageHeader snapshot message header

func (*SnapshotMessageHeader) Descriptor 

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

func (*SnapshotMessageHeader) GetFrom 

func (m *SnapshotMessageHeader) GetFrom() metapb.Peer

func (*SnapshotMessageHeader) GetIndex 

func (m *SnapshotMessageHeader) GetIndex() uint64

func (*SnapshotMessageHeader) GetShard 

func (m *SnapshotMessageHeader) GetShard() bhmetapb.Shard

func (*SnapshotMessageHeader) GetTerm 

func (m *SnapshotMessageHeader) GetTerm() uint64

func (*SnapshotMessageHeader) GetTo 

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

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.