package opworker

import (
	"context"

	"github.com/tidbcloud/account/internel/svc/monitor"
)

// ClusterRelationSyncWorker sync cluster relation to resource_relations table
type ClusterRelationSyncWorker struct{ GlobalWorker }

func (w ClusterRelationSyncWorker) Run(ctx context.Context) error {
	_ = monitor.SyncClusterRelations(ctx, 0)
	return nil
}

// ClusterRelationMonitorWorker delete cluster relation on resource_relations table when cluster is deleted
type ClusterRelationMonitorWorker struct{ GlobalWorker }

func (w ClusterRelationMonitorWorker) Run(ctx context.Context) error {
	_ = monitor.MonitorClusterRelations(ctx)
	return nil
}