Documentation ¶
Index ¶
- Variables
- func RegisterLeaderElectionServiceServer(s *grpc.Server, srv LeaderElectionServiceServer)
- type AnointRequest
- func (*AnointRequest) Descriptor() ([]byte, []int)
- func (m *AnointRequest) GetCandidateID() string
- func (m *AnointRequest) GetHeaders() primitive.RequestHeaders
- 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 (*AnointRequest) ProtoMessage()
- 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
- func (*AnointResponse) Descriptor() ([]byte, []int)
- func (m *AnointResponse) GetHeaders() primitive.ResponseHeaders
- 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 (*AnointResponse) ProtoMessage()
- 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 EnterRequest
- func (*EnterRequest) Descriptor() ([]byte, []int)
- func (m *EnterRequest) GetCandidateID() string
- func (m *EnterRequest) GetHeaders() primitive.RequestHeaders
- 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 (*EnterRequest) ProtoMessage()
- 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
- func (*EnterResponse) Descriptor() ([]byte, []int)
- func (m *EnterResponse) GetHeaders() primitive.ResponseHeaders
- 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 (*EnterResponse) ProtoMessage()
- 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
- func (*Event) Descriptor() ([]byte, []int)
- 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 (*Event) ProtoMessage()
- 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
- type EventsRequest
- func (*EventsRequest) Descriptor() ([]byte, []int)
- func (m *EventsRequest) GetHeaders() primitive.RequestHeaders
- 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 (*EventsRequest) ProtoMessage()
- 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
- func (*EventsResponse) Descriptor() ([]byte, []int)
- func (m *EventsResponse) GetEvent() Event
- func (m *EventsResponse) GetHeaders() primitive.ResponseHeaders
- 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 (*EventsResponse) ProtoMessage()
- 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
- func (*EvictRequest) Descriptor() ([]byte, []int)
- func (m *EvictRequest) GetCandidateID() string
- func (m *EvictRequest) GetHeaders() primitive.RequestHeaders
- 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 (*EvictRequest) ProtoMessage()
- 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
- func (*EvictResponse) Descriptor() ([]byte, []int)
- func (m *EvictResponse) GetHeaders() primitive.ResponseHeaders
- 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 (*EvictResponse) ProtoMessage()
- 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
- func (*GetTermRequest) Descriptor() ([]byte, []int)
- func (m *GetTermRequest) GetHeaders() primitive.RequestHeaders
- 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 (*GetTermRequest) ProtoMessage()
- 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
- func (*GetTermResponse) Descriptor() ([]byte, []int)
- func (m *GetTermResponse) GetHeaders() primitive.ResponseHeaders
- 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 (*GetTermResponse) ProtoMessage()
- 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 LeaderElectionServiceClient
- type LeaderElectionServiceServer
- type LeaderElectionService_EventsClient
- type LeaderElectionService_EventsServer
- type PromoteRequest
- func (*PromoteRequest) Descriptor() ([]byte, []int)
- func (m *PromoteRequest) GetCandidateID() string
- func (m *PromoteRequest) GetHeaders() primitive.RequestHeaders
- 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 (*PromoteRequest) ProtoMessage()
- 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
- func (*PromoteResponse) Descriptor() ([]byte, []int)
- func (m *PromoteResponse) GetHeaders() primitive.ResponseHeaders
- 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 (*PromoteResponse) ProtoMessage()
- 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
- func (*Term) Descriptor() ([]byte, []int)
- 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 (*Term) ProtoMessage()
- 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 UnimplementedLeaderElectionServiceServer
- func (*UnimplementedLeaderElectionServiceServer) Anoint(ctx context.Context, req *AnointRequest) (*AnointResponse, error)
- func (*UnimplementedLeaderElectionServiceServer) Enter(ctx context.Context, req *EnterRequest) (*EnterResponse, error)
- func (*UnimplementedLeaderElectionServiceServer) Events(req *EventsRequest, srv LeaderElectionService_EventsServer) error
- func (*UnimplementedLeaderElectionServiceServer) Evict(ctx context.Context, req *EvictRequest) (*EvictResponse, error)
- func (*UnimplementedLeaderElectionServiceServer) GetTerm(ctx context.Context, req *GetTermRequest) (*GetTermResponse, error)
- func (*UnimplementedLeaderElectionServiceServer) Promote(ctx context.Context, req *PromoteRequest) (*PromoteResponse, error)
- func (*UnimplementedLeaderElectionServiceServer) Withdraw(ctx context.Context, req *WithdrawRequest) (*WithdrawResponse, error)
- type WithdrawRequest
- func (*WithdrawRequest) Descriptor() ([]byte, []int)
- func (m *WithdrawRequest) GetCandidateID() string
- func (m *WithdrawRequest) GetHeaders() primitive.RequestHeaders
- 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 (*WithdrawRequest) ProtoMessage()
- 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
- func (*WithdrawResponse) Descriptor() ([]byte, []int)
- func (m *WithdrawResponse) GetHeaders() primitive.ResponseHeaders
- 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 (*WithdrawResponse) ProtoMessage()
- 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
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 Event_Type_name = map[int32]string{
0: "NONE",
1: "CHANGED",
}
View Source
var Event_Type_value = map[string]int32{
"NONE": 0,
"CHANGED": 1,
}
Functions ¶
func RegisterLeaderElectionServiceServer ¶
func RegisterLeaderElectionServiceServer(s *grpc.Server, srv LeaderElectionServiceServer)
Types ¶
type AnointRequest ¶
type AnointRequest struct { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` 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) GetHeaders ¶
func (m *AnointRequest) GetHeaders() primitive.RequestHeaders
func (*AnointRequest) Marshal ¶
func (m *AnointRequest) Marshal() (dAtA []byte, err 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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Term Term `protobuf:"bytes,2,opt,name=term,proto3" json:"term"` }
func (*AnointResponse) Descriptor ¶
func (*AnointResponse) Descriptor() ([]byte, []int)
func (*AnointResponse) GetHeaders ¶
func (m *AnointResponse) GetHeaders() primitive.ResponseHeaders
func (*AnointResponse) GetTerm ¶
func (m *AnointResponse) GetTerm() Term
func (*AnointResponse) Marshal ¶
func (m *AnointResponse) Marshal() (dAtA []byte, err 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 EnterRequest ¶
type EnterRequest struct { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` 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 ¶ added in v0.4.1
func (m *EnterRequest) GetCandidateID() string
func (*EnterRequest) GetHeaders ¶
func (m *EnterRequest) GetHeaders() primitive.RequestHeaders
func (*EnterRequest) Marshal ¶
func (m *EnterRequest) Marshal() (dAtA []byte, err 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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Term Term `protobuf:"bytes,2,opt,name=term,proto3" json:"term"` }
func (*EnterResponse) Descriptor ¶
func (*EnterResponse) Descriptor() ([]byte, []int)
func (*EnterResponse) GetHeaders ¶
func (m *EnterResponse) GetHeaders() primitive.ResponseHeaders
func (*EnterResponse) GetTerm ¶
func (m *EnterResponse) GetTerm() Term
func (*EnterResponse) Marshal ¶
func (m *EnterResponse) Marshal() (dAtA []byte, err 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 Event ¶
type Event struct { Type Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.election.Event_Type" json:"type,omitempty"` Term Term `protobuf:"bytes,2,opt,name=term,proto3" json:"term"` }
func (*Event) Descriptor ¶
func (*Event) GetType ¶
func (m *Event) GetType() Event_Type
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type Event_Type ¶
type Event_Type int32
const ( Event_NONE Event_Type = 0 Event_CHANGED Event_Type = 1 )
func (Event_Type) EnumDescriptor ¶
func (Event_Type) EnumDescriptor() ([]byte, []int)
func (Event_Type) String ¶
func (x Event_Type) String() string
type EventsRequest ¶
type EventsRequest struct {
Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}
func (*EventsRequest) Descriptor ¶
func (*EventsRequest) Descriptor() ([]byte, []int)
func (*EventsRequest) GetHeaders ¶
func (m *EventsRequest) GetHeaders() primitive.RequestHeaders
func (*EventsRequest) Marshal ¶
func (m *EventsRequest) Marshal() (dAtA []byte, err error)
func (*EventsRequest) MarshalToSizedBuffer ¶
func (m *EventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventsRequest) ProtoMessage ¶
func (*EventsRequest) ProtoMessage()
func (*EventsRequest) Reset ¶
func (m *EventsRequest) Reset()
func (*EventsRequest) Size ¶
func (m *EventsRequest) Size() (n int)
func (*EventsRequest) String ¶
func (m *EventsRequest) String() string
func (*EventsRequest) Unmarshal ¶
func (m *EventsRequest) Unmarshal(dAtA []byte) error
func (*EventsRequest) XXX_DiscardUnknown ¶
func (m *EventsRequest) XXX_DiscardUnknown()
func (*EventsRequest) XXX_Marshal ¶
func (m *EventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventsRequest) XXX_Merge ¶
func (m *EventsRequest) XXX_Merge(src proto.Message)
func (*EventsRequest) XXX_Size ¶
func (m *EventsRequest) XXX_Size() int
func (*EventsRequest) XXX_Unmarshal ¶
func (m *EventsRequest) XXX_Unmarshal(b []byte) error
type EventsResponse ¶
type EventsResponse struct { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Event Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event"` }
func (*EventsResponse) Descriptor ¶
func (*EventsResponse) Descriptor() ([]byte, []int)
func (*EventsResponse) GetEvent ¶
func (m *EventsResponse) GetEvent() Event
func (*EventsResponse) GetHeaders ¶
func (m *EventsResponse) GetHeaders() primitive.ResponseHeaders
func (*EventsResponse) Marshal ¶
func (m *EventsResponse) Marshal() (dAtA []byte, err error)
func (*EventsResponse) MarshalToSizedBuffer ¶
func (m *EventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventsResponse) ProtoMessage ¶
func (*EventsResponse) ProtoMessage()
func (*EventsResponse) Reset ¶
func (m *EventsResponse) Reset()
func (*EventsResponse) Size ¶
func (m *EventsResponse) Size() (n int)
func (*EventsResponse) String ¶
func (m *EventsResponse) String() string
func (*EventsResponse) Unmarshal ¶
func (m *EventsResponse) Unmarshal(dAtA []byte) error
func (*EventsResponse) XXX_DiscardUnknown ¶
func (m *EventsResponse) XXX_DiscardUnknown()
func (*EventsResponse) XXX_Marshal ¶
func (m *EventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventsResponse) XXX_Merge ¶
func (m *EventsResponse) XXX_Merge(src proto.Message)
func (*EventsResponse) XXX_Size ¶
func (m *EventsResponse) XXX_Size() int
func (*EventsResponse) XXX_Unmarshal ¶
func (m *EventsResponse) XXX_Unmarshal(b []byte) error
type EvictRequest ¶
type EvictRequest struct { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` 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) GetHeaders ¶
func (m *EvictRequest) GetHeaders() primitive.RequestHeaders
func (*EvictRequest) Marshal ¶
func (m *EvictRequest) Marshal() (dAtA []byte, err 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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Term Term `protobuf:"bytes,2,opt,name=term,proto3" json:"term"` }
func (*EvictResponse) Descriptor ¶
func (*EvictResponse) Descriptor() ([]byte, []int)
func (*EvictResponse) GetHeaders ¶
func (m *EvictResponse) GetHeaders() primitive.ResponseHeaders
func (*EvictResponse) GetTerm ¶
func (m *EvictResponse) GetTerm() Term
func (*EvictResponse) Marshal ¶
func (m *EvictResponse) Marshal() (dAtA []byte, err 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 {
Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}
func (*GetTermRequest) Descriptor ¶
func (*GetTermRequest) Descriptor() ([]byte, []int)
func (*GetTermRequest) GetHeaders ¶
func (m *GetTermRequest) GetHeaders() primitive.RequestHeaders
func (*GetTermRequest) Marshal ¶
func (m *GetTermRequest) Marshal() (dAtA []byte, err 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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Term Term `protobuf:"bytes,2,opt,name=term,proto3" json:"term"` }
func (*GetTermResponse) Descriptor ¶
func (*GetTermResponse) Descriptor() ([]byte, []int)
func (*GetTermResponse) GetHeaders ¶
func (m *GetTermResponse) GetHeaders() primitive.ResponseHeaders
func (*GetTermResponse) GetTerm ¶
func (m *GetTermResponse) GetTerm() Term
func (*GetTermResponse) Marshal ¶
func (m *GetTermResponse) Marshal() (dAtA []byte, err 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 { // 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 *EventsRequest, 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 { // 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(*EventsRequest, LeaderElectionService_EventsServer) error }
LeaderElectionServiceServer is the server API for LeaderElectionService service.
type LeaderElectionService_EventsClient ¶
type LeaderElectionService_EventsClient interface { Recv() (*EventsResponse, error) grpc.ClientStream }
type LeaderElectionService_EventsServer ¶
type LeaderElectionService_EventsServer interface { Send(*EventsResponse) error grpc.ServerStream }
type PromoteRequest ¶
type PromoteRequest struct { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` 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) GetHeaders ¶
func (m *PromoteRequest) GetHeaders() primitive.RequestHeaders
func (*PromoteRequest) Marshal ¶
func (m *PromoteRequest) Marshal() (dAtA []byte, err 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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Term Term `protobuf:"bytes,2,opt,name=term,proto3" json:"term"` }
func (*PromoteResponse) Descriptor ¶
func (*PromoteResponse) Descriptor() ([]byte, []int)
func (*PromoteResponse) GetHeaders ¶
func (m *PromoteResponse) GetHeaders() primitive.ResponseHeaders
func (*PromoteResponse) GetTerm ¶
func (m *PromoteResponse) GetTerm() Term
func (*PromoteResponse) Marshal ¶
func (m *PromoteResponse) Marshal() (dAtA []byte, err 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 { meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"` Leader string `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"` Candidates []string `protobuf:"bytes,3,rep,name=candidates,proto3" json:"candidates,omitempty"` }
func (*Term) Descriptor ¶
func (*Term) GetCandidates ¶
func (*Term) ProtoMessage ¶
func (*Term) ProtoMessage()
func (*Term) XXX_DiscardUnknown ¶
func (m *Term) XXX_DiscardUnknown()
func (*Term) XXX_Unmarshal ¶
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) Enter ¶
func (*UnimplementedLeaderElectionServiceServer) Enter(ctx context.Context, req *EnterRequest) (*EnterResponse, error)
func (*UnimplementedLeaderElectionServiceServer) Events ¶
func (*UnimplementedLeaderElectionServiceServer) Events(req *EventsRequest, 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 { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` 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 ¶ added in v0.4.1
func (m *WithdrawRequest) GetCandidateID() string
func (*WithdrawRequest) GetHeaders ¶
func (m *WithdrawRequest) GetHeaders() primitive.RequestHeaders
func (*WithdrawRequest) Marshal ¶
func (m *WithdrawRequest) Marshal() (dAtA []byte, err 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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Term Term `protobuf:"bytes,2,opt,name=term,proto3" json:"term"` }
func (*WithdrawResponse) Descriptor ¶
func (*WithdrawResponse) Descriptor() ([]byte, []int)
func (*WithdrawResponse) GetHeaders ¶
func (m *WithdrawResponse) GetHeaders() primitive.ResponseHeaders
func (*WithdrawResponse) GetTerm ¶
func (m *WithdrawResponse) GetTerm() Term
func (*WithdrawResponse) Marshal ¶
func (m *WithdrawResponse) Marshal() (dAtA []byte, err 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
Click to show internal directories.
Click to hide internal directories.