redirectpolicy

Documentation

Overview

Package redirectpolicy defines an internal representation of the Cilium Local Redirect Policy. The structures are managed by the RedirectPolicyManager.

Index

• Variables
• type LRPConfig
  • func Parse(clrp *v2.CiliumLocalRedirectPolicy, sanitize bool) (*LRPConfig, error)
  • func (config *LRPConfig) GetModel() *models.LRPSpec
• type Manager
  • func NewRedirectPolicyManager(svc svcManager, svcCache *k8s.ServiceCache, lpr agentK8s.LocalPodResource, ...) *Manager
  • func (rpm *Manager) AddRedirectPolicy(config LRPConfig) (bool, error)
  • func (rpm *Manager) DeleteRedirectPolicy(config LRPConfig) error
  • func (rpm *Manager) EndpointCreated(ep *endpoint.Endpoint)
  • func (rpm *Manager) EndpointDeleted(ep *endpoint.Endpoint, conf endpoint.DeleteConfig)
  • func (rpm *Manager) EndpointRestored(ep *endpoint.Endpoint)
  • func (rpm *Manager) GetLRPs() []*LRPConfig
  • func (rpm *Manager) OnAddPod(pod *slimcorev1.Pod)
  • func (rpm *Manager) OnAddService(svcID k8s.ServiceID)
  • func (rpm *Manager) OnDeletePod(pod *slimcorev1.Pod)
  • func (rpm *Manager) OnDeleteService(svcID k8s.ServiceID)
  • func (rpm *Manager) OnUpdatePod(pod *slimcorev1.Pod, needsReassign bool, ready bool)
  • func (rpm *Manager) OnUpdatePodLocked(pod *slimcorev1.Pod, removeOld bool, upsertNew bool)

Variables

var Cell = cell.Module(
	"lrp-manager",
	"LRP Manager",

	cell.Provide(newLRPManager),
	cell.Provide(newLRPApiHandler),
)

Cell provides access to the Local Redirect Policy Manager.

Types

type LRPConfig

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

LRPConfig is the internal representation of Cilium Local Redirect Policy.

func Parse

func Parse(clrp *v2.CiliumLocalRedirectPolicy, sanitize bool) (*LRPConfig, error)

Parse parses the specified cilium local redirect policy spec, and returns a sanitized LRPConfig.

func (*LRPConfig) GetModel

func (config *LRPConfig) GetModel() *models.LRPSpec

type Manager

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

Manager manages configurations related to Local Redirect Policies that enable redirecting traffic from the specified frontend to a set of node-local backend pods selected based on the backend configuration. To do that, it keeps track of add/delete events for resources like LRP, Pod and Service. For every local redirect policy configuration, it creates a new lb.SVCTypeLocalRedirect service with a frontend that has at least one node-local backend.

func NewRedirectPolicyManager

func NewRedirectPolicyManager(svc svcManager, svcCache *k8s.ServiceCache, lpr agentK8s.LocalPodResource, epM endpointManager) *Manager

func (*Manager) AddRedirectPolicy

func (rpm *Manager) AddRedirectPolicy(config LRPConfig) (bool, error)

AddRedirectPolicy parses the given local redirect policy config, and updates internal state with the config fields.

func (*Manager) DeleteRedirectPolicy

func (rpm *Manager) DeleteRedirectPolicy(config LRPConfig) error

DeleteRedirectPolicy deletes the internal state associated with the given policy.

func (*Manager) EndpointCreated

func (rpm *Manager) EndpointCreated(ep *endpoint.Endpoint)

func (*Manager) EndpointDeleted

func (rpm *Manager) EndpointDeleted(ep *endpoint.Endpoint, conf endpoint.DeleteConfig)

func (*Manager) EndpointRestored

func (rpm *Manager) EndpointRestored(ep *endpoint.Endpoint)

func (*Manager) GetLRPs

func (rpm *Manager) GetLRPs() []*LRPConfig

func (*Manager) OnAddPod

func (rpm *Manager) OnAddPod(pod *slimcorev1.Pod)

func (*Manager) OnAddService

func (rpm *Manager) OnAddService(svcID k8s.ServiceID)

OnAddService handles Kubernetes service (clusterIP type) add events, and updates the internal state for the policy config associated with the service.

func (*Manager) OnDeletePod

func (rpm *Manager) OnDeletePod(pod *slimcorev1.Pod)

func (*Manager) OnDeleteService

func (rpm *Manager) OnDeleteService(svcID k8s.ServiceID)

OnDeleteService handles Kubernetes service deletes, and deletes the internal state for the policy config that might be associated with the service.

func (*Manager) OnUpdatePod

func (rpm *Manager) OnUpdatePod(pod *slimcorev1.Pod, needsReassign bool, ready bool)

func (*Manager) OnUpdatePodLocked

func (rpm *Manager) OnUpdatePodLocked(pod *slimcorev1.Pod, removeOld bool, upsertNew bool)