election

package
v0.3.3 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthElection        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowElection          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupElection = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EventResponse_Type_name = map[int32]string{
	0: "CHANGED",
}
View Source 
var EventResponse_Type_value = map[string]int32{
	"CHANGED": 0,
}

Functions

func RegisterLeaderElectionServiceServer 

func RegisterLeaderElectionServiceServer(s *grpc.Server, srv LeaderElectionServiceServer)

Types

type AnointRequest 

type AnointRequest struct {
	Header      *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	CandidateID string                 `protobuf:"bytes,2,opt,name=candidate_id,json=candidateId,proto3" json:"candidate_id,omitempty"`
}

func (*AnointRequest) Descriptor 

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

func (*AnointRequest) GetCandidateID 

func (m *AnointRequest) GetCandidateID() string

func (*AnointRequest) GetHeader 

func (m *AnointRequest) GetHeader() *headers.RequestHeader

func (*AnointRequest) Marshal 

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

func (*AnointRequest) MarshalTo 

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

func (*AnointRequest) MarshalToSizedBuffer 

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

func (*AnointRequest) ProtoMessage 

func (*AnointRequest) ProtoMessage()

func (*AnointRequest) Reset 

func (m *AnointRequest) Reset()

func (*AnointRequest) Size 

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

func (*AnointRequest) String 

func (m *AnointRequest) String() string

func (*AnointRequest) Unmarshal 

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

func (*AnointRequest) XXX_DiscardUnknown 

func (m *AnointRequest) XXX_DiscardUnknown()

func (*AnointRequest) XXX_Marshal 

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

func (*AnointRequest) XXX_Merge 

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

func (*AnointRequest) XXX_Size 

func (m *AnointRequest) XXX_Size() int

func (*AnointRequest) XXX_Unmarshal 

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

type AnointResponse 

type AnointResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term   *Term                   `protobuf:"bytes,2,opt,name=term,proto3" json:"term,omitempty"`
}

func (*AnointResponse) Descriptor 

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

func (*AnointResponse) GetHeader 

func (m *AnointResponse) GetHeader() *headers.ResponseHeader

func (*AnointResponse) GetTerm 

func (m *AnointResponse) GetTerm() *Term

func (*AnointResponse) Marshal 

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

func (*AnointResponse) MarshalTo 

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

func (*AnointResponse) MarshalToSizedBuffer 

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

func (*AnointResponse) ProtoMessage 

func (*AnointResponse) ProtoMessage()

func (*AnointResponse) Reset 

func (m *AnointResponse) Reset()

func (*AnointResponse) Size 

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

func (*AnointResponse) String 

func (m *AnointResponse) String() string

func (*AnointResponse) Unmarshal 

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

func (*AnointResponse) XXX_DiscardUnknown 

func (m *AnointResponse) XXX_DiscardUnknown()

func (*AnointResponse) XXX_Marshal 

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

func (*AnointResponse) XXX_Merge 

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

func (*AnointResponse) XXX_Size 

func (m *AnointResponse) XXX_Size() int

func (*AnointResponse) XXX_Unmarshal 

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

type CloseRequest 

type CloseRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Delete bool                   `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) GetDelete 

func (m *CloseRequest) GetDelete() bool

func (*CloseRequest) GetHeader 

func (m *CloseRequest) GetHeader() *headers.RequestHeader

func (*CloseRequest) Marshal 

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

func (*CloseRequest) MarshalTo 

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

func (*CloseRequest) MarshalToSizedBuffer 

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

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) Size 

func (m *CloseRequest) Size() (n int)

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) Unmarshal 

func (m *CloseRequest) Unmarshal(dAtA []byte) error

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

func (m *CloseRequest) XXX_Merge(src proto.Message)

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

func (m *CloseRequest) XXX_Unmarshal(b []byte) error

type CloseResponse 

type CloseResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*CloseResponse) Descriptor 

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

func (*CloseResponse) GetHeader 

func (m *CloseResponse) GetHeader() *headers.ResponseHeader

func (*CloseResponse) Marshal 

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

func (*CloseResponse) MarshalTo 

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

func (*CloseResponse) MarshalToSizedBuffer 

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

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset 

func (m *CloseResponse) Reset()

func (*CloseResponse) Size 

func (m *CloseResponse) Size() (n int)

func (*CloseResponse) String 

func (m *CloseResponse) String() string

func (*CloseResponse) Unmarshal 

func (m *CloseResponse) Unmarshal(dAtA []byte) error

func (*CloseResponse) XXX_DiscardUnknown 

func (m *CloseResponse) XXX_DiscardUnknown()

func (*CloseResponse) XXX_Marshal 

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

func (*CloseResponse) XXX_Merge 

func (m *CloseResponse) XXX_Merge(src proto.Message)

func (*CloseResponse) XXX_Size 

func (m *CloseResponse) XXX_Size() int

func (*CloseResponse) XXX_Unmarshal 

func (m *CloseResponse) XXX_Unmarshal(b []byte) error

type CreateRequest 

type CreateRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetHeader 

func (m *CreateRequest) GetHeader() *headers.RequestHeader

func (*CreateRequest) Marshal 

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

func (*CreateRequest) MarshalTo 

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

func (*CreateRequest) MarshalToSizedBuffer 

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

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) Size 

func (m *CreateRequest) Size() (n int)

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) Unmarshal 

func (m *CreateRequest) Unmarshal(dAtA []byte) error

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

func (m *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

func (m *CreateRequest) XXX_Unmarshal(b []byte) error

type CreateResponse 

type CreateResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) GetHeader 

func (m *CreateResponse) GetHeader() *headers.ResponseHeader

func (*CreateResponse) Marshal 

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

func (*CreateResponse) MarshalTo 

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

func (*CreateResponse) MarshalToSizedBuffer 

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

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) Size 

func (m *CreateResponse) Size() (n int)

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) Unmarshal 

func (m *CreateResponse) Unmarshal(dAtA []byte) error

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

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

func (*CreateResponse) XXX_Merge 

func (m *CreateResponse) XXX_Merge(src proto.Message)

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

func (m *CreateResponse) XXX_Unmarshal(b []byte) error

type EnterRequest 

type EnterRequest struct {
	Header      *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	CandidateID string                 `protobuf:"bytes,2,opt,name=candidate_id,json=candidateId,proto3" json:"candidate_id,omitempty"`
}

func (*EnterRequest) Descriptor 

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

func (*EnterRequest) GetCandidateID 

func (m *EnterRequest) GetCandidateID() string

func (*EnterRequest) GetHeader 

func (m *EnterRequest) GetHeader() *headers.RequestHeader

func (*EnterRequest) Marshal 

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

func (*EnterRequest) MarshalTo 

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

func (*EnterRequest) MarshalToSizedBuffer 

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

func (*EnterRequest) ProtoMessage 

func (*EnterRequest) ProtoMessage()

func (*EnterRequest) Reset 

func (m *EnterRequest) Reset()

func (*EnterRequest) Size 

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

func (*EnterRequest) String 

func (m *EnterRequest) String() string

func (*EnterRequest) Unmarshal 

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

func (*EnterRequest) XXX_DiscardUnknown 

func (m *EnterRequest) XXX_DiscardUnknown()

func (*EnterRequest) XXX_Marshal 

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

func (*EnterRequest) XXX_Merge 

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

func (*EnterRequest) XXX_Size 

func (m *EnterRequest) XXX_Size() int

func (*EnterRequest) XXX_Unmarshal 

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

type EnterResponse 

type EnterResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term   *Term                   `protobuf:"bytes,2,opt,name=term,proto3" json:"term,omitempty"`
}

func (*EnterResponse) Descriptor 

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

func (*EnterResponse) GetHeader 

func (m *EnterResponse) GetHeader() *headers.ResponseHeader

func (*EnterResponse) GetTerm 

func (m *EnterResponse) GetTerm() *Term

func (*EnterResponse) Marshal 

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

func (*EnterResponse) MarshalTo 

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

func (*EnterResponse) MarshalToSizedBuffer 

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

func (*EnterResponse) ProtoMessage 

func (*EnterResponse) ProtoMessage()

func (*EnterResponse) Reset 

func (m *EnterResponse) Reset()

func (*EnterResponse) Size 

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

func (*EnterResponse) String 

func (m *EnterResponse) String() string

func (*EnterResponse) Unmarshal 

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

func (*EnterResponse) XXX_DiscardUnknown 

func (m *EnterResponse) XXX_DiscardUnknown()

func (*EnterResponse) XXX_Marshal 

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

func (*EnterResponse) XXX_Merge 

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

func (*EnterResponse) XXX_Size 

func (m *EnterResponse) XXX_Size() int

func (*EnterResponse) XXX_Unmarshal 

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

type EventRequest 

type EventRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*EventRequest) Descriptor 

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

func (*EventRequest) GetHeader 

func (m *EventRequest) GetHeader() *headers.RequestHeader

func (*EventRequest) Marshal 

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

func (*EventRequest) MarshalTo 

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

func (*EventRequest) MarshalToSizedBuffer 

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

func (*EventRequest) ProtoMessage 

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset 

func (m *EventRequest) Reset()

func (*EventRequest) Size 

func (m *EventRequest) Size() (n int)

func (*EventRequest) String 

func (m *EventRequest) String() string

func (*EventRequest) Unmarshal 

func (m *EventRequest) Unmarshal(dAtA []byte) error

func (*EventRequest) XXX_DiscardUnknown 

func (m *EventRequest) XXX_DiscardUnknown()

func (*EventRequest) XXX_Marshal 

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

func (*EventRequest) XXX_Merge 

func (m *EventRequest) XXX_Merge(src proto.Message)

func (*EventRequest) XXX_Size 

func (m *EventRequest) XXX_Size() int

func (*EventRequest) XXX_Unmarshal 

func (m *EventRequest) XXX_Unmarshal(b []byte) error

type EventResponse 

type EventResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Type   EventResponse_Type      `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.election.EventResponse_Type" json:"type,omitempty"`
	Term   *Term                   `protobuf:"bytes,3,opt,name=term,proto3" json:"term,omitempty"`
}

func (*EventResponse) Descriptor 

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

func (*EventResponse) GetHeader 

func (m *EventResponse) GetHeader() *headers.ResponseHeader

func (*EventResponse) GetTerm 

func (m *EventResponse) GetTerm() *Term

func (*EventResponse) GetType 

func (m *EventResponse) GetType() EventResponse_Type

func (*EventResponse) Marshal 

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

func (*EventResponse) MarshalTo 

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

func (*EventResponse) MarshalToSizedBuffer 

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

func (*EventResponse) ProtoMessage 

func (*EventResponse) ProtoMessage()

func (*EventResponse) Reset 

func (m *EventResponse) Reset()

func (*EventResponse) Size 

func (m *EventResponse) Size() (n int)

func (*EventResponse) String 

func (m *EventResponse) String() string

func (*EventResponse) Unmarshal 

func (m *EventResponse) Unmarshal(dAtA []byte) error

func (*EventResponse) XXX_DiscardUnknown 

func (m *EventResponse) XXX_DiscardUnknown()

func (*EventResponse) XXX_Marshal 

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

func (*EventResponse) XXX_Merge 

func (m *EventResponse) XXX_Merge(src proto.Message)

func (*EventResponse) XXX_Size 

func (m *EventResponse) XXX_Size() int

func (*EventResponse) XXX_Unmarshal 

func (m *EventResponse) XXX_Unmarshal(b []byte) error

type EventResponse_Type 

type EventResponse_Type int32
const (
	EventResponse_CHANGED EventResponse_Type = 0
)

func (EventResponse_Type) EnumDescriptor 

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

func (EventResponse_Type) String 

func (x EventResponse_Type) String() string

type EvictRequest 

type EvictRequest struct {
	Header      *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	CandidateID string                 `protobuf:"bytes,2,opt,name=candidate_id,json=candidateId,proto3" json:"candidate_id,omitempty"`
}

func (*EvictRequest) Descriptor 

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

func (*EvictRequest) GetCandidateID 

func (m *EvictRequest) GetCandidateID() string

func (*EvictRequest) GetHeader 

func (m *EvictRequest) GetHeader() *headers.RequestHeader

func (*EvictRequest) Marshal 

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

func (*EvictRequest) MarshalTo 

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

func (*EvictRequest) MarshalToSizedBuffer 

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

func (*EvictRequest) ProtoMessage 

func (*EvictRequest) ProtoMessage()

func (*EvictRequest) Reset 

func (m *EvictRequest) Reset()

func (*EvictRequest) Size 

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

func (*EvictRequest) String 

func (m *EvictRequest) String() string

func (*EvictRequest) Unmarshal 

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

func (*EvictRequest) XXX_DiscardUnknown 

func (m *EvictRequest) XXX_DiscardUnknown()

func (*EvictRequest) XXX_Marshal 

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

func (*EvictRequest) XXX_Merge 

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

func (*EvictRequest) XXX_Size 

func (m *EvictRequest) XXX_Size() int

func (*EvictRequest) XXX_Unmarshal 

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

type EvictResponse 

type EvictResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term   *Term                   `protobuf:"bytes,2,opt,name=term,proto3" json:"term,omitempty"`
}

func (*EvictResponse) Descriptor 

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

func (*EvictResponse) GetHeader 

func (m *EvictResponse) GetHeader() *headers.ResponseHeader

func (*EvictResponse) GetTerm 

func (m *EvictResponse) GetTerm() *Term

func (*EvictResponse) Marshal 

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

func (*EvictResponse) MarshalTo 

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

func (*EvictResponse) MarshalToSizedBuffer 

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

func (*EvictResponse) ProtoMessage 

func (*EvictResponse) ProtoMessage()

func (*EvictResponse) Reset 

func (m *EvictResponse) Reset()

func (*EvictResponse) Size 

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

func (*EvictResponse) String 

func (m *EvictResponse) String() string

func (*EvictResponse) Unmarshal 

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

func (*EvictResponse) XXX_DiscardUnknown 

func (m *EvictResponse) XXX_DiscardUnknown()

func (*EvictResponse) XXX_Marshal 

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

func (*EvictResponse) XXX_Merge 

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

func (*EvictResponse) XXX_Size 

func (m *EvictResponse) XXX_Size() int

func (*EvictResponse) XXX_Unmarshal 

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

type GetTermRequest 

type GetTermRequest struct {
	Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}

func (*GetTermRequest) Descriptor 

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

func (*GetTermRequest) GetHeader 

func (m *GetTermRequest) GetHeader() *headers.RequestHeader

func (*GetTermRequest) Marshal 

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

func (*GetTermRequest) MarshalTo 

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

func (*GetTermRequest) MarshalToSizedBuffer 

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

func (*GetTermRequest) ProtoMessage 

func (*GetTermRequest) ProtoMessage()

func (*GetTermRequest) Reset 

func (m *GetTermRequest) Reset()

func (*GetTermRequest) Size 

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

func (*GetTermRequest) String 

func (m *GetTermRequest) String() string

func (*GetTermRequest) Unmarshal 

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

func (*GetTermRequest) XXX_DiscardUnknown 

func (m *GetTermRequest) XXX_DiscardUnknown()

func (*GetTermRequest) XXX_Marshal 

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

func (*GetTermRequest) XXX_Merge 

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

func (*GetTermRequest) XXX_Size 

func (m *GetTermRequest) XXX_Size() int

func (*GetTermRequest) XXX_Unmarshal 

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

type GetTermResponse 

type GetTermResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term   *Term                   `protobuf:"bytes,2,opt,name=term,proto3" json:"term,omitempty"`
}

func (*GetTermResponse) Descriptor 

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

func (*GetTermResponse) GetHeader 

func (m *GetTermResponse) GetHeader() *headers.ResponseHeader

func (*GetTermResponse) GetTerm 

func (m *GetTermResponse) GetTerm() *Term

func (*GetTermResponse) Marshal 

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

func (*GetTermResponse) MarshalTo 

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

func (*GetTermResponse) MarshalToSizedBuffer 

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

func (*GetTermResponse) ProtoMessage 

func (*GetTermResponse) ProtoMessage()

func (*GetTermResponse) Reset 

func (m *GetTermResponse) Reset()

func (*GetTermResponse) Size 

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

func (*GetTermResponse) String 

func (m *GetTermResponse) String() string

func (*GetTermResponse) Unmarshal 

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

func (*GetTermResponse) XXX_DiscardUnknown 

func (m *GetTermResponse) XXX_DiscardUnknown()

func (*GetTermResponse) XXX_Marshal 

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

func (*GetTermResponse) XXX_Merge 

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

func (*GetTermResponse) XXX_Size 

func (m *GetTermResponse) XXX_Size() int

func (*GetTermResponse) XXX_Unmarshal 

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

type LeaderElectionServiceClient 

type LeaderElectionServiceClient interface {
	// Create creates a LeaderElection instance
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Close closes a LeaderElection instance
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	// Enter enters the leader election
	Enter(ctx context.Context, in *EnterRequest, opts ...grpc.CallOption) (*EnterResponse, error)
	// Withdraw withdraws a candidate from the leader election
	Withdraw(ctx context.Context, in *WithdrawRequest, opts ...grpc.CallOption) (*WithdrawResponse, error)
	// Anoint anoints a candidate leader
	Anoint(ctx context.Context, in *AnointRequest, opts ...grpc.CallOption) (*AnointResponse, error)
	// Promote promotes a candidate
	Promote(ctx context.Context, in *PromoteRequest, opts ...grpc.CallOption) (*PromoteResponse, error)
	// Evict evicts a candidate from the election
	Evict(ctx context.Context, in *EvictRequest, opts ...grpc.CallOption) (*EvictResponse, error)
	// GetTerm gets the current leadership term
	GetTerm(ctx context.Context, in *GetTermRequest, opts ...grpc.CallOption) (*GetTermResponse, error)
	// Events listens for leadership events
	Events(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (LeaderElectionService_EventsClient, error)
}

LeaderElectionServiceClient is the client API for LeaderElectionService service.

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

func NewLeaderElectionServiceClient 

func NewLeaderElectionServiceClient(cc *grpc.ClientConn) LeaderElectionServiceClient

type LeaderElectionServiceServer 

type LeaderElectionServiceServer interface {
	// Create creates a LeaderElection instance
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Close closes a LeaderElection instance
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	// Enter enters the leader election
	Enter(context.Context, *EnterRequest) (*EnterResponse, error)
	// Withdraw withdraws a candidate from the leader election
	Withdraw(context.Context, *WithdrawRequest) (*WithdrawResponse, error)
	// Anoint anoints a candidate leader
	Anoint(context.Context, *AnointRequest) (*AnointResponse, error)
	// Promote promotes a candidate
	Promote(context.Context, *PromoteRequest) (*PromoteResponse, error)
	// Evict evicts a candidate from the election
	Evict(context.Context, *EvictRequest) (*EvictResponse, error)
	// GetTerm gets the current leadership term
	GetTerm(context.Context, *GetTermRequest) (*GetTermResponse, error)
	// Events listens for leadership events
	Events(*EventRequest, LeaderElectionService_EventsServer) error
}

LeaderElectionServiceServer is the server API for LeaderElectionService service.

type LeaderElectionService_EventsClient 

type LeaderElectionService_EventsClient interface {
	Recv() (*EventResponse, error)
	grpc.ClientStream
}

type LeaderElectionService_EventsServer 

type LeaderElectionService_EventsServer interface {
	Send(*EventResponse) error
	grpc.ServerStream
}

type PromoteRequest 

type PromoteRequest struct {
	Header      *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	CandidateID string                 `protobuf:"bytes,2,opt,name=candidate_id,json=candidateId,proto3" json:"candidate_id,omitempty"`
}

func (*PromoteRequest) Descriptor 

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

func (*PromoteRequest) GetCandidateID 

func (m *PromoteRequest) GetCandidateID() string

func (*PromoteRequest) GetHeader 

func (m *PromoteRequest) GetHeader() *headers.RequestHeader

func (*PromoteRequest) Marshal 

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

func (*PromoteRequest) MarshalTo 

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

func (*PromoteRequest) MarshalToSizedBuffer 

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

func (*PromoteRequest) ProtoMessage 

func (*PromoteRequest) ProtoMessage()

func (*PromoteRequest) Reset 

func (m *PromoteRequest) Reset()

func (*PromoteRequest) Size 

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

func (*PromoteRequest) String 

func (m *PromoteRequest) String() string

func (*PromoteRequest) Unmarshal 

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

func (*PromoteRequest) XXX_DiscardUnknown 

func (m *PromoteRequest) XXX_DiscardUnknown()

func (*PromoteRequest) XXX_Marshal 

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

func (*PromoteRequest) XXX_Merge 

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

func (*PromoteRequest) XXX_Size 

func (m *PromoteRequest) XXX_Size() int

func (*PromoteRequest) XXX_Unmarshal 

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

type PromoteResponse 

type PromoteResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term   *Term                   `protobuf:"bytes,2,opt,name=term,proto3" json:"term,omitempty"`
}

func (*PromoteResponse) Descriptor 

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

func (*PromoteResponse) GetHeader 

func (m *PromoteResponse) GetHeader() *headers.ResponseHeader

func (*PromoteResponse) GetTerm 

func (m *PromoteResponse) GetTerm() *Term

func (*PromoteResponse) Marshal 

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

func (*PromoteResponse) MarshalTo 

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

func (*PromoteResponse) MarshalToSizedBuffer 

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

func (*PromoteResponse) ProtoMessage 

func (*PromoteResponse) ProtoMessage()

func (*PromoteResponse) Reset 

func (m *PromoteResponse) Reset()

func (*PromoteResponse) Size 

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

func (*PromoteResponse) String 

func (m *PromoteResponse) String() string

func (*PromoteResponse) Unmarshal 

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

func (*PromoteResponse) XXX_DiscardUnknown 

func (m *PromoteResponse) XXX_DiscardUnknown()

func (*PromoteResponse) XXX_Marshal 

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

func (*PromoteResponse) XXX_Merge 

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

func (*PromoteResponse) XXX_Size 

func (m *PromoteResponse) XXX_Size() int

func (*PromoteResponse) XXX_Unmarshal 

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

type Term 

type Term struct {
	ID         uint64     `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp  *time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp,omitempty"`
	Leader     string     `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"`
	Candidates []string   `protobuf:"bytes,4,rep,name=candidates,proto3" json:"candidates,omitempty"`
}

func (*Term) Descriptor 

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

func (*Term) GetCandidates 

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

func (*Term) GetID 

func (m *Term) GetID() uint64

func (*Term) GetLeader 

func (m *Term) GetLeader() string

func (*Term) GetTimestamp 

func (m *Term) GetTimestamp() *time.Time

func (*Term) Marshal 

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

func (*Term) MarshalTo 

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

func (*Term) MarshalToSizedBuffer 

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

func (*Term) ProtoMessage 

func (*Term) ProtoMessage()

func (*Term) Reset 

func (m *Term) Reset()

func (*Term) Size 

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

func (*Term) String 

func (m *Term) String() string

func (*Term) Unmarshal 

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

func (*Term) XXX_DiscardUnknown 

func (m *Term) XXX_DiscardUnknown()

func (*Term) XXX_Marshal 

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

func (*Term) XXX_Merge 

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

func (*Term) XXX_Size 

func (m *Term) XXX_Size() int

func (*Term) XXX_Unmarshal 

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

type UnimplementedLeaderElectionServiceServer 

type UnimplementedLeaderElectionServiceServer struct {
}

UnimplementedLeaderElectionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLeaderElectionServiceServer) Anoint 

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

func (*UnimplementedLeaderElectionServiceServer) Close 

func (*UnimplementedLeaderElectionServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

func (*UnimplementedLeaderElectionServiceServer) Create 

func (*UnimplementedLeaderElectionServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

func (*UnimplementedLeaderElectionServiceServer) Enter 

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

func (*UnimplementedLeaderElectionServiceServer) Events 

func (*UnimplementedLeaderElectionServiceServer) Events(req *EventRequest, srv LeaderElectionService_EventsServer) error

func (*UnimplementedLeaderElectionServiceServer) Evict 

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

func (*UnimplementedLeaderElectionServiceServer) GetTerm 

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

func (*UnimplementedLeaderElectionServiceServer) Promote 

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

func (*UnimplementedLeaderElectionServiceServer) Withdraw 

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

type WithdrawRequest 

type WithdrawRequest struct {
	Header      *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	CandidateID string                 `protobuf:"bytes,2,opt,name=candidate_id,json=candidateId,proto3" json:"candidate_id,omitempty"`
}

func (*WithdrawRequest) Descriptor 

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

func (*WithdrawRequest) GetCandidateID 

func (m *WithdrawRequest) GetCandidateID() string

func (*WithdrawRequest) GetHeader 

func (m *WithdrawRequest) GetHeader() *headers.RequestHeader

func (*WithdrawRequest) Marshal 

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

func (*WithdrawRequest) MarshalTo 

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

func (*WithdrawRequest) MarshalToSizedBuffer 

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

func (*WithdrawRequest) ProtoMessage 

func (*WithdrawRequest) ProtoMessage()

func (*WithdrawRequest) Reset 

func (m *WithdrawRequest) Reset()

func (*WithdrawRequest) Size 

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

func (*WithdrawRequest) String 

func (m *WithdrawRequest) String() string

func (*WithdrawRequest) Unmarshal 

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

func (*WithdrawRequest) XXX_DiscardUnknown 

func (m *WithdrawRequest) XXX_DiscardUnknown()

func (*WithdrawRequest) XXX_Marshal 

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

func (*WithdrawRequest) XXX_Merge 

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

func (*WithdrawRequest) XXX_Size 

func (m *WithdrawRequest) XXX_Size() int

func (*WithdrawRequest) XXX_Unmarshal 

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

type WithdrawResponse 

type WithdrawResponse struct {
	Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Term   *Term                   `protobuf:"bytes,2,opt,name=term,proto3" json:"term,omitempty"`
}

func (*WithdrawResponse) Descriptor 

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

func (*WithdrawResponse) GetHeader 

func (m *WithdrawResponse) GetHeader() *headers.ResponseHeader

func (*WithdrawResponse) GetTerm 

func (m *WithdrawResponse) GetTerm() *Term

func (*WithdrawResponse) Marshal 

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

func (*WithdrawResponse) MarshalTo 

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

func (*WithdrawResponse) MarshalToSizedBuffer 

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

func (*WithdrawResponse) ProtoMessage 

func (*WithdrawResponse) ProtoMessage()

func (*WithdrawResponse) Reset 

func (m *WithdrawResponse) Reset()

func (*WithdrawResponse) Size 

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

func (*WithdrawResponse) String 

func (m *WithdrawResponse) String() string

func (*WithdrawResponse) Unmarshal 

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

func (*WithdrawResponse) XXX_DiscardUnknown 

func (m *WithdrawResponse) XXX_DiscardUnknown()

func (*WithdrawResponse) XXX_Marshal 

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

func (*WithdrawResponse) XXX_Merge 

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

func (*WithdrawResponse) XXX_Size 

func (m *WithdrawResponse) XXX_Size() int

func (*WithdrawResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.