controller

Documentation

Index

• Constants
• Variables
• func Add(mgr manager.Manager) error
• func DefaultPredicates() []predicate.Predicate
• func GenerationChangedPredicate() predicate.Predicate
• type NetcatOutput
  • func NetCat(ctx context.Context, config *rest.Config, ...) (*NetcatOutput, error)
• type PingOutput
  • func Ping(ctx context.Context, config *rest.Config, ...) (*PingOutput, error)
• type ReconcileNetworkConnectivityTest
  • func (r *ReconcileNetworkConnectivityTest) IPNetcat(ctx context.Context, status *v1alpha1.NetcatStatus, ...) error
  • func (r *ReconcileNetworkConnectivityTest) IPPing(ctx context.Context, status *v1alpha1.PingStatus, ...)
  • func (r *ReconcileNetworkConnectivityTest) InjectClient(client client.Client) error
  • func (r *ReconcileNetworkConnectivityTest) InjectConfig(config *rest.Config) error
  • func (r *ReconcileNetworkConnectivityTest) InjectStopChannel(stopCh <-chan struct{}) error
  • func (r *ReconcileNetworkConnectivityTest) PodNetcat(ctx context.Context, status *v1alpha1.NetcatStatus, ...) error
  • func (r *ReconcileNetworkConnectivityTest) PodPing(ctx context.Context, status *v1alpha1.PingStatus, ...) error
  • func (r *ReconcileNetworkConnectivityTest) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *ReconcileNetworkConnectivityTest) ServiceNetcat(ctx context.Context, status *v1alpha1.NetcatStatus, ...) error
  • func (r *ReconcileNetworkConnectivityTest) ServicePing(ctx context.Context, status *v1alpha1.PingStatus, ...) error

Constants

const (
	LogKey = "NetworkConnnectivityTest"
	// FinalizerName is the controlplane controller finalizer.
	FinalizerName = "networkmachinery.io/networkconnectivity"
)

const Name = "networkconnectivity-test-controller"

Variables

var NetcatStatusTypeMeta = metav1.TypeMeta{
	APIVersion: v1alpha1.SchemeGroupVersion.String(),
	Kind:       "NetcatStatus",
}

var (
	PingStatusTypeMeta = metav1.TypeMeta{
		APIVersion: v1alpha1.SchemeGroupVersion.String(),
		Kind:       "PingStatus",
	}
)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new NetworkMonitor Controller and adds it to the Manager

func DefaultPredicates

func DefaultPredicates() []predicate.Predicate

DefaultPredicates returns the default predicates for an infrastructure reconciler.

func GenerationChangedPredicate

func GenerationChangedPredicate() predicate.Predicate

GenerationChangedPredicate is a predicate for generation changes.

Types

type NetcatOutput

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

func NetCat

func NetCat(ctx context.Context, config *rest.Config, source networkmachineryv1alpha1.NetworkSourceEndpoint, host, port string) (*NetcatOutput, error)

type PingOutput

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

func Ping

func Ping(ctx context.Context, config *rest.Config, source networkmachineryv1alpha1.NetworkSourceEndpoint, host string) (*PingOutput, error)

type ReconcileNetworkConnectivityTest

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

ReconcileMachineDeployment reconciles a MachineDeployment object.

func (*ReconcileNetworkConnectivityTest) IPNetcat

func (r *ReconcileNetworkConnectivityTest) IPNetcat(ctx context.Context, status *v1alpha1.NetcatStatus, source *v1alpha1.NetworkSourceEndpoint, destination *v1alpha1.NetworkDestinationEndpoint) error

func (*ReconcileNetworkConnectivityTest) IPPing

func (r *ReconcileNetworkConnectivityTest) IPPing(ctx context.Context, status *v1alpha1.PingStatus, source *v1alpha1.NetworkSourceEndpoint, destination string)

func (*ReconcileNetworkConnectivityTest) InjectClient

func (r *ReconcileNetworkConnectivityTest) InjectClient(client client.Client) error

func (*ReconcileNetworkConnectivityTest) InjectConfig

func (r *ReconcileNetworkConnectivityTest) InjectConfig(config *rest.Config) error

InjectConfig implements inject.Config.

func (*ReconcileNetworkConnectivityTest) InjectStopChannel

func (r *ReconcileNetworkConnectivityTest) InjectStopChannel(stopCh <-chan struct{}) error

func (*ReconcileNetworkConnectivityTest) PodNetcat

func (r *ReconcileNetworkConnectivityTest) PodNetcat(ctx context.Context, status *v1alpha1.NetcatStatus, source *v1alpha1.NetworkSourceEndpoint, destination *v1alpha1.NetworkDestinationEndpoint) error

func (*ReconcileNetworkConnectivityTest) PodPing

func (r *ReconcileNetworkConnectivityTest) PodPing(ctx context.Context, status *v1alpha1.PingStatus, source *v1alpha1.NetworkSourceEndpoint, destination *v1alpha1.NetworkDestinationEndpoint) error

func (*ReconcileNetworkConnectivityTest) Reconcile

func (r *ReconcileNetworkConnectivityTest) Reconcile(request reconcile.Request) (reconcile.Result, error)

func (*ReconcileNetworkConnectivityTest) ServiceNetcat

func (r *ReconcileNetworkConnectivityTest) ServiceNetcat(ctx context.Context, status *v1alpha1.NetcatStatus, source *v1alpha1.NetworkSourceEndpoint, destination *v1alpha1.NetworkDestinationEndpoint) error

func (*ReconcileNetworkConnectivityTest) ServicePing

func (r *ReconcileNetworkConnectivityTest) ServicePing(ctx context.Context, status *v1alpha1.PingStatus, source *v1alpha1.NetworkSourceEndpoint, destination *v1alpha1.NetworkDestinationEndpoint) error