election

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)

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)