proto

package
v0.0.0-...-3d1347b Latest Latest
Warning

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

 Go to latest Published: May 5, 2023 License: BSD-2-Clause Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RaftAdmin_AddNonvoter_FullMethodName                = "/admin.RaftAdmin/AddNonvoter"
	RaftAdmin_AddVoter_FullMethodName                   = "/admin.RaftAdmin/AddVoter"
	RaftAdmin_AppliedIndex_FullMethodName               = "/admin.RaftAdmin/AppliedIndex"
	RaftAdmin_ApplyLog_FullMethodName                   = "/admin.RaftAdmin/ApplyLog"
	RaftAdmin_Barrier_FullMethodName                    = "/admin.RaftAdmin/Barrier"
	RaftAdmin_DemoteVoter_FullMethodName                = "/admin.RaftAdmin/DemoteVoter"
	RaftAdmin_GetConfiguration_FullMethodName           = "/admin.RaftAdmin/GetConfiguration"
	RaftAdmin_LastContact_FullMethodName                = "/admin.RaftAdmin/LastContact"
	RaftAdmin_LastIndex_FullMethodName                  = "/admin.RaftAdmin/LastIndex"
	RaftAdmin_Leader_FullMethodName                     = "/admin.RaftAdmin/Leader"
	RaftAdmin_LeadershipTransfer_FullMethodName         = "/admin.RaftAdmin/LeadershipTransfer"
	RaftAdmin_LeadershipTransferToServer_FullMethodName = "/admin.RaftAdmin/LeadershipTransferToServer"
	RaftAdmin_RemoveServer_FullMethodName               = "/admin.RaftAdmin/RemoveServer"
	RaftAdmin_Shutdown_FullMethodName                   = "/admin.RaftAdmin/Shutdown"
	RaftAdmin_Snapshot_FullMethodName                   = "/admin.RaftAdmin/Snapshot"
	RaftAdmin_State_FullMethodName                      = "/admin.RaftAdmin/State"
	RaftAdmin_Stats_FullMethodName                      = "/admin.RaftAdmin/Stats"
	RaftAdmin_VerifyLeader_FullMethodName               = "/admin.RaftAdmin/VerifyLeader"
	RaftAdmin_Await_FullMethodName                      = "/admin.RaftAdmin/Await"
	RaftAdmin_Forget_FullMethodName                     = "/admin.RaftAdmin/Forget"
)

Variables

View Source 
var (
	GetConfigurationResponse_Server_Suffrage_name = map[int32]string{
		0: "VOTER",
		1: "NONVOTER",
		2: "STAGING",
	}
	GetConfigurationResponse_Server_Suffrage_value = map[string]int32{
		"VOTER":    0,
		"NONVOTER": 1,
		"STAGING":  2,
	}
)

Enum value maps for GetConfigurationResponse_Server_Suffrage.

View Source 
var (
	StateResponse_State_name = map[int32]string{
		0: "FOLLOWER",
		1: "CANDIDATE",
		2: "LEADER",
		3: "SHUTDOWN",
	}
	StateResponse_State_value = map[string]int32{
		"FOLLOWER":  0,
		"CANDIDATE": 1,
		"LEADER":    2,
		"SHUTDOWN":  3,
	}
)

Enum value maps for StateResponse_State.

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_raftadmin_proto protoreflect.FileDescriptor
View Source 
var RaftAdmin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "admin.RaftAdmin",
	HandlerType: (*RaftAdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddNonvoter",
			Handler:    _RaftAdmin_AddNonvoter_Handler,
		},
		{
			MethodName: "AddVoter",
			Handler:    _RaftAdmin_AddVoter_Handler,
		},
		{
			MethodName: "AppliedIndex",
			Handler:    _RaftAdmin_AppliedIndex_Handler,
		},
		{
			MethodName: "ApplyLog",
			Handler:    _RaftAdmin_ApplyLog_Handler,
		},
		{
			MethodName: "Barrier",
			Handler:    _RaftAdmin_Barrier_Handler,
		},
		{
			MethodName: "DemoteVoter",
			Handler:    _RaftAdmin_DemoteVoter_Handler,
		},
		{
			MethodName: "GetConfiguration",
			Handler:    _RaftAdmin_GetConfiguration_Handler,
		},
		{
			MethodName: "LastContact",
			Handler:    _RaftAdmin_LastContact_Handler,
		},
		{
			MethodName: "LastIndex",
			Handler:    _RaftAdmin_LastIndex_Handler,
		},
		{
			MethodName: "Leader",
			Handler:    _RaftAdmin_Leader_Handler,
		},
		{
			MethodName: "LeadershipTransfer",
			Handler:    _RaftAdmin_LeadershipTransfer_Handler,
		},
		{
			MethodName: "LeadershipTransferToServer",
			Handler:    _RaftAdmin_LeadershipTransferToServer_Handler,
		},
		{
			MethodName: "RemoveServer",
			Handler:    _RaftAdmin_RemoveServer_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _RaftAdmin_Shutdown_Handler,
		},
		{
			MethodName: "Snapshot",
			Handler:    _RaftAdmin_Snapshot_Handler,
		},
		{
			MethodName: "State",
			Handler:    _RaftAdmin_State_Handler,
		},
		{
			MethodName: "Stats",
			Handler:    _RaftAdmin_Stats_Handler,
		},
		{
			MethodName: "VerifyLeader",
			Handler:    _RaftAdmin_VerifyLeader_Handler,
		},
		{
			MethodName: "Await",
			Handler:    _RaftAdmin_Await_Handler,
		},
		{
			MethodName: "Forget",
			Handler:    _RaftAdmin_Forget_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "raftadmin.proto",
}

RaftAdmin_ServiceDesc is the grpc.ServiceDesc for RaftAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRaftAdminServer 

func RegisterRaftAdminServer(s grpc.ServiceRegistrar, srv RaftAdminServer)

Types

type AddNonvoterRequest 

type AddNonvoterRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,3,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNonvoterRequest) Descriptor deprecated 

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

Deprecated: Use AddNonvoterRequest.ProtoReflect.Descriptor instead.

func (*AddNonvoterRequest) GetAddress 

func (x *AddNonvoterRequest) GetAddress() string

func (*AddNonvoterRequest) GetId 

func (x *AddNonvoterRequest) GetId() string

func (*AddNonvoterRequest) GetPreviousIndex 

func (x *AddNonvoterRequest) GetPreviousIndex() uint64

func (*AddNonvoterRequest) MarshalToSizedBufferVT 

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

func (*AddNonvoterRequest) MarshalToVT 

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

func (*AddNonvoterRequest) MarshalVT 

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

func (*AddNonvoterRequest) ProtoMessage 

func (*AddNonvoterRequest) ProtoMessage()

func (*AddNonvoterRequest) ProtoReflect 

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

func (*AddNonvoterRequest) Reset 

func (x *AddNonvoterRequest) Reset()

func (*AddNonvoterRequest) SizeVT 

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

func (*AddNonvoterRequest) String 

func (x *AddNonvoterRequest) String() string

func (*AddNonvoterRequest) UnmarshalVT 

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

type AddVoterRequest 

type AddVoterRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,3,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// contains filtered or unexported fields
}

func (*AddVoterRequest) Descriptor deprecated 

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

Deprecated: Use AddVoterRequest.ProtoReflect.Descriptor instead.

func (*AddVoterRequest) GetAddress 

func (x *AddVoterRequest) GetAddress() string

func (*AddVoterRequest) GetId 

func (x *AddVoterRequest) GetId() string

func (*AddVoterRequest) GetPreviousIndex 

func (x *AddVoterRequest) GetPreviousIndex() uint64

func (*AddVoterRequest) MarshalToSizedBufferVT 

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

func (*AddVoterRequest) MarshalToVT 

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

func (*AddVoterRequest) MarshalVT 

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

func (*AddVoterRequest) ProtoMessage 

func (*AddVoterRequest) ProtoMessage()

func (*AddVoterRequest) ProtoReflect 

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

func (*AddVoterRequest) Reset 

func (x *AddVoterRequest) Reset()

func (*AddVoterRequest) SizeVT 

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

func (*AddVoterRequest) String 

func (x *AddVoterRequest) String() string

func (*AddVoterRequest) UnmarshalVT 

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

type AppliedIndexRequest 

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

func (*AppliedIndexRequest) Descriptor deprecated 

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

Deprecated: Use AppliedIndexRequest.ProtoReflect.Descriptor instead.

func (*AppliedIndexRequest) MarshalToSizedBufferVT 

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

func (*AppliedIndexRequest) MarshalToVT 

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

func (*AppliedIndexRequest) MarshalVT 

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

func (*AppliedIndexRequest) ProtoMessage 

func (*AppliedIndexRequest) ProtoMessage()

func (*AppliedIndexRequest) ProtoReflect 

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

func (*AppliedIndexRequest) Reset 

func (x *AppliedIndexRequest) Reset()

func (*AppliedIndexRequest) SizeVT 

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

func (*AppliedIndexRequest) String 

func (x *AppliedIndexRequest) String() string

func (*AppliedIndexRequest) UnmarshalVT 

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

type AppliedIndexResponse 

type AppliedIndexResponse struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*AppliedIndexResponse) Descriptor deprecated 

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

Deprecated: Use AppliedIndexResponse.ProtoReflect.Descriptor instead.

func (*AppliedIndexResponse) GetIndex 

func (x *AppliedIndexResponse) GetIndex() uint64

func (*AppliedIndexResponse) MarshalToSizedBufferVT 

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

func (*AppliedIndexResponse) MarshalToVT 

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

func (*AppliedIndexResponse) MarshalVT 

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

func (*AppliedIndexResponse) ProtoMessage 

func (*AppliedIndexResponse) ProtoMessage()

func (*AppliedIndexResponse) ProtoReflect 

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

func (*AppliedIndexResponse) Reset 

func (x *AppliedIndexResponse) Reset()

func (*AppliedIndexResponse) SizeVT 

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

func (*AppliedIndexResponse) String 

func (x *AppliedIndexResponse) String() string

func (*AppliedIndexResponse) UnmarshalVT 

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

type ApplyLogRequest 

type ApplyLogRequest struct {
	Data       []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Extensions []byte `protobuf:"bytes,2,opt,name=extensions,proto3" json:"extensions,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyLogRequest) Descriptor deprecated 

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

Deprecated: Use ApplyLogRequest.ProtoReflect.Descriptor instead.

func (*ApplyLogRequest) GetData 

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

func (*ApplyLogRequest) GetExtensions 

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

func (*ApplyLogRequest) MarshalToSizedBufferVT 

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

func (*ApplyLogRequest) MarshalToVT 

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

func (*ApplyLogRequest) MarshalVT 

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

func (*ApplyLogRequest) ProtoMessage 

func (*ApplyLogRequest) ProtoMessage()

func (*ApplyLogRequest) ProtoReflect 

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

func (*ApplyLogRequest) Reset 

func (x *ApplyLogRequest) Reset()

func (*ApplyLogRequest) SizeVT 

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

func (*ApplyLogRequest) String 

func (x *ApplyLogRequest) String() string

func (*ApplyLogRequest) UnmarshalVT 

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

type AwaitResponse 

type AwaitResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*AwaitResponse) Descriptor deprecated 

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

Deprecated: Use AwaitResponse.ProtoReflect.Descriptor instead.

func (*AwaitResponse) GetError 

func (x *AwaitResponse) GetError() string

func (*AwaitResponse) GetIndex 

func (x *AwaitResponse) GetIndex() uint64

func (*AwaitResponse) MarshalToSizedBufferVT 

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

func (*AwaitResponse) MarshalToVT 

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

func (*AwaitResponse) MarshalVT 

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

func (*AwaitResponse) ProtoMessage 

func (*AwaitResponse) ProtoMessage()

func (*AwaitResponse) ProtoReflect 

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

func (*AwaitResponse) Reset 

func (x *AwaitResponse) Reset()

func (*AwaitResponse) SizeVT 

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

func (*AwaitResponse) String 

func (x *AwaitResponse) String() string

func (*AwaitResponse) UnmarshalVT 

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

type BarrierRequest 

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

func (*BarrierRequest) Descriptor deprecated 

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

Deprecated: Use BarrierRequest.ProtoReflect.Descriptor instead.

func (*BarrierRequest) MarshalToSizedBufferVT 

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

func (*BarrierRequest) MarshalToVT 

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

func (*BarrierRequest) MarshalVT 

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

func (*BarrierRequest) ProtoMessage 

func (*BarrierRequest) ProtoMessage()

func (*BarrierRequest) ProtoReflect 

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

func (*BarrierRequest) Reset 

func (x *BarrierRequest) Reset()

func (*BarrierRequest) SizeVT 

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

func (*BarrierRequest) String 

func (x *BarrierRequest) String() string

func (*BarrierRequest) UnmarshalVT 

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

type DemoteVoterRequest 

type DemoteVoterRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,2,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// contains filtered or unexported fields
}

func (*DemoteVoterRequest) Descriptor deprecated 

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

Deprecated: Use DemoteVoterRequest.ProtoReflect.Descriptor instead.

func (*DemoteVoterRequest) GetId 

func (x *DemoteVoterRequest) GetId() string

func (*DemoteVoterRequest) GetPreviousIndex 

func (x *DemoteVoterRequest) GetPreviousIndex() uint64

func (*DemoteVoterRequest) MarshalToSizedBufferVT 

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

func (*DemoteVoterRequest) MarshalToVT 

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

func (*DemoteVoterRequest) MarshalVT 

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

func (*DemoteVoterRequest) ProtoMessage 

func (*DemoteVoterRequest) ProtoMessage()

func (*DemoteVoterRequest) ProtoReflect 

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

func (*DemoteVoterRequest) Reset 

func (x *DemoteVoterRequest) Reset()

func (*DemoteVoterRequest) SizeVT 

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

func (*DemoteVoterRequest) String 

func (x *DemoteVoterRequest) String() string

func (*DemoteVoterRequest) UnmarshalVT 

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

type ForgetResponse 

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

func (*ForgetResponse) Descriptor deprecated 

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

Deprecated: Use ForgetResponse.ProtoReflect.Descriptor instead.

func (*ForgetResponse) MarshalToSizedBufferVT 

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

func (*ForgetResponse) MarshalToVT 

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

func (*ForgetResponse) MarshalVT 

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

func (*ForgetResponse) ProtoMessage 

func (*ForgetResponse) ProtoMessage()

func (*ForgetResponse) ProtoReflect 

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

func (*ForgetResponse) Reset 

func (x *ForgetResponse) Reset()

func (*ForgetResponse) SizeVT 

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

func (*ForgetResponse) String 

func (x *ForgetResponse) String() string

func (*ForgetResponse) UnmarshalVT 

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

type Future 

type Future struct {
	OperationToken string `protobuf:"bytes,1,opt,name=operation_token,json=operationToken,proto3" json:"operation_token,omitempty"`
	// contains filtered or unexported fields
}

func (*Future) Descriptor deprecated 

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

Deprecated: Use Future.ProtoReflect.Descriptor instead.

func (*Future) GetOperationToken 

func (x *Future) GetOperationToken() string

func (*Future) MarshalToSizedBufferVT 

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

func (*Future) MarshalToVT 

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

func (*Future) MarshalVT 

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

func (*Future) ProtoMessage 

func (*Future) ProtoMessage()

func (*Future) ProtoReflect 

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

func (*Future) Reset 

func (x *Future) Reset()

func (*Future) SizeVT 

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

func (*Future) String 

func (x *Future) String() string

func (*Future) UnmarshalVT 

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

type GetConfigurationRequest 

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

func (*GetConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) MarshalToSizedBufferVT 

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

func (*GetConfigurationRequest) MarshalToVT 

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

func (*GetConfigurationRequest) MarshalVT 

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

func (*GetConfigurationRequest) ProtoMessage 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect 

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

func (*GetConfigurationRequest) Reset 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) SizeVT 

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

func (*GetConfigurationRequest) String 

func (x *GetConfigurationRequest) String() string

func (*GetConfigurationRequest) UnmarshalVT 

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

type GetConfigurationResponse 

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

func (*GetConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetServers 

func (x *GetConfigurationResponse) GetServers() []*GetConfigurationResponse_Server

func (*GetConfigurationResponse) MarshalToSizedBufferVT 

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

func (*GetConfigurationResponse) MarshalToVT 

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

func (*GetConfigurationResponse) MarshalVT 

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

func (*GetConfigurationResponse) ProtoMessage 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect 

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

func (*GetConfigurationResponse) Reset 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) SizeVT 

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

func (*GetConfigurationResponse) String 

func (x *GetConfigurationResponse) String() string

func (*GetConfigurationResponse) UnmarshalVT 

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

type GetConfigurationResponse_Server 

type GetConfigurationResponse_Server struct {
	Suffrage GetConfigurationResponse_Server_Suffrage `protobuf:"varint,1,opt,name=suffrage,proto3,enum=admin.GetConfigurationResponse_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"`
	// contains filtered or unexported fields
}

func (*GetConfigurationResponse_Server) Descriptor deprecated 

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

Deprecated: Use GetConfigurationResponse_Server.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse_Server) GetAddress 

func (x *GetConfigurationResponse_Server) GetAddress() string

func (*GetConfigurationResponse_Server) GetId 

func (x *GetConfigurationResponse_Server) GetId() string

func (*GetConfigurationResponse_Server) GetSuffrage 

func (x *GetConfigurationResponse_Server) GetSuffrage() GetConfigurationResponse_Server_Suffrage

func (*GetConfigurationResponse_Server) MarshalToSizedBufferVT 

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

func (*GetConfigurationResponse_Server) MarshalToVT 

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

func (*GetConfigurationResponse_Server) MarshalVT 

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

func (*GetConfigurationResponse_Server) ProtoMessage 

func (*GetConfigurationResponse_Server) ProtoMessage()

func (*GetConfigurationResponse_Server) ProtoReflect 

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

func (*GetConfigurationResponse_Server) Reset 

func (x *GetConfigurationResponse_Server) Reset()

func (*GetConfigurationResponse_Server) SizeVT 

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

func (*GetConfigurationResponse_Server) String 

func (x *GetConfigurationResponse_Server) String() string

func (*GetConfigurationResponse_Server) UnmarshalVT 

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

type GetConfigurationResponse_Server_Suffrage 

type GetConfigurationResponse_Server_Suffrage int32
const (
	GetConfigurationResponse_Server_VOTER    GetConfigurationResponse_Server_Suffrage = 0
	GetConfigurationResponse_Server_NONVOTER GetConfigurationResponse_Server_Suffrage = 1
	GetConfigurationResponse_Server_STAGING  GetConfigurationResponse_Server_Suffrage = 2
)

func (GetConfigurationResponse_Server_Suffrage) Descriptor 

func (GetConfigurationResponse_Server_Suffrage) Descriptor() protoreflect.EnumDescriptor

func (GetConfigurationResponse_Server_Suffrage) Enum 

func (x GetConfigurationResponse_Server_Suffrage) Enum() *GetConfigurationResponse_Server_Suffrage

func (GetConfigurationResponse_Server_Suffrage) EnumDescriptor deprecated 

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

Deprecated: Use GetConfigurationResponse_Server_Suffrage.Descriptor instead.

func (GetConfigurationResponse_Server_Suffrage) Number 

func (x GetConfigurationResponse_Server_Suffrage) Number() protoreflect.EnumNumber

func (GetConfigurationResponse_Server_Suffrage) String 

func (x GetConfigurationResponse_Server_Suffrage) String() string

func (GetConfigurationResponse_Server_Suffrage) Type 

func (GetConfigurationResponse_Server_Suffrage) Type() protoreflect.EnumType

type LastContactRequest 

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

func (*LastContactRequest) Descriptor deprecated 

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

Deprecated: Use LastContactRequest.ProtoReflect.Descriptor instead.

func (*LastContactRequest) MarshalToSizedBufferVT 

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

func (*LastContactRequest) MarshalToVT 

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

func (*LastContactRequest) MarshalVT 

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

func (*LastContactRequest) ProtoMessage 

func (*LastContactRequest) ProtoMessage()

func (*LastContactRequest) ProtoReflect 

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

func (*LastContactRequest) Reset 

func (x *LastContactRequest) Reset()

func (*LastContactRequest) SizeVT 

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

func (*LastContactRequest) String 

func (x *LastContactRequest) String() string

func (*LastContactRequest) UnmarshalVT 

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

type LastContactResponse 

type LastContactResponse struct {
	UnixNano int64 `protobuf:"varint,1,opt,name=unix_nano,json=unixNano,proto3" json:"unix_nano,omitempty"`
	// contains filtered or unexported fields
}

func (*LastContactResponse) Descriptor deprecated 

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

Deprecated: Use LastContactResponse.ProtoReflect.Descriptor instead.

func (*LastContactResponse) GetUnixNano 

func (x *LastContactResponse) GetUnixNano() int64

func (*LastContactResponse) MarshalToSizedBufferVT 

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

func (*LastContactResponse) MarshalToVT 

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

func (*LastContactResponse) MarshalVT 

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

func (*LastContactResponse) ProtoMessage 

func (*LastContactResponse) ProtoMessage()

func (*LastContactResponse) ProtoReflect 

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

func (*LastContactResponse) Reset 

func (x *LastContactResponse) Reset()

func (*LastContactResponse) SizeVT 

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

func (*LastContactResponse) String 

func (x *LastContactResponse) String() string

func (*LastContactResponse) UnmarshalVT 

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

type LastIndexRequest 

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

func (*LastIndexRequest) Descriptor deprecated 

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

Deprecated: Use LastIndexRequest.ProtoReflect.Descriptor instead.

func (*LastIndexRequest) MarshalToSizedBufferVT 

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

func (*LastIndexRequest) MarshalToVT 

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

func (*LastIndexRequest) MarshalVT 

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

func (*LastIndexRequest) ProtoMessage 

func (*LastIndexRequest) ProtoMessage()

func (*LastIndexRequest) ProtoReflect 

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

func (*LastIndexRequest) Reset 

func (x *LastIndexRequest) Reset()

func (*LastIndexRequest) SizeVT 

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

func (*LastIndexRequest) String 

func (x *LastIndexRequest) String() string

func (*LastIndexRequest) UnmarshalVT 

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

type LastIndexResponse 

type LastIndexResponse struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*LastIndexResponse) Descriptor deprecated 

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

Deprecated: Use LastIndexResponse.ProtoReflect.Descriptor instead.

func (*LastIndexResponse) GetIndex 

func (x *LastIndexResponse) GetIndex() uint64

func (*LastIndexResponse) MarshalToSizedBufferVT 

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

func (*LastIndexResponse) MarshalToVT 

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

func (*LastIndexResponse) MarshalVT 

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

func (*LastIndexResponse) ProtoMessage 

func (*LastIndexResponse) ProtoMessage()

func (*LastIndexResponse) ProtoReflect 

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

func (*LastIndexResponse) Reset 

func (x *LastIndexResponse) Reset()

func (*LastIndexResponse) SizeVT 

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

func (*LastIndexResponse) String 

func (x *LastIndexResponse) String() string

func (*LastIndexResponse) UnmarshalVT 

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

type LeaderRequest 

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

func (*LeaderRequest) Descriptor deprecated 

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

Deprecated: Use LeaderRequest.ProtoReflect.Descriptor instead.

func (*LeaderRequest) MarshalToSizedBufferVT 

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

func (*LeaderRequest) MarshalToVT 

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

func (*LeaderRequest) MarshalVT 

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

func (*LeaderRequest) ProtoMessage 

func (*LeaderRequest) ProtoMessage()

func (*LeaderRequest) ProtoReflect 

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

func (*LeaderRequest) Reset 

func (x *LeaderRequest) Reset()

func (*LeaderRequest) SizeVT 

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

func (*LeaderRequest) String 

func (x *LeaderRequest) String() string

func (*LeaderRequest) UnmarshalVT 

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

type LeaderResponse 

type LeaderResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaderResponse) Descriptor deprecated 

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

Deprecated: Use LeaderResponse.ProtoReflect.Descriptor instead.

func (*LeaderResponse) GetAddress 

func (x *LeaderResponse) GetAddress() string

func (*LeaderResponse) MarshalToSizedBufferVT 

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

func (*LeaderResponse) MarshalToVT 

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

func (*LeaderResponse) MarshalVT 

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

func (*LeaderResponse) ProtoMessage 

func (*LeaderResponse) ProtoMessage()

func (*LeaderResponse) ProtoReflect 

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

func (*LeaderResponse) Reset 

func (x *LeaderResponse) Reset()

func (*LeaderResponse) SizeVT 

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

func (*LeaderResponse) String 

func (x *LeaderResponse) String() string

func (*LeaderResponse) UnmarshalVT 

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

type LeadershipTransferRequest 

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

func (*LeadershipTransferRequest) Descriptor deprecated 

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

Deprecated: Use LeadershipTransferRequest.ProtoReflect.Descriptor instead.

func (*LeadershipTransferRequest) MarshalToSizedBufferVT 

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

func (*LeadershipTransferRequest) MarshalToVT 

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

func (*LeadershipTransferRequest) MarshalVT 

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

func (*LeadershipTransferRequest) ProtoMessage 

func (*LeadershipTransferRequest) ProtoMessage()

func (*LeadershipTransferRequest) ProtoReflect 

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

func (*LeadershipTransferRequest) Reset 

func (x *LeadershipTransferRequest) Reset()

func (*LeadershipTransferRequest) SizeVT 

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

func (*LeadershipTransferRequest) String 

func (x *LeadershipTransferRequest) String() string

func (*LeadershipTransferRequest) UnmarshalVT 

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

type LeadershipTransferToServerRequest 

type LeadershipTransferToServerRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*LeadershipTransferToServerRequest) Descriptor deprecated 

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

Deprecated: Use LeadershipTransferToServerRequest.ProtoReflect.Descriptor instead.

func (*LeadershipTransferToServerRequest) GetAddress 

func (x *LeadershipTransferToServerRequest) GetAddress() string

func (*LeadershipTransferToServerRequest) GetId 

func (x *LeadershipTransferToServerRequest) GetId() string

func (*LeadershipTransferToServerRequest) MarshalToSizedBufferVT 

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

func (*LeadershipTransferToServerRequest) MarshalToVT 

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

func (*LeadershipTransferToServerRequest) MarshalVT 

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

func (*LeadershipTransferToServerRequest) ProtoMessage 

func (*LeadershipTransferToServerRequest) ProtoMessage()

func (*LeadershipTransferToServerRequest) ProtoReflect 

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

func (*LeadershipTransferToServerRequest) Reset 

func (x *LeadershipTransferToServerRequest) Reset()

func (*LeadershipTransferToServerRequest) SizeVT 

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

func (*LeadershipTransferToServerRequest) String 

func (x *LeadershipTransferToServerRequest) String() string

func (*LeadershipTransferToServerRequest) UnmarshalVT 

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

type RaftAdminClient 

type RaftAdminClient interface {
	AddNonvoter(ctx context.Context, in *AddNonvoterRequest, opts ...grpc.CallOption) (*Future, error)
	AddVoter(ctx context.Context, in *AddVoterRequest, opts ...grpc.CallOption) (*Future, error)
	AppliedIndex(ctx context.Context, in *AppliedIndexRequest, opts ...grpc.CallOption) (*AppliedIndexResponse, error)
	ApplyLog(ctx context.Context, in *ApplyLogRequest, opts ...grpc.CallOption) (*Future, error)
	Barrier(ctx context.Context, in *BarrierRequest, opts ...grpc.CallOption) (*Future, error)
	DemoteVoter(ctx context.Context, in *DemoteVoterRequest, opts ...grpc.CallOption) (*Future, error)
	GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	LastContact(ctx context.Context, in *LastContactRequest, opts ...grpc.CallOption) (*LastContactResponse, error)
	LastIndex(ctx context.Context, in *LastIndexRequest, opts ...grpc.CallOption) (*LastIndexResponse, error)
	Leader(ctx context.Context, in *LeaderRequest, opts ...grpc.CallOption) (*LeaderResponse, error)
	LeadershipTransfer(ctx context.Context, in *LeadershipTransferRequest, opts ...grpc.CallOption) (*Future, error)
	LeadershipTransferToServer(ctx context.Context, in *LeadershipTransferToServerRequest, opts ...grpc.CallOption) (*Future, error)
	RemoveServer(ctx context.Context, in *RemoveServerRequest, opts ...grpc.CallOption) (*Future, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*Future, error)
	Snapshot(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*Future, error)
	State(ctx context.Context, in *StateRequest, opts ...grpc.CallOption) (*StateResponse, error)
	Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error)
	VerifyLeader(ctx context.Context, in *VerifyLeaderRequest, opts ...grpc.CallOption) (*Future, error)
	Await(ctx context.Context, in *Future, opts ...grpc.CallOption) (*AwaitResponse, error)
	Forget(ctx context.Context, in *Future, opts ...grpc.CallOption) (*ForgetResponse, error)
}

RaftAdminClient is the client API for RaftAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRaftAdminClient 

func NewRaftAdminClient(cc grpc.ClientConnInterface) RaftAdminClient

type RaftAdminServer 

type RaftAdminServer interface {
	AddNonvoter(context.Context, *AddNonvoterRequest) (*Future, error)
	AddVoter(context.Context, *AddVoterRequest) (*Future, error)
	AppliedIndex(context.Context, *AppliedIndexRequest) (*AppliedIndexResponse, error)
	ApplyLog(context.Context, *ApplyLogRequest) (*Future, error)
	Barrier(context.Context, *BarrierRequest) (*Future, error)
	DemoteVoter(context.Context, *DemoteVoterRequest) (*Future, error)
	GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	LastContact(context.Context, *LastContactRequest) (*LastContactResponse, error)
	LastIndex(context.Context, *LastIndexRequest) (*LastIndexResponse, error)
	Leader(context.Context, *LeaderRequest) (*LeaderResponse, error)
	LeadershipTransfer(context.Context, *LeadershipTransferRequest) (*Future, error)
	LeadershipTransferToServer(context.Context, *LeadershipTransferToServerRequest) (*Future, error)
	RemoveServer(context.Context, *RemoveServerRequest) (*Future, error)
	Shutdown(context.Context, *ShutdownRequest) (*Future, error)
	Snapshot(context.Context, *SnapshotRequest) (*Future, error)
	State(context.Context, *StateRequest) (*StateResponse, error)
	Stats(context.Context, *StatsRequest) (*StatsResponse, error)
	VerifyLeader(context.Context, *VerifyLeaderRequest) (*Future, error)
	Await(context.Context, *Future) (*AwaitResponse, error)
	Forget(context.Context, *Future) (*ForgetResponse, error)
	// contains filtered or unexported methods
}

RaftAdminServer is the server API for RaftAdmin service. All implementations must embed UnimplementedRaftAdminServer for forward compatibility

type RemoveServerRequest 

type RemoveServerRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PreviousIndex uint64 `protobuf:"varint,2,opt,name=previous_index,json=previousIndex,proto3" json:"previous_index,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveServerRequest) Descriptor deprecated 

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

Deprecated: Use RemoveServerRequest.ProtoReflect.Descriptor instead.

func (*RemoveServerRequest) GetId 

func (x *RemoveServerRequest) GetId() string

func (*RemoveServerRequest) GetPreviousIndex 

func (x *RemoveServerRequest) GetPreviousIndex() uint64

func (*RemoveServerRequest) MarshalToSizedBufferVT 

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

func (*RemoveServerRequest) MarshalToVT 

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

func (*RemoveServerRequest) MarshalVT 

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

func (*RemoveServerRequest) ProtoMessage 

func (*RemoveServerRequest) ProtoMessage()

func (*RemoveServerRequest) ProtoReflect 

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

func (*RemoveServerRequest) Reset 

func (x *RemoveServerRequest) Reset()

func (*RemoveServerRequest) SizeVT 

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

func (*RemoveServerRequest) String 

func (x *RemoveServerRequest) String() string

func (*RemoveServerRequest) UnmarshalVT 

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

type ShutdownRequest 

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

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) MarshalToSizedBufferVT 

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

func (*ShutdownRequest) MarshalToVT 

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

func (*ShutdownRequest) MarshalVT 

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

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) SizeVT 

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

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

func (*ShutdownRequest) UnmarshalVT 

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

type SnapshotRequest 

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

func (*SnapshotRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRequest) MarshalToSizedBufferVT 

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

func (*SnapshotRequest) MarshalToVT 

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

func (*SnapshotRequest) MarshalVT 

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

func (*SnapshotRequest) ProtoMessage 

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) ProtoReflect 

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

func (*SnapshotRequest) Reset 

func (x *SnapshotRequest) Reset()

func (*SnapshotRequest) SizeVT 

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

func (*SnapshotRequest) String 

func (x *SnapshotRequest) String() string

func (*SnapshotRequest) UnmarshalVT 

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

type StateRequest 

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

func (*StateRequest) Descriptor deprecated 

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

Deprecated: Use StateRequest.ProtoReflect.Descriptor instead.

func (*StateRequest) MarshalToSizedBufferVT 

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

func (*StateRequest) MarshalToVT 

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

func (*StateRequest) MarshalVT 

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

func (*StateRequest) ProtoMessage 

func (*StateRequest) ProtoMessage()

func (*StateRequest) ProtoReflect 

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

func (*StateRequest) Reset 

func (x *StateRequest) Reset()

func (*StateRequest) SizeVT 

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

func (*StateRequest) String 

func (x *StateRequest) String() string

func (*StateRequest) UnmarshalVT 

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

type StateResponse 

type StateResponse struct {
	State StateResponse_State `protobuf:"varint,1,opt,name=state,proto3,enum=admin.StateResponse_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*StateResponse) Descriptor deprecated 

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

Deprecated: Use StateResponse.ProtoReflect.Descriptor instead.

func (*StateResponse) GetState 

func (x *StateResponse) GetState() StateResponse_State

func (*StateResponse) MarshalToSizedBufferVT 

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

func (*StateResponse) MarshalToVT 

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

func (*StateResponse) MarshalVT 

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

func (*StateResponse) ProtoMessage 

func (*StateResponse) ProtoMessage()

func (*StateResponse) ProtoReflect 

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

func (*StateResponse) Reset 

func (x *StateResponse) Reset()

func (*StateResponse) SizeVT 

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

func (*StateResponse) String 

func (x *StateResponse) String() string

func (*StateResponse) UnmarshalVT 

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

type StateResponse_State 

type StateResponse_State int32
const (
	StateResponse_FOLLOWER  StateResponse_State = 0
	StateResponse_CANDIDATE StateResponse_State = 1
	StateResponse_LEADER    StateResponse_State = 2
	StateResponse_SHUTDOWN  StateResponse_State = 3
)

func (StateResponse_State) Descriptor 

func (StateResponse_State) Descriptor() protoreflect.EnumDescriptor

func (StateResponse_State) Enum 

func (x StateResponse_State) Enum() *StateResponse_State

func (StateResponse_State) EnumDescriptor deprecated 

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

Deprecated: Use StateResponse_State.Descriptor instead.

func (StateResponse_State) Number 

func (x StateResponse_State) Number() protoreflect.EnumNumber

func (StateResponse_State) String 

func (x StateResponse_State) String() string

func (StateResponse_State) Type 

func (StateResponse_State) Type() protoreflect.EnumType

type StatsRequest 

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

func (*StatsRequest) Descriptor deprecated 

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

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) MarshalToSizedBufferVT 

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

func (*StatsRequest) MarshalToVT 

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

func (*StatsRequest) MarshalVT 

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

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect 

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

func (*StatsRequest) Reset 

func (x *StatsRequest) Reset()

func (*StatsRequest) SizeVT 

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

func (*StatsRequest) String 

func (x *StatsRequest) String() string

func (*StatsRequest) UnmarshalVT 

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

type StatsResponse 

type StatsResponse struct {
	Stats map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatsResponse) Descriptor deprecated 

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

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetStats 

func (x *StatsResponse) GetStats() map[string]string

func (*StatsResponse) MarshalToSizedBufferVT 

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

func (*StatsResponse) MarshalToVT 

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

func (*StatsResponse) MarshalVT 

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

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect 

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

func (*StatsResponse) Reset 

func (x *StatsResponse) Reset()

func (*StatsResponse) SizeVT 

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

func (*StatsResponse) String 

func (x *StatsResponse) String() string

func (*StatsResponse) UnmarshalVT 

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

type UnimplementedRaftAdminServer 

type UnimplementedRaftAdminServer struct {
}

UnimplementedRaftAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedRaftAdminServer) AddNonvoter 

func (UnimplementedRaftAdminServer) AddNonvoter(context.Context, *AddNonvoterRequest) (*Future, error)

func (UnimplementedRaftAdminServer) AddVoter 

func (UnimplementedRaftAdminServer) AddVoter(context.Context, *AddVoterRequest) (*Future, error)

func (UnimplementedRaftAdminServer) AppliedIndex 

func (UnimplementedRaftAdminServer) AppliedIndex(context.Context, *AppliedIndexRequest) (*AppliedIndexResponse, error)

func (UnimplementedRaftAdminServer) ApplyLog 

func (UnimplementedRaftAdminServer) ApplyLog(context.Context, *ApplyLogRequest) (*Future, error)

func (UnimplementedRaftAdminServer) Await 

func (UnimplementedRaftAdminServer) Await(context.Context, *Future) (*AwaitResponse, error)

func (UnimplementedRaftAdminServer) Barrier 

func (UnimplementedRaftAdminServer) Barrier(context.Context, *BarrierRequest) (*Future, error)

func (UnimplementedRaftAdminServer) DemoteVoter 

func (UnimplementedRaftAdminServer) DemoteVoter(context.Context, *DemoteVoterRequest) (*Future, error)

func (UnimplementedRaftAdminServer) Forget 

func (UnimplementedRaftAdminServer) Forget(context.Context, *Future) (*ForgetResponse, error)

func (UnimplementedRaftAdminServer) GetConfiguration 

func (UnimplementedRaftAdminServer) GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)

func (UnimplementedRaftAdminServer) LastContact 

func (UnimplementedRaftAdminServer) LastContact(context.Context, *LastContactRequest) (*LastContactResponse, error)

func (UnimplementedRaftAdminServer) LastIndex 

func (UnimplementedRaftAdminServer) LastIndex(context.Context, *LastIndexRequest) (*LastIndexResponse, error)

func (UnimplementedRaftAdminServer) Leader 

func (UnimplementedRaftAdminServer) Leader(context.Context, *LeaderRequest) (*LeaderResponse, error)

func (UnimplementedRaftAdminServer) LeadershipTransfer 

func (UnimplementedRaftAdminServer) LeadershipTransfer(context.Context, *LeadershipTransferRequest) (*Future, error)

func (UnimplementedRaftAdminServer) LeadershipTransferToServer 

func (UnimplementedRaftAdminServer) LeadershipTransferToServer(context.Context, *LeadershipTransferToServerRequest) (*Future, error)

func (UnimplementedRaftAdminServer) RemoveServer 

func (UnimplementedRaftAdminServer) RemoveServer(context.Context, *RemoveServerRequest) (*Future, error)

func (UnimplementedRaftAdminServer) Shutdown 

func (UnimplementedRaftAdminServer) Shutdown(context.Context, *ShutdownRequest) (*Future, error)

func (UnimplementedRaftAdminServer) Snapshot 

func (UnimplementedRaftAdminServer) Snapshot(context.Context, *SnapshotRequest) (*Future, error)

func (UnimplementedRaftAdminServer) State 

func (UnimplementedRaftAdminServer) State(context.Context, *StateRequest) (*StateResponse, error)

func (UnimplementedRaftAdminServer) Stats 

func (UnimplementedRaftAdminServer) Stats(context.Context, *StatsRequest) (*StatsResponse, error)

func (UnimplementedRaftAdminServer) VerifyLeader 

func (UnimplementedRaftAdminServer) VerifyLeader(context.Context, *VerifyLeaderRequest) (*Future, error)

type UnsafeRaftAdminServer 

type UnsafeRaftAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeRaftAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RaftAdminServer will result in compilation errors.

type VerifyLeaderRequest 

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

func (*VerifyLeaderRequest) Descriptor deprecated 

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

Deprecated: Use VerifyLeaderRequest.ProtoReflect.Descriptor instead.

func (*VerifyLeaderRequest) MarshalToSizedBufferVT 

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

func (*VerifyLeaderRequest) MarshalToVT 

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

func (*VerifyLeaderRequest) MarshalVT 

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

func (*VerifyLeaderRequest) ProtoMessage 

func (*VerifyLeaderRequest) ProtoMessage()

func (*VerifyLeaderRequest) ProtoReflect 

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

func (*VerifyLeaderRequest) Reset 

func (x *VerifyLeaderRequest) Reset()

func (*VerifyLeaderRequest) SizeVT 

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

func (*VerifyLeaderRequest) String 

func (x *VerifyLeaderRequest) String() string

func (*VerifyLeaderRequest) UnmarshalVT 

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