Documentation ¶
Index ¶
- func NewProxyServer(s electionapi.LeaderElectionServiceServer) electionapi.LeaderElectionServiceServer
- type ProxyServer
- func (s *ProxyServer) Anoint(ctx context.Context, request *electionapi.AnointRequest) (*electionapi.AnointResponse, error)
- func (s *ProxyServer) Enter(ctx context.Context, request *electionapi.EnterRequest) (*electionapi.EnterResponse, error)
- func (s *ProxyServer) Events(request *electionapi.EventsRequest, ...) error
- func (s *ProxyServer) Evict(ctx context.Context, request *electionapi.EvictRequest) (*electionapi.EvictResponse, error)
- func (s *ProxyServer) GetTerm(ctx context.Context, request *electionapi.GetTermRequest) (*electionapi.GetTermResponse, error)
- func (s *ProxyServer) Promote(ctx context.Context, request *electionapi.PromoteRequest) (*electionapi.PromoteResponse, error)
- func (s *ProxyServer) Withdraw(ctx context.Context, request *electionapi.WithdrawRequest) (*electionapi.WithdrawResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProxyServer ¶
func NewProxyServer(s electionapi.LeaderElectionServiceServer) electionapi.LeaderElectionServiceServer
NewProxyServer creates a new read-only election server
Types ¶
type ProxyServer ¶
type ProxyServer struct {
// contains filtered or unexported fields
}
ProxyServer is a read-only election primitive server
func (*ProxyServer) Anoint ¶
func (s *ProxyServer) Anoint(ctx context.Context, request *electionapi.AnointRequest) (*electionapi.AnointResponse, error)
func (*ProxyServer) Enter ¶
func (s *ProxyServer) Enter(ctx context.Context, request *electionapi.EnterRequest) (*electionapi.EnterResponse, error)
func (*ProxyServer) Events ¶
func (s *ProxyServer) Events(request *electionapi.EventsRequest, server electionapi.LeaderElectionService_EventsServer) error
func (*ProxyServer) Evict ¶
func (s *ProxyServer) Evict(ctx context.Context, request *electionapi.EvictRequest) (*electionapi.EvictResponse, error)
func (*ProxyServer) GetTerm ¶
func (s *ProxyServer) GetTerm(ctx context.Context, request *electionapi.GetTermRequest) (*electionapi.GetTermResponse, error)
func (*ProxyServer) Promote ¶
func (s *ProxyServer) Promote(ctx context.Context, request *electionapi.PromoteRequest) (*electionapi.PromoteResponse, error)
func (*ProxyServer) Withdraw ¶
func (s *ProxyServer) Withdraw(ctx context.Context, request *electionapi.WithdrawRequest) (*electionapi.WithdrawResponse, error)
Click to show internal directories.
Click to hide internal directories.