dpshim

package

v1.4.21 Latest Latest Go to latest Published: Mar 10, 2022 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

type DPShim struct {
	OutChannel chan *protos.Events
	// contains filtered or unexported fields
}

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) GetAllIPSets() []string

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

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

GetIPSet is a no-op in DPShim since DPShim does not deal with IPSet object

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

HydrateClients is used in DPShim to hydrate a restarted Daemon Client

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