Function newTestClient

internal/proxy/fuse_test.go:45–77

newTestClient is a convenience function for testing that creates a proxy.Client and starts it. The returned cleanup function is also a convenience. Callers may choose to ignore it and manually close the client.

(t *testing.T, d cloudsql.Dialer, fuseDir, fuseTempDir string)

// proxy.Client and starts it. The returned cleanup function is also a
// convenience. Callers may choose to ignore it and manually close the client.
func newTestClient(t *testing.T, d cloudsql.Dialer, fuseDir, fuseTempDir string) (*proxy.Client, chan error, func()) {
	conf := &proxy.Config{FUSEDir: fuseDir, FUSETempDir: fuseTempDir}

	// This context is only used to call the Cloud SQL API
	c, err := proxy.NewClient(context.Background(), d, testLogger, conf, nil)
	if err != nil {
		t.Fatalf("want error = nil, got = %v", err)
	}

	ready := make(chan struct{})
	servErrCh := make(chan error)

	ctx, cancel := context.WithCancel(context.Background())
	go func() {

		servErr := c.Serve(ctx, func() { close(ready) })
		select {
		case servErrCh <- servErr:
		case <-ctx.Done():
		}
	}()
	select {
	case <-ready:
	case <-time.Tick(5 * time.Second):
		t.Fatal("failed to Serve")
	}
	return c, servErrCh, func() {
		if cErr := c.Close(); cErr != nil {
			t.Logf("failed to close client: %v", cErr)
		}
		cancel()
	}
}

func TestFUSEREADME(t *testing.T) {
	if testing.Short() {