proto

package
Version: v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2020 License: BSD-2-Clause Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

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 File_raftadmin_proto protoreflect.FileDescriptor

Functions

func RegisterRaftAdminServer

func RegisterRaftAdminServer(s *grpc.Server, 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

This method has been 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) ProtoMessage

func (*AddNonvoterRequest) ProtoMessage()

func (*AddNonvoterRequest) ProtoReflect

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

func (*AddNonvoterRequest) Reset

func (x *AddNonvoterRequest) Reset()

func (*AddNonvoterRequest) String

func (x *AddNonvoterRequest) String() string

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

This method has been 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) ProtoMessage

func (*AddVoterRequest) ProtoMessage()

func (*AddVoterRequest) ProtoReflect

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

func (*AddVoterRequest) Reset

func (x *AddVoterRequest) Reset()

func (*AddVoterRequest) String

func (x *AddVoterRequest) String() string

type AppliedIndexRequest

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

func (*AppliedIndexRequest) Descriptor deprecated

This method has been deprecated.
func (*AppliedIndexRequest) Descriptor() ([]byte, []int)

Deprecated: Use AppliedIndexRequest.ProtoReflect.Descriptor instead.

func (*AppliedIndexRequest) ProtoMessage

func (*AppliedIndexRequest) ProtoMessage()

func (*AppliedIndexRequest) ProtoReflect

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

func (*AppliedIndexRequest) Reset

func (x *AppliedIndexRequest) Reset()

func (*AppliedIndexRequest) String

func (x *AppliedIndexRequest) String() string

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

This method has been deprecated.
func (*AppliedIndexResponse) Descriptor() ([]byte, []int)

Deprecated: Use AppliedIndexResponse.ProtoReflect.Descriptor instead.

func (*AppliedIndexResponse) GetIndex

func (x *AppliedIndexResponse) GetIndex() uint64

func (*AppliedIndexResponse) ProtoMessage

func (*AppliedIndexResponse) ProtoMessage()

func (*AppliedIndexResponse) ProtoReflect

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

func (*AppliedIndexResponse) Reset

func (x *AppliedIndexResponse) Reset()

func (*AppliedIndexResponse) String

func (x *AppliedIndexResponse) String() string

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

This method has been 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) ProtoMessage

func (*ApplyLogRequest) ProtoMessage()

func (*ApplyLogRequest) ProtoReflect

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

func (*ApplyLogRequest) Reset

func (x *ApplyLogRequest) Reset()

func (*ApplyLogRequest) String

func (x *ApplyLogRequest) String() string

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

This method has been 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) ProtoMessage

func (*AwaitResponse) ProtoMessage()

func (*AwaitResponse) ProtoReflect

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

func (*AwaitResponse) Reset

func (x *AwaitResponse) Reset()

func (*AwaitResponse) String

func (x *AwaitResponse) String() string

type BarrierRequest

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

func (*BarrierRequest) Descriptor deprecated

This method has been deprecated.
func (*BarrierRequest) Descriptor() ([]byte, []int)

Deprecated: Use BarrierRequest.ProtoReflect.Descriptor instead.

func (*BarrierRequest) ProtoMessage

func (*BarrierRequest) ProtoMessage()

func (*BarrierRequest) ProtoReflect

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

func (*BarrierRequest) Reset

func (x *BarrierRequest) Reset()

func (*BarrierRequest) String

func (x *BarrierRequest) String() string

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

This method has been 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) ProtoMessage

func (*DemoteVoterRequest) ProtoMessage()

func (*DemoteVoterRequest) ProtoReflect

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

func (*DemoteVoterRequest) Reset

func (x *DemoteVoterRequest) Reset()

func (*DemoteVoterRequest) String

func (x *DemoteVoterRequest) String() string

type ForgetResponse

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

func (*ForgetResponse) Descriptor deprecated

This method has been deprecated.
func (*ForgetResponse) Descriptor() ([]byte, []int)

Deprecated: Use ForgetResponse.ProtoReflect.Descriptor instead.

func (*ForgetResponse) ProtoMessage

func (*ForgetResponse) ProtoMessage()

func (*ForgetResponse) ProtoReflect

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

func (*ForgetResponse) Reset

func (x *ForgetResponse) Reset()

func (*ForgetResponse) String

func (x *ForgetResponse) String() string

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

This method has been deprecated.
func (*Future) Descriptor() ([]byte, []int)

Deprecated: Use Future.ProtoReflect.Descriptor instead.

func (*Future) GetOperationToken

func (x *Future) GetOperationToken() string

func (*Future) ProtoMessage

func (*Future) ProtoMessage()

func (*Future) ProtoReflect

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

func (*Future) Reset

func (x *Future) Reset()

func (*Future) String

func (x *Future) String() string

type GetConfigurationRequest

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

func (*GetConfigurationRequest) Descriptor deprecated

This method has been deprecated.
func (*GetConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) ProtoMessage

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect

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

func (*GetConfigurationRequest) Reset

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String

func (x *GetConfigurationRequest) String() string

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

This method has been deprecated.
func (*GetConfigurationResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetServers

func (*GetConfigurationResponse) ProtoMessage

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect

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

func (*GetConfigurationResponse) Reset

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String

func (x *GetConfigurationResponse) String() string

type GetConfigurationResponse_Server

type GetConfigurationResponse_Server struct {
	Suffrage GetConfigurationResponse_Server_Suffrage `protobuf:"varint,1,opt,name=suffrage,proto3,enum=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

This method has been 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 (*GetConfigurationResponse_Server) GetSuffrage

func (*GetConfigurationResponse_Server) ProtoMessage

func (*GetConfigurationResponse_Server) ProtoMessage()

func (*GetConfigurationResponse_Server) ProtoReflect

func (*GetConfigurationResponse_Server) Reset

func (*GetConfigurationResponse_Server) String

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) Enum

func (GetConfigurationResponse_Server_Suffrage) EnumDescriptor deprecated

This method has been deprecated.
func (GetConfigurationResponse_Server_Suffrage) EnumDescriptor() ([]byte, []int)

Deprecated: Use GetConfigurationResponse_Server_Suffrage.Descriptor instead.

func (GetConfigurationResponse_Server_Suffrage) Number

func (GetConfigurationResponse_Server_Suffrage) String

func (GetConfigurationResponse_Server_Suffrage) Type

type LastContactRequest

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

func (*LastContactRequest) Descriptor deprecated

This method has been deprecated.
func (*LastContactRequest) Descriptor() ([]byte, []int)

Deprecated: Use LastContactRequest.ProtoReflect.Descriptor instead.

func (*LastContactRequest) ProtoMessage

func (*LastContactRequest) ProtoMessage()

func (*LastContactRequest) ProtoReflect

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

func (*LastContactRequest) Reset

func (x *LastContactRequest) Reset()

func (*LastContactRequest) String

func (x *LastContactRequest) String() string

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

This method has been deprecated.
func (*LastContactResponse) Descriptor() ([]byte, []int)

Deprecated: Use LastContactResponse.ProtoReflect.Descriptor instead.

func (*LastContactResponse) GetUnixNano

func (x *LastContactResponse) GetUnixNano() int64

func (*LastContactResponse) ProtoMessage

func (*LastContactResponse) ProtoMessage()

func (*LastContactResponse) ProtoReflect

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

func (*LastContactResponse) Reset

func (x *LastContactResponse) Reset()

func (*LastContactResponse) String

func (x *LastContactResponse) String() string

type LastIndexRequest

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

func (*LastIndexRequest) Descriptor deprecated

This method has been deprecated.
func (*LastIndexRequest) Descriptor() ([]byte, []int)

Deprecated: Use LastIndexRequest.ProtoReflect.Descriptor instead.

func (*LastIndexRequest) ProtoMessage

func (*LastIndexRequest) ProtoMessage()

func (*LastIndexRequest) ProtoReflect

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

func (*LastIndexRequest) Reset

func (x *LastIndexRequest) Reset()

func (*LastIndexRequest) String

func (x *LastIndexRequest) String() string

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

This method has been deprecated.
func (*LastIndexResponse) Descriptor() ([]byte, []int)

Deprecated: Use LastIndexResponse.ProtoReflect.Descriptor instead.

func (*LastIndexResponse) GetIndex

func (x *LastIndexResponse) GetIndex() uint64

func (*LastIndexResponse) ProtoMessage

func (*LastIndexResponse) ProtoMessage()

func (*LastIndexResponse) ProtoReflect

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

func (*LastIndexResponse) Reset

func (x *LastIndexResponse) Reset()

func (*LastIndexResponse) String

func (x *LastIndexResponse) String() string

type LeaderRequest

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

func (*LeaderRequest) Descriptor deprecated

This method has been deprecated.
func (*LeaderRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeaderRequest.ProtoReflect.Descriptor instead.

func (*LeaderRequest) ProtoMessage

func (*LeaderRequest) ProtoMessage()

func (*LeaderRequest) ProtoReflect

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

func (*LeaderRequest) Reset

func (x *LeaderRequest) Reset()

func (*LeaderRequest) String

func (x *LeaderRequest) String() string

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

This method has been deprecated.
func (*LeaderResponse) Descriptor() ([]byte, []int)

Deprecated: Use LeaderResponse.ProtoReflect.Descriptor instead.

func (*LeaderResponse) GetAddress

func (x *LeaderResponse) GetAddress() string

func (*LeaderResponse) ProtoMessage

func (*LeaderResponse) ProtoMessage()

func (*LeaderResponse) ProtoReflect

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

func (*LeaderResponse) Reset

func (x *LeaderResponse) Reset()

func (*LeaderResponse) String

func (x *LeaderResponse) String() string

type LeadershipTransferRequest

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

func (*LeadershipTransferRequest) Descriptor deprecated

This method has been deprecated.
func (*LeadershipTransferRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeadershipTransferRequest.ProtoReflect.Descriptor instead.

func (*LeadershipTransferRequest) ProtoMessage

func (*LeadershipTransferRequest) ProtoMessage()

func (*LeadershipTransferRequest) ProtoReflect

func (*LeadershipTransferRequest) Reset

func (x *LeadershipTransferRequest) Reset()

func (*LeadershipTransferRequest) String

func (x *LeadershipTransferRequest) String() string

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

This method has been deprecated.
func (*LeadershipTransferToServerRequest) Descriptor() ([]byte, []int)

Deprecated: Use LeadershipTransferToServerRequest.ProtoReflect.Descriptor instead.

func (*LeadershipTransferToServerRequest) GetAddress

func (x *LeadershipTransferToServerRequest) GetAddress() string

func (*LeadershipTransferToServerRequest) GetId

func (*LeadershipTransferToServerRequest) ProtoMessage

func (*LeadershipTransferToServerRequest) ProtoMessage()

func (*LeadershipTransferToServerRequest) ProtoReflect

func (*LeadershipTransferToServerRequest) Reset

func (*LeadershipTransferToServerRequest) String

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRaftAdminClient

func NewRaftAdminClient(cc grpc.ClientConnInterface) RaftAdminClient

type RaftAdminServer

RaftAdminServer is the server API for RaftAdmin service.

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

This method has been 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) ProtoMessage

func (*RemoveServerRequest) ProtoMessage()

func (*RemoveServerRequest) ProtoReflect

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

func (*RemoveServerRequest) Reset

func (x *RemoveServerRequest) Reset()

func (*RemoveServerRequest) String

func (x *RemoveServerRequest) String() string

type ShutdownRequest

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

func (*ShutdownRequest) Descriptor deprecated

This method has been deprecated.
func (*ShutdownRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect

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

func (*ShutdownRequest) Reset

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String

func (x *ShutdownRequest) String() string

type SnapshotRequest

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

func (*SnapshotRequest) Descriptor deprecated

This method has been deprecated.
func (*SnapshotRequest) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRequest) ProtoMessage

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) ProtoReflect

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

func (*SnapshotRequest) Reset

func (x *SnapshotRequest) Reset()

func (*SnapshotRequest) String

func (x *SnapshotRequest) String() string

type StateRequest

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

func (*StateRequest) Descriptor deprecated

This method has been deprecated.
func (*StateRequest) Descriptor() ([]byte, []int)

Deprecated: Use StateRequest.ProtoReflect.Descriptor instead.

func (*StateRequest) ProtoMessage

func (*StateRequest) ProtoMessage()

func (*StateRequest) ProtoReflect

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

func (*StateRequest) Reset

func (x *StateRequest) Reset()

func (*StateRequest) String

func (x *StateRequest) String() string

type StateResponse

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

func (*StateResponse) Descriptor deprecated

This method has been deprecated.
func (*StateResponse) Descriptor() ([]byte, []int)

Deprecated: Use StateResponse.ProtoReflect.Descriptor instead.

func (*StateResponse) GetState

func (x *StateResponse) GetState() StateResponse_State

func (*StateResponse) ProtoMessage

func (*StateResponse) ProtoMessage()

func (*StateResponse) ProtoReflect

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

func (*StateResponse) Reset

func (x *StateResponse) Reset()

func (*StateResponse) String

func (x *StateResponse) String() string

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) Enum

func (StateResponse_State) EnumDescriptor deprecated

This method has been deprecated.
func (StateResponse_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use StateResponse_State.Descriptor instead.

func (StateResponse_State) Number

func (StateResponse_State) String

func (x StateResponse_State) String() string

func (StateResponse_State) Type

type StatsRequest

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

func (*StatsRequest) Descriptor deprecated

This method has been deprecated.
func (*StatsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) ProtoMessage

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect

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

func (*StatsRequest) Reset

func (x *StatsRequest) Reset()

func (*StatsRequest) String

func (x *StatsRequest) String() string

type StatsResponse

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

func (*StatsResponse) Descriptor deprecated

This method has been deprecated.
func (*StatsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetStats

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

func (*StatsResponse) ProtoMessage

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect

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

func (*StatsResponse) Reset

func (x *StatsResponse) Reset()

func (*StatsResponse) String

func (x *StatsResponse) String() string

type UnimplementedRaftAdminServer

type UnimplementedRaftAdminServer struct {
}

UnimplementedRaftAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedRaftAdminServer) AddNonvoter

func (*UnimplementedRaftAdminServer) AddVoter

func (*UnimplementedRaftAdminServer) AppliedIndex

func (*UnimplementedRaftAdminServer) ApplyLog

func (*UnimplementedRaftAdminServer) Await

func (*UnimplementedRaftAdminServer) Barrier

func (*UnimplementedRaftAdminServer) DemoteVoter

func (*UnimplementedRaftAdminServer) Forget

func (*UnimplementedRaftAdminServer) GetConfiguration

func (*UnimplementedRaftAdminServer) LastContact

func (*UnimplementedRaftAdminServer) LastIndex

func (*UnimplementedRaftAdminServer) Leader

func (*UnimplementedRaftAdminServer) LeadershipTransfer

func (*UnimplementedRaftAdminServer) LeadershipTransferToServer

func (*UnimplementedRaftAdminServer) RemoveServer

func (*UnimplementedRaftAdminServer) Shutdown

func (*UnimplementedRaftAdminServer) Snapshot

func (*UnimplementedRaftAdminServer) State

func (*UnimplementedRaftAdminServer) Stats

func (*UnimplementedRaftAdminServer) VerifyLeader

type VerifyLeaderRequest

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

func (*VerifyLeaderRequest) Descriptor deprecated

This method has been deprecated.
func (*VerifyLeaderRequest) Descriptor() ([]byte, []int)

Deprecated: Use VerifyLeaderRequest.ProtoReflect.Descriptor instead.

func (*VerifyLeaderRequest) ProtoMessage

func (*VerifyLeaderRequest) ProtoMessage()

func (*VerifyLeaderRequest) ProtoReflect

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

func (*VerifyLeaderRequest) Reset

func (x *VerifyLeaderRequest) Reset()

func (*VerifyLeaderRequest) String

func (x *VerifyLeaderRequest) String() string

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL