v1

package
v0.0.30 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2023 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Raft_Log_Type_name = map[int32]string{
		0: "Command",
		1: "Noop",
		2: "AddPeerDeprecated",
		3: "RemovePeerDeprecated",
		4: "Barrier",
		5: "Configuration",
	}
	Raft_Log_Type_value = map[string]int32{
		"Command":              0,
		"Noop":                 1,
		"AddPeerDeprecated":    2,
		"RemovePeerDeprecated": 3,
		"Barrier":              4,
		"Configuration":        5,
	}
)

Enum value maps for Raft_Log_Type.

View Source 
var (
	Raft_Config_Server_Suffrage_name = map[int32]string{
		0: "Voter",
		1: "Nonvoter",
		2: "Staging",
	}
	Raft_Config_Server_Suffrage_value = map[string]int32{
		"Voter":    0,
		"Nonvoter": 1,
		"Staging":  2,
	}
)

Enum value maps for Raft_Config_Server_Suffrage.

View Source 
var (
	Raft_RPC_Command_InstallSnapshot_Request_Version_name = map[int32]string{
		0: "Min",
		1: "Max",
	}
	Raft_RPC_Command_InstallSnapshot_Request_Version_value = map[string]int32{
		"Min": 0,
		"Max": 1,
	}
)

Enum value maps for Raft_RPC_Command_InstallSnapshot_Request_Version.

View Source 
var (
	Raft_RPC_Command_Header_Version_name = map[int32]string{
		0: "Min",
		1: "Max",
	}
	Raft_RPC_Command_Header_Version_value = map[string]int32{
		"Min": 0,
		"Max": 1,
	}
)

Enum value maps for Raft_RPC_Command_Header_Version.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_vince_raft_v1_raft_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Raft 

type Raft struct {
	// contains filtered or unexported fields
}

func (*Raft) Descriptor deprecated 

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

Deprecated: Use Raft.ProtoReflect.Descriptor instead.

func (*Raft) MarshalToSizedBufferVT 

func (m *Raft) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft) MarshalToVT 

func (m *Raft) MarshalToVT(dAtA []byte) (int, error)

func (*Raft) MarshalVT 

func (m *Raft) MarshalVT() (dAtA []byte, err error)

func (*Raft) ProtoMessage 

func (*Raft) ProtoMessage()

func (*Raft) ProtoReflect 

func (x *Raft) ProtoReflect() protoreflect.Message

func (*Raft) Reset 

func (x *Raft) Reset()

func (*Raft) SizeVT 

func (m *Raft) SizeVT() (n int)

func (*Raft) String 

func (x *Raft) String() string

func (*Raft) UnmarshalVT 

func (m *Raft) UnmarshalVT(dAtA []byte) error

type Raft_Config 

type Raft_Config struct {
	Servers []*Raft_Config_Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_Config) Descriptor deprecated 

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

Deprecated: Use Raft_Config.ProtoReflect.Descriptor instead.

func (*Raft_Config) GetServers 

func (x *Raft_Config) GetServers() []*Raft_Config_Server

func (*Raft_Config) MarshalToSizedBufferVT 

func (m *Raft_Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_Config) MarshalToVT 

func (m *Raft_Config) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_Config) MarshalVT 

func (m *Raft_Config) MarshalVT() (dAtA []byte, err error)

func (*Raft_Config) ProtoMessage 

func (*Raft_Config) ProtoMessage()

func (*Raft_Config) ProtoReflect 

func (x *Raft_Config) ProtoReflect() protoreflect.Message

func (*Raft_Config) Reset 

func (x *Raft_Config) Reset()

func (*Raft_Config) SizeVT 

func (m *Raft_Config) SizeVT() (n int)

func (*Raft_Config) String 

func (x *Raft_Config) String() string

func (*Raft_Config) UnmarshalVT 

func (m *Raft_Config) UnmarshalVT(dAtA []byte) error

type Raft_Config_Server 

type Raft_Config_Server struct {
	Suffrage Raft_Config_Server_Suffrage `protobuf:"varint,1,opt,name=suffrage,proto3,enum=v1.Raft_Config_Server_Suffrage" json:"suffrage,omitempty"`
	Id       string                      `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Address  string                      `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	Token    string                      `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_Config_Server) Descriptor deprecated 

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

Deprecated: Use Raft_Config_Server.ProtoReflect.Descriptor instead.

func (*Raft_Config_Server) GetAddress 

func (x *Raft_Config_Server) GetAddress() string

func (*Raft_Config_Server) GetId 

func (x *Raft_Config_Server) GetId() string

func (*Raft_Config_Server) GetSuffrage 

func (x *Raft_Config_Server) GetSuffrage() Raft_Config_Server_Suffrage

func (*Raft_Config_Server) GetToken 

func (x *Raft_Config_Server) GetToken() string

func (*Raft_Config_Server) MarshalToSizedBufferVT 

func (m *Raft_Config_Server) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_Config_Server) MarshalToVT 

func (m *Raft_Config_Server) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_Config_Server) MarshalVT 

func (m *Raft_Config_Server) MarshalVT() (dAtA []byte, err error)

func (*Raft_Config_Server) ProtoMessage 

func (*Raft_Config_Server) ProtoMessage()

func (*Raft_Config_Server) ProtoReflect 

func (x *Raft_Config_Server) ProtoReflect() protoreflect.Message

func (*Raft_Config_Server) Reset 

func (x *Raft_Config_Server) Reset()

func (*Raft_Config_Server) SizeVT 

func (m *Raft_Config_Server) SizeVT() (n int)

func (*Raft_Config_Server) String 

func (x *Raft_Config_Server) String() string

func (*Raft_Config_Server) UnmarshalVT 

func (m *Raft_Config_Server) UnmarshalVT(dAtA []byte) error

type Raft_Config_Server_Suffrage 

type Raft_Config_Server_Suffrage int32
const (
	Raft_Config_Server_Voter    Raft_Config_Server_Suffrage = 0
	Raft_Config_Server_Nonvoter Raft_Config_Server_Suffrage = 1
	Raft_Config_Server_Staging  Raft_Config_Server_Suffrage = 2
)

func (Raft_Config_Server_Suffrage) Descriptor 

func (Raft_Config_Server_Suffrage) Descriptor() protoreflect.EnumDescriptor

func (Raft_Config_Server_Suffrage) Enum 

func (x Raft_Config_Server_Suffrage) Enum() *Raft_Config_Server_Suffrage

func (Raft_Config_Server_Suffrage) EnumDescriptor deprecated 

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

Deprecated: Use Raft_Config_Server_Suffrage.Descriptor instead.

func (Raft_Config_Server_Suffrage) Number 

func (x Raft_Config_Server_Suffrage) Number() protoreflect.EnumNumber

func (Raft_Config_Server_Suffrage) String 

func (x Raft_Config_Server_Suffrage) String() string

func (Raft_Config_Server_Suffrage) Type 

func (Raft_Config_Server_Suffrage) Type() protoreflect.EnumType

type Raft_Entry 

type Raft_Entry 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"`
	Expires *durationpb.Duration `protobuf:"bytes,3,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_Entry) Descriptor deprecated 

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

Deprecated: Use Raft_Entry.ProtoReflect.Descriptor instead.

func (*Raft_Entry) GetExpires 

func (x *Raft_Entry) GetExpires() *durationpb.Duration

func (*Raft_Entry) GetKey 

func (x *Raft_Entry) GetKey() []byte

func (*Raft_Entry) GetValue 

func (x *Raft_Entry) GetValue() []byte

func (*Raft_Entry) MarshalToSizedBufferVT 

func (m *Raft_Entry) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_Entry) MarshalToVT 

func (m *Raft_Entry) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_Entry) MarshalVT 

func (m *Raft_Entry) MarshalVT() (dAtA []byte, err error)

func (*Raft_Entry) ProtoMessage 

func (*Raft_Entry) ProtoMessage()

func (*Raft_Entry) ProtoReflect 

func (x *Raft_Entry) ProtoReflect() protoreflect.Message

func (*Raft_Entry) Reset 

func (x *Raft_Entry) Reset()

func (*Raft_Entry) SizeVT 

func (m *Raft_Entry) SizeVT() (n int)

func (*Raft_Entry) String 

func (x *Raft_Entry) String() string

func (*Raft_Entry) UnmarshalVT 

func (m *Raft_Entry) UnmarshalVT(dAtA []byte) error

type Raft_Log 

type Raft_Log 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"`
	Type       Raft_Log_Type          `protobuf:"varint,3,opt,name=type,proto3,enum=v1.Raft_Log_Type" json:"type,omitempty"`
	Data       []byte                 `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Extensions []byte                 `protobuf:"bytes,5,opt,name=extensions,proto3" json:"extensions,omitempty"`
	AppendedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=appended_at,json=appendedAt,proto3" json:"appended_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_Log) Descriptor deprecated 

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

Deprecated: Use Raft_Log.ProtoReflect.Descriptor instead.

func (*Raft_Log) GetAppendedAt 

func (x *Raft_Log) GetAppendedAt() *timestamppb.Timestamp

func (*Raft_Log) GetData 

func (x *Raft_Log) GetData() []byte

func (*Raft_Log) GetExtensions 

func (x *Raft_Log) GetExtensions() []byte

func (*Raft_Log) GetIndex 

func (x *Raft_Log) GetIndex() uint64

func (*Raft_Log) GetTerm 

func (x *Raft_Log) GetTerm() uint64

func (*Raft_Log) GetType 

func (x *Raft_Log) GetType() Raft_Log_Type

func (*Raft_Log) MarshalToSizedBufferVT 

func (m *Raft_Log) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_Log) MarshalToVT 

func (m *Raft_Log) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_Log) MarshalVT 

func (m *Raft_Log) MarshalVT() (dAtA []byte, err error)

func (*Raft_Log) ProtoMessage 

func (*Raft_Log) ProtoMessage()

func (*Raft_Log) ProtoReflect 

func (x *Raft_Log) ProtoReflect() protoreflect.Message

func (*Raft_Log) Reset 

func (x *Raft_Log) Reset()

func (*Raft_Log) SizeVT 

func (m *Raft_Log) SizeVT() (n int)

func (*Raft_Log) String 

func (x *Raft_Log) String() string

func (*Raft_Log) UnmarshalVT 

func (m *Raft_Log) UnmarshalVT(dAtA []byte) error

type Raft_Log_Type 

type Raft_Log_Type int32
const (
	Raft_Log_Command              Raft_Log_Type = 0
	Raft_Log_Noop                 Raft_Log_Type = 1
	Raft_Log_AddPeerDeprecated    Raft_Log_Type = 2
	Raft_Log_RemovePeerDeprecated Raft_Log_Type = 3
	Raft_Log_Barrier              Raft_Log_Type = 4
	Raft_Log_Configuration        Raft_Log_Type = 5
)

func (Raft_Log_Type) Descriptor 

func (Raft_Log_Type) Descriptor() protoreflect.EnumDescriptor

func (Raft_Log_Type) Enum 

func (x Raft_Log_Type) Enum() *Raft_Log_Type

func (Raft_Log_Type) EnumDescriptor deprecated 

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

Deprecated: Use Raft_Log_Type.Descriptor instead.

func (Raft_Log_Type) Number 

func (x Raft_Log_Type) Number() protoreflect.EnumNumber

func (Raft_Log_Type) String 

func (x Raft_Log_Type) String() string

func (Raft_Log_Type) Type 

func (Raft_Log_Type) Type() protoreflect.EnumType

type Raft_RPC 

type Raft_RPC struct {
	// contains filtered or unexported fields
}

func (*Raft_RPC) Descriptor deprecated 

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

Deprecated: Use Raft_RPC.ProtoReflect.Descriptor instead.

func (*Raft_RPC) MarshalToSizedBufferVT 

func (m *Raft_RPC) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC) MarshalToVT 

func (m *Raft_RPC) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC) MarshalVT 

func (m *Raft_RPC) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC) ProtoMessage 

func (*Raft_RPC) ProtoMessage()

func (*Raft_RPC) ProtoReflect 

func (x *Raft_RPC) ProtoReflect() protoreflect.Message

func (*Raft_RPC) Reset 

func (x *Raft_RPC) Reset()

func (*Raft_RPC) SizeVT 

func (m *Raft_RPC) SizeVT() (n int)

func (*Raft_RPC) String 

func (x *Raft_RPC) String() string

func (*Raft_RPC) UnmarshalVT 

func (m *Raft_RPC) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Call 

type Raft_RPC_Call struct {
	// contains filtered or unexported fields
}

func (*Raft_RPC_Call) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Call.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Call) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call) MarshalToVT 

func (m *Raft_RPC_Call) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call) MarshalVT 

func (m *Raft_RPC_Call) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Call) ProtoMessage 

func (*Raft_RPC_Call) ProtoMessage()

func (*Raft_RPC_Call) ProtoReflect 

func (x *Raft_RPC_Call) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Call) Reset 

func (x *Raft_RPC_Call) Reset()

func (*Raft_RPC_Call) SizeVT 

func (m *Raft_RPC_Call) SizeVT() (n int)

func (*Raft_RPC_Call) String 

func (x *Raft_RPC_Call) String() string

func (*Raft_RPC_Call) UnmarshalVT 

func (m *Raft_RPC_Call) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Call_Request 

type Raft_RPC_Call_Request struct {

	// Types that are assignable to Kind:
	//
	//	*Raft_RPC_Call_Request_AppendEntries
	//	*Raft_RPC_Call_Request_Vote
	//	*Raft_RPC_Call_Request_InstallSnapshot
	//	*Raft_RPC_Call_Request_TimeoutNow
	Kind isRaft_RPC_Call_Request_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Call_Request) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Call_Request.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Call_Request) GetAppendEntries 

func (x *Raft_RPC_Call_Request) GetAppendEntries() *Raft_RPC_Command_AppendEntries_Request

func (*Raft_RPC_Call_Request) GetInstallSnapshot 

func (x *Raft_RPC_Call_Request) GetInstallSnapshot() *Raft_RPC_Command_InstallSnapshot_Request

func (*Raft_RPC_Call_Request) GetKind 

func (m *Raft_RPC_Call_Request) GetKind() isRaft_RPC_Call_Request_Kind

func (*Raft_RPC_Call_Request) GetTimeoutNow 

func (x *Raft_RPC_Call_Request) GetTimeoutNow() *Raft_RPC_Command_TimeoutNow_Request

func (*Raft_RPC_Call_Request) GetVote 

func (x *Raft_RPC_Call_Request) GetVote() *Raft_RPC_Command_Vote_Request

func (*Raft_RPC_Call_Request) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request) MarshalToVT 

func (m *Raft_RPC_Call_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request) MarshalVT 

func (m *Raft_RPC_Call_Request) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Call_Request) ProtoMessage 

func (*Raft_RPC_Call_Request) ProtoMessage()

func (*Raft_RPC_Call_Request) ProtoReflect 

func (x *Raft_RPC_Call_Request) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Call_Request) Reset 

func (x *Raft_RPC_Call_Request) Reset()

func (*Raft_RPC_Call_Request) SizeVT 

func (m *Raft_RPC_Call_Request) SizeVT() (n int)

func (*Raft_RPC_Call_Request) String 

func (x *Raft_RPC_Call_Request) String() string

func (*Raft_RPC_Call_Request) UnmarshalVT 

func (m *Raft_RPC_Call_Request) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Call_Request_AppendEntries 

type Raft_RPC_Call_Request_AppendEntries struct {
	AppendEntries *Raft_RPC_Command_AppendEntries_Request `protobuf:"bytes,1,opt,name=append_entries,json=appendEntries,proto3,oneof"`
}

func (*Raft_RPC_Call_Request_AppendEntries) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Request_AppendEntries) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_AppendEntries) MarshalToVT 

func (m *Raft_RPC_Call_Request_AppendEntries) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_AppendEntries) SizeVT 

func (m *Raft_RPC_Call_Request_AppendEntries) SizeVT() (n int)

type Raft_RPC_Call_Request_InstallSnapshot 

type Raft_RPC_Call_Request_InstallSnapshot struct {
	InstallSnapshot *Raft_RPC_Command_InstallSnapshot_Request `protobuf:"bytes,3,opt,name=install_snapshot,json=installSnapshot,proto3,oneof"`
}

func (*Raft_RPC_Call_Request_InstallSnapshot) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Request_InstallSnapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_InstallSnapshot) MarshalToVT 

func (m *Raft_RPC_Call_Request_InstallSnapshot) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_InstallSnapshot) SizeVT 

func (m *Raft_RPC_Call_Request_InstallSnapshot) SizeVT() (n int)

type Raft_RPC_Call_Request_TimeoutNow 

type Raft_RPC_Call_Request_TimeoutNow struct {
	TimeoutNow *Raft_RPC_Command_TimeoutNow_Request `protobuf:"bytes,4,opt,name=timeout_now,json=timeoutNow,proto3,oneof"`
}

func (*Raft_RPC_Call_Request_TimeoutNow) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Request_TimeoutNow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_TimeoutNow) MarshalToVT 

func (m *Raft_RPC_Call_Request_TimeoutNow) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_TimeoutNow) SizeVT 

func (m *Raft_RPC_Call_Request_TimeoutNow) SizeVT() (n int)

type Raft_RPC_Call_Request_Vote 

type Raft_RPC_Call_Request_Vote struct {
	Vote *Raft_RPC_Command_Vote_Request `protobuf:"bytes,2,opt,name=vote,proto3,oneof"`
}

func (*Raft_RPC_Call_Request_Vote) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Request_Vote) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_Vote) MarshalToVT 

func (m *Raft_RPC_Call_Request_Vote) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Request_Vote) SizeVT 

func (m *Raft_RPC_Call_Request_Vote) SizeVT() (n int)

type Raft_RPC_Call_Response 

type Raft_RPC_Call_Response struct {

	// Types that are assignable to Kind:
	//
	//	*Raft_RPC_Call_Response_AppendEntries
	//	*Raft_RPC_Call_Response_Vote
	//	*Raft_RPC_Call_Response_InstallSnapshot
	//	*Raft_RPC_Call_Response_TimeoutNow
	Kind  isRaft_RPC_Call_Response_Kind `protobuf_oneof:"kind"`
	Error string                        `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Call_Response) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Call_Response.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Call_Response) GetAppendEntries 

func (x *Raft_RPC_Call_Response) GetAppendEntries() *Raft_RPC_Command_AppendEntries_Response

func (*Raft_RPC_Call_Response) GetError 

func (x *Raft_RPC_Call_Response) GetError() string

func (*Raft_RPC_Call_Response) GetInstallSnapshot 

func (x *Raft_RPC_Call_Response) GetInstallSnapshot() *Raft_RPC_Command_InstallSnapshot_Response

func (*Raft_RPC_Call_Response) GetKind 

func (m *Raft_RPC_Call_Response) GetKind() isRaft_RPC_Call_Response_Kind

func (*Raft_RPC_Call_Response) GetTimeoutNow 

func (x *Raft_RPC_Call_Response) GetTimeoutNow() *Raft_RPC_Command_TimeoutNow_Response

func (*Raft_RPC_Call_Response) GetVote 

func (x *Raft_RPC_Call_Response) GetVote() *Raft_RPC_Command_Vote_Response

func (*Raft_RPC_Call_Response) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response) MarshalToVT 

func (m *Raft_RPC_Call_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response) MarshalVT 

func (m *Raft_RPC_Call_Response) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Call_Response) ProtoMessage 

func (*Raft_RPC_Call_Response) ProtoMessage()

func (*Raft_RPC_Call_Response) ProtoReflect 

func (x *Raft_RPC_Call_Response) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Call_Response) Reset 

func (x *Raft_RPC_Call_Response) Reset()

func (*Raft_RPC_Call_Response) SizeVT 

func (m *Raft_RPC_Call_Response) SizeVT() (n int)

func (*Raft_RPC_Call_Response) String 

func (x *Raft_RPC_Call_Response) String() string

func (*Raft_RPC_Call_Response) UnmarshalVT 

func (m *Raft_RPC_Call_Response) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Call_Response_AppendEntries 

type Raft_RPC_Call_Response_AppendEntries struct {
	AppendEntries *Raft_RPC_Command_AppendEntries_Response `protobuf:"bytes,1,opt,name=append_entries,json=appendEntries,proto3,oneof"`
}

func (*Raft_RPC_Call_Response_AppendEntries) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Response_AppendEntries) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_AppendEntries) MarshalToVT 

func (m *Raft_RPC_Call_Response_AppendEntries) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_AppendEntries) SizeVT 

func (m *Raft_RPC_Call_Response_AppendEntries) SizeVT() (n int)

type Raft_RPC_Call_Response_InstallSnapshot 

type Raft_RPC_Call_Response_InstallSnapshot struct {
	InstallSnapshot *Raft_RPC_Command_InstallSnapshot_Response `protobuf:"bytes,3,opt,name=install_snapshot,json=installSnapshot,proto3,oneof"`
}

func (*Raft_RPC_Call_Response_InstallSnapshot) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Response_InstallSnapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_InstallSnapshot) MarshalToVT 

func (m *Raft_RPC_Call_Response_InstallSnapshot) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_InstallSnapshot) SizeVT 

func (m *Raft_RPC_Call_Response_InstallSnapshot) SizeVT() (n int)

type Raft_RPC_Call_Response_TimeoutNow 

type Raft_RPC_Call_Response_TimeoutNow struct {
	TimeoutNow *Raft_RPC_Command_TimeoutNow_Response `protobuf:"bytes,4,opt,name=timeout_now,json=timeoutNow,proto3,oneof"`
}

func (*Raft_RPC_Call_Response_TimeoutNow) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Response_TimeoutNow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_TimeoutNow) MarshalToVT 

func (m *Raft_RPC_Call_Response_TimeoutNow) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_TimeoutNow) SizeVT 

func (m *Raft_RPC_Call_Response_TimeoutNow) SizeVT() (n int)

type Raft_RPC_Call_Response_Vote 

type Raft_RPC_Call_Response_Vote struct {
	Vote *Raft_RPC_Command_Vote_Response `protobuf:"bytes,2,opt,name=vote,proto3,oneof"`
}

func (*Raft_RPC_Call_Response_Vote) MarshalToSizedBufferVT 

func (m *Raft_RPC_Call_Response_Vote) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_Vote) MarshalToVT 

func (m *Raft_RPC_Call_Response_Vote) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Call_Response_Vote) SizeVT 

func (m *Raft_RPC_Call_Response_Vote) SizeVT() (n int)

type Raft_RPC_Command 

type Raft_RPC_Command struct {
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command) MarshalToVT 

func (m *Raft_RPC_Command) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command) MarshalVT 

func (m *Raft_RPC_Command) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command) ProtoMessage 

func (*Raft_RPC_Command) ProtoMessage()

func (*Raft_RPC_Command) ProtoReflect 

func (x *Raft_RPC_Command) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command) Reset 

func (x *Raft_RPC_Command) Reset()

func (*Raft_RPC_Command) SizeVT 

func (m *Raft_RPC_Command) SizeVT() (n int)

func (*Raft_RPC_Command) String 

func (x *Raft_RPC_Command) String() string

func (*Raft_RPC_Command) UnmarshalVT 

func (m *Raft_RPC_Command) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_AppendEntries 

type Raft_RPC_Command_AppendEntries struct {
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_AppendEntries) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_AppendEntries.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_AppendEntries) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_AppendEntries) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_AppendEntries) MarshalToVT 

func (m *Raft_RPC_Command_AppendEntries) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_AppendEntries) MarshalVT 

func (m *Raft_RPC_Command_AppendEntries) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_AppendEntries) ProtoMessage 

func (*Raft_RPC_Command_AppendEntries) ProtoMessage()

func (*Raft_RPC_Command_AppendEntries) ProtoReflect 

func (x *Raft_RPC_Command_AppendEntries) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_AppendEntries) Reset 

func (x *Raft_RPC_Command_AppendEntries) Reset()

func (*Raft_RPC_Command_AppendEntries) SizeVT 

func (m *Raft_RPC_Command_AppendEntries) SizeVT() (n int)

func (*Raft_RPC_Command_AppendEntries) String 

func (x *Raft_RPC_Command_AppendEntries) String() string

func (*Raft_RPC_Command_AppendEntries) UnmarshalVT 

func (m *Raft_RPC_Command_AppendEntries) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_AppendEntries_Request 

type Raft_RPC_Command_AppendEntries_Request struct {
	Header            *Raft_RPC_Command_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term              uint64                   `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	PrevLogEntry      uint64                   `protobuf:"varint,4,opt,name=prev_log_entry,json=prevLogEntry,proto3" json:"prev_log_entry,omitempty"`
	PrevLogTerm       uint64                   `protobuf:"varint,5,opt,name=prev_log_term,json=prevLogTerm,proto3" json:"prev_log_term,omitempty"`
	Entries           []*Raft_Log              `protobuf:"bytes,6,rep,name=entries,proto3" json:"entries,omitempty"`
	LeaderCommitIndex uint64                   `protobuf:"varint,7,opt,name=leader_commit_index,json=leaderCommitIndex,proto3" json:"leader_commit_index,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_AppendEntries_Request) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_AppendEntries_Request.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_AppendEntries_Request) GetEntries 

func (x *Raft_RPC_Command_AppendEntries_Request) GetEntries() []*Raft_Log

func (*Raft_RPC_Command_AppendEntries_Request) GetHeader 

func (x *Raft_RPC_Command_AppendEntries_Request) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_AppendEntries_Request) GetLeaderCommitIndex 

func (x *Raft_RPC_Command_AppendEntries_Request) GetLeaderCommitIndex() uint64

func (*Raft_RPC_Command_AppendEntries_Request) GetPrevLogEntry 

func (x *Raft_RPC_Command_AppendEntries_Request) GetPrevLogEntry() uint64

func (*Raft_RPC_Command_AppendEntries_Request) GetPrevLogTerm 

func (x *Raft_RPC_Command_AppendEntries_Request) GetPrevLogTerm() uint64

func (*Raft_RPC_Command_AppendEntries_Request) GetTerm 

func (x *Raft_RPC_Command_AppendEntries_Request) GetTerm() uint64

func (*Raft_RPC_Command_AppendEntries_Request) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_AppendEntries_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_AppendEntries_Request) MarshalToVT 

func (m *Raft_RPC_Command_AppendEntries_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_AppendEntries_Request) MarshalVT 

func (m *Raft_RPC_Command_AppendEntries_Request) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_AppendEntries_Request) ProtoMessage 

func (*Raft_RPC_Command_AppendEntries_Request) ProtoMessage()

func (*Raft_RPC_Command_AppendEntries_Request) ProtoReflect 

func (x *Raft_RPC_Command_AppendEntries_Request) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_AppendEntries_Request) Reset 

func (x *Raft_RPC_Command_AppendEntries_Request) Reset()

func (*Raft_RPC_Command_AppendEntries_Request) SizeVT 

func (m *Raft_RPC_Command_AppendEntries_Request) SizeVT() (n int)

func (*Raft_RPC_Command_AppendEntries_Request) String 

func (x *Raft_RPC_Command_AppendEntries_Request) String() string

func (*Raft_RPC_Command_AppendEntries_Request) UnmarshalVT 

func (m *Raft_RPC_Command_AppendEntries_Request) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_AppendEntries_Response 

type Raft_RPC_Command_AppendEntries_Response struct {
	Header         *Raft_RPC_Command_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term           uint64                   `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	LastLog        uint64                   `protobuf:"varint,3,opt,name=last_log,json=lastLog,proto3" json:"last_log,omitempty"`
	Success        bool                     `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	NoRetryBackoff bool                     `protobuf:"varint,5,opt,name=no_retry_backoff,json=noRetryBackoff,proto3" json:"no_retry_backoff,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_AppendEntries_Response) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_AppendEntries_Response.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_AppendEntries_Response) GetHeader 

func (x *Raft_RPC_Command_AppendEntries_Response) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_AppendEntries_Response) GetLastLog 

func (x *Raft_RPC_Command_AppendEntries_Response) GetLastLog() uint64

func (*Raft_RPC_Command_AppendEntries_Response) GetNoRetryBackoff 

func (x *Raft_RPC_Command_AppendEntries_Response) GetNoRetryBackoff() bool

func (*Raft_RPC_Command_AppendEntries_Response) GetSuccess 

func (x *Raft_RPC_Command_AppendEntries_Response) GetSuccess() bool

func (*Raft_RPC_Command_AppendEntries_Response) GetTerm 

func (x *Raft_RPC_Command_AppendEntries_Response) GetTerm() uint64

func (*Raft_RPC_Command_AppendEntries_Response) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_AppendEntries_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_AppendEntries_Response) MarshalToVT 

func (m *Raft_RPC_Command_AppendEntries_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_AppendEntries_Response) MarshalVT 

func (m *Raft_RPC_Command_AppendEntries_Response) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_AppendEntries_Response) ProtoMessage 

func (*Raft_RPC_Command_AppendEntries_Response) ProtoMessage()

func (*Raft_RPC_Command_AppendEntries_Response) ProtoReflect 

func (x *Raft_RPC_Command_AppendEntries_Response) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_AppendEntries_Response) Reset 

func (x *Raft_RPC_Command_AppendEntries_Response) Reset()

func (*Raft_RPC_Command_AppendEntries_Response) SizeVT 

func (m *Raft_RPC_Command_AppendEntries_Response) SizeVT() (n int)

func (*Raft_RPC_Command_AppendEntries_Response) String 

func (x *Raft_RPC_Command_AppendEntries_Response) String() string

func (*Raft_RPC_Command_AppendEntries_Response) UnmarshalVT 

func (m *Raft_RPC_Command_AppendEntries_Response) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_Header 

type Raft_RPC_Command_Header struct {
	Version Raft_RPC_Command_Header_Version `protobuf:"varint,1,opt,name=version,proto3,enum=v1.Raft_RPC_Command_Header_Version" json:"version,omitempty"`
	Id      []byte                          `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Addr    []byte                          `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_Header) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_Header.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_Header) GetAddr 

func (x *Raft_RPC_Command_Header) GetAddr() []byte

func (*Raft_RPC_Command_Header) GetId 

func (x *Raft_RPC_Command_Header) GetId() []byte

func (*Raft_RPC_Command_Header) GetVersion 

func (x *Raft_RPC_Command_Header) GetVersion() Raft_RPC_Command_Header_Version

func (*Raft_RPC_Command_Header) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_Header) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Header) MarshalToVT 

func (m *Raft_RPC_Command_Header) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Header) MarshalVT 

func (m *Raft_RPC_Command_Header) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_Header) ProtoMessage 

func (*Raft_RPC_Command_Header) ProtoMessage()

func (*Raft_RPC_Command_Header) ProtoReflect 

func (x *Raft_RPC_Command_Header) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_Header) Reset 

func (x *Raft_RPC_Command_Header) Reset()

func (*Raft_RPC_Command_Header) SizeVT 

func (m *Raft_RPC_Command_Header) SizeVT() (n int)

func (*Raft_RPC_Command_Header) String 

func (x *Raft_RPC_Command_Header) String() string

func (*Raft_RPC_Command_Header) UnmarshalVT 

func (m *Raft_RPC_Command_Header) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_Header_Version 

type Raft_RPC_Command_Header_Version int32
const (
	Raft_RPC_Command_Header_Min Raft_RPC_Command_Header_Version = 0
	Raft_RPC_Command_Header_Max Raft_RPC_Command_Header_Version = 1
)

func (Raft_RPC_Command_Header_Version) Descriptor 

func (Raft_RPC_Command_Header_Version) Descriptor() protoreflect.EnumDescriptor

func (Raft_RPC_Command_Header_Version) Enum 

func (x Raft_RPC_Command_Header_Version) Enum() *Raft_RPC_Command_Header_Version

func (Raft_RPC_Command_Header_Version) EnumDescriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_Header_Version.Descriptor instead.

func (Raft_RPC_Command_Header_Version) Number 

func (x Raft_RPC_Command_Header_Version) Number() protoreflect.EnumNumber

func (Raft_RPC_Command_Header_Version) String 

func (x Raft_RPC_Command_Header_Version) String() string

func (Raft_RPC_Command_Header_Version) Type 

func (Raft_RPC_Command_Header_Version) Type() protoreflect.EnumType

type Raft_RPC_Command_InstallSnapshot 

type Raft_RPC_Command_InstallSnapshot struct {
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_InstallSnapshot) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_InstallSnapshot.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_InstallSnapshot) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_InstallSnapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_InstallSnapshot) MarshalToVT 

func (m *Raft_RPC_Command_InstallSnapshot) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_InstallSnapshot) MarshalVT 

func (m *Raft_RPC_Command_InstallSnapshot) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_InstallSnapshot) ProtoMessage 

func (*Raft_RPC_Command_InstallSnapshot) ProtoMessage()

func (*Raft_RPC_Command_InstallSnapshot) ProtoReflect 

func (x *Raft_RPC_Command_InstallSnapshot) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_InstallSnapshot) Reset 

func (x *Raft_RPC_Command_InstallSnapshot) Reset()

func (*Raft_RPC_Command_InstallSnapshot) SizeVT 

func (m *Raft_RPC_Command_InstallSnapshot) SizeVT() (n int)

func (*Raft_RPC_Command_InstallSnapshot) String 

func (x *Raft_RPC_Command_InstallSnapshot) String() string

func (*Raft_RPC_Command_InstallSnapshot) UnmarshalVT 

func (m *Raft_RPC_Command_InstallSnapshot) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_InstallSnapshot_Request 

type Raft_RPC_Command_InstallSnapshot_Request struct {
	Header             *Raft_RPC_Command_Header                         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SnapshotVersion    Raft_RPC_Command_InstallSnapshot_Request_Version `` /* 164-byte string literal not displayed */
	Term               uint64                                           `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	Leader             []byte                                           `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	LastLogIndex       uint64                                           `protobuf:"varint,5,opt,name=last_log_index,json=lastLogIndex,proto3" json:"last_log_index,omitempty"`
	LastLogTerm        uint64                                           `protobuf:"varint,6,opt,name=last_log_term,json=lastLogTerm,proto3" json:"last_log_term,omitempty"`
	Configuration      []byte                                           `protobuf:"bytes,7,opt,name=configuration,proto3" json:"configuration,omitempty"`
	ConfigurationIndex uint64                                           `protobuf:"varint,8,opt,name=configuration_index,json=configurationIndex,proto3" json:"configuration_index,omitempty"`
	Size               int64                                            `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_InstallSnapshot_Request) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_InstallSnapshot_Request.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_InstallSnapshot_Request) GetConfiguration 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetConfiguration() []byte

func (*Raft_RPC_Command_InstallSnapshot_Request) GetConfigurationIndex 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetConfigurationIndex() uint64

func (*Raft_RPC_Command_InstallSnapshot_Request) GetHeader 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_InstallSnapshot_Request) GetLastLogIndex 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetLastLogIndex() uint64

func (*Raft_RPC_Command_InstallSnapshot_Request) GetLastLogTerm 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetLastLogTerm() uint64

func (*Raft_RPC_Command_InstallSnapshot_Request) GetLeader 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetLeader() []byte

func (*Raft_RPC_Command_InstallSnapshot_Request) GetSize 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetSize() int64

func (*Raft_RPC_Command_InstallSnapshot_Request) GetSnapshotVersion 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetSnapshotVersion() Raft_RPC_Command_InstallSnapshot_Request_Version

func (*Raft_RPC_Command_InstallSnapshot_Request) GetTerm 

func (x *Raft_RPC_Command_InstallSnapshot_Request) GetTerm() uint64

func (*Raft_RPC_Command_InstallSnapshot_Request) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_InstallSnapshot_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_InstallSnapshot_Request) MarshalToVT 

func (m *Raft_RPC_Command_InstallSnapshot_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_InstallSnapshot_Request) MarshalVT 

func (m *Raft_RPC_Command_InstallSnapshot_Request) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_InstallSnapshot_Request) ProtoMessage 

func (*Raft_RPC_Command_InstallSnapshot_Request) ProtoMessage()

func (*Raft_RPC_Command_InstallSnapshot_Request) ProtoReflect 

func (x *Raft_RPC_Command_InstallSnapshot_Request) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_InstallSnapshot_Request) Reset 

func (x *Raft_RPC_Command_InstallSnapshot_Request) Reset()

func (*Raft_RPC_Command_InstallSnapshot_Request) SizeVT 

func (m *Raft_RPC_Command_InstallSnapshot_Request) SizeVT() (n int)

func (*Raft_RPC_Command_InstallSnapshot_Request) String 

func (x *Raft_RPC_Command_InstallSnapshot_Request) String() string

func (*Raft_RPC_Command_InstallSnapshot_Request) UnmarshalVT 

func (m *Raft_RPC_Command_InstallSnapshot_Request) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_InstallSnapshot_Request_Version 

type Raft_RPC_Command_InstallSnapshot_Request_Version int32
const (
	Raft_RPC_Command_InstallSnapshot_Request_Min Raft_RPC_Command_InstallSnapshot_Request_Version = 0
	Raft_RPC_Command_InstallSnapshot_Request_Max Raft_RPC_Command_InstallSnapshot_Request_Version = 1
)

func (Raft_RPC_Command_InstallSnapshot_Request_Version) Descriptor 

func (Raft_RPC_Command_InstallSnapshot_Request_Version) Descriptor() protoreflect.EnumDescriptor

func (Raft_RPC_Command_InstallSnapshot_Request_Version) Enum 

func (x Raft_RPC_Command_InstallSnapshot_Request_Version) Enum() *Raft_RPC_Command_InstallSnapshot_Request_Version

func (Raft_RPC_Command_InstallSnapshot_Request_Version) EnumDescriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_InstallSnapshot_Request_Version.Descriptor instead.

func (Raft_RPC_Command_InstallSnapshot_Request_Version) Number 

func (x Raft_RPC_Command_InstallSnapshot_Request_Version) Number() protoreflect.EnumNumber

func (Raft_RPC_Command_InstallSnapshot_Request_Version) String 

func (x Raft_RPC_Command_InstallSnapshot_Request_Version) String() string

func (Raft_RPC_Command_InstallSnapshot_Request_Version) Type 

func (Raft_RPC_Command_InstallSnapshot_Request_Version) Type() protoreflect.EnumType

type Raft_RPC_Command_InstallSnapshot_Response 

type Raft_RPC_Command_InstallSnapshot_Response struct {
	Header  *Raft_RPC_Command_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term    uint64                   `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Success bool                     `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_InstallSnapshot_Response) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_InstallSnapshot_Response.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_InstallSnapshot_Response) GetHeader 

func (x *Raft_RPC_Command_InstallSnapshot_Response) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_InstallSnapshot_Response) GetSuccess 

func (x *Raft_RPC_Command_InstallSnapshot_Response) GetSuccess() bool

func (*Raft_RPC_Command_InstallSnapshot_Response) GetTerm 

func (x *Raft_RPC_Command_InstallSnapshot_Response) GetTerm() uint64

func (*Raft_RPC_Command_InstallSnapshot_Response) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_InstallSnapshot_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_InstallSnapshot_Response) MarshalToVT 

func (m *Raft_RPC_Command_InstallSnapshot_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_InstallSnapshot_Response) MarshalVT 

func (m *Raft_RPC_Command_InstallSnapshot_Response) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_InstallSnapshot_Response) ProtoMessage 

func (*Raft_RPC_Command_InstallSnapshot_Response) ProtoMessage()

func (*Raft_RPC_Command_InstallSnapshot_Response) ProtoReflect 

func (x *Raft_RPC_Command_InstallSnapshot_Response) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_InstallSnapshot_Response) Reset 

func (x *Raft_RPC_Command_InstallSnapshot_Response) Reset()

func (*Raft_RPC_Command_InstallSnapshot_Response) SizeVT 

func (m *Raft_RPC_Command_InstallSnapshot_Response) SizeVT() (n int)

func (*Raft_RPC_Command_InstallSnapshot_Response) String 

func (x *Raft_RPC_Command_InstallSnapshot_Response) String() string

func (*Raft_RPC_Command_InstallSnapshot_Response) UnmarshalVT 

func (m *Raft_RPC_Command_InstallSnapshot_Response) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_TimeoutNow 

type Raft_RPC_Command_TimeoutNow struct {
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_TimeoutNow) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_TimeoutNow.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_TimeoutNow) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_TimeoutNow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_TimeoutNow) MarshalToVT 

func (m *Raft_RPC_Command_TimeoutNow) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_TimeoutNow) MarshalVT 

func (m *Raft_RPC_Command_TimeoutNow) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_TimeoutNow) ProtoMessage 

func (*Raft_RPC_Command_TimeoutNow) ProtoMessage()

func (*Raft_RPC_Command_TimeoutNow) ProtoReflect 

func (x *Raft_RPC_Command_TimeoutNow) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_TimeoutNow) Reset 

func (x *Raft_RPC_Command_TimeoutNow) Reset()

func (*Raft_RPC_Command_TimeoutNow) SizeVT 

func (m *Raft_RPC_Command_TimeoutNow) SizeVT() (n int)

func (*Raft_RPC_Command_TimeoutNow) String 

func (x *Raft_RPC_Command_TimeoutNow) String() string

func (*Raft_RPC_Command_TimeoutNow) UnmarshalVT 

func (m *Raft_RPC_Command_TimeoutNow) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_TimeoutNow_Request 

type Raft_RPC_Command_TimeoutNow_Request struct {
	Header *Raft_RPC_Command_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_TimeoutNow_Request) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_TimeoutNow_Request.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_TimeoutNow_Request) GetHeader 

func (x *Raft_RPC_Command_TimeoutNow_Request) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_TimeoutNow_Request) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_TimeoutNow_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_TimeoutNow_Request) MarshalToVT 

func (m *Raft_RPC_Command_TimeoutNow_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_TimeoutNow_Request) MarshalVT 

func (m *Raft_RPC_Command_TimeoutNow_Request) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_TimeoutNow_Request) ProtoMessage 

func (*Raft_RPC_Command_TimeoutNow_Request) ProtoMessage()

func (*Raft_RPC_Command_TimeoutNow_Request) ProtoReflect 

func (x *Raft_RPC_Command_TimeoutNow_Request) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_TimeoutNow_Request) Reset 

func (x *Raft_RPC_Command_TimeoutNow_Request) Reset()

func (*Raft_RPC_Command_TimeoutNow_Request) SizeVT 

func (m *Raft_RPC_Command_TimeoutNow_Request) SizeVT() (n int)

func (*Raft_RPC_Command_TimeoutNow_Request) String 

func (x *Raft_RPC_Command_TimeoutNow_Request) String() string

func (*Raft_RPC_Command_TimeoutNow_Request) UnmarshalVT 

func (m *Raft_RPC_Command_TimeoutNow_Request) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_TimeoutNow_Response 

type Raft_RPC_Command_TimeoutNow_Response struct {
	Header *Raft_RPC_Command_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_TimeoutNow_Response) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_TimeoutNow_Response.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_TimeoutNow_Response) GetHeader 

func (x *Raft_RPC_Command_TimeoutNow_Response) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_TimeoutNow_Response) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_TimeoutNow_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_TimeoutNow_Response) MarshalToVT 

func (m *Raft_RPC_Command_TimeoutNow_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_TimeoutNow_Response) MarshalVT 

func (m *Raft_RPC_Command_TimeoutNow_Response) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_TimeoutNow_Response) ProtoMessage 

func (*Raft_RPC_Command_TimeoutNow_Response) ProtoMessage()

func (*Raft_RPC_Command_TimeoutNow_Response) ProtoReflect 

func (x *Raft_RPC_Command_TimeoutNow_Response) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_TimeoutNow_Response) Reset 

func (x *Raft_RPC_Command_TimeoutNow_Response) Reset()

func (*Raft_RPC_Command_TimeoutNow_Response) SizeVT 

func (m *Raft_RPC_Command_TimeoutNow_Response) SizeVT() (n int)

func (*Raft_RPC_Command_TimeoutNow_Response) String 

func (x *Raft_RPC_Command_TimeoutNow_Response) String() string

func (*Raft_RPC_Command_TimeoutNow_Response) UnmarshalVT 

func (m *Raft_RPC_Command_TimeoutNow_Response) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_Vote 

type Raft_RPC_Command_Vote struct {
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_Vote) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_Vote.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_Vote) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_Vote) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Vote) MarshalToVT 

func (m *Raft_RPC_Command_Vote) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Vote) MarshalVT 

func (m *Raft_RPC_Command_Vote) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_Vote) ProtoMessage 

func (*Raft_RPC_Command_Vote) ProtoMessage()

func (*Raft_RPC_Command_Vote) ProtoReflect 

func (x *Raft_RPC_Command_Vote) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_Vote) Reset 

func (x *Raft_RPC_Command_Vote) Reset()

func (*Raft_RPC_Command_Vote) SizeVT 

func (m *Raft_RPC_Command_Vote) SizeVT() (n int)

func (*Raft_RPC_Command_Vote) String 

func (x *Raft_RPC_Command_Vote) String() string

func (*Raft_RPC_Command_Vote) UnmarshalVT 

func (m *Raft_RPC_Command_Vote) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_Vote_Request 

type Raft_RPC_Command_Vote_Request struct {
	Header             *Raft_RPC_Command_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term               uint64                   `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	LastLogIndex       uint64                   `protobuf:"varint,3,opt,name=last_log_index,json=lastLogIndex,proto3" json:"last_log_index,omitempty"`
	LastLogTerm        uint64                   `protobuf:"varint,4,opt,name=last_log_term,json=lastLogTerm,proto3" json:"last_log_term,omitempty"`
	LeadershipTransfer bool                     `protobuf:"varint,5,opt,name=leadership_transfer,json=leadershipTransfer,proto3" json:"leadership_transfer,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_Vote_Request) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_Vote_Request.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_Vote_Request) GetHeader 

func (x *Raft_RPC_Command_Vote_Request) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_Vote_Request) GetLastLogIndex 

func (x *Raft_RPC_Command_Vote_Request) GetLastLogIndex() uint64

func (*Raft_RPC_Command_Vote_Request) GetLastLogTerm 

func (x *Raft_RPC_Command_Vote_Request) GetLastLogTerm() uint64

func (*Raft_RPC_Command_Vote_Request) GetLeadershipTransfer 

func (x *Raft_RPC_Command_Vote_Request) GetLeadershipTransfer() bool

func (*Raft_RPC_Command_Vote_Request) GetTerm 

func (x *Raft_RPC_Command_Vote_Request) GetTerm() uint64

func (*Raft_RPC_Command_Vote_Request) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_Vote_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Vote_Request) MarshalToVT 

func (m *Raft_RPC_Command_Vote_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Vote_Request) MarshalVT 

func (m *Raft_RPC_Command_Vote_Request) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_Vote_Request) ProtoMessage 

func (*Raft_RPC_Command_Vote_Request) ProtoMessage()

func (*Raft_RPC_Command_Vote_Request) ProtoReflect 

func (x *Raft_RPC_Command_Vote_Request) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_Vote_Request) Reset 

func (x *Raft_RPC_Command_Vote_Request) Reset()

func (*Raft_RPC_Command_Vote_Request) SizeVT 

func (m *Raft_RPC_Command_Vote_Request) SizeVT() (n int)

func (*Raft_RPC_Command_Vote_Request) String 

func (x *Raft_RPC_Command_Vote_Request) String() string

func (*Raft_RPC_Command_Vote_Request) UnmarshalVT 

func (m *Raft_RPC_Command_Vote_Request) UnmarshalVT(dAtA []byte) error

type Raft_RPC_Command_Vote_Response 

type Raft_RPC_Command_Vote_Response struct {
	Header  *Raft_RPC_Command_Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term    uint64                   `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Granted bool                     `protobuf:"varint,3,opt,name=granted,proto3" json:"granted,omitempty"`
	// contains filtered or unexported fields
}

func (*Raft_RPC_Command_Vote_Response) Descriptor deprecated 

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

Deprecated: Use Raft_RPC_Command_Vote_Response.ProtoReflect.Descriptor instead.

func (*Raft_RPC_Command_Vote_Response) GetGranted 

func (x *Raft_RPC_Command_Vote_Response) GetGranted() bool

func (*Raft_RPC_Command_Vote_Response) GetHeader 

func (x *Raft_RPC_Command_Vote_Response) GetHeader() *Raft_RPC_Command_Header

func (*Raft_RPC_Command_Vote_Response) GetTerm 

func (x *Raft_RPC_Command_Vote_Response) GetTerm() uint64

func (*Raft_RPC_Command_Vote_Response) MarshalToSizedBufferVT 

func (m *Raft_RPC_Command_Vote_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Vote_Response) MarshalToVT 

func (m *Raft_RPC_Command_Vote_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Raft_RPC_Command_Vote_Response) MarshalVT 

func (m *Raft_RPC_Command_Vote_Response) MarshalVT() (dAtA []byte, err error)

func (*Raft_RPC_Command_Vote_Response) ProtoMessage 

func (*Raft_RPC_Command_Vote_Response) ProtoMessage()

func (*Raft_RPC_Command_Vote_Response) ProtoReflect 

func (x *Raft_RPC_Command_Vote_Response) ProtoReflect() protoreflect.Message

func (*Raft_RPC_Command_Vote_Response) Reset 

func (x *Raft_RPC_Command_Vote_Response) Reset()

func (*Raft_RPC_Command_Vote_Response) SizeVT 

func (m *Raft_RPC_Command_Vote_Response) SizeVT() (n int)

func (*Raft_RPC_Command_Vote_Response) String 

func (x *Raft_RPC_Command_Vote_Response) String() string

func (*Raft_RPC_Command_Vote_Response) UnmarshalVT 

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