dpshim

Feb 4, 2022

Changes in this version

type DPShim

+ func (dp *DPShim) InitializeDataPlane() error

+ func (dp *DPShim) ResetDataPlane() error

Nov 20, 2023

Changes in this version

+ var ErrChannelUnset = errors.New("channel must be set")

+ type DPShim struct

+ OutChannel chan *protos.Events

+ func NewDPSim(stopChannel <-chan struct{}) (*DPShim, error)

+ func (dp *DPShim) AddPolicy(networkpolicies *policies.NPMNetworkPolicy) error

+ func (dp *DPShim) AddToLists(listMetadatas, setMetadatas []*ipsets.IPSetMetadata) error

+ func (dp *DPShim) AddToSets(setMetadatas []*ipsets.IPSetMetadata, podMetadata *dataplane.PodMetadata) error

+ func (dp *DPShim) ApplyDataPlane() error

+ func (dp *DPShim) BootupDataplane() error

+ func (dp *DPShim) CreateIPSets(setMetadatas []*ipsets.IPSetMetadata)

+ func (dp *DPShim) DeleteIPSet(setMetadata *ipsets.IPSetMetadata, _ util.DeleteOption)

+ func (dp *DPShim) FinishBootupPhase()

+ func (dp *DPShim) GetAllIPSets() map[string]string

+ func (dp *DPShim) GetAllPolicies() []string

+ func (dp *DPShim) GetIPSet(setName string) *ipsets.IPSet

+ func (dp *DPShim) HydrateClients() (*protos.Events, error)

+ func (dp *DPShim) RemoveFromList(listMetadata *ipsets.IPSetMetadata, setMetadatas []*ipsets.IPSetMetadata) error

+ func (dp *DPShim) RemoveFromSets(setMetadatas []*ipsets.IPSetMetadata, podMetadata *dataplane.PodMetadata) error

+ func (dp *DPShim) RemovePolicy(policyKey string) error

+ func (dp *DPShim) RunPeriodicTasks()

+ func (dp *DPShim) UpdatePolicy(networkpolicies *policies.NPMNetworkPolicy) error