Documentation ¶
Overview ¶
Code generated by atomix-go-framework. DO NOT EDIT.
Index ¶
- Constants
- func NewProxyServer(client *rsm.Client, readSync bool) election.LeaderElectionServiceServer
- func Register(protocol *rsm.Protocol)
- type ProxyServer
- func (s *ProxyServer) Anoint(ctx context.Context, request *election.AnointRequest) (*election.AnointResponse, error)
- func (s *ProxyServer) Enter(ctx context.Context, request *election.EnterRequest) (*election.EnterResponse, error)
- func (s *ProxyServer) Events(request *election.EventsRequest, ...) error
- func (s *ProxyServer) Evict(ctx context.Context, request *election.EvictRequest) (*election.EvictResponse, error)
- func (s *ProxyServer) GetTerm(ctx context.Context, request *election.GetTermRequest) (*election.GetTermResponse, error)
- func (s *ProxyServer) Promote(ctx context.Context, request *election.PromoteRequest) (*election.PromoteResponse, error)
- func (s *ProxyServer) Withdraw(ctx context.Context, request *election.WithdrawRequest) (*election.WithdrawResponse, error)
Constants ¶
View Source
const Type = "Election"
Variables ¶
This section is empty.
Functions ¶
func NewProxyServer ¶
func NewProxyServer(client *rsm.Client, readSync bool) election.LeaderElectionServiceServer
NewProxyServer creates a new ProxyServer
Types ¶
type ProxyServer ¶
func (*ProxyServer) Anoint ¶
func (s *ProxyServer) Anoint(ctx context.Context, request *election.AnointRequest) (*election.AnointResponse, error)
func (*ProxyServer) Enter ¶
func (s *ProxyServer) Enter(ctx context.Context, request *election.EnterRequest) (*election.EnterResponse, error)
func (*ProxyServer) Events ¶
func (s *ProxyServer) Events(request *election.EventsRequest, srv election.LeaderElectionService_EventsServer) error
func (*ProxyServer) Evict ¶
func (s *ProxyServer) Evict(ctx context.Context, request *election.EvictRequest) (*election.EvictResponse, error)
func (*ProxyServer) GetTerm ¶
func (s *ProxyServer) GetTerm(ctx context.Context, request *election.GetTermRequest) (*election.GetTermResponse, error)
func (*ProxyServer) Promote ¶
func (s *ProxyServer) Promote(ctx context.Context, request *election.PromoteRequest) (*election.PromoteResponse, error)
func (*ProxyServer) Withdraw ¶
func (s *ProxyServer) Withdraw(ctx context.Context, request *election.WithdrawRequest) (*election.WithdrawResponse, error)
Click to show internal directories.
Click to hide internal directories.