handler

Documentation

Index

• type ENIClient
• type Handler
  • func NewHandler(logger *slog.Logger, coreClient clientv1.CoreV1Interface, eniClient ENIClient) *Handler
  • func (h *Handler) AddOrUpdate(key string, pod v1.Pod) error
  • func (h *Handler) Delete(key string) error
• type PodEvent
  • func NewPodEvent(key string, pod v1.Pod) PodEvent
  • func (p PodEvent) GetAddressPoolId() *string
  • func (p PodEvent) GetPublicIPLabel() (string, bool)
  • func (p PodEvent) HasEIPAnnotation() bool

Types

type ENIClient

type ENIClient interface {
	AssociateAddress(podKey, podIP, hostIP string, addressPoolId *string) (string, error)
	DisassociateAddress(podKey string) error
	HasAssociatedAddress(podIP, hostIP string) (bool, error)
}

type Handler

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

func NewHandler

func NewHandler(logger *slog.Logger, coreClient clientv1.CoreV1Interface, eniClient ENIClient) *Handler

func (*Handler) AddOrUpdate

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

func (*Handler) Delete

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

type PodEvent

type PodEvent struct {
	Key             string
	Name            string
	Namespace       string
	Annotations     map[string]string
	Labels          map[string]string
	IP              string
	HostIP          string
	ResourceVersion string
}

func NewPodEvent

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

func (PodEvent) GetAddressPoolId

func (p PodEvent) GetAddressPoolId() *string

func (PodEvent) GetPublicIPLabel

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

func (PodEvent) HasEIPAnnotation

func (p PodEvent) HasEIPAnnotation() bool