func InitializeServer() *connectorpb.InitializeResponse {
	grpcServer = grpc.NewServer()
	return conreg.InitializeServer(grpcServer)
}
InitializeServer prepares the server for future RPC requests. It must be called before
attempting to response to any requests.
package main
import (
	"bytes"
	"io/ioutil"
	"net/http"
	"net/url"
	"strconv"
	"strings"
	statuspb "google.golang.org/genproto/googleapis/rpc/status"
	"google.golang.org/grpc"
	"google.golang.org/grpc/codes"
	conreg "github.com/GoogleCloudPlatform/declarative-resource-client-library/connector/server_registration"
	connectorpb "github.com/GoogleCloudPlatform/declarative-resource-client-library/python/proto/connector_go_proto"
)
const (
	CredentialsMetadataKey = "X-Call-Credentials"
	UserAgentMetadataKey = "User-Agent"
)
var grpcServer *grpc.Server
type BodyWriter struct {
	header http.Header
	b      bytes.Buffer
	code   int
}
func (b *BodyWriter) Header() http.Header {
	return b.header
}
func (b *BodyWriter) Write(data []byte) (int, error) {
	return b.b.Write(data)
}
func (b *BodyWriter) WriteHeader(statusCode int) {
	b.code = statusCode
}
func (b *BodyWriter) Flush() {}