election

package

Go to main page

Versions in this module

v0

v0.8.0

Nov 21, 2021

Changes in this version

type EnterResponse

+ CandidateID uint64

+ func (m *EnterResponse) GetCandidateID() uint64

v0.7.0

Nov 19, 2021

Changes in this version

+ var ErrIntOverflowManager = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthManager = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group")

+ func RegisterLeaderElectionManagerServer(s *grpc.Server, srv LeaderElectionManagerServer)

+ type LeaderElectionManagerClient interface

+ CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)

+ OpenSession func(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)

+ func NewLeaderElectionManagerClient(cc *grpc.ClientConn) LeaderElectionManagerClient

+ type LeaderElectionManagerServer interface

+ CloseSession func(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)

+ OpenSession func(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)

+ type UnimplementedLeaderElectionManagerServer struct

+ func (*UnimplementedLeaderElectionManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

+ func (*UnimplementedLeaderElectionManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)

v0.6.1

Nov 13, 2021

v0.6.0

Nov 3, 2021

v0.5.0

Nov 2, 2021

Changes in this version

+ var ErrIntOverflowPrimitive = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowSession = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPrimitive = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthSession = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupSession = fmt.Errorf("proto: unexpected end of group")

+ var Event_Type_name = map[int32]string

+ var Event_Type_value = map[string]int32

+ func RegisterLeaderElectionServer(s *grpc.Server, srv LeaderElectionServer)

+ func RegisterLeaderElectionSessionServer(s *grpc.Server, srv LeaderElectionSessionServer)

+ type AnointRequest struct

+ CandidateID string

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

+ func (*AnointRequest) ProtoMessage()

+ func (m *AnointRequest) GetCandidateID() string

+ func (m *AnointRequest) Marshal() (dAtA []byte, err error)

+ func (m *AnointRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AnointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AnointRequest) Reset()

+ func (m *AnointRequest) Size() (n int)

+ func (m *AnointRequest) String() string

+ func (m *AnointRequest) Unmarshal(dAtA []byte) error

+ func (m *AnointRequest) XXX_DiscardUnknown()

+ func (m *AnointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AnointRequest) XXX_Merge(src proto.Message)

+ func (m *AnointRequest) XXX_Size() int

+ func (m *AnointRequest) XXX_Unmarshal(b []byte) error

+ type AnointResponse struct

+ Term Term

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

+ func (*AnointResponse) ProtoMessage()

+ func (m *AnointResponse) GetTerm() Term

+ func (m *AnointResponse) Marshal() (dAtA []byte, err error)

+ func (m *AnointResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AnointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AnointResponse) Reset()

+ func (m *AnointResponse) Size() (n int)

+ func (m *AnointResponse) String() string

+ func (m *AnointResponse) Unmarshal(dAtA []byte) error

+ func (m *AnointResponse) XXX_DiscardUnknown()

+ func (m *AnointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AnointResponse) XXX_Merge(src proto.Message)

+ func (m *AnointResponse) XXX_Size() int

+ func (m *AnointResponse) XXX_Unmarshal(b []byte) error

+ type CloseSessionRequest struct

+ SessionID github_com_atomix_atomix_api_go_atomix_primitive.SessionID

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

+ func (*CloseSessionRequest) ProtoMessage()

+ func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive.SessionID

+ func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error)

+ func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseSessionRequest) Reset()

+ func (m *CloseSessionRequest) Size() (n int)

+ func (m *CloseSessionRequest) String() string

+ func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error

+ func (m *CloseSessionRequest) XXX_DiscardUnknown()

+ func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CloseSessionRequest) XXX_Merge(src proto.Message)

+ func (m *CloseSessionRequest) XXX_Size() int

+ func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error

+ type CloseSessionResponse struct

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

+ func (*CloseSessionResponse) ProtoMessage()

+ func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error)

+ func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseSessionResponse) Reset()

+ func (m *CloseSessionResponse) Size() (n int)

+ func (m *CloseSessionResponse) String() string

+ func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error

+ func (m *CloseSessionResponse) XXX_DiscardUnknown()

+ func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CloseSessionResponse) XXX_Merge(src proto.Message)

+ func (m *CloseSessionResponse) XXX_Size() int

+ func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error

+ type EnterRequest struct

+ CandidateID string

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

+ func (*EnterRequest) ProtoMessage()

+ func (m *EnterRequest) GetCandidateID() string

+ func (m *EnterRequest) Marshal() (dAtA []byte, err error)

+ func (m *EnterRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *EnterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EnterRequest) Reset()

+ func (m *EnterRequest) Size() (n int)

+ func (m *EnterRequest) String() string

+ func (m *EnterRequest) Unmarshal(dAtA []byte) error

+ func (m *EnterRequest) XXX_DiscardUnknown()

+ func (m *EnterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EnterRequest) XXX_Merge(src proto.Message)

+ func (m *EnterRequest) XXX_Size() int

+ func (m *EnterRequest) XXX_Unmarshal(b []byte) error

+ type EnterResponse struct

+ Term Term

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

+ func (*EnterResponse) ProtoMessage()

+ func (m *EnterResponse) GetTerm() Term

+ func (m *EnterResponse) Marshal() (dAtA []byte, err error)

+ func (m *EnterResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *EnterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EnterResponse) Reset()

+ func (m *EnterResponse) Size() (n int)

+ func (m *EnterResponse) String() string

+ func (m *EnterResponse) Unmarshal(dAtA []byte) error

+ func (m *EnterResponse) XXX_DiscardUnknown()

+ func (m *EnterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EnterResponse) XXX_Merge(src proto.Message)

+ func (m *EnterResponse) XXX_Size() int

+ func (m *EnterResponse) XXX_Unmarshal(b []byte) error

+ type Event struct

+ Term Term

+ Type Event_Type

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

+ func (*Event) ProtoMessage()

+ func (m *Event) GetTerm() Term

+ func (m *Event) GetType() Event_Type

+ func (m *Event) Marshal() (dAtA []byte, err error)

+ func (m *Event) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event) Reset()

+ func (m *Event) Size() (n int)

+ func (m *Event) String() string

+ func (m *Event) Unmarshal(dAtA []byte) error

+ func (m *Event) XXX_DiscardUnknown()

+ func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Event) XXX_Merge(src proto.Message)

+ func (m *Event) XXX_Size() int

+ func (m *Event) XXX_Unmarshal(b []byte) error

+ type Event_Type int32

+ const Event_CHANGED

+ const Event_NONE

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

+ func (x Event_Type) String() string

+ type EventsRequest struct

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

+ func (*EventsRequest) ProtoMessage()

+ func (m *EventsRequest) Marshal() (dAtA []byte, err error)

+ func (m *EventsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventsRequest) Reset()

+ func (m *EventsRequest) Size() (n int)

+ func (m *EventsRequest) String() string

+ func (m *EventsRequest) Unmarshal(dAtA []byte) error

+ func (m *EventsRequest) XXX_DiscardUnknown()

+ func (m *EventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventsRequest) XXX_Merge(src proto.Message)

+ func (m *EventsRequest) XXX_Size() int

+ func (m *EventsRequest) XXX_Unmarshal(b []byte) error

+ type EventsResponse struct

+ Event Event

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

+ func (*EventsResponse) ProtoMessage()

+ func (m *EventsResponse) GetEvent() Event

+ func (m *EventsResponse) Marshal() (dAtA []byte, err error)

+ func (m *EventsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventsResponse) Reset()

+ func (m *EventsResponse) Size() (n int)

+ func (m *EventsResponse) String() string

+ func (m *EventsResponse) Unmarshal(dAtA []byte) error

+ func (m *EventsResponse) XXX_DiscardUnknown()

+ func (m *EventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventsResponse) XXX_Merge(src proto.Message)

+ func (m *EventsResponse) XXX_Size() int

+ func (m *EventsResponse) XXX_Unmarshal(b []byte) error

+ type EvictRequest struct

+ CandidateID string

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

+ func (*EvictRequest) ProtoMessage()

+ func (m *EvictRequest) GetCandidateID() string

+ func (m *EvictRequest) Marshal() (dAtA []byte, err error)

+ func (m *EvictRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *EvictRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvictRequest) Reset()

+ func (m *EvictRequest) Size() (n int)

+ func (m *EvictRequest) String() string

+ func (m *EvictRequest) Unmarshal(dAtA []byte) error

+ func (m *EvictRequest) XXX_DiscardUnknown()

+ func (m *EvictRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EvictRequest) XXX_Merge(src proto.Message)

+ func (m *EvictRequest) XXX_Size() int

+ func (m *EvictRequest) XXX_Unmarshal(b []byte) error

+ type EvictResponse struct

+ Term Term

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

+ func (*EvictResponse) ProtoMessage()

+ func (m *EvictResponse) GetTerm() Term

+ func (m *EvictResponse) Marshal() (dAtA []byte, err error)

+ func (m *EvictResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *EvictResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EvictResponse) Reset()

+ func (m *EvictResponse) Size() (n int)

+ func (m *EvictResponse) String() string

+ func (m *EvictResponse) Unmarshal(dAtA []byte) error

+ func (m *EvictResponse) XXX_DiscardUnknown()

+ func (m *EvictResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EvictResponse) XXX_Merge(src proto.Message)

+ func (m *EvictResponse) XXX_Size() int

+ func (m *EvictResponse) XXX_Unmarshal(b []byte) error

+ type GetTermRequest struct

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

+ func (*GetTermRequest) ProtoMessage()

+ func (m *GetTermRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTermRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTermRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetTermRequest) Reset()

+ func (m *GetTermRequest) Size() (n int)

+ func (m *GetTermRequest) String() string

+ func (m *GetTermRequest) Unmarshal(dAtA []byte) error

+ func (m *GetTermRequest) XXX_DiscardUnknown()

+ func (m *GetTermRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTermRequest) XXX_Merge(src proto.Message)

+ func (m *GetTermRequest) XXX_Size() int

+ func (m *GetTermRequest) XXX_Unmarshal(b []byte) error

+ type GetTermResponse struct

+ Term Term

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

+ func (*GetTermResponse) ProtoMessage()

+ func (m *GetTermResponse) GetTerm() Term

+ func (m *GetTermResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetTermResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTermResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetTermResponse) Reset()

+ func (m *GetTermResponse) Size() (n int)

+ func (m *GetTermResponse) String() string

+ func (m *GetTermResponse) Unmarshal(dAtA []byte) error

+ func (m *GetTermResponse) XXX_DiscardUnknown()

+ func (m *GetTermResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTermResponse) XXX_Merge(src proto.Message)

+ func (m *GetTermResponse) XXX_Size() int

+ func (m *GetTermResponse) XXX_Unmarshal(b []byte) error

+ type LeaderElectionClient interface

+ Anoint func(ctx context.Context, in *AnointRequest, opts ...grpc.CallOption) (*AnointResponse, error)

+ Enter func(ctx context.Context, in *EnterRequest, opts ...grpc.CallOption) (*EnterResponse, error)

+ Events func(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (LeaderElection_EventsClient, error)

+ Evict func(ctx context.Context, in *EvictRequest, opts ...grpc.CallOption) (*EvictResponse, error)

+ GetTerm func(ctx context.Context, in *GetTermRequest, opts ...grpc.CallOption) (*GetTermResponse, error)

+ Promote func(ctx context.Context, in *PromoteRequest, opts ...grpc.CallOption) (*PromoteResponse, error)

+ Withdraw func(ctx context.Context, in *WithdrawRequest, opts ...grpc.CallOption) (*WithdrawResponse, error)

+ func NewLeaderElectionClient(cc *grpc.ClientConn) LeaderElectionClient

+ type LeaderElectionServer interface

+ Anoint func(context.Context, *AnointRequest) (*AnointResponse, error)

+ Enter func(context.Context, *EnterRequest) (*EnterResponse, error)

+ Events func(*EventsRequest, LeaderElection_EventsServer) error

+ Evict func(context.Context, *EvictRequest) (*EvictResponse, error)

+ GetTerm func(context.Context, *GetTermRequest) (*GetTermResponse, error)

+ Promote func(context.Context, *PromoteRequest) (*PromoteResponse, error)

+ Withdraw func(context.Context, *WithdrawRequest) (*WithdrawResponse, error)

+ type LeaderElectionSessionClient interface

+ CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)

+ OpenSession func(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)

+ func NewLeaderElectionSessionClient(cc *grpc.ClientConn) LeaderElectionSessionClient

+ type LeaderElectionSessionOptions struct

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

+ func (*LeaderElectionSessionOptions) ProtoMessage()

+ func (m *LeaderElectionSessionOptions) Marshal() (dAtA []byte, err error)

+ func (m *LeaderElectionSessionOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *LeaderElectionSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LeaderElectionSessionOptions) Reset()

+ func (m *LeaderElectionSessionOptions) Size() (n int)

+ func (m *LeaderElectionSessionOptions) String() string

+ func (m *LeaderElectionSessionOptions) Unmarshal(dAtA []byte) error

+ func (m *LeaderElectionSessionOptions) XXX_DiscardUnknown()

+ func (m *LeaderElectionSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LeaderElectionSessionOptions) XXX_Merge(src proto.Message)

+ func (m *LeaderElectionSessionOptions) XXX_Size() int

+ func (m *LeaderElectionSessionOptions) XXX_Unmarshal(b []byte) error

+ type LeaderElectionSessionServer interface

+ CloseSession func(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)

+ OpenSession func(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)

+ type LeaderElection_EventsClient interface

+ Recv func() (*EventsResponse, error)

+ type LeaderElection_EventsServer interface

+ Send func(*EventsResponse) error

+ type OpenSessionRequest struct

+ Options LeaderElectionSessionOptions

+ PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive.ID

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

+ func (*OpenSessionRequest) ProtoMessage()

+ func (m *OpenSessionRequest) GetOptions() LeaderElectionSessionOptions

+ func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive.ID

+ func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)

+ func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OpenSessionRequest) Reset()

+ func (m *OpenSessionRequest) Size() (n int)

+ func (m *OpenSessionRequest) String() string

+ func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error

+ func (m *OpenSessionRequest) XXX_DiscardUnknown()

+ func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OpenSessionRequest) XXX_Merge(src proto.Message)

+ func (m *OpenSessionRequest) XXX_Size() int

+ func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error

+ type OpenSessionResponse struct

+ SessionID github_com_atomix_atomix_api_go_atomix_primitive.SessionID

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

+ func (*OpenSessionResponse) ProtoMessage()

+ func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive.SessionID

+ func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)

+ func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OpenSessionResponse) Reset()

+ func (m *OpenSessionResponse) Size() (n int)

+ func (m *OpenSessionResponse) String() string

+ func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error

+ func (m *OpenSessionResponse) XXX_DiscardUnknown()

+ func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OpenSessionResponse) XXX_Merge(src proto.Message)

+ func (m *OpenSessionResponse) XXX_Size() int

+ func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error

+ type PromoteRequest struct

+ CandidateID string

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

+ func (*PromoteRequest) ProtoMessage()

+ func (m *PromoteRequest) GetCandidateID() string

+ func (m *PromoteRequest) Marshal() (dAtA []byte, err error)

+ func (m *PromoteRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PromoteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PromoteRequest) Reset()

+ func (m *PromoteRequest) Size() (n int)

+ func (m *PromoteRequest) String() string

+ func (m *PromoteRequest) Unmarshal(dAtA []byte) error

+ func (m *PromoteRequest) XXX_DiscardUnknown()

+ func (m *PromoteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PromoteRequest) XXX_Merge(src proto.Message)

+ func (m *PromoteRequest) XXX_Size() int

+ func (m *PromoteRequest) XXX_Unmarshal(b []byte) error

+ type PromoteResponse struct

+ Term Term

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

+ func (*PromoteResponse) ProtoMessage()

+ func (m *PromoteResponse) GetTerm() Term

+ func (m *PromoteResponse) Marshal() (dAtA []byte, err error)

+ func (m *PromoteResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PromoteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PromoteResponse) Reset()

+ func (m *PromoteResponse) Size() (n int)

+ func (m *PromoteResponse) String() string

+ func (m *PromoteResponse) Unmarshal(dAtA []byte) error

+ func (m *PromoteResponse) XXX_DiscardUnknown()

+ func (m *PromoteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PromoteResponse) XXX_Merge(src proto.Message)

+ func (m *PromoteResponse) XXX_Size() int

+ func (m *PromoteResponse) XXX_Unmarshal(b []byte) error

+ type Term struct

+ Candidates []string

+ Leader string

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

+ func (*Term) ProtoMessage()

+ func (m *Term) GetCandidates() []string

+ func (m *Term) GetLeader() string

+ func (m *Term) Marshal() (dAtA []byte, err error)

+ func (m *Term) MarshalTo(dAtA []byte) (int, error)

+ func (m *Term) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Term) Reset()

+ func (m *Term) Size() (n int)

+ func (m *Term) String() string

+ func (m *Term) Unmarshal(dAtA []byte) error

+ func (m *Term) XXX_DiscardUnknown()

+ func (m *Term) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Term) XXX_Merge(src proto.Message)

+ func (m *Term) XXX_Size() int

+ func (m *Term) XXX_Unmarshal(b []byte) error

+ type UnimplementedLeaderElectionServer struct

+ func (*UnimplementedLeaderElectionServer) Anoint(ctx context.Context, req *AnointRequest) (*AnointResponse, error)

+ func (*UnimplementedLeaderElectionServer) Enter(ctx context.Context, req *EnterRequest) (*EnterResponse, error)

+ func (*UnimplementedLeaderElectionServer) Events(req *EventsRequest, srv LeaderElection_EventsServer) error

+ func (*UnimplementedLeaderElectionServer) Evict(ctx context.Context, req *EvictRequest) (*EvictResponse, error)

+ func (*UnimplementedLeaderElectionServer) GetTerm(ctx context.Context, req *GetTermRequest) (*GetTermResponse, error)

+ func (*UnimplementedLeaderElectionServer) Promote(ctx context.Context, req *PromoteRequest) (*PromoteResponse, error)

+ func (*UnimplementedLeaderElectionServer) Withdraw(ctx context.Context, req *WithdrawRequest) (*WithdrawResponse, error)

+ type UnimplementedLeaderElectionSessionServer struct

+ func (*UnimplementedLeaderElectionSessionServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

+ func (*UnimplementedLeaderElectionSessionServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)

+ type WithdrawRequest struct

+ CandidateID string

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

+ func (*WithdrawRequest) ProtoMessage()

+ func (m *WithdrawRequest) GetCandidateID() string

+ func (m *WithdrawRequest) Marshal() (dAtA []byte, err error)

+ func (m *WithdrawRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *WithdrawRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WithdrawRequest) Reset()

+ func (m *WithdrawRequest) Size() (n int)

+ func (m *WithdrawRequest) String() string

+ func (m *WithdrawRequest) Unmarshal(dAtA []byte) error

+ func (m *WithdrawRequest) XXX_DiscardUnknown()

+ func (m *WithdrawRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WithdrawRequest) XXX_Merge(src proto.Message)

+ func (m *WithdrawRequest) XXX_Size() int

+ func (m *WithdrawRequest) XXX_Unmarshal(b []byte) error

+ type WithdrawResponse struct

+ Term Term

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

+ func (*WithdrawResponse) ProtoMessage()

+ func (m *WithdrawResponse) GetTerm() Term

+ func (m *WithdrawResponse) Marshal() (dAtA []byte, err error)

+ func (m *WithdrawResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *WithdrawResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WithdrawResponse) Reset()

+ func (m *WithdrawResponse) Size() (n int)

+ func (m *WithdrawResponse) String() string

+ func (m *WithdrawResponse) Unmarshal(dAtA []byte) error

+ func (m *WithdrawResponse) XXX_DiscardUnknown()

+ func (m *WithdrawResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WithdrawResponse) XXX_Merge(src proto.Message)

+ func (m *WithdrawResponse) XXX_Size() int

+ func (m *WithdrawResponse) XXX_Unmarshal(b []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL