Documentation

Overview

    Package agent implements functional-tester agent server.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    This section is empty.

    Types

    type Server

    type Server struct {
    	rpcpb.TransportServer
    
    	*rpcpb.Member
    	*rpcpb.Tester
    	// contains filtered or unexported fields
    }

      Server implements "rpcpb.TransportServer" and other etcd operations as an agent no need to lock fields since request operations are serialized in tester-side

      func NewServer

      func NewServer(
      	lg *zap.Logger,
      	network string,
      	address string,
      ) *Server

        NewServer returns a new agent server.

        func (*Server) StartServe

        func (srv *Server) StartServe() error

          StartServe starts serving agent server.

          func (*Server) Stop

          func (srv *Server) Stop()

            Stop stops serving gRPC server.

            func (*Server) Transport

            func (srv *Server) Transport(stream rpcpb.Transport_TransportServer) (err error)

              Transport communicates with etcd tester.