pvtz

Documentation

Index

• Constants
• func Add(mgr manager.Manager, ctx *shared.SharedContext) error
• func IsIPv4(address string) bool
• func IsIPv6(address string) bool
• type Actuator
  • func NewActuator(c client.Client, p prvd.Provider) *Actuator
  • func (a *Actuator) DeletePod(podName types.NamespacedName) error
  • func (a *Actuator) DeleteService(svcName types.NamespacedName) error
  • func (a *Actuator) UpdatePod(pod *corev1.Pod) error
  • func (a *Actuator) UpdateService(svc *corev1.Service) error
• type EventHandlerWithClient
  • func NewEventHandlerWithClient() *EventHandlerWithClient
  • func (e *EventHandlerWithClient) InjectClient(c client.Client) error
• type NamedPortMap
  • func NewNamedPortMap(ep *corev1.Endpoints) NamedPortMap
  • func (m NamedPortMap) GetByProtocolAndPortName(protocol, portName string) (int32, bool)
• type PodReconciler
  • func (m *PodReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type ServicePredicate
  • func (sp *ServicePredicate) Create(e event.CreateEvent) bool
  • func (sp *ServicePredicate) Update(e event.UpdateEvent) bool
• type ServiceReconciler
  • func (m *ServiceReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (
	EventReasonHandleServiceDeletionError   = "HandleServiceDeletionError"
	EventReasonHandleServiceDeletionSucceed = "HandleServiceDeletionSucceed"
	EventReasonHandleServiceUpdateError     = "HandleServiceUpdateError"
	EventReasonHandleServiceUpdateSucceed   = "HandleServiceUpdateSucceed"
	EventReasonHandlePodDeletionError       = "HandlePodDeletionError"
	EventReasonHandlePodDeletionSucceed     = "HandlePodDeletionSucceed"
	EventReasonHandlePodUpdateError         = "HandlePodUpdateError"
	EventReasonHandlePodUpdateSucceed       = "HandlePodUpdateSucceed"
)

Functions

func Add

func Add(mgr manager.Manager, ctx *shared.SharedContext) error

func IsIPv4

func IsIPv4(address string) bool

func IsIPv6

func IsIPv6(address string) bool

Types

type Actuator

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

func NewActuator

func NewActuator(c client.Client, p prvd.Provider) *Actuator

func (*Actuator) DeletePod

func (a *Actuator) DeletePod(podName types.NamespacedName) error

func (*Actuator) DeleteService

func (a *Actuator) DeleteService(svcName types.NamespacedName) error

func (*Actuator) UpdatePod

func (a *Actuator) UpdatePod(pod *corev1.Pod) error

func (*Actuator) UpdateService

func (a *Actuator) UpdateService(svc *corev1.Service) error

type EventHandlerWithClient

type EventHandlerWithClient struct {
	handler.EventHandler
	// contains filtered or unexported fields
}

func NewEventHandlerWithClient

func NewEventHandlerWithClient() *EventHandlerWithClient

func (*EventHandlerWithClient) InjectClient

func (e *EventHandlerWithClient) InjectClient(c client.Client) error

type NamedPortMap

type NamedPortMap map[string]map[string]int32

func NewNamedPortMap

func NewNamedPortMap(ep *corev1.Endpoints) NamedPortMap

func (NamedPortMap) GetByProtocolAndPortName

func (m NamedPortMap) GetByProtocolAndPortName(protocol, portName string) (int32, bool)

type PodReconciler

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

func (*PodReconciler) Reconcile

func (m *PodReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type ServicePredicate

type ServicePredicate struct {
	predicate.Funcs
}

func (*ServicePredicate) Create

func (sp *ServicePredicate) Create(e event.CreateEvent) bool

func (*ServicePredicate) Update

func (sp *ServicePredicate) Update(e event.UpdateEvent) bool

type ServiceReconciler

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

func (*ServiceReconciler) Reconcile

func (m *ServiceReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)