types

Documentation

Index

• Variables
• type DatapathHandler
• type IPListEntrySlice
  • func (s IPListEntrySlice) Len() int
  • func (s IPListEntrySlice) Less(i, j int) bool
  • func (s IPListEntrySlice) Swap(i, j int)
• type NodeHandler
• type PolicyHandler
• type ResourceID
  • func NewResourceID(kind ResourceKind, namespace, name string) ResourceID
• type ResourceKind

Variables

var (
	ResourceKindEndpoint             = ResourceKind("ep")
	ResourceKindEndpointSlice        = ResourceKind("endpointslices")
	ResourceKindEndpointSlicev1beta1 = ResourceKind("endpointslices_v1beta1")
	ResourceKindNode                 = ResourceKind("node")
)

Types

type DatapathHandler

type DatapathHandler interface {
	UpdatePolicyMaps(context.Context, *sync.WaitGroup) *sync.WaitGroup
}

DatapathHandler is responsible for ensuring that policy updates in the core policy engine are pushed into the underlying BPF policy maps, to ensure that the policies are actively being enforced in the datapath for any new identities that have been updated using 'PolicyHandler'.

Wait on the returned sync.WaitGroup to ensure that the operation is complete before updating the datapath's IPCache maps.

type IPListEntrySlice

type IPListEntrySlice []*models.IPListEntry

func (IPListEntrySlice) Len

func (s IPListEntrySlice) Len() int

func (IPListEntrySlice) Less

func (s IPListEntrySlice) Less(i, j int) bool

Less sorts the IPListEntry objects by CIDR prefix then IP address. Given that the same IP cannot map to more than one identity, no further sorting is performed.

func (IPListEntrySlice) Swap

func (s IPListEntrySlice) Swap(i, j int)

type NodeHandler

type NodeHandler interface {
	AllocateNodeID(net.IP) uint16
}

NodeHandler is responsible for the management of node identities.

type PolicyHandler

type PolicyHandler interface {
	UpdateIdentities(added, deleted cache.IdentityCache, wg *sync.WaitGroup)
}

PolicyHandler is responsible for handling identity updates into the core policy engine. See SelectorCache.UpdateIdentities() for more details.

type ResourceID

type ResourceID string

ResourceID identifies a unique copy of a resource that provides a source for information tied to an IP address in the IPCache.

func NewResourceID

func NewResourceID(kind ResourceKind, namespace, name string) ResourceID

NewResourceID returns a ResourceID populated with the standard fields for uniquely identifying a source of IPCache information.

type ResourceKind

type ResourceKind string

ResourceKind determines the source of the ResourceID. Typically this is the short name for the k8s resource.