dpshim

Documentation

Index

• Variables
• type DPShim
  • 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

Variables

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

Types

type DPShim

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

func NewDPSim

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

func (*DPShim) AddPolicy

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

func (*DPShim) AddToLists

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

func (*DPShim) AddToSets

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

func (*DPShim) ApplyDataPlane

func (dp *DPShim) ApplyDataPlane() error

func (*DPShim) BootupDataplane

func (dp *DPShim) BootupDataplane() error

func (*DPShim) CreateIPSets

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

func (*DPShim) DeleteIPSet

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

func (*DPShim) FinishBootupPhase

func (dp *DPShim) FinishBootupPhase()

func (*DPShim) GetAllIPSets

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

func (*DPShim) GetAllPolicies

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

func (*DPShim) GetIPSet

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

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

func (*DPShim) HydrateClients

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

HydrateClients is used in DPShim to hydrate a restarted Daemon Client

func (*DPShim) RemoveFromList

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

func (*DPShim) RemoveFromSets

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

func (*DPShim) RemovePolicy

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

func (*DPShim) RunPeriodicTasks

func (dp *DPShim) RunPeriodicTasks()

func (*DPShim) UpdatePolicy

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