Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proto

package

Go to main page

Versions in this module

v1

v1.2.1

Aug 24, 2023

v1.2.0

Sep 9, 2020

v1.1.1

Sep 8, 2020

v1.1.0

Sep 8, 2020

v1.0.0

Sep 7, 2020

Changes in this version

+ var File_raftadmin_proto protoreflect.FileDescriptor

+ var GetConfigurationResponse_Server_Suffrage_name = map[int32]string

+ var GetConfigurationResponse_Server_Suffrage_value = map[string]int32

+ var StateResponse_State_name = map[int32]string

+ var StateResponse_State_value = map[string]int32

+ func RegisterRaftAdminServer(s *grpc.Server, srv RaftAdminServer)

+ type AddNonvoterRequest struct

+ Address string

+ Id string

+ PreviousIndex uint64

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

+ func (*AddNonvoterRequest) ProtoMessage()

+ func (x *AddNonvoterRequest) GetAddress() string

+ func (x *AddNonvoterRequest) GetId() string

+ func (x *AddNonvoterRequest) GetPreviousIndex() uint64

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

+ func (x *AddNonvoterRequest) Reset()

+ func (x *AddNonvoterRequest) String() string

+ type AddVoterRequest struct

+ Address string

+ Id string

+ PreviousIndex uint64

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

+ func (*AddVoterRequest) ProtoMessage()

+ func (x *AddVoterRequest) GetAddress() string

+ func (x *AddVoterRequest) GetId() string

+ func (x *AddVoterRequest) GetPreviousIndex() uint64

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

+ func (x *AddVoterRequest) Reset()

+ func (x *AddVoterRequest) String() string

+ type AppliedIndexRequest struct

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

+ func (*AppliedIndexRequest) ProtoMessage()

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

+ func (x *AppliedIndexRequest) Reset()

+ func (x *AppliedIndexRequest) String() string

+ type AppliedIndexResponse struct

+ Index uint64

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

+ func (*AppliedIndexResponse) ProtoMessage()

+ func (x *AppliedIndexResponse) GetIndex() uint64

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

+ func (x *AppliedIndexResponse) Reset()

+ func (x *AppliedIndexResponse) String() string

+ type ApplyLogRequest struct

+ Data []byte

+ Extensions []byte

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

+ func (*ApplyLogRequest) ProtoMessage()

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

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

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

+ func (x *ApplyLogRequest) Reset()

+ func (x *ApplyLogRequest) String() string

+ type AwaitResponse struct

+ Error string

+ Index uint64

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

+ func (*AwaitResponse) ProtoMessage()

+ func (x *AwaitResponse) GetError() string

+ func (x *AwaitResponse) GetIndex() uint64

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

+ func (x *AwaitResponse) Reset()

+ func (x *AwaitResponse) String() string

+ type BarrierRequest struct

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

+ func (*BarrierRequest) ProtoMessage()

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

+ func (x *BarrierRequest) Reset()

+ func (x *BarrierRequest) String() string

+ type DemoteVoterRequest struct

+ Id string

+ PreviousIndex uint64

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

+ func (*DemoteVoterRequest) ProtoMessage()

+ func (x *DemoteVoterRequest) GetId() string

+ func (x *DemoteVoterRequest) GetPreviousIndex() uint64

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

+ func (x *DemoteVoterRequest) Reset()

+ func (x *DemoteVoterRequest) String() string

+ type ForgetResponse struct

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

+ func (*ForgetResponse) ProtoMessage()

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

+ func (x *ForgetResponse) Reset()

+ func (x *ForgetResponse) String() string

+ type Future struct

+ OperationToken string

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

+ func (*Future) ProtoMessage()

+ func (x *Future) GetOperationToken() string

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

+ func (x *Future) Reset()

+ func (x *Future) String() string

+ type GetConfigurationRequest struct

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

+ func (*GetConfigurationRequest) ProtoMessage()

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

+ func (x *GetConfigurationRequest) Reset()

+ func (x *GetConfigurationRequest) String() string

+ type GetConfigurationResponse struct

+ Servers []*GetConfigurationResponse_Server

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

+ func (*GetConfigurationResponse) ProtoMessage()

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

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

+ func (x *GetConfigurationResponse) Reset()

+ func (x *GetConfigurationResponse) String() string

+ type GetConfigurationResponse_Server struct

+ Address string

+ Id string

+ Suffrage GetConfigurationResponse_Server_Suffrage

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

+ func (*GetConfigurationResponse_Server) ProtoMessage()

+ func (x *GetConfigurationResponse_Server) GetAddress() string

+ func (x *GetConfigurationResponse_Server) GetId() string

+ func (x *GetConfigurationResponse_Server) GetSuffrage() GetConfigurationResponse_Server_Suffrage

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

+ func (x *GetConfigurationResponse_Server) Reset()

+ func (x *GetConfigurationResponse_Server) String() string

+ type GetConfigurationResponse_Server_Suffrage int32

+ const GetConfigurationResponse_Server_NONVOTER

+ const GetConfigurationResponse_Server_STAGING

+ const GetConfigurationResponse_Server_VOTER

+ func (GetConfigurationResponse_Server_Suffrage) Descriptor() protoreflect.EnumDescriptor

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

+ func (GetConfigurationResponse_Server_Suffrage) Type() protoreflect.EnumType

+ func (x GetConfigurationResponse_Server_Suffrage) Enum() *GetConfigurationResponse_Server_Suffrage

+ func (x GetConfigurationResponse_Server_Suffrage) Number() protoreflect.EnumNumber

+ func (x GetConfigurationResponse_Server_Suffrage) String() string

+ type LastContactRequest struct

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

+ func (*LastContactRequest) ProtoMessage()

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

+ func (x *LastContactRequest) Reset()

+ func (x *LastContactRequest) String() string

+ type LastContactResponse struct

+ UnixNano int64

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

+ func (*LastContactResponse) ProtoMessage()

+ func (x *LastContactResponse) GetUnixNano() int64

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

+ func (x *LastContactResponse) Reset()

+ func (x *LastContactResponse) String() string

+ type LastIndexRequest struct

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

+ func (*LastIndexRequest) ProtoMessage()

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

+ func (x *LastIndexRequest) Reset()

+ func (x *LastIndexRequest) String() string

+ type LastIndexResponse struct

+ Index uint64

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

+ func (*LastIndexResponse) ProtoMessage()

+ func (x *LastIndexResponse) GetIndex() uint64

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

+ func (x *LastIndexResponse) Reset()

+ func (x *LastIndexResponse) String() string

+ type LeaderRequest struct

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

+ func (*LeaderRequest) ProtoMessage()

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

+ func (x *LeaderRequest) Reset()

+ func (x *LeaderRequest) String() string

+ type LeaderResponse struct

+ Address string

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

+ func (*LeaderResponse) ProtoMessage()

+ func (x *LeaderResponse) GetAddress() string

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

+ func (x *LeaderResponse) Reset()

+ func (x *LeaderResponse) String() string

+ type LeadershipTransferRequest struct

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

+ func (*LeadershipTransferRequest) ProtoMessage()

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

+ func (x *LeadershipTransferRequest) Reset()

+ func (x *LeadershipTransferRequest) String() string

+ type LeadershipTransferToServerRequest struct

+ Address string

+ Id string

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

+ func (*LeadershipTransferToServerRequest) ProtoMessage()

+ func (x *LeadershipTransferToServerRequest) GetAddress() string

+ func (x *LeadershipTransferToServerRequest) GetId() string

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

+ func (x *LeadershipTransferToServerRequest) Reset()

+ func (x *LeadershipTransferToServerRequest) String() string

+ type RaftAdminClient interface

+ AddNonvoter func(ctx context.Context, in *AddNonvoterRequest, opts ...grpc.CallOption) (*Future, error)

+ AddVoter func(ctx context.Context, in *AddVoterRequest, opts ...grpc.CallOption) (*Future, error)

+ AppliedIndex func(ctx context.Context, in *AppliedIndexRequest, opts ...grpc.CallOption) (*AppliedIndexResponse, error)

+ ApplyLog func(ctx context.Context, in *ApplyLogRequest, opts ...grpc.CallOption) (*Future, error)

+ Await func(ctx context.Context, in *Future, opts ...grpc.CallOption) (*AwaitResponse, error)

+ Barrier func(ctx context.Context, in *BarrierRequest, opts ...grpc.CallOption) (*Future, error)

+ DemoteVoter func(ctx context.Context, in *DemoteVoterRequest, opts ...grpc.CallOption) (*Future, error)

+ Forget func(ctx context.Context, in *Future, opts ...grpc.CallOption) (*ForgetResponse, error)

+ GetConfiguration func(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)

+ LastContact func(ctx context.Context, in *LastContactRequest, opts ...grpc.CallOption) (*LastContactResponse, error)

+ LastIndex func(ctx context.Context, in *LastIndexRequest, opts ...grpc.CallOption) (*LastIndexResponse, error)

+ Leader func(ctx context.Context, in *LeaderRequest, opts ...grpc.CallOption) (*LeaderResponse, error)

+ LeadershipTransfer func(ctx context.Context, in *LeadershipTransferRequest, opts ...grpc.CallOption) (*Future, error)

+ LeadershipTransferToServer func(ctx context.Context, in *LeadershipTransferToServerRequest, ...) (*Future, error)

+ RemoveServer func(ctx context.Context, in *RemoveServerRequest, opts ...grpc.CallOption) (*Future, error)

+ Shutdown func(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*Future, error)

+ Snapshot func(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*Future, error)

+ State func(ctx context.Context, in *StateRequest, opts ...grpc.CallOption) (*StateResponse, error)

+ Stats func(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error)

+ VerifyLeader func(ctx context.Context, in *VerifyLeaderRequest, opts ...grpc.CallOption) (*Future, error)

+ func NewRaftAdminClient(cc grpc.ClientConnInterface) RaftAdminClient

+ type RaftAdminServer interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type RemoveServerRequest struct

+ Id string

+ PreviousIndex uint64

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

+ func (*RemoveServerRequest) ProtoMessage()

+ func (x *RemoveServerRequest) GetId() string

+ func (x *RemoveServerRequest) GetPreviousIndex() uint64

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

+ func (x *RemoveServerRequest) Reset()

+ func (x *RemoveServerRequest) String() string

+ type ShutdownRequest struct

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

+ func (*ShutdownRequest) ProtoMessage()

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

+ func (x *ShutdownRequest) Reset()

+ func (x *ShutdownRequest) String() string

+ type SnapshotRequest struct

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

+ func (*SnapshotRequest) ProtoMessage()

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

+ func (x *SnapshotRequest) Reset()

+ func (x *SnapshotRequest) String() string

+ type StateRequest struct

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

+ func (*StateRequest) ProtoMessage()

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

+ func (x *StateRequest) Reset()

+ func (x *StateRequest) String() string

+ type StateResponse struct

+ State StateResponse_State

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

+ func (*StateResponse) ProtoMessage()

+ func (x *StateResponse) GetState() StateResponse_State

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

+ func (x *StateResponse) Reset()

+ func (x *StateResponse) String() string

+ type StateResponse_State int32

+ const StateResponse_CANDIDATE

+ const StateResponse_FOLLOWER

+ const StateResponse_LEADER

+ const StateResponse_SHUTDOWN

+ func (StateResponse_State) Descriptor() protoreflect.EnumDescriptor

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

+ func (StateResponse_State) Type() protoreflect.EnumType

+ func (x StateResponse_State) Enum() *StateResponse_State

+ func (x StateResponse_State) Number() protoreflect.EnumNumber

+ func (x StateResponse_State) String() string

+ type StatsRequest struct

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

+ func (*StatsRequest) ProtoMessage()

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

+ func (x *StatsRequest) Reset()

+ func (x *StatsRequest) String() string

+ type StatsResponse struct

+ Stats map[string]string

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

+ func (*StatsResponse) ProtoMessage()

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

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

+ func (x *StatsResponse) Reset()

+ func (x *StatsResponse) String() string

+ type UnimplementedRaftAdminServer struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type VerifyLeaderRequest struct

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

+ func (*VerifyLeaderRequest) ProtoMessage()

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

+ func (x *VerifyLeaderRequest) Reset()

+ func (x *VerifyLeaderRequest) String() string