pstest sample

pstest_sample.go

ctx := context.Background()

// Start a fake server running locally.
srv := pstest.NewServer()
defer srv.Close()

// Connect to the server without using TLS.
conn, err := grpc.Dial(srv.Addr, grpc.WithInsecure())
if err != nil {
    // TODO: Handle error.
}
defer conn.Close()

// Use the connection when creating a pubsub client.
client, err := pubsub.NewClient(ctx, "project", option.WithGRPCConn(conn))
if err != nil {
    // TODO: Handle error.
}
defer client.Close()

_ = client // TODO: Use the client.