lb

Documentation

Index

• Constants
• func IsOpenELBNPService(obj runtime.Object) bool
• func IsOpenELBService(obj runtime.Object) bool
• func SetupServiceReconciler(mgr ctrl.Manager) error
• type EnqueueRequestForDeAndDs
  • func (e *EnqueueRequestForDeAndDs) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForDeAndDs) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForDeAndDs) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForDeAndDs) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type EnqueueRequestForNode
  • func (e *EnqueueRequestForNode) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForNode) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForNode) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForNode) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type ServiceReconciler
  • func (r *ServiceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *ServiceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SvcAnnotator
  • func (r *SvcAnnotator) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (r *SvcAnnotator) InjectDecoder(d *admission.Decoder) error

Constants

const (
	ReasonDeleteLoadBalancer = "deleteLoadBalancer"
	ReasonAddLoadBalancer    = "addLoadBalancer"
	AddLoadBalancerMsg       = "success to add nexthops %v"
	AddLoadBalancerFailedMsg = "failed to add nexthops %v, err=%v"
	DelLoadBalancerMsg       = "loadbalancer ip changed from %s to %s"
	DelLoadBalancerFailedMsg = "speaker del loadbalancer failed, err=%v"
)

Functions

func IsOpenELBNPService

func IsOpenELBNPService(obj runtime.Object) bool

Judge whether this load balancer should be exposed by OpenELB Service Such Service will be exposed by Proxy Pod

func IsOpenELBService

func IsOpenELBService(obj runtime.Object) bool

func SetupServiceReconciler

func SetupServiceReconciler(mgr ctrl.Manager) error

Types

type EnqueueRequestForDeAndDs

type EnqueueRequestForDeAndDs struct {
	client.Client
}

Enqueue requests for Deployments and DaemonSets type Only OpenELB NodeProxy needs this

func (*EnqueueRequestForDeAndDs) Create

func (e *EnqueueRequestForDeAndDs) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

Create implements EventHandler

func (*EnqueueRequestForDeAndDs) Delete

func (e *EnqueueRequestForDeAndDs) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

Delete implements EventHandler

func (*EnqueueRequestForDeAndDs) Generic

func (e *EnqueueRequestForDeAndDs) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

Generic implements EventHandler

func (*EnqueueRequestForDeAndDs) Update

func (e *EnqueueRequestForDeAndDs) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Update implements EventHandler

type EnqueueRequestForNode

type EnqueueRequestForNode struct {
	client.Client
}

func (*EnqueueRequestForNode) Create

func (e *EnqueueRequestForNode) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

Create implements EventHandler

func (*EnqueueRequestForNode) Delete

func (e *EnqueueRequestForNode) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

Delete implements EventHandler

func (*EnqueueRequestForNode) Generic

func (e *EnqueueRequestForNode) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

Generic implements EventHandler

func (*EnqueueRequestForNode) Update

func (e *EnqueueRequestForNode) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Update implements EventHandler

type ServiceReconciler

type ServiceReconciler struct {
	client.Client
	record.EventRecorder
}

ServiceReconciler reconciles a Service object

func (*ServiceReconciler) Reconcile

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

func (*ServiceReconciler) SetupWithManager

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

type SvcAnnotator

type SvcAnnotator struct {
	client.Client
	// contains filtered or unexported fields
}

func (*SvcAnnotator) Handle

func (r *SvcAnnotator) Handle(ctx context.Context, req admission.Request) admission.Response

func (*SvcAnnotator) InjectDecoder

func (r *SvcAnnotator) InjectDecoder(d *admission.Decoder) error