This does something

Signed-off-by: Miek Gieben <miek@miek.nl>
This commit is contained in:
Miek Gieben
2020-01-13 11:51:06 +01:00
parent 519ef9ca79
commit b5008763c9
2 changed files with 18 additions and 2 deletions

View File

@@ -57,12 +57,17 @@ func New(opts Options) (*Client, error) {
case opts.Config.BalancerName == "": case opts.Config.BalancerName == "":
return nil, errors.New("xds: no xds_server name provided in options") return nil, errors.New("xds: no xds_server name provided in options")
case opts.Config.Creds == nil: case opts.Config.Creds == nil:
return nil, errors.New("xds: no credentials provided in options") fmt.Printf("%s\n", errors.New("xds: no credentials provided in options"))
case opts.Config.NodeProto == nil: case opts.Config.NodeProto == nil:
return nil, errors.New("xds: no node_proto provided in options") return nil, errors.New("xds: no node_proto provided in options")
} }
dopts := append([]grpc.DialOption{opts.Config.Creds}, opts.DialOpts...) var dopts []grpc.DialOption
if opts.Config.Creds == nil {
dopts = append([]grpc.DialOption{grpc.WithInsecure()}, opts.DialOpts...)
} else {
dopts = append([]grpc.DialOption{opts.Config.Creds}, opts.DialOpts...)
}
cc, err := grpc.Dial(opts.Config.BalancerName, dopts...) cc, err := grpc.Dial(opts.Config.BalancerName, dopts...)
if err != nil { if err != nil {
// An error from a non-blocking dial indicates something serious. // An error from a non-blocking dial indicates something serious.

View File

@@ -0,0 +1,11 @@
{
"node": {
"id": "ENVOY_NODE_ID",
"metadata": {
"TRAFFICDIRECTOR_GRPC_HOSTNAME": "trafficdirector"
}
},
"xds_servers" : [{
"server_uri": "localhost:18000"
}]
}