// Copyright 2018 Google LLC // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package pstest_test import ( "context" "cloud.google.com/go/pubsub" "cloud.google.com/go/pubsub/pstest" "google.golang.org/api/option" "google.golang.org/grpc" ) func ExampleNewServer() { 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. }