peering_request_operator

Documentation

Index

• func GetBroadcasterDeployment(request *discoveryv1alpha1.PeeringRequest, nameSA string, namespace string, ...) appsv1.Deployment
• func StartOperator(namespace string, broadcasterImage string, broadcasterServiceAccount string, ...)
• type Config
  • func GetConfig(crdClient *crdClient.CRDClient, namespace string) (*Config, error)
• type PeeringRequestReconciler
  • func GetPRReconciler(scheme *runtime.Scheme, crdClient *crdClient.CRDClient, namespace string, ...) *PeeringRequestReconciler
  • func (r *PeeringRequestReconciler) BroadcasterExists(request *discoveryv1alpha1.PeeringRequest) (bool, error)
  • func (r *PeeringRequestReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *PeeringRequestReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *PeeringRequestReconciler) UpdateForeignCluster(pr *v1alpha1.PeeringRequest) error

Functions

func GetBroadcasterDeployment

func GetBroadcasterDeployment(request *discoveryv1alpha1.PeeringRequest, nameSA string, namespace string, image string, clusterId string) appsv1.Deployment

func StartOperator

func StartOperator(namespace string, broadcasterImage string, broadcasterServiceAccount string, kubeconfigPath string)

Types

type Config

type Config struct {
	AllowAll bool `json:"allowAll"`
}

func GetConfig

func GetConfig(crdClient *crdClient.CRDClient, namespace string) (*Config, error)

type PeeringRequestReconciler

type PeeringRequestReconciler struct {
	Scheme *runtime.Scheme

	Namespace string

	// testing
	ForeignConfig *rest.Config
	// contains filtered or unexported fields
}

PeeringRequestReconciler reconciles a PeeringRequest object

func GetPRReconciler

func GetPRReconciler(scheme *runtime.Scheme, crdClient *crdClient.CRDClient, namespace string, clusterId *clusterID.ClusterID, broadcasterImage string, broadcasterServiceAccount string) *PeeringRequestReconciler

func (*PeeringRequestReconciler) BroadcasterExists

func (r *PeeringRequestReconciler) BroadcasterExists(request *discoveryv1alpha1.PeeringRequest) (bool, error)

func (*PeeringRequestReconciler) Reconcile

func (r *PeeringRequestReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*PeeringRequestReconciler) SetupWithManager

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

func (*PeeringRequestReconciler) UpdateForeignCluster

func (r *PeeringRequestReconciler) UpdateForeignCluster(pr *v1alpha1.PeeringRequest) error