handler

Jun 11, 2025

Changes in this version

type Handler

+ func (h *Handler) AssociateAddress(event PodEvent) error

+ func (h *Handler) DisassociateAddress(event PodEvent) error

type PodEvent

+ func (p PodEvent) GetAddressPoolIdAnnotation() (string, bool)

+ func (p PodEvent) GetAddressPoolIdLabel() (string, bool)

+ func (p PodEvent) GetFixedTagAnnotation() (string, bool)

+ func (p PodEvent) GetFixedTagLabel() (string, bool)

+ func (p PodEvent) GetFixedTagValueAnnotation() (string, bool)

+ func (p PodEvent) GetFixedTagValueLabel() (string, bool)

+ func (p PodEvent) GetPECTypeAnnotation() (string, bool)

+ func (p PodEvent) GetPECTypeLabel() (string, bool)

May 18, 2024

Changes in this version

type PodEvent

+ HostIP string

Apr 27, 2024

Changes in this version

+ type ENIClient interface

+ AssociateAddress func(podKey, podIP string, addressPoolId *string) (string, error)

+ DisassociateAddress func(podKey string) error

+ HasAssociatedAddress func(podIP string) (bool, error)

type Handler

+ func (h *Handler) AddOrUpdate(key string, pod v1.Pod) error

+ func (h *Handler) Delete(key string) error

+ type PodEvent struct

+ Annotations map[string]string

+ IP string

+ Key string

+ Labels map[string]string

+ Name string

+ Namespace string

+ ResourceVersion string

+ func NewPodEvent(key string, pod v1.Pod) PodEvent

+ func (p PodEvent) GetAddressPoolId() *string

+ func (p PodEvent) GetPublicIPLabel() (string, bool)

+ func (p PodEvent) HasEIPAnnotation() bool

Oct 9, 2023

Changes in this version

type Handler

+ K8sClient *kubernetes.Clientset

Sep 11, 2023

Changes in this version

+ type Handler struct

+ ChannelSize int32

+ EC2Service *service.EC2Service

+ EipStatusMap []map[string]event

+ ProcessChannel []chan event

+ ShiedService *service.ShiedService

+ func NewHandler(channelSize int32, vpcid string, region string) (handler *Handler, err error)

+ func (h *Handler) HandleEvent(obj *unstructured.Unstructured, oldObj *unstructured.Unstructured, ...) (err error)