|
|
@ -130,7 +130,7 @@ func getStatusWatcher(factory Factory) (watcher.StatusWatcher, error) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// New creates a new Client.
|
|
|
|
// New creates a new Client.
|
|
|
|
func New(getter genericclioptions.RESTClientGetter, waiter Waiter) *Client {
|
|
|
|
func New(getter genericclioptions.RESTClientGetter, waiter Waiter) (*Client, error) {
|
|
|
|
if getter == nil {
|
|
|
|
if getter == nil {
|
|
|
|
getter = genericclioptions.NewConfigFlags(true)
|
|
|
|
getter = genericclioptions.NewConfigFlags(true)
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -138,9 +138,7 @@ func New(getter genericclioptions.RESTClientGetter, waiter Waiter) *Client {
|
|
|
|
if waiter == nil {
|
|
|
|
if waiter == nil {
|
|
|
|
sw, err := getStatusWatcher(factory)
|
|
|
|
sw, err := getStatusWatcher(factory)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
// TODO, likely will move how the stats watcher is created so it doesn't need to be created
|
|
|
|
return nil, err
|
|
|
|
// unless it's going to be used
|
|
|
|
|
|
|
|
panic(err)
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
waiter = &kstatusWaiter{sw, nopLogger}
|
|
|
|
waiter = &kstatusWaiter{sw, nopLogger}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -148,7 +146,7 @@ func New(getter genericclioptions.RESTClientGetter, waiter Waiter) *Client {
|
|
|
|
Factory: factory,
|
|
|
|
Factory: factory,
|
|
|
|
Log: nopLogger,
|
|
|
|
Log: nopLogger,
|
|
|
|
Waiter: waiter,
|
|
|
|
Waiter: waiter,
|
|
|
|
}
|
|
|
|
}, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
var nopLogger = func(_ string, _ ...interface{}) {}
|
|
|
|
var nopLogger = func(_ string, _ ...interface{}) {}
|
|
|
|