config/cmd: standardise error handling (#1816)
* runtime/kubernetes: remove reference to runtime cells * config/cmd: standardize error handling Co-authored-by: Asim Aslam <asim@aslam.me>
This commit is contained in:
parent
8e30ede8c7
commit
4e7621da18
@ -4,7 +4,6 @@ package cmd
|
|||||||
import (
|
import (
|
||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
"crypto/x509"
|
"crypto/x509"
|
||||||
"fmt"
|
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"math/rand"
|
"math/rand"
|
||||||
"strings"
|
"strings"
|
||||||
@ -669,7 +668,7 @@ func (c *cmd) Before(ctx *cli.Context) error {
|
|||||||
|
|
||||||
// verify the auth's service account
|
// verify the auth's service account
|
||||||
if err := authutil.Verify(*c.opts.Auth); err != nil {
|
if err := authutil.Verify(*c.opts.Auth); err != nil {
|
||||||
return err
|
logger.Fatalf("Error generating auth account: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Setup broker options.
|
// Setup broker options.
|
||||||
@ -781,7 +780,7 @@ func (c *cmd) Before(ctx *cli.Context) error {
|
|||||||
if name := ctx.String("router"); len(name) > 0 && (*c.opts.Router).String() != name {
|
if name := ctx.String("router"); len(name) > 0 && (*c.opts.Router).String() != name {
|
||||||
r, ok := c.opts.Routers[name]
|
r, ok := c.opts.Routers[name]
|
||||||
if !ok {
|
if !ok {
|
||||||
return fmt.Errorf("Router %s not found", name)
|
logger.Fatalf("Router %s not found", name)
|
||||||
}
|
}
|
||||||
|
|
||||||
// close the default router before replacing it
|
// close the default router before replacing it
|
||||||
|
Loading…
Reference in New Issue
Block a user