peering_request_operator

package

v0.2.1 Latest Latest Go to latest Published: Apr 29, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/liqotech/liqo

Links

Documentation ¶

Index ¶

Variables
func GetBroadcasterDeployment(request *discoveryv1alpha1.PeeringRequest, nameSA string, remoteSA 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

Constants ¶

This section is empty.

Variables ¶

View Source

var BroadcasterBaseLabels = map[string]string{
	"app": "broadcaster",
}

Functions ¶

func GetBroadcasterDeployment ¶

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

func StartOperator ¶

func StartOperator(namespace string, broadcasterImage string, broadcasterServiceAccount string, vkServiceAccount 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, vkServiceAccount 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

Source Files ¶

View all Source files

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