rpc

Documentation

Overview

Package rpc provides internal gRPC utilities.

Index

• func RunServer(r io.Reader, w io.Writer, svcs []*testing.Service) error
• type Client
  • func Dial(ctx context.Context, d *dut.DUT, h *testing.RPCHint, bundleName string) (*Client, error)
  • func (c *Client) Close(ctx context.Context) error

Functions

func RunServer

func RunServer(r io.Reader, w io.Writer, svcs []*testing.Service) error

RunServer runs a gRPC server providing svcs on r/w channels. It blocks until the client connection is closed or it encounters an error.

Types

type Client

type Client struct {
	// Conn is the gRPC connection. Use this to create gRPC service stubs.
	Conn *grpc.ClientConn
	// contains filtered or unexported fields
}

Client owns a gRPC connection to the DUT for remote tests to use.

func Dial

func Dial(ctx context.Context, d *dut.DUT, h *testing.RPCHint, bundleName string) (*Client, error)

Dial establishes a gRPC connection to the test bundle executable named bundleName using d and h.

Example:

cl, err := rpc.Dial(ctx, d, s.RPCHint(), "cros")
if err != nil {
	return err
}
defer cl.Close(ctx)

fs := base.NewFileSystemClient(cl.Conn)

res, err := fs.ReadDir(ctx, &base.ReadDirRequest{Dir: "/mnt/stateful_partition"})
if err != nil {
	return err
}

func (*Client) Close

func (c *Client) Close(ctx context.Context) error

Close closes this client.