Azure
/
ARO-RP
зеркало из https://github.com/Azure/ARO-RP.git
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность

Metrics/GenevaActions for Clustersync (#3785) 

* Metrics for SyncSet and SelectorSyncSets

merging 8659 and 9545

Metrics for SyncSet and SelectorSyncSets

* Since emitClusterSync is run unconditionally, even in environment
without Hive, make sure that it doesn't panic when the monitor's
hive.ClusterManager is nil

Compare to preexisting code in emitHiveRegistrationStatus

* Add Hive rest config and ClusterManager to monitor

---------

Co-authored-by: kimorris27 <kimorris@redhat.com>
This commit is contained in:
Amit Arora 2025-01-22 14:42:42 +05:30 коммит произвёл GitHub
Родитель e1efeb6857
Коммит 9ea0e524dd
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: B5690EEEBB952194
19 изменённых файлов: 1270 добавлений и 14 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

69
pkg/frontend/admin_hive_syncset_resources.go Normal file
Просмотреть файл

@ -0,0 +1,69 @@
package frontend
// Copyright (c) Microsoft Corporation.
// Licensed under the Apache License 2.0.
import (
"context"
"net/http"
"path/filepath"
"strings"
"github.com/sirupsen/logrus"
"github.com/ugorji/go/codec"
"github.com/Azure/ARO-RP/pkg/api"
"github.com/Azure/ARO-RP/pkg/database/cosmosdb"
"github.com/Azure/ARO-RP/pkg/frontend/middleware"
)
func (f *frontend) getAdminHiveClusterSync(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
log := ctx.Value(middleware.ContextKeyLog).(*logrus.Entry)
resourceId := strings.TrimPrefix(filepath.Dir(r.URL.Path), "/admin")
b, err := f._getAdminHiveClusterSync(ctx, resourceId)
if cloudErr, ok := err.(*api.CloudError); ok {
api.WriteCloudError(w, cloudErr)
return
}
adminReply(log, w, nil, b, err)
}
func (f *frontend) _getAdminHiveClusterSync(ctx context.Context, resourceId string) ([]byte, error) {
// We have to check if the frontend has a valid clustermanager since hive is not everywhere.
if f.hiveClusterManager == nil {
return nil, api.NewCloudError(http.StatusBadRequest, api.CloudErrorCodeInvalidParameter, "", "hive is not enabled")
}
dbOpenShiftClusters, err := f.dbGroup.OpenShiftClusters()
if err != nil {
return nil, api.NewCloudError(http.StatusInternalServerError, api.CloudErrorCodeInternalServerError, "", err.Error())
}
doc, err := dbOpenShiftClusters.Get(ctx, resourceId)
switch {
case cosmosdb.IsErrorStatusCode(err, http.StatusNotFound):
return nil, api.NewCloudError(http.StatusNotFound, api.CloudErrorCodeResourceNotFound, "", err.Error())
case err != nil:
return nil, err
}
if doc.OpenShiftCluster.Properties.HiveProfile.Namespace == "" {
return nil, api.NewCloudError(http.StatusNoContent, api.CloudErrorCodeResourceNotFound, "", "cluster is not managed by hive")
}
cd, err := f.hiveClusterManager.GetClusterSync(ctx, doc)
if err != nil {
return nil, api.NewCloudError(http.StatusNotFound, api.CloudErrorCodeNotFound, "", err.Error())
}
var b []byte
err = codec.NewEncoderBytes(&b, &codec.JsonHandle{}).Encode(cd)
if err != nil {
return nil, api.NewCloudError(http.StatusInternalServerError, api.CloudErrorCodeInternalServerError, "", err.Error())
}
return b, nil
}

116
pkg/frontend/admin_hive_syncset_resources_test.go Normal file
Просмотреть файл

@ -0,0 +1,116 @@
package frontend
// Copyright (c) Microsoft Corporation.
// Licensed under the Apache License 2.0.
import (
"context"
"fmt"
"net/http"
"strings"
"testing"
"time"
hivev1alpha1 "github.com/openshift/hive/apis/hiveinternal/v1alpha1"
"go.uber.org/mock/gomock"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"github.com/Azure/ARO-RP/pkg/api"
"github.com/Azure/ARO-RP/pkg/metrics/noop"
mock_env "github.com/Azure/ARO-RP/pkg/util/mocks/env"
mock_hive "github.com/Azure/ARO-RP/pkg/util/mocks/hive"
)
func Test_getAdminHiveClusterSync(t *testing.T) {
fakeUUID := "00000000-0000-0000-0000-000000000000"
ctx := context.Background()
clusterSync := hivev1alpha1.ClusterSync{Spec: hivev1alpha1.ClusterSyncSpec{}, Status: hivev1alpha1.ClusterSyncStatus{
SyncSets: []hivev1alpha1.SyncStatus{{Name: "syncSet1", ObservedGeneration: 0, Result: "success", LastTransitionTime: metav1.Time{Time: time.Date(2024, 7, 1, 0, 0, 0, 0, time.UTC)}}},
}}
type test struct {
name string
resourceID string
properties api.OpenShiftClusterProperties
hiveEnabled bool
expectedGetClusterSyncCallCount int
wantStatusCode int
wantResponse []byte
wantError string
}
for _, tt := range []*test{
{
name: "cluster has hive profile with namespace",
resourceID: fmt.Sprintf("/subscriptions/%s/resourcegroups/resourceGroup/providers/Microsoft.RedHatOpenShift/openShiftClusters/hive", fakeUUID),
properties: api.OpenShiftClusterProperties{HiveProfile: api.HiveProfile{Namespace: fmt.Sprintf("aro-%s", fakeUUID)}},
hiveEnabled: true,
expectedGetClusterSyncCallCount: 1,
wantResponse: []byte(`{"status":{"syncSets":[{"name":"syncSet1","observedGeneration":0,"result":"success","lastTransitionTime":"2024-07-01T00:00:00Z"}]}}`),
},
{
name: "cluster does not have hive profile with namespace",
resourceID: fmt.Sprintf("/subscriptions/%s/resourcegroups/resourceGroup/providers/Microsoft.RedHatOpenShift/openShiftClusters/nonHive", fakeUUID),
hiveEnabled: true,
expectedGetClusterSyncCallCount: 0,
wantStatusCode: http.StatusNoContent,
wantError: "204: ResourceNotFound: : cluster is not managed by hive",
},
{
name: "hive is not enabled",
resourceID: fmt.Sprintf("/subscriptions/%s/resourcegroups/resourceGroup/providers/Microsoft.RedHatOpenShift/openShiftClusters/nonHive", fakeUUID),
hiveEnabled: false,
expectedGetClusterSyncCallCount: 0,
wantStatusCode: http.StatusBadRequest,
wantError: "400: InvalidParameter: : hive is not enabled",
},
} {
t.Run(tt.name, func(t *testing.T) {
ti := newTestInfra(t).WithOpenShiftClusters().WithSubscriptions()
controller := gomock.NewController(t)
defer ti.done()
defer controller.Finish()
ti.fixture.AddOpenShiftClusterDocuments(&api.OpenShiftClusterDocument{
Key: strings.ToLower(tt.resourceID),
OpenShiftCluster: &api.OpenShiftCluster{
ID: tt.resourceID,
Name: "hive",
Type: "Microsoft.RedHatOpenShift/openshiftClusters",
Properties: tt.properties,
},
})
err := ti.buildFixtures(nil)
if err != nil {
t.Fatal(err)
}
_env := ti.env.(*mock_env.MockInterface)
var f *frontend
if tt.hiveEnabled {
clusterManager := mock_hive.NewMockClusterManager(controller)
clusterManager.EXPECT().GetClusterSync(gomock.Any(), gomock.Any()).Return(&clusterSync, nil).Times(tt.expectedGetClusterSyncCallCount)
f, err = NewFrontend(ctx, ti.audit, ti.log, _env, ti.dbGroup, api.APIs, &noop.Noop{}, &noop.Noop{}, nil, clusterManager, nil, nil, nil, nil)
} else {
f, err = NewFrontend(ctx, ti.audit, ti.log, _env, ti.dbGroup, api.APIs, &noop.Noop{}, &noop.Noop{}, nil, nil, nil, nil, nil, nil)
}
if err != nil {
t.Fatal(err)
}
hiveClusterSync, err := f._getAdminHiveClusterSync(ctx, strings.ToLower(tt.resourceID))
cloudErr, isCloudErr := err.(*api.CloudError)
if tt.wantError != "" && isCloudErr && cloudErr != nil {
if tt.wantError != cloudErr.Error() {
t.Errorf("got %q but wanted %q", cloudErr.Error(), tt.wantError)
}
if tt.wantStatusCode != 0 && tt.wantStatusCode != cloudErr.StatusCode {
t.Errorf("got %q but wanted %q", cloudErr.Error(), tt.wantError)
}
}
if !strings.EqualFold(string(hiveClusterSync), string(tt.wantResponse)) {
t.Errorf("got %q and expected %q", hiveClusterSync, tt.wantResponse)
}
})
}
}

2
pkg/frontend/frontend.go
Просмотреть файл

@ -314,6 +314,8 @@ func (f *frontend) chiAuthenticatedRoutes(router chi.Router) {
r.Get("/clusterdeployment", f.getAdminHiveClusterDeployment)
r.Get("/clustersync", f.getAdminHiveClusterSync)
r.With(f.maintenanceMiddleware.UnplannedMaintenanceSignal).Post("/redeployvm", f.postAdminOpenShiftClusterRedeployVM)
r.With(f.maintenanceMiddleware.UnplannedMaintenanceSignal).Post("/stopvm", f.postAdminOpenShiftClusterStopVM)

18
pkg/hive/manager.go
Просмотреть файл

@ -11,6 +11,7 @@ import (
"strings"
hivev1 "github.com/openshift/hive/apis/hive/v1"
hivev1alpha1 "github.com/openshift/hive/apis/hiveinternal/v1alpha1"
"github.com/sirupsen/logrus"
corev1 "k8s.io/api/core/v1"
kerrors "k8s.io/apimachinery/pkg/api/errors"
@ -44,6 +45,7 @@ type ClusterManager interface {
IsClusterInstallationComplete(ctx context.Context, doc *api.OpenShiftClusterDocument) (bool, error)
GetClusterDeployment(ctx context.Context, doc *api.OpenShiftClusterDocument) (*hivev1.ClusterDeployment, error)
ResetCorrelationData(ctx context.Context, doc *api.OpenShiftClusterDocument) error
GetClusterSync(ctx context.Context, doc *api.OpenShiftClusterDocument) (*hivev1alpha1.ClusterSync, error)
}
type clusterManager struct {
@ -277,3 +279,19 @@ func (hr *clusterManager) installLogsForLatestDeployment(ctx context.Context, cd
return latestProvision.Spec.InstallLog, nil
}
func (hr *clusterManager) GetClusterSync(ctx context.Context, doc *api.OpenShiftClusterDocument) (*hivev1alpha1.ClusterSync, error) {
clusterSync := &hivev1alpha1.ClusterSync{}
key := client.ObjectKey{
Name: ClusterDeploymentName, // "cluster",
Namespace: doc.OpenShiftCluster.Properties.HiveProfile.Namespace,
}
err := hr.hiveClientset.Get(ctx, key, clusterSync)
if err != nil {
return nil, err
}
return clusterSync, nil
}

50
pkg/hive/manager_test.go
Просмотреть файл

@ -10,6 +10,7 @@ import (
"testing"
hivev1 "github.com/openshift/hive/apis/hive/v1"
hivev1alpha1 "github.com/openshift/hive/apis/hiveinternal/v1alpha1"
"github.com/sirupsen/logrus"
"go.uber.org/mock/gomock"
corev1 "k8s.io/api/core/v1"
@ -566,3 +567,52 @@ func TestGetClusterDeployment(t *testing.T) {
})
}
}
func TestGetClusterSyncforClusterDeployment(t *testing.T) {
fakeNamespace := "aro-00000000-0000-0000-0000-000000000000"
doc := &api.OpenShiftClusterDocument{
OpenShiftCluster: &api.OpenShiftCluster{
Properties: api.OpenShiftClusterProperties{
HiveProfile: api.HiveProfile{
Namespace: fakeNamespace,
},
},
},
}
cs := &hivev1alpha1.ClusterSync{
ObjectMeta: metav1.ObjectMeta{
Name: ClusterDeploymentName,
Namespace: fakeNamespace,
},
}
for _, tt := range []struct {
name string
wantErr string
}{
{name: "syncset exists and returned"},
{name: "syncset does not exist err returned", wantErr: `clustersyncs.hiveinternal.openshift.io "cluster" not found`},
} {
t.Run(tt.name, func(t *testing.T) {
fakeClientBuilder := fake.NewClientBuilder()
if tt.wantErr == "" {
fakeClientBuilder = fakeClientBuilder.WithRuntimeObjects(cs)
}
c := clusterManager{
hiveClientset: fakeClientBuilder.Build(),
log: logrus.NewEntry(logrus.StandardLogger()),
}
result, err := c.GetClusterSync(context.Background(), doc)
if err != nil && err.Error() != tt.wantErr ||
err == nil && tt.wantErr != "" {
t.Error(err)
}
if result != nil && result.Name != cs.Name && result.Namespace != cs.Namespace {
t.Error("Unexpected cluster sync returned", result)
}
})
}
}

30
pkg/monitor/cluster/cluster.go
Просмотреть файл

@ -22,6 +22,7 @@ import (
"sigs.k8s.io/controller-runtime/pkg/client/apiutil"
"github.com/Azure/ARO-RP/pkg/api"
"github.com/Azure/ARO-RP/pkg/hive"
"github.com/Azure/ARO-RP/pkg/metrics"
"github.com/Azure/ARO-RP/pkg/monitor/dimension"
"github.com/Azure/ARO-RP/pkg/monitor/emitter"
@ -60,10 +61,12 @@ type Monitor struct {
arodl *appsv1.DeploymentList
}
wg *sync.WaitGroup
wg *sync.WaitGroup
hiveClusterManager hive.ClusterManager
doc *api.OpenShiftClusterDocument
}
func NewMonitor(log *logrus.Entry, restConfig *rest.Config, oc *api.OpenShiftCluster, m metrics.Emitter, hiveRestConfig *rest.Config, hourlyRun bool, wg *sync.WaitGroup) (*Monitor, error) {
func NewMonitor(log *logrus.Entry, restConfig *rest.Config, oc *api.OpenShiftCluster, doc *api.OpenShiftClusterDocument, m metrics.Emitter, hiveRestConfig *rest.Config, hourlyRun bool, wg *sync.WaitGroup, hiveClusterManager hive.ClusterManager) (*Monitor, error) {
r, err := azure.ParseResourceID(oc.ID)
if err != nil {
return nil, err
@ -126,16 +129,18 @@ func NewMonitor(log *logrus.Entry, restConfig *rest.Config, oc *api.OpenShiftClu
oc: oc,
dims: dims,
restconfig: restConfig,
cli: cli,
configcli: configcli,
maocli: maocli,
mcocli: mcocli,
arocli: arocli,
m: m,
ocpclientset: ocpclientset,
hiveclientset: hiveclientset,
wg: wg,
restconfig: restConfig,
cli: cli,
configcli: configcli,
maocli: maocli,
mcocli: mcocli,
arocli: arocli,
m: m,
ocpclientset: ocpclientset,
hiveclientset: hiveclientset,
wg: wg,
hiveClusterManager: hiveClusterManager,
doc: doc,
}, nil
}
@ -208,6 +213,7 @@ func (mon *Monitor) Monitor(ctx context.Context) (errs []error) {
mon.emitJobConditions,
mon.emitSummary,
mon.emitHiveRegistrationStatus,
mon.emitClusterSync,
mon.emitOperatorFlagsAndSupportBanner,
mon.emitMaintenanceState,
mon.emitCertificateExpirationStatuses,

79
pkg/monitor/cluster/clustersync.go Normal file
Просмотреть файл

@ -0,0 +1,79 @@
package cluster
// Copyright (c) Microsoft Corporation.
// Licensed under the Apache License 2.0.
import (
"context"
"github.com/sirupsen/logrus"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
func (mon *Monitor) emitClusterSync(ctx context.Context) error {
if mon.hiveClusterManager == nil {
// TODO(hive): remove this once we have Hive everywhere.
mon.log.Info("skipping: no hive cluster manager")
return nil
}
clusterSync, err := mon.hiveClusterManager.GetClusterSync(ctx, mon.doc)
if err != nil {
return err
}
if clusterSync == nil {
return nil
} else {
if clusterSync.Status.SyncSets == nil {
return nil
} else {
for _, s := range clusterSync.Status.SyncSets {
mon.emitGauge("hive.clustersync", 1, map[string]string{
"syncType": "SyncSets",
"name": s.Name,
"result": string(s.Result),
})
if mon.hourlyRun {
mon.log.WithFields(logrus.Fields{
"syncType": "SyncSets",
"name": s.Name,
"result": string(s.Result),
"firstSuccessTime": timeToString(s.FirstSuccessTime),
"lastTransitionTime": timeToString(&s.LastTransitionTime),
"failureMessage": s.FailureMessage,
}).Print()
}
}
}
if clusterSync.Status.SelectorSyncSets == nil {
return nil
} else {
for _, s := range clusterSync.Status.SelectorSyncSets {
mon.emitGauge("hive.clustersync", 1, map[string]string{
"syncType": "SelectorSyncSets",
"name": s.Name,
"result": string(s.Result),
})
if mon.hourlyRun {
mon.log.WithFields(logrus.Fields{
"syncType": "SelectorSyncSets",
"name": s.Name,
"result": string(s.Result),
"firstSuccessTime": timeToString(s.FirstSuccessTime),
"lastTransitionTime": timeToString(&s.LastTransitionTime),
"failureMessage": s.FailureMessage,
}).Print()
}
}
}
}
return nil
}
func timeToString(t *metav1.Time) string {
if t == nil {
return ""
}
return t.String()
}

209
pkg/monitor/cluster/clustersync_test.go Normal file
Просмотреть файл

@ -0,0 +1,209 @@
package cluster
// Copyright (c) Microsoft Corporation.
// Licensed under the Apache License 2.0.
import (
"context"
"errors"
"testing"
"time"
hivev1alpha1 "github.com/openshift/hive/apis/hiveinternal/v1alpha1"
"github.com/sirupsen/logrus"
"github.com/sirupsen/logrus/hooks/test"
"github.com/stretchr/testify/assert"
"go.uber.org/mock/gomock"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"github.com/Azure/ARO-RP/pkg/hive"
mock_hive "github.com/Azure/ARO-RP/pkg/util/mocks/hive"
mock_metrics "github.com/Azure/ARO-RP/pkg/util/mocks/metrics"
)
func TestEmitClusterSync(t *testing.T) {
for _, tt := range []struct {
name string
withClusterManager bool
clusterSync *hivev1alpha1.ClusterSync
getClusterSyncErr error
expectedError error
expectedGauges []struct {
name string
value int64
labels map[string]string
}
wantLog string
}{
{
name: "Don't do anything because Monitor does not have a Hive ClusterManager",
withClusterManager: false,
wantLog: "skipping: no hive cluster manager",
},
{
name: "SyncSets and SelectorSyncSets have elements",
withClusterManager: true,
clusterSync: &hivev1alpha1.ClusterSync{
Status: hivev1alpha1.ClusterSyncStatus{
SyncSets: []hivev1alpha1.SyncStatus{
{
Name: "syncset1",
Result: "Success",
FirstSuccessTime: &metav1.Time{Time: time.Now()},
LastTransitionTime: metav1.Time{Time: time.Now()},
FailureMessage: "",
},
},
SelectorSyncSets: []hivev1alpha1.SyncStatus{
{
Name: "selectorsyncset1",
Result: "Success",
FirstSuccessTime: &metav1.Time{Time: time.Now()},
LastTransitionTime: metav1.Time{Time: time.Now()},
FailureMessage: "",
},
},
},
},
expectedError: nil,
expectedGauges: []struct {
name string
value int64
labels map[string]string
}{
{
name: "hive.clustersync",
value: 1,
labels: map[string]string{
"syncType": "SyncSets",
"name": "syncset1",
"result": "Success",
},
},
{
name: "hive.clustersync",
value: 1,
labels: map[string]string{
"syncType": "SelectorSyncSets",
"name": "selectorsyncset1",
"result": "Success",
},
},
},
},
{
name: "SyncSets and SelectorSyncSets have success and failure",
withClusterManager: true,
clusterSync: &hivev1alpha1.ClusterSync{
Status: hivev1alpha1.ClusterSyncStatus{
SyncSets: []hivev1alpha1.SyncStatus{
{
Name: "syncset2",
Result: "Failure",
FirstSuccessTime: &metav1.Time{Time: time.Now()},
LastTransitionTime: metav1.Time{Time: time.Now()},
FailureMessage: "",
},
},
SelectorSyncSets: []hivev1alpha1.SyncStatus{
{
Name: "selectorsyncset2",
Result: "Success",
FirstSuccessTime: &metav1.Time{Time: time.Now()},
LastTransitionTime: metav1.Time{Time: time.Now()},
FailureMessage: "",
},
},
},
},
expectedError: nil,
expectedGauges: []struct {
name string
value int64
labels map[string]string
}{
{
name: "hive.clustersync",
value: 1,
labels: map[string]string{
"syncType": "SyncSets",
"name": "syncset2",
"result": "Failure",
},
},
{
name: "hive.clustersync",
value: 1,
labels: map[string]string{
"syncType": "SelectorSyncSets",
"name": "selectorsyncset2",
"result": "Success",
},
},
},
},
{
name: "SyncSets and SelectorSyncSets are nil",
withClusterManager: true,
clusterSync: &hivev1alpha1.ClusterSync{
Status: hivev1alpha1.ClusterSyncStatus{
SyncSets: nil,
SelectorSyncSets: nil,
},
},
expectedError: nil,
expectedGauges: []struct {
name string
value int64
labels map[string]string
}{},
},
{
name: "GetSyncSetResources returns error",
withClusterManager: true,
getClusterSyncErr: errors.New("some error"),
expectedError: errors.New("some error"),
expectedGauges: []struct {
name string
value int64
labels map[string]string
}{},
},
} {
t.Run(tt.name, func(t *testing.T) {
ctrl := gomock.NewController(t)
defer ctrl.Finish()
ctx := context.Background()
var mockHiveClusterManager hive.ClusterManager
if tt.withClusterManager {
_mockHiveClusterManager := mock_hive.NewMockClusterManager(ctrl)
_mockHiveClusterManager.EXPECT().GetClusterSync(ctx, gomock.Any()).Return(tt.clusterSync, tt.getClusterSyncErr).AnyTimes()
mockHiveClusterManager = _mockHiveClusterManager
}
m := mock_metrics.NewMockEmitter(ctrl)
logger, hook := test.NewNullLogger()
log := logrus.NewEntry(logger)
mockMonitor := &Monitor{
hiveClusterManager: mockHiveClusterManager,
m: m,
log: log,
}
for _, gauge := range tt.expectedGauges {
m.EXPECT().EmitGauge(gauge.name, gauge.value, gauge.labels).Times(1)
}
err := mockMonitor.emitClusterSync(ctx)
assert.Equal(t, tt.expectedError, err)
if tt.wantLog != "" {
x := hook.LastEntry()
assert.Equal(t, tt.wantLog, x.Message)
}
})
}
}

11
pkg/monitor/worker.go
Просмотреть файл

@ -15,6 +15,8 @@ import (
"k8s.io/client-go/rest"
"github.com/Azure/ARO-RP/pkg/api"
"github.com/Azure/ARO-RP/pkg/env"
"github.com/Azure/ARO-RP/pkg/hive"
"github.com/Azure/ARO-RP/pkg/monitor/azure/nsg"
"github.com/Azure/ARO-RP/pkg/monitor/cluster"
"github.com/Azure/ARO-RP/pkg/monitor/dimension"
@ -281,9 +283,16 @@ func (mon *monitor) workOne(ctx context.Context, log *logrus.Entry, doc *api.Ope
var monitors []monitoring.Monitor
var wg sync.WaitGroup
_env, err := env.NewEnv(ctx, log, env.COMPONENT_MONITOR)
if err != nil {
log.Error(err)
return
}
hiveClusterManager, _ := hive.NewFromConfig(log, _env, hiveRestConfig)
nsgMon := nsg.NewMonitor(log, doc.OpenShiftCluster, mon.env, sub.ID, sub.Subscription.Properties.TenantID, mon.clusterm, dims, &wg, nsgMonTicker.C)
c, err := cluster.NewMonitor(log, restConfig, doc.OpenShiftCluster, mon.clusterm, hiveRestConfig, hourlyRun, &wg)
c, err := cluster.NewMonitor(log, restConfig, doc.OpenShiftCluster, doc, mon.clusterm, hiveRestConfig, hourlyRun, &wg, hiveClusterManager)
if err != nil {
log.Error(err)
mon.m.EmitGauge("monitor.cluster.failedworker", 1, map[string]string{

16
pkg/util/mocks/hive/hive.go
Просмотреть файл

@ -14,6 +14,7 @@ import (
reflect "reflect"
v1 "github.com/openshift/hive/apis/hive/v1"
v1alpha1 "github.com/openshift/hive/apis/hiveinternal/v1alpha1"
gomock "go.uber.org/mock/gomock"
v10 "k8s.io/api/core/v1"
runtime "k8s.io/apimachinery/pkg/runtime"
@ -102,6 +103,21 @@ func (mr *MockClusterManagerMockRecorder) GetClusterDeployment(arg0, arg1 any) *
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetClusterDeployment", reflect.TypeOf((*MockClusterManager)(nil).GetClusterDeployment), arg0, arg1)
}
// GetClusterSync mocks base method.
func (m *MockClusterManager) GetClusterSync(arg0 context.Context, arg1 *api.OpenShiftClusterDocument) (*v1alpha1.ClusterSync, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "GetClusterSync", arg0, arg1)
ret0, _ := ret[0].(*v1alpha1.ClusterSync)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetClusterSync indicates an expected call of GetClusterSync.
func (mr *MockClusterManagerMockRecorder) GetClusterSync(arg0, arg1 any) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetClusterSync", reflect.TypeOf((*MockClusterManager)(nil).GetClusterSync), arg0, arg1)
}
// Install mocks base method.
func (m *MockClusterManager) Install(arg0 context.Context, arg1 *api.SubscriptionDocument, arg2 *api.OpenShiftClusterDocument, arg3 *api.OpenShiftVersion, arg4 map[string]runtime.Object) error {
m.ctrl.T.Helper()

2
pkg/util/scheme/scheme.go
Просмотреть файл

@ -14,6 +14,7 @@ import (
securityv1 "github.com/openshift/api/security/v1"
cloudcredentialv1 "github.com/openshift/cloud-credential-operator/pkg/apis/cloudcredential/v1"
hivev1 "github.com/openshift/hive/apis/hive/v1"
hivev1alpha1 "github.com/openshift/hive/apis/hiveinternal/v1alpha1"
mcv1 "github.com/openshift/machine-config-operator/pkg/apis/machineconfiguration.openshift.io/v1"
monitoringv1 "github.com/prometheus-operator/prometheus-operator/pkg/apis/monitoring/v1"
appsv1 "k8s.io/api/apps/v1"
@ -51,6 +52,7 @@ func init() {
utilruntime.Must(operatorv1.AddToScheme(scheme.Scheme))
utilruntime.Must(cloudcredentialv1.AddToScheme(scheme.Scheme))
utilruntime.Must(hivev1.AddToScheme(scheme.Scheme))
utilruntime.Must(hivev1alpha1.AddToScheme(scheme.Scheme))
utilruntime.Must(imageregistryv1.AddToScheme(scheme.Scheme))
utilruntime.Must(templatesv1.AddToScheme(scheme.Scheme))
}

4
test/e2e/monitor.go
Просмотреть файл

@ -23,7 +23,9 @@ var _ = Describe("Monitor", func() {
wg.Add(1)
mon, err := cluster.NewMonitor(log, clients.RestConfig, &api.OpenShiftCluster{
ID: resourceIDFromEnv(),
}, &noop.Noop{}, nil, true, &wg)
}, &api.OpenShiftClusterDocument{
ID: resourceIDFromEnv(),
}, &noop.Noop{}, nil, true, &wg, nil)
Expect(err).NotTo(HaveOccurred())
By("running the monitor once")

163
vendor/github.com/openshift/hive/apis/hiveinternal/v1alpha1/clustersync_types.go сгенерированный поставляемый Normal file
Просмотреть файл

@ -0,0 +1,163 @@
package v1alpha1
import (
hivev1 "github.com/openshift/hive/apis/hive/v1"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// ClusterSync is the status of all of the SelectorSyncSets and SyncSets that apply to a ClusterDeployment.
// +k8s:openapi-gen=true
// +kubebuilder:subresource:status
// +kubebuilder:resource:path=clustersyncs,shortName=csync,scope=Namespaced
// +kubebuilder:printcolumn:name="Status",type=string,JSONPath=`.status.conditions[0].reason`
// +kubebuilder:printcolumn:name="Message",type=string,priority=1,JSONPath=`.status.conditions[?(@.type=="Failed")].message`
type ClusterSync struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ClusterSyncSpec `json:"spec,omitempty"`
Status ClusterSyncStatus `json:"status,omitempty"`
}
// ClusterSyncSpec defines the desired state of ClusterSync
type ClusterSyncSpec struct{}
// ClusterSyncStatus defines the observed state of ClusterSync
type ClusterSyncStatus struct {
// SyncSets is the sync status of all of the SyncSets for the cluster.
// +optional
SyncSets []SyncStatus `json:"syncSets,omitempty"`
// SelectorSyncSets is the sync status of all of the SelectorSyncSets for the cluster.
// +optional
SelectorSyncSets []SyncStatus `json:"selectorSyncSets,omitempty"`
// Conditions is a list of conditions associated with syncing to the cluster.
// +optional
Conditions []ClusterSyncCondition `json:"conditions,omitempty"`
// FirstSuccessTime is the time we first successfully applied all (selector)syncsets to a cluster.
// +optional
FirstSuccessTime *metav1.Time `json:"firstSuccessTime,omitempty"`
// ControlledByReplica indicates which replica of the hive-clustersync StatefulSet is responsible
// for (the CD related to) this clustersync. Note that this value indicates the replica that most
// recently handled the ClusterSync. If the hive-clustersync statefulset is scaled up or down, the
// controlling replica can change, potentially causing logs to be spread across multiple pods.
ControlledByReplica *int64 `json:"controlledByReplica,omitempty"`
}
// SyncStatus is the status of applying a specific SyncSet or SelectorSyncSet to the cluster.
type SyncStatus struct {
// Name is the name of the SyncSet or SelectorSyncSet.
Name string `json:"name"`
// ObservedGeneration is the generation of the SyncSet or SelectorSyncSet that was last observed.
ObservedGeneration int64 `json:"observedGeneration"`
// ResourcesToDelete is the list of resources in the cluster that should be deleted when the SyncSet or SelectorSyncSet
// is deleted or is no longer matched to the cluster.
// +optional
ResourcesToDelete []SyncResourceReference `json:"resourcesToDelete,omitempty"`
// Result is the result of the last attempt to apply the SyncSet or SelectorSyncSet to the cluster.
Result SyncSetResult `json:"result"`
// FailureMessage is a message describing why the SyncSet or SelectorSyncSet could not be applied. This is only
// set when Result is Failure.
// +optional
FailureMessage string `json:"failureMessage,omitempty"`
// LastTransitionTime is the time when this status last changed.
LastTransitionTime metav1.Time `json:"lastTransitionTime"`
// FirstSuccessTime is the time when the SyncSet or SelectorSyncSet was first successfully applied to the cluster.
// +optional
FirstSuccessTime *metav1.Time `json:"firstSuccessTime,omitempty"`
}
// SyncResourceReference is a reference to a resource that is synced to a cluster via a SyncSet or SelectorSyncSet.
type SyncResourceReference struct {
// APIVersion is the Group and Version of the resource.
APIVersion string `json:"apiVersion"`
// Kind is the Kind of the resource.
// +optional
Kind string `json:"kind"`
// Name is the name of the resource.
Name string `json:"name"`
// Namespace is the namespace of the resource.
// +optional
Namespace string `json:"namespace,omitempty"`
}
// SyncSetResult is the result of a sync attempt.
// +kubebuilder:validation:Enum=Success;Failure
type SyncSetResult string
const (
// SuccessSyncSetResult is the result when the SyncSet or SelectorSyncSet was applied successfully to the cluster.
SuccessSyncSetResult SyncSetResult = "Success"
// FailureSyncSetResult is the result when there was an error when attempting to apply the SyncSet or SelectorSyncSet
// to the cluster
FailureSyncSetResult SyncSetResult = "Failure"
)
// ClusterSyncCondition contains details for the current condition of a ClusterSync
type ClusterSyncCondition struct {
// Type is the type of the condition.
Type ClusterSyncConditionType `json:"type"`
// Status is the status of the condition.
Status corev1.ConditionStatus `json:"status"`
// LastProbeTime is the last time we probed the condition.
// +optional
LastProbeTime metav1.Time `json:"lastProbeTime,omitempty"`
// LastTransitionTime is the last time the condition transitioned from one status to another.
// +optional
LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
// Reason is a unique, one-word, CamelCase reason for the condition's last transition.
// +optional
Reason string `json:"reason,omitempty"`
// Message is a human-readable message indicating details about the last transition.
// +optional
Message string `json:"message,omitempty"`
}
// ClusterSyncConditionType is a valid value for ClusterSyncCondition.Type
type ClusterSyncConditionType string
// ConditionType satisfies the generics.Condition interface
func (c ClusterSyncCondition) ConditionType() hivev1.ConditionType {
return c.Type
}
// String satisfies the generics.ConditionType interface
func (t ClusterSyncConditionType) String() string {
return string(t)
}
const (
// ClusterSyncFailed is the type of condition used to indicate whether there are SyncSets or SelectorSyncSets which
// have not been applied due to an error.
ClusterSyncFailed ClusterSyncConditionType = "Failed"
)
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// ClusterSyncList contains a list of ClusterSync
type ClusterSyncList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ClusterSync `json:"items"`
}
func init() {
SchemeBuilder.Register(&ClusterSync{}, &ClusterSyncList{})
}

37
vendor/github.com/openshift/hive/apis/hiveinternal/v1alpha1/clustersynclease_types.go сгенерированный поставляемый Normal file
Просмотреть файл

@ -0,0 +1,37 @@
package v1alpha1
import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// ClusterSyncLease is a record of the last time that SyncSets and SelectorSyncSets were applied to a cluster.
// +k8s:openapi-gen=true
// +kubebuilder:resource:path=clustersyncleases,shortName=csl,scope=Namespaced
type ClusterSyncLease struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ClusterSyncLeaseSpec `json:"spec,omitempty"`
}
// ClusterSyncLeaseSpec is the specification of a ClusterSyncLease.
type ClusterSyncLeaseSpec struct {
// RenewTime is the time when SyncSets and SelectorSyncSets were last applied to the cluster.
RenewTime metav1.MicroTime `json:"renewTime"`
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// ClusterSyncLeaseList contains a list of ClusterSyncLeases.
type ClusterSyncLeaseList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ClusterSyncLease `json:"items"`
}
func init() {
SchemeBuilder.Register(&ClusterSyncLease{}, &ClusterSyncLeaseList{})
}

7
vendor/github.com/openshift/hive/apis/hiveinternal/v1alpha1/doc.go сгенерированный поставляемый Normal file
Просмотреть файл

@ -0,0 +1,7 @@
// Package v1alpha1 contains API Schema definitions for the hiveinternal v1alpha1 API group
// +k8s:openapi-gen=true
// +k8s:deepcopy-gen=package,register
// +k8s:conversion-gen=github.com/openshift/hive/apis/hiveinternal
// +k8s:defaulter-gen=TypeMeta
// +groupName=hiveinternal.openshift.io
package v1alpha1

56
vendor/github.com/openshift/hive/apis/hiveinternal/v1alpha1/fakeclusterinstall_types.go сгенерированный поставляемый Normal file
Просмотреть файл

@ -0,0 +1,56 @@
package v1alpha1
import (
hivev1 "github.com/openshift/hive/apis/hive/v1"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
// FakeClusterInstallSpec defines the desired state of the FakeClusterInstall.
type FakeClusterInstallSpec struct {
// ImageSetRef is a reference to a ClusterImageSet. The release image specified in the ClusterImageSet will be used
// to install the cluster.
ImageSetRef hivev1.ClusterImageSetReference `json:"imageSetRef"`
// ClusterDeploymentRef is a reference to the ClusterDeployment associated with this AgentClusterInstall.
ClusterDeploymentRef corev1.LocalObjectReference `json:"clusterDeploymentRef"`
// ClusterMetadata contains metadata information about the installed cluster. It should be populated once the cluster install is completed. (it can be populated sooner if desired, but Hive will not copy back to ClusterDeployment until the Installed condition goes True.
ClusterMetadata *hivev1.ClusterMetadata `json:"clusterMetadata,omitempty"`
}
// FakeClusterInstallStatus defines the observed state of the FakeClusterInstall.
type FakeClusterInstallStatus struct {
// Conditions includes more detailed status for the cluster install.
// +optional
Conditions []hivev1.ClusterInstallCondition `json:"conditions,omitempty"`
}
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// FakeClusterInstall represents a fake request to provision an agent based cluster.
//
// +k8s:openapi-gen=true
// +kubebuilder:subresource:status
type FakeClusterInstall struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec FakeClusterInstallSpec `json:"spec"`
Status FakeClusterInstallStatus `json:"status,omitempty"`
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// FakeClusterInstallList contains a list of FakeClusterInstall
type FakeClusterInstallList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []FakeClusterInstall `json:"items"`
}
func init() {
SchemeBuilder.Register(&FakeClusterInstall{}, &FakeClusterInstallList{})
}

36
vendor/github.com/openshift/hive/apis/hiveinternal/v1alpha1/register.go сгенерированный поставляемый Normal file
Просмотреть файл

@ -0,0 +1,36 @@
// NOTE: Boilerplate only. Ignore this file.
// Package v1alpha1 contains API Schema definitions for the hiveinternal v1alpha1 API group
// +k8s:openapi-gen=true
// +k8s:deepcopy-gen=package,register
// +k8s:conversion-gen=github.com/openshift/hive/apis/hiveinternal
// +k8s:defaulter-gen=TypeMeta
// +groupName=hiveinternal.openshift.io
package v1alpha1
import (
"github.com/openshift/hive/apis/scheme"
"k8s.io/apimachinery/pkg/runtime/schema"
)
var (
// HiveInternalAPIGroup is the group that all hiveinternal objects belong to in the API server.
HiveInternalAPIGroup = "hiveinternal.openshift.io"
// HiveInternalAPIVersion is the api version that all hiveinternal objects are currently at.
HiveInternalAPIVersion = "v1alpha1"
// SchemeGroupVersion is group version used to register these objects
SchemeGroupVersion = schema.GroupVersion{Group: HiveInternalAPIGroup, Version: HiveInternalAPIVersion}
// SchemeBuilder is used to add go types to the GroupVersionKind scheme
SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
// AddToScheme is a shortcut for SchemeBuilder.AddToScheme
AddToScheme = SchemeBuilder.AddToScheme
)
// Resource takes an unqualified resource and returns a Group qualified GroupResource
func Resource(resource string) schema.GroupResource {
return SchemeGroupVersion.WithResource(resource).GroupResource()
}

378
vendor/github.com/openshift/hive/apis/hiveinternal/v1alpha1/zz_generated.deepcopy.go сгенерированный поставляемый Normal file
Просмотреть файл

@ -0,0 +1,378 @@
//go:build !ignore_autogenerated
// +build !ignore_autogenerated
// Code generated by deepcopy-gen. DO NOT EDIT.
package v1alpha1
import (
v1 "github.com/openshift/hive/apis/hive/v1"
runtime "k8s.io/apimachinery/pkg/runtime"
)
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSync) DeepCopyInto(out *ClusterSync) {
*out = *in
out.TypeMeta = in.TypeMeta
in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
out.Spec = in.Spec
in.Status.DeepCopyInto(&out.Status)
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSync.
func (in *ClusterSync) DeepCopy() *ClusterSync {
if in == nil {
return nil
}
out := new(ClusterSync)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *ClusterSync) DeepCopyObject() runtime.Object {
if c := in.DeepCopy(); c != nil {
return c
}
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSyncCondition) DeepCopyInto(out *ClusterSyncCondition) {
*out = *in
in.LastProbeTime.DeepCopyInto(&out.LastProbeTime)
in.LastTransitionTime.DeepCopyInto(&out.LastTransitionTime)
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSyncCondition.
func (in *ClusterSyncCondition) DeepCopy() *ClusterSyncCondition {
if in == nil {
return nil
}
out := new(ClusterSyncCondition)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSyncLease) DeepCopyInto(out *ClusterSyncLease) {
*out = *in
out.TypeMeta = in.TypeMeta
in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
in.Spec.DeepCopyInto(&out.Spec)
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSyncLease.
func (in *ClusterSyncLease) DeepCopy() *ClusterSyncLease {
if in == nil {
return nil
}
out := new(ClusterSyncLease)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *ClusterSyncLease) DeepCopyObject() runtime.Object {
if c := in.DeepCopy(); c != nil {
return c
}
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSyncLeaseList) DeepCopyInto(out *ClusterSyncLeaseList) {
*out = *in
out.TypeMeta = in.TypeMeta
in.ListMeta.DeepCopyInto(&out.ListMeta)
if in.Items != nil {
in, out := &in.Items, &out.Items
*out = make([]ClusterSyncLease, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSyncLeaseList.
func (in *ClusterSyncLeaseList) DeepCopy() *ClusterSyncLeaseList {
if in == nil {
return nil
}
out := new(ClusterSyncLeaseList)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *ClusterSyncLeaseList) DeepCopyObject() runtime.Object {
if c := in.DeepCopy(); c != nil {
return c
}
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSyncLeaseSpec) DeepCopyInto(out *ClusterSyncLeaseSpec) {
*out = *in
in.RenewTime.DeepCopyInto(&out.RenewTime)
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSyncLeaseSpec.
func (in *ClusterSyncLeaseSpec) DeepCopy() *ClusterSyncLeaseSpec {
if in == nil {
return nil
}
out := new(ClusterSyncLeaseSpec)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSyncList) DeepCopyInto(out *ClusterSyncList) {
*out = *in
out.TypeMeta = in.TypeMeta
in.ListMeta.DeepCopyInto(&out.ListMeta)
if in.Items != nil {
in, out := &in.Items, &out.Items
*out = make([]ClusterSync, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSyncList.
func (in *ClusterSyncList) DeepCopy() *ClusterSyncList {
if in == nil {
return nil
}
out := new(ClusterSyncList)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *ClusterSyncList) DeepCopyObject() runtime.Object {
if c := in.DeepCopy(); c != nil {
return c
}
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSyncSpec) DeepCopyInto(out *ClusterSyncSpec) {
*out = *in
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSyncSpec.
func (in *ClusterSyncSpec) DeepCopy() *ClusterSyncSpec {
if in == nil {
return nil
}
out := new(ClusterSyncSpec)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ClusterSyncStatus) DeepCopyInto(out *ClusterSyncStatus) {
*out = *in
if in.SyncSets != nil {
in, out := &in.SyncSets, &out.SyncSets
*out = make([]SyncStatus, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
if in.SelectorSyncSets != nil {
in, out := &in.SelectorSyncSets, &out.SelectorSyncSets
*out = make([]SyncStatus, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
if in.Conditions != nil {
in, out := &in.Conditions, &out.Conditions
*out = make([]ClusterSyncCondition, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
if in.FirstSuccessTime != nil {
in, out := &in.FirstSuccessTime, &out.FirstSuccessTime
*out = (*in).DeepCopy()
}
if in.ControlledByReplica != nil {
in, out := &in.ControlledByReplica, &out.ControlledByReplica
*out = new(int64)
**out = **in
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSyncStatus.
func (in *ClusterSyncStatus) DeepCopy() *ClusterSyncStatus {
if in == nil {
return nil
}
out := new(ClusterSyncStatus)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *FakeClusterInstall) DeepCopyInto(out *FakeClusterInstall) {
*out = *in
out.TypeMeta = in.TypeMeta
in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
in.Spec.DeepCopyInto(&out.Spec)
in.Status.DeepCopyInto(&out.Status)
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FakeClusterInstall.
func (in *FakeClusterInstall) DeepCopy() *FakeClusterInstall {
if in == nil {
return nil
}
out := new(FakeClusterInstall)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *FakeClusterInstall) DeepCopyObject() runtime.Object {
if c := in.DeepCopy(); c != nil {
return c
}
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *FakeClusterInstallList) DeepCopyInto(out *FakeClusterInstallList) {
*out = *in
out.TypeMeta = in.TypeMeta
in.ListMeta.DeepCopyInto(&out.ListMeta)
if in.Items != nil {
in, out := &in.Items, &out.Items
*out = make([]FakeClusterInstall, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FakeClusterInstallList.
func (in *FakeClusterInstallList) DeepCopy() *FakeClusterInstallList {
if in == nil {
return nil
}
out := new(FakeClusterInstallList)
in.DeepCopyInto(out)
return out
}
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *FakeClusterInstallList) DeepCopyObject() runtime.Object {
if c := in.DeepCopy(); c != nil {
return c
}
return nil
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *FakeClusterInstallSpec) DeepCopyInto(out *FakeClusterInstallSpec) {
*out = *in
out.ImageSetRef = in.ImageSetRef
out.ClusterDeploymentRef = in.ClusterDeploymentRef
if in.ClusterMetadata != nil {
in, out := &in.ClusterMetadata, &out.ClusterMetadata
*out = new(v1.ClusterMetadata)
(*in).DeepCopyInto(*out)
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FakeClusterInstallSpec.
func (in *FakeClusterInstallSpec) DeepCopy() *FakeClusterInstallSpec {
if in == nil {
return nil
}
out := new(FakeClusterInstallSpec)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *FakeClusterInstallStatus) DeepCopyInto(out *FakeClusterInstallStatus) {
*out = *in
if in.Conditions != nil {
in, out := &in.Conditions, &out.Conditions
*out = make([]v1.ClusterInstallCondition, len(*in))
for i := range *in {
(*in)[i].DeepCopyInto(&(*out)[i])
}
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FakeClusterInstallStatus.
func (in *FakeClusterInstallStatus) DeepCopy() *FakeClusterInstallStatus {
if in == nil {
return nil
}
out := new(FakeClusterInstallStatus)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SyncResourceReference) DeepCopyInto(out *SyncResourceReference) {
*out = *in
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SyncResourceReference.
func (in *SyncResourceReference) DeepCopy() *SyncResourceReference {
if in == nil {
return nil
}
out := new(SyncResourceReference)
in.DeepCopyInto(out)
return out
}
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SyncStatus) DeepCopyInto(out *SyncStatus) {
*out = *in
if in.ResourcesToDelete != nil {
in, out := &in.ResourcesToDelete, &out.ResourcesToDelete
*out = make([]SyncResourceReference, len(*in))
copy(*out, *in)
}
in.LastTransitionTime.DeepCopyInto(&out.LastTransitionTime)
if in.FirstSuccessTime != nil {
in, out := &in.FirstSuccessTime, &out.FirstSuccessTime
*out = (*in).DeepCopy()
}
return
}
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SyncStatus.
func (in *SyncStatus) DeepCopy() *SyncStatus {
if in == nil {
return nil
}
out := new(SyncStatus)
in.DeepCopyInto(out)
return out
}

1
vendor/modules.txt поставляемый
Просмотреть файл

@ -1182,6 +1182,7 @@ github.com/openshift/hive/apis/hive/v1/none
github.com/openshift/hive/apis/hive/v1/openstack
github.com/openshift/hive/apis/hive/v1/ovirt
github.com/openshift/hive/apis/hive/v1/vsphere
github.com/openshift/hive/apis/hiveinternal/v1alpha1
github.com/openshift/hive/apis/scheme
# github.com/openshift/library-go v0.0.0-20230620084201-504ca4bd5a83 => github.com/openshift/library-go v0.0.0-20230222114049-eac44a078a6e
## explicit; go 1.17