kubernetes/vendor/go.etcd.io/etcd/server/v3/proxy/grpcproxy/adapter/election_client_adapter.go

type es2ec …

func ElectionServerToElectionClient(es v3electionpb.ElectionServer) v3electionpb.ElectionClient { … }

func (s *es2ec) Campaign(ctx context.Context, r *v3electionpb.CampaignRequest, opts ...grpc.CallOption) (*v3electionpb.CampaignResponse, error) { … }

func (s *es2ec) Proclaim(ctx context.Context, r *v3electionpb.ProclaimRequest, opts ...grpc.CallOption) (*v3electionpb.ProclaimResponse, error) { … }

func (s *es2ec) Leader(ctx context.Context, r *v3electionpb.LeaderRequest, opts ...grpc.CallOption) (*v3electionpb.LeaderResponse, error) { … }

func (s *es2ec) Resign(ctx context.Context, r *v3electionpb.ResignRequest, opts ...grpc.CallOption) (*v3electionpb.ResignResponse, error) { … }

func (s *es2ec) Observe(ctx context.Context, in *v3electionpb.LeaderRequest, opts ...grpc.CallOption) (v3electionpb.Election_ObserveClient, error) { … }

type es2ecClientStream …

type es2ecServerStream …

func (s *es2ecClientStream) Send(rr *v3electionpb.LeaderRequest) error { … }

func (s *es2ecClientStream) Recv() (*v3electionpb.LeaderResponse, error) { … }

func (s *es2ecServerStream) Send(rr *v3electionpb.LeaderResponse) error { … }

func (s *es2ecServerStream) Recv() (*v3electionpb.LeaderRequest, error) { … }