Documentation

Overview

    Package fakeserver provides a fake implementation of the management server.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    This section is empty.

    Types

    type Request

    type Request struct {
    	Req proto.Message
    	Err error
    }

      Request wraps the request protobuf (xds/LRS) and error received by the Server in a call to stream.Recv().

      type Response

      type Response struct {
      	Resp proto.Message
      	Err  error
      }

        Response wraps the response protobuf (xds/LRS) and error that the Server should send out to the client through a call to stream.Send()

        type Server

        type Server struct {
        	// XDSRequestChan is a channel on which received xDS requests are made
        	// available to the users of this Server.
        	XDSRequestChan *testutils.Channel
        	// XDSResponseChan is a channel on which the Server accepts xDS responses
        	// to be sent to the client.
        	XDSResponseChan chan *Response
        	// LRSRequestChan is a channel on which received LRS requests are made
        	// available to the users of this Server.
        	LRSRequestChan *testutils.Channel
        	// LRSResponseChan is a channel on which the Server accepts the LRS
        	// response to be sent to the client.
        	LRSResponseChan chan *Response
        	// NewConnChan is a channel on which the fake server notifies receipt of new
        	// connection attempts. Tests can gate on this event before proceeding to
        	// other actions which depend on a connection to the fake server being up.
        	NewConnChan *testutils.Channel
        	// Address is the host:port on which the Server is listening for requests.
        	Address string
        	// contains filtered or unexported fields
        }

          Server is a fake implementation of xDS and LRS protocols. It listens on the same port for both services and exposes a bunch of channels to send/receive messages.

          func StartServer

          func StartServer() (*Server, func(), error)

            StartServer makes a new Server and gets it to start listening on a local port for gRPC requests. The returned cancel function should be invoked by the caller upon completion of the test.

            func (*Server) XDSClientConn

            func (xdsS *Server) XDSClientConn() (*grpc.ClientConn, func(), error)

              XDSClientConn returns a grpc.ClientConn connected to the fakeServer.

              Source Files