election

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

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

Go to latest
Published: Jan 23, 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"`
	Timeout *time.Duration         `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
}

func (*CreateRequest) Descriptor

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

func (*CreateRequest) GetHeader

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

func (*CreateRequest) GetTimeout

func (m *CreateRequest) GetTimeout() *time.Duration

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 KeepAliveRequest

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

func (*KeepAliveRequest) Descriptor

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

func (*KeepAliveRequest) GetHeader

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

func (*KeepAliveRequest) Marshal

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

func (*KeepAliveRequest) MarshalTo

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

func (*KeepAliveRequest) MarshalToSizedBuffer

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

func (*KeepAliveRequest) ProtoMessage

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) Reset

func (m *KeepAliveRequest) Reset()

func (*KeepAliveRequest) Size

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

func (*KeepAliveRequest) String

func (m *KeepAliveRequest) String() string

func (*KeepAliveRequest) Unmarshal

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

func (*KeepAliveRequest) XXX_DiscardUnknown

func (m *KeepAliveRequest) XXX_DiscardUnknown()

func (*KeepAliveRequest) XXX_Marshal

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

func (*KeepAliveRequest) XXX_Merge

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

func (*KeepAliveRequest) XXX_Size

func (m *KeepAliveRequest) XXX_Size() int

func (*KeepAliveRequest) XXX_Unmarshal

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

type KeepAliveResponse

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

func (*KeepAliveResponse) Descriptor

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

func (*KeepAliveResponse) GetHeader

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

func (*KeepAliveResponse) Marshal

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

func (*KeepAliveResponse) MarshalTo

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

func (*KeepAliveResponse) MarshalToSizedBuffer

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

func (*KeepAliveResponse) ProtoMessage

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) Reset

func (m *KeepAliveResponse) Reset()

func (*KeepAliveResponse) Size

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

func (*KeepAliveResponse) String

func (m *KeepAliveResponse) String() string

func (*KeepAliveResponse) Unmarshal

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

func (*KeepAliveResponse) XXX_DiscardUnknown

func (m *KeepAliveResponse) XXX_DiscardUnknown()

func (*KeepAliveResponse) XXX_Marshal

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

func (*KeepAliveResponse) XXX_Merge

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

func (*KeepAliveResponse) XXX_Size

func (m *KeepAliveResponse) XXX_Size() int

func (*KeepAliveResponse) XXX_Unmarshal

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

type LeaderElectionServiceClient

type LeaderElectionServiceClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	KeepAlive(ctx context.Context, in *KeepAliveRequest, opts ...grpc.CallOption) (*KeepAliveResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	Enter(ctx context.Context, in *EnterRequest, opts ...grpc.CallOption) (*EnterResponse, error)
	Withdraw(ctx context.Context, in *WithdrawRequest, opts ...grpc.CallOption) (*WithdrawResponse, error)
	Anoint(ctx context.Context, in *AnointRequest, opts ...grpc.CallOption) (*AnointResponse, error)
	Promote(ctx context.Context, in *PromoteRequest, opts ...grpc.CallOption) (*PromoteResponse, error)
	Evict(ctx context.Context, in *EvictRequest, opts ...grpc.CallOption) (*EvictResponse, error)
	GetTerm(ctx context.Context, in *GetTermRequest, opts ...grpc.CallOption) (*GetTermResponse, error)
	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 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) Close

func (*UnimplementedLeaderElectionServiceServer) Create

func (*UnimplementedLeaderElectionServiceServer) Enter

func (*UnimplementedLeaderElectionServiceServer) Events

func (*UnimplementedLeaderElectionServiceServer) Evict

func (*UnimplementedLeaderElectionServiceServer) GetTerm

func (*UnimplementedLeaderElectionServiceServer) KeepAlive

func (*UnimplementedLeaderElectionServiceServer) Promote

func (*UnimplementedLeaderElectionServiceServer) Withdraw

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

Jump to

Keyboard shortcuts

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