grpc: google.golang.org/grpc/xds/internal/testutils/fakeserver Index | Files

package fakeserver

import "google.golang.org/grpc/xds/internal/testutils/fakeserver"

Package fakeserver provides a fake implementation of an xDS server.

Index

Package Files

server.go

type Request Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

XDSClientConn returns a grpc.ClientConn connected to the fakeServer.

Package fakeserver imports 13 packages (graph). Updated 2020-08-28. Refresh now. Tools for package owners.