controllers

Documentation

Index

• Constants
• type ClusterClient
• type NetworkTopologyReconciler
  • func NewNetworkTopologyReconciler(client ClusterClient, registrars []Registrar) *NetworkTopologyReconciler
  • func (r *NetworkTopologyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NetworkTopologyReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RAMClient
• type Registrar
• type ShareReconciler
  • func NewShareReconciler(clusterClient ClusterClient, ramClient RAMClient) *ShareReconciler
  • func (r *ShareReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ShareReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	FinalizerNetTop = "network-topology.finalizers.giantswarm.io"
)

const FinalizerResourceShare = "network-topology.finalizers.giantswarm.io/share"

Types

type ClusterClient

type ClusterClient interface {
	Get(context.Context, types.NamespacedName) (*capi.Cluster, error)
	AddFinalizer(context.Context, *capi.Cluster, string) error
	RemoveFinalizer(context.Context, *capi.Cluster, string) error
	ContainsFinalizer(*capi.Cluster, string) bool
	UpdateStatus(ctx context.Context, cluster *capi.Cluster) error
	GetAWSClusterRoleIdentity(context.Context, types.NamespacedName) (*capa.AWSClusterRoleIdentity, error)
}

type NetworkTopologyReconciler

type NetworkTopologyReconciler struct {
	// contains filtered or unexported fields
}

func NewNetworkTopologyReconciler

func NewNetworkTopologyReconciler(client ClusterClient, registrars []Registrar) *NetworkTopologyReconciler

func (*NetworkTopologyReconciler) Reconcile

func (r *NetworkTopologyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NetworkTopologyReconciler) SetupWithManager

func (r *NetworkTopologyReconciler) SetupWithManager(mgr ctrl.Manager) error

type RAMClient

type RAMClient interface {
	ApplyResourceShare(context.Context, aws.ResourceShare) error
	DeleteResourceShare(context.Context, string) error
}

type Registrar

type Registrar interface {
	Register(context.Context, *capi.Cluster) error
	Unregister(context.Context, *capi.Cluster) error
}

type ShareReconciler

type ShareReconciler struct {
	// contains filtered or unexported fields
}

func NewShareReconciler

func NewShareReconciler(clusterClient ClusterClient, ramClient RAMClient) *ShareReconciler

func (*ShareReconciler) Reconcile

func (r *ShareReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ShareReconciler) SetupWithManager

func (r *ShareReconciler) SetupWithManager(mgr ctrl.Manager) error