raft

package
v3.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2023 License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaft        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaft          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaft = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var LinkNode_NodeState_name = map[int32]string{
	0: "UNKNOWN",
	1: "ACTIVE",
	2: "INACTIVE",
}
View Source 
var LinkNode_NodeState_value = map[string]int32{
	"UNKNOWN":  0,
	"ACTIVE":   1,
	"INACTIVE": 2,
}
View Source 
var RAFRMsgType_name = map[int32]string{
	0: "MSG_HEARTBEAT",
	1: "MSG_NODELINK",
}
View Source 
var RAFRMsgType_value = map[string]int32{
	"MSG_HEARTBEAT": 0,
	"MSG_NODELINK":  1,
}

Functions

This section is empty.

Types

type HeartBeat 

type HeartBeat struct {
	ID        string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*HeartBeat) Descriptor 

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

func (*HeartBeat) GetID 

func (m *HeartBeat) GetID() string

func (*HeartBeat) GetTimestamp 

func (m *HeartBeat) GetTimestamp() int64

func (*HeartBeat) Marshal 

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

func (*HeartBeat) MarshalTo 

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

func (*HeartBeat) MarshalToSizedBuffer 

func (m *HeartBeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeartBeat) ProtoMessage 

func (*HeartBeat) ProtoMessage()

func (*HeartBeat) Reset 

func (m *HeartBeat) Reset()

func (*HeartBeat) Size 

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

func (*HeartBeat) String 

func (m *HeartBeat) String() string

func (*HeartBeat) Unmarshal 

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

func (*HeartBeat) XXX_DiscardUnknown 

func (m *HeartBeat) XXX_DiscardUnknown()

func (*HeartBeat) XXX_Marshal 

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

func (*HeartBeat) XXX_Merge 

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

func (*HeartBeat) XXX_Size 

func (m *HeartBeat) XXX_Size() int

func (*HeartBeat) XXX_Unmarshal 

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

type LinkNode 

type LinkNode struct {
	ID    string             `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	State LinkNode_NodeState `protobuf:"varint,2,opt,name=State,proto3,enum=raft.LinkNode_NodeState" json:"State,omitempty"`
}

func (*LinkNode) Descriptor 

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

func (*LinkNode) GetID 

func (m *LinkNode) GetID() string

func (*LinkNode) GetState 

func (m *LinkNode) GetState() LinkNode_NodeState

func (*LinkNode) Marshal 

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

func (*LinkNode) MarshalTo 

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

func (*LinkNode) MarshalToSizedBuffer 

func (m *LinkNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LinkNode) ProtoMessage 

func (*LinkNode) ProtoMessage()

func (*LinkNode) Reset 

func (m *LinkNode) Reset()

func (*LinkNode) Size 

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

func (*LinkNode) String 

func (m *LinkNode) String() string

func (*LinkNode) Unmarshal 

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

func (*LinkNode) XXX_DiscardUnknown 

func (m *LinkNode) XXX_DiscardUnknown()

func (*LinkNode) XXX_Marshal 

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

func (*LinkNode) XXX_Merge 

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

func (*LinkNode) XXX_Size 

func (m *LinkNode) XXX_Size() int

func (*LinkNode) XXX_Unmarshal 

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

type LinkNode_NodeState 

type LinkNode_NodeState int32
const (
	LinkNode_UNKNOWN  LinkNode_NodeState = 0
	LinkNode_ACTIVE   LinkNode_NodeState = 1
	LinkNode_INACTIVE LinkNode_NodeState = 2
)

func (LinkNode_NodeState) EnumDescriptor 

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

func (LinkNode_NodeState) String 

func (x LinkNode_NodeState) String() string

type LinkNodes 

type LinkNodes struct {
	ID    string      `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Nodes []*LinkNode `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*LinkNodes) Descriptor 

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

func (*LinkNodes) GetID 

func (m *LinkNodes) GetID() string

func (*LinkNodes) GetNodes 

func (m *LinkNodes) GetNodes() []*LinkNode

func (*LinkNodes) Marshal 

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

func (*LinkNodes) MarshalTo 

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

func (*LinkNodes) MarshalToSizedBuffer 

func (m *LinkNodes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LinkNodes) ProtoMessage 

func (*LinkNodes) ProtoMessage()

func (*LinkNodes) Reset 

func (m *LinkNodes) Reset()

func (*LinkNodes) Size 

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

func (*LinkNodes) String 

func (m *LinkNodes) String() string

func (*LinkNodes) Unmarshal 

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

func (*LinkNodes) XXX_DiscardUnknown 

func (m *LinkNodes) XXX_DiscardUnknown()

func (*LinkNodes) XXX_Marshal 

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

func (*LinkNodes) XXX_Merge 

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

func (*LinkNodes) XXX_Size 

func (m *LinkNodes) XXX_Size() int

func (*LinkNodes) XXX_Unmarshal 

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

type RAFRMsgType 

type RAFRMsgType int32
const (
	RAFRMsgType_MSG_HEARTBEAT RAFRMsgType = 0
	RAFRMsgType_MSG_NODELINK  RAFRMsgType = 1
)

func (RAFRMsgType) EnumDescriptor 

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

func (RAFRMsgType) String 

func (x RAFRMsgType) String() string

type RAFTMsg 

type RAFTMsg struct {
	Type RAFRMsgType `protobuf:"varint,1,opt,name=type,proto3,enum=raft.RAFRMsgType" json:"type,omitempty"`
	Msg  []byte      `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*RAFTMsg) Descriptor 

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

func (*RAFTMsg) GetMsg 

func (m *RAFTMsg) GetMsg() []byte

func (*RAFTMsg) GetType 

func (m *RAFTMsg) GetType() RAFRMsgType

func (*RAFTMsg) Marshal 

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

func (*RAFTMsg) MarshalTo 

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

func (*RAFTMsg) MarshalToSizedBuffer 

func (m *RAFTMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RAFTMsg) ProtoMessage 

func (*RAFTMsg) ProtoMessage()

func (*RAFTMsg) Reset 

func (m *RAFTMsg) Reset()

func (*RAFTMsg) Size 

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

func (*RAFTMsg) String 

func (m *RAFTMsg) String() string

func (*RAFTMsg) Unmarshal 

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

func (*RAFTMsg) XXX_DiscardUnknown 

func (m *RAFTMsg) XXX_DiscardUnknown()

func (*RAFTMsg) XXX_Marshal 

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

func (*RAFTMsg) XXX_Merge 

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

func (*RAFTMsg) XXX_Size 

func (m *RAFTMsg) XXX_Size() int

func (*RAFTMsg) XXX_Unmarshal 

func (m *RAFTMsg) 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.