migcluster

package

v0.0.0-...-ec8378c Latest Latest Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 37 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/konveyor/mig-controller

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Add(mgr manager.Manager) error
func IsRemoteWatchConsistent(nsName types.NamespacedName, config *rest.Config) bool
func StartRemoteWatch(r *ReconcileMigCluster, config remote.ManagerConfig) error
func StopRemoteWatch(nsName types.NamespacedName)
type ClusterPredicate
type ReconcileMigCluster
- func (r *ReconcileMigCluster) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
type RemoteClusterSource
- func (r *RemoteClusterSource) Start(ctx context.Context, handler handler.EventHandler, ...) error

Constants ¶

View Source

const (
	InvalidURL                     = "InvalidURL"
	InvalidSaSecretRef             = "InvalidSaSecretRef"
	InvalidSaToken                 = "InvalidSaToken"
	InvalidRegistryRoute           = "InvalidRegistryRoute"
	TestConnectFailed              = "TestConnectFailed"
	SaTokenNotPrivileged           = "SaTokenNotPrivileged"
	OperatorVersionMismatch        = "OperatorVersionMismatch"
	ClusterOperatorVersionNotFound = "ClusterOperatorVersionNotFound"
)

Types

View Source

const (
	Critical = migapi.Critical
	Warn     = migapi.Warn
)

Variables ¶

View Source

var Settings = &settings.Settings

Functions ¶

func Add ¶

func Add(mgr manager.Manager) error

Add creates a new MigCluster Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

func IsRemoteWatchConsistent ¶

func IsRemoteWatchConsistent(nsName types.NamespacedName, config *rest.Config) bool

IsRemoteWatchConsistent checks whether remote watch in-memory is consistent with given new config

func StartRemoteWatch ¶

func StartRemoteWatch(r *ReconcileMigCluster, config remote.ManagerConfig) error

StartRemoteWatch will configure a new RemoteWatcher manager that provides a cached client

func StopRemoteWatch ¶

func StopRemoteWatch(nsName types.NamespacedName)

StopRemoteWatch will run the remote manager stopFunc and delete it from the remote watch map.

Types ¶

type ClusterPredicate ¶

type ClusterPredicate struct {
	predicate.Funcs
	Namespace string
}

func (ClusterPredicate) Create ¶

func (r ClusterPredicate) Create(e event.CreateEvent) bool

func (ClusterPredicate) Delete ¶

func (r ClusterPredicate) Delete(e event.DeleteEvent) bool

func (ClusterPredicate) Update ¶

func (r ClusterPredicate) Update(e event.UpdateEvent) bool

type ReconcileMigCluster ¶

type ReconcileMigCluster struct {
	k8sclient.Client
	record.EventRecorder

	Controller controller.Controller
	// contains filtered or unexported fields
}

ReconcileMigCluster reconciles a MigCluster object

func (*ReconcileMigCluster) Reconcile ¶

func (r *ReconcileMigCluster) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type RemoteClusterSource ¶

type RemoteClusterSource struct {
	Client   client.Client
	Interval time.Duration

	Namespace string
	// contains filtered or unexported fields
}

RemoteClusterSource is a `watch` source used to checkup on the connectivity of remote clusters.

Client - A controller-runtime client.
Interval - The connection test interval

func (*RemoteClusterSource) Start ¶

func (r *RemoteClusterSource) Start(
	ctx context.Context,
	handler handler.EventHandler,
	queue workqueue.RateLimitingInterface,
	predicates ...predicate.Predicate) error

Start the source.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL