loadbalancer

Documentation

Overview

Copyright 2018 Oracle and/or its affiliates. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2018 Oracle and/or its affiliates. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• func CreateOrUpdateBackend(c clientset.Interface, controllerRef *metav1.OwnerReference, ...) (*v1alpha1.Backend, bool, error)
• func CreateOrUpdateBackendSet(c clientset.Interface, controllerRef *metav1.OwnerReference, ...) (*v1alpha1.BackendSet, bool, error)
• func CreateOrUpdateCertificate(c clientset.Interface, controllerRef *metav1.OwnerReference, ...) (*v1alpha1.Certificate, bool, error)
• func CreateOrUpdateListener(c clientset.Interface, controllerRef *metav1.OwnerReference, ...) (*v1alpha1.Listener, bool, error)
• func CreateOrUpdateLoadBalancer(c clientset.Interface, controllerRef *metav1.OwnerReference, ...) (*v1alpha1.LoadBalancer, bool, error)
• func DeleteBackend(c clientset.Interface, namespace string, name string) (*v1alpha1.Backend, error)
• func DeleteBackendSet(c clientset.Interface, lb *cloudv1alpha1.LoadBalancer) (*v1alpha1.BackendSet, error)
• func DeleteCertificate(c clientset.Interface, lb *cloudv1alpha1.LoadBalancer) (*v1alpha1.Certificate, error)
• func DeleteListener(c clientset.Interface, namespace string, name string) (*v1alpha1.Listener, error)
• func DeleteLoadBalancer(c clientset.Interface, lb *cloudv1alpha1.LoadBalancer) (*v1alpha1.LoadBalancer, error)
• func NewLoadBalancerAdapter(clientSet versioned.Interface, kubeclient kubernetes.Interface) cloudcommon.CloudTypeAdapter
• type LoadBalancerAdapter
  • func (a *LoadBalancerAdapter) CallbackForResource(resource schema.GroupVersionResource) cache.ResourceEventHandlerFuncs
  • func (a *LoadBalancerAdapter) Delete(obj runtime.Object) (runtime.Object, error)
  • func (a *LoadBalancerAdapter) Equivalent(obj1, obj2 runtime.Object) bool
  • func (a *LoadBalancerAdapter) GroupVersionWithResource() schema.GroupVersionResource
  • func (a *LoadBalancerAdapter) Kind() string
  • func (a *LoadBalancerAdapter) ObjectMeta(obj runtime.Object) *metav1.ObjectMeta
  • func (a *LoadBalancerAdapter) Reconcile(obj runtime.Object) (runtime.Object, error)
  • func (a *LoadBalancerAdapter) Resource() string
  • func (a *LoadBalancerAdapter) SetLister(lister cache.GenericLister)
  • func (a *LoadBalancerAdapter) SetQueue(q workqueue.RateLimitingInterface)
  • func (a *LoadBalancerAdapter) Subscriptions() []schema.GroupVersionResource
  • func (a *LoadBalancerAdapter) Update(obj runtime.Object) (runtime.Object, error)

Constants

const (
	CloudDomain = "cloudloadbalancer"
)

Functions

func CreateOrUpdateBackend

func CreateOrUpdateBackend(c clientset.Interface,
	controllerRef *metav1.OwnerReference,
	lb *cloudv1alpha1.LoadBalancer,
	instanceName string,
	weight int) (*v1alpha1.Backend, bool, error)

CreateOrUpdateBackend reconciles the backend resource

func CreateOrUpdateBackendSet

func CreateOrUpdateBackendSet(c clientset.Interface,
	controllerRef *metav1.OwnerReference,
	lb *cloudv1alpha1.LoadBalancer) (*v1alpha1.BackendSet, bool, error)

CreateOrUpdateIBackendSet reconciles the backendset resource

func CreateOrUpdateCertificate

func CreateOrUpdateCertificate(c clientset.Interface,
	controllerRef *metav1.OwnerReference,
	lb *cloudv1alpha1.LoadBalancer,
	listener *cloudv1alpha1.Listener) (*v1alpha1.Certificate, bool, error)

CreateOrUpdateCertificate reconciles the certificate resource

func CreateOrUpdateListener

func CreateOrUpdateListener(c clientset.Interface,
	controllerRef *metav1.OwnerReference,
	lb *cloudv1alpha1.LoadBalancer,
	listener *cloudv1alpha1.Listener) (*v1alpha1.Listener, bool, error)

CreateOrUpdateListener reconciles the listener resource

func CreateOrUpdateLoadBalancer

func CreateOrUpdateLoadBalancer(c clientset.Interface,
	controllerRef *metav1.OwnerReference,
	lb *cloudv1alpha1.LoadBalancer,
	subnets []string) (*v1alpha1.LoadBalancer, bool, error)

CreateOrUpdateLoadBalancer reconciles the loadbalancer resource

func DeleteBackend

func DeleteBackend(c clientset.Interface, namespace string, name string) (*v1alpha1.Backend, error)

DeleteBackend deletes the backend resource

func DeleteBackendSet

func DeleteBackendSet(c clientset.Interface, lb *cloudv1alpha1.LoadBalancer) (*v1alpha1.BackendSet, error)

DeleteBackendSet deletes the backendset resource

func DeleteCertificate

func DeleteCertificate(c clientset.Interface, lb *cloudv1alpha1.LoadBalancer) (*v1alpha1.Certificate, error)

DeleteCertificate deletes the certificate resource

func DeleteListener

func DeleteListener(c clientset.Interface, namespace string, name string) (*v1alpha1.Listener, error)

DeleteListener deletes the listener resource

func DeleteLoadBalancer

func DeleteLoadBalancer(c clientset.Interface, lb *cloudv1alpha1.LoadBalancer) (*v1alpha1.LoadBalancer, error)

DeleteLoadBalancer deletes the loadBalancer resource

func NewLoadBalancerAdapter

func NewLoadBalancerAdapter(clientSet versioned.Interface, kubeclient kubernetes.Interface) cloudcommon.CloudTypeAdapter

factory method

Types

type LoadBalancerAdapter

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

func (*LoadBalancerAdapter) CallbackForResource

func (a *LoadBalancerAdapter) CallbackForResource(resource schema.GroupVersionResource) cache.ResourceEventHandlerFuncs

callback for resource

func (*LoadBalancerAdapter) Delete

func (a *LoadBalancerAdapter) Delete(obj runtime.Object) (runtime.Object, error)

delete loadBalancer cloud event handler

func (*LoadBalancerAdapter) Equivalent

func (a *LoadBalancerAdapter) Equivalent(obj1, obj2 runtime.Object) bool

equivalent

func (*LoadBalancerAdapter) GroupVersionWithResource

func (a *LoadBalancerAdapter) GroupVersionWithResource() schema.GroupVersionResource

group version with resource

func (*LoadBalancerAdapter) Kind

func (a *LoadBalancerAdapter) Kind() string

kind

func (*LoadBalancerAdapter) ObjectMeta

func (a *LoadBalancerAdapter) ObjectMeta(obj runtime.Object) *metav1.ObjectMeta

object meta

func (*LoadBalancerAdapter) Reconcile

func (a *LoadBalancerAdapter) Reconcile(obj runtime.Object) (runtime.Object, error)

reconcile - handles create and updates

func (*LoadBalancerAdapter) Resource

func (a *LoadBalancerAdapter) Resource() string

resource

func (*LoadBalancerAdapter) SetLister

func (a *LoadBalancerAdapter) SetLister(lister cache.GenericLister)

set lister

func (*LoadBalancerAdapter) SetQueue

func (a *LoadBalancerAdapter) SetQueue(q workqueue.RateLimitingInterface)

set queue

func (*LoadBalancerAdapter) Subscriptions

func (a *LoadBalancerAdapter) Subscriptions() []schema.GroupVersionResource

subscriptions

func (*LoadBalancerAdapter) Update

func (a *LoadBalancerAdapter) Update(obj runtime.Object) (runtime.Object, error)

update loadBalancer cloud event handler