ciliumenvoyconfig

Documentation

Index

• Constants
• Variables
• func NewCECTable(db *statedb.DB) (statedb.RWTable[*CEC], error)
• func NewEnvoyResourcesTable(db *statedb.DB) (statedb.RWTable[*EnvoyResource], error)
• type CEC
  • func (cec *CEC) Clone() *CEC
  • func (*CEC) TableHeader() []string
  • func (cec *CEC) TableRow() []string
• type CECMetrics
• type CECName
• type EnvoyResource
  • func (r *EnvoyResource) Clone() *EnvoyResource
  • func (r *EnvoyResource) GetStatus() reconciler.Status
  • func (r *EnvoyResource) SetStatus(newStatus reconciler.Status) *EnvoyResource
  • func (*EnvoyResource) TableHeader() []string
  • func (r *EnvoyResource) TableRow() []string
• type PortAllocator

Constants

const (
	CECTableName = "ciliumenvoyconfigs"
)

const (
	EnvoyResourcesTableName = "envoy-resources"
)

Variables

var (
	CECByName = cecNameIndex.Query

	CECByServiceName = cecServiceIndex.Query
)

var Cell = cell.Module(
	"ciliumenvoyconfig",
	"CiliumEnvoyConfig",

	cell.Config(cecConfig{}),
	cell.Invoke(registerCECK8sReconciler),
	cell.ProvidePrivate(newCECManager),
	cell.ProvidePrivate(newCECResourceParser),
	cell.ProvidePrivate(newEnvoyServiceBackendSyncer),
	cell.ProvidePrivate(newPortAllocator),

	experimentalCell,
)

Cell provides support for the CRD CiliumEnvoyConfig that backs Ingress, Gateway API and L7 loadbalancing.

var (
	EnvoyResourceByName = envoyResourceNameIndex.Query
)

Functions

func NewCECTable

func NewCECTable(db *statedb.DB) (statedb.RWTable[*CEC], error)

func NewEnvoyResourcesTable

func NewEnvoyResourcesTable(db *statedb.DB) (statedb.RWTable[*EnvoyResource], error)

Types

type CEC

type CEC struct {
	Name k8sTypes.NamespacedName
	Spec *ciliumv2.CiliumEnvoyConfigSpec

	Selector         labels.Selector `json:"-" yaml:"-"`
	SelectsLocalNode bool
	Listeners        part.Map[string, uint16]

	// Resources is the parsed envoy.Resources with the endpoints filled in.
	Resources envoy.Resources
}

func (*CEC) Clone

func (cec *CEC) Clone() *CEC

func (*CEC) TableHeader

func (*CEC) TableHeader() []string

func (*CEC) TableRow

func (cec *CEC) TableRow() []string

type CECMetrics

type CECMetrics interface {
	AddCEC(cec *ciliumv2.CiliumEnvoyConfigSpec)
	DelCEC(cec *ciliumv2.CiliumEnvoyConfigSpec)
	AddCCEC(spec *ciliumv2.CiliumEnvoyConfigSpec)
	DelCCEC(spec *ciliumv2.CiliumEnvoyConfigSpec)
}

type CECName

type CECName = k8sTypes.NamespacedName

type EnvoyResource

type EnvoyResource struct {
	Name      CECName
	Resources envoy.Resources
	Redirects map[loadbalancer.ServiceName]*experimental.ProxyRedirect `json:"-"`

	ReconciledResources *envoy.Resources
	ReconciledRedirects map[loadbalancer.ServiceName]*experimental.ProxyRedirect `json:"-"`

	Status reconciler.Status
}

func (*EnvoyResource) Clone

func (r *EnvoyResource) Clone() *EnvoyResource

func (*EnvoyResource) GetStatus

func (r *EnvoyResource) GetStatus() reconciler.Status

func (*EnvoyResource) SetStatus

func (r *EnvoyResource) SetStatus(newStatus reconciler.Status) *EnvoyResource

func (*EnvoyResource) TableHeader

func (*EnvoyResource) TableHeader() []string

func (*EnvoyResource) TableRow

func (r *EnvoyResource) TableRow() []string

type PortAllocator

type PortAllocator interface {
	AllocateCRDProxyPort(name string) (uint16, error)
	AckProxyPort(ctx context.Context, name string) error
	ReleaseProxyPort(name string) error
}