Skip to content

Commit 5efd053

Browse files
committed
Implement GetOperatorStateWithQuorum
1 parent 40b366d commit 5efd053

File tree

2 files changed

+10
-1
lines changed

2 files changed

+10
-1
lines changed

pkg/console/operator/operator.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -261,7 +261,7 @@ type configSet struct {
261261
func (c *consoleOperator) Sync(ctx context.Context, controllerContext factory.SyncContext) error {
262262
operatorConfig, err := c.consoleOperatorLister.Get(api.ConfigResourceName)
263263
if err != nil {
264-
klog.Error("failed to retrieve operator config: %v", err)
264+
klog.Errorf("failed to retrieve operator config: %v", err)
265265
return err
266266
}
267267

pkg/console/operatorclient/operatorclient.go

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,3 +71,12 @@ func (c *OperatorClient) UpdateOperatorStatus(ctx context.Context, resourceVersi
7171

7272
return &ret.Status.OperatorStatus, nil
7373
}
74+
75+
func (c OperatorClient) GetOperatorStateWithQuorum(ctx context.Context) (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error) {
76+
instance, err := c.Client.Consoles().Get(ctx, api.ConfigResourceName, metav1.GetOptions{})
77+
if err != nil {
78+
return nil, nil, "", err
79+
}
80+
81+
return &instance.Spec.OperatorSpec, &instance.Status.OperatorStatus, instance.GetResourceVersion(), nil
82+
}

0 commit comments

Comments
 (0)