__

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2022 License: BSD-2-Clause Imports: 8 Imported by: 0

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

Functions

func RegisterRaftAdminWqServer 

func RegisterRaftAdminWqServer(s *grpc.Server, srv RaftAdminWqServer)

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

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetServers 

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

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 

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

func (x *GetConfigurationResponse_Server) String() 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) 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 GetLogByIdxRequest 

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

func (*GetLogByIdxRequest) Descriptor deprecated 

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

Deprecated: Use GetLogByIdxRequest.ProtoReflect.Descriptor instead.

func (*GetLogByIdxRequest) GetIndex 

func (x *GetLogByIdxRequest) GetIndex() uint64

func (*GetLogByIdxRequest) ProtoMessage 

func (*GetLogByIdxRequest) ProtoMessage()

func (*GetLogByIdxRequest) ProtoReflect 

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

func (*GetLogByIdxRequest) Reset 

func (x *GetLogByIdxRequest) Reset()

func (*GetLogByIdxRequest) String 

func (x *GetLogByIdxRequest) String() string

type GetLogByIdxResponse 

type GetLogByIdxResponse 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 (*GetLogByIdxResponse) Descriptor deprecated 

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

Deprecated: Use GetLogByIdxResponse.ProtoReflect.Descriptor instead.

func (*GetLogByIdxResponse) GetData 

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

func (*GetLogByIdxResponse) GetExtensions 

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

func (*GetLogByIdxResponse) ProtoMessage 

func (*GetLogByIdxResponse) ProtoMessage()

func (*GetLogByIdxResponse) ProtoReflect 

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

func (*GetLogByIdxResponse) Reset 

func (x *GetLogByIdxResponse) Reset()

func (*GetLogByIdxResponse) String 

func (x *GetLogByIdxResponse) String() string

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) 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"`
	Index     uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Extension []byte `protobuf:"bytes,4,opt,name=extension,proto3" json:"extension,omitempty"`
	// contains filtered or unexported fields
}

func (*LastContactResponse) Descriptor deprecated 

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

Deprecated: Use LastContactResponse.ProtoReflect.Descriptor instead.

func (*LastContactResponse) GetData 

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

func (*LastContactResponse) GetExtension 

func (x *LastContactResponse) GetExtension() []byte

func (*LastContactResponse) GetIndex 

func (x *LastContactResponse) GetIndex() uint64

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 LastContentRequest 

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

func (*LastContentRequest) Descriptor deprecated 

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

Deprecated: Use LastContentRequest.ProtoReflect.Descriptor instead.

func (*LastContentRequest) ProtoMessage 

func (*LastContentRequest) ProtoMessage()

func (*LastContentRequest) ProtoReflect 

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

func (*LastContentRequest) Reset 

func (x *LastContentRequest) Reset()

func (*LastContentRequest) String 

func (x *LastContentRequest) String() string

type LastContentResponse 

type LastContentResponse 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"`
	Lastindex  uint64 `protobuf:"varint,3,opt,name=lastindex,proto3" json:"lastindex,omitempty"`
	// contains filtered or unexported fields
}

func (*LastContentResponse) Descriptor deprecated 

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

Deprecated: Use LastContentResponse.ProtoReflect.Descriptor instead.

func (*LastContentResponse) GetData 

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

func (*LastContentResponse) GetExtensions 

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

func (*LastContentResponse) GetLastindex 

func (x *LastContentResponse) GetLastindex() uint64

func (*LastContentResponse) ProtoMessage 

func (*LastContentResponse) ProtoMessage()

func (*LastContentResponse) ProtoReflect 

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

func (*LastContentResponse) Reset 

func (x *LastContentResponse) Reset()

func (*LastContentResponse) String 

func (x *LastContentResponse) String() string

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

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 

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 

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 

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

Deprecated: Use LeadershipTransferRequest.ProtoReflect.Descriptor instead.

func (*LeadershipTransferRequest) ProtoMessage 

func (*LeadershipTransferRequest) ProtoMessage()

func (*LeadershipTransferRequest) ProtoReflect 

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

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 

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

func (*LeadershipTransferToServerRequest) ProtoMessage()

func (*LeadershipTransferToServerRequest) ProtoReflect 

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

func (*LeadershipTransferToServerRequest) Reset 

func (x *LeadershipTransferToServerRequest) Reset()

func (*LeadershipTransferToServerRequest) String 

func (x *LeadershipTransferToServerRequest) String() string

type RaftAdminWqClient 

type RaftAdminWqClient 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)
	GetLogByIdx(ctx context.Context, in *GetLogByIdxRequest, opts ...grpc.CallOption) (*GetLogByIdxResponse, 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)
	GetLastContent(ctx context.Context, in *LastContentRequest, opts ...grpc.CallOption) (*LastContentResponse, error)
}

RaftAdminWqClient is the client API for RaftAdminWq service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRaftAdminWqClient 

func NewRaftAdminWqClient(cc grpc.ClientConnInterface) RaftAdminWqClient

type RaftAdminWqServer 

type RaftAdminWqServer 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)
	GetLogByIdx(context.Context, *GetLogByIdxRequest) (*GetLogByIdxResponse, 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)
	GetLastContent(context.Context, *LastContentRequest) (*LastContentResponse, error)
}

RaftAdminWqServer is the server API for RaftAdminWq 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 

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 

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 

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 

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 

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

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 UnimplementedRaftAdminWqServer 

type UnimplementedRaftAdminWqServer struct {
}

UnimplementedRaftAdminWqServer can be embedded to have forward compatible implementations.

func (*UnimplementedRaftAdminWqServer) AddNonvoter 

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

func (*UnimplementedRaftAdminWqServer) AddVoter 

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

func (*UnimplementedRaftAdminWqServer) AppliedIndex 

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

func (*UnimplementedRaftAdminWqServer) ApplyLog 

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

func (*UnimplementedRaftAdminWqServer) Await 

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

func (*UnimplementedRaftAdminWqServer) Barrier 

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

func (*UnimplementedRaftAdminWqServer) DemoteVoter 

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

func (*UnimplementedRaftAdminWqServer) Forget 

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

func (*UnimplementedRaftAdminWqServer) GetConfiguration 

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

func (*UnimplementedRaftAdminWqServer) GetLastContent 

func (*UnimplementedRaftAdminWqServer) GetLastContent(context.Context, *LastContentRequest) (*LastContentResponse, error)

func (*UnimplementedRaftAdminWqServer) GetLogByIdx 

func (*UnimplementedRaftAdminWqServer) GetLogByIdx(context.Context, *GetLogByIdxRequest) (*GetLogByIdxResponse, error)

func (*UnimplementedRaftAdminWqServer) LastContact 

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

func (*UnimplementedRaftAdminWqServer) LastIndex 

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

func (*UnimplementedRaftAdminWqServer) Leader 

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

func (*UnimplementedRaftAdminWqServer) LeadershipTransfer 

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

func (*UnimplementedRaftAdminWqServer) LeadershipTransferToServer 

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

func (*UnimplementedRaftAdminWqServer) RemoveServer 

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

func (*UnimplementedRaftAdminWqServer) Shutdown 

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

func (*UnimplementedRaftAdminWqServer) Snapshot 

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

func (*UnimplementedRaftAdminWqServer) State 

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

func (*UnimplementedRaftAdminWqServer) Stats 

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

func (*UnimplementedRaftAdminWqServer) VerifyLeader 

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

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

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.