networkpolicy

Documentation

Index

• Variables
• type Config
  • func (c *Config) Defaults() error
• type Controller
  • func NewController(client clientset.Interface, ...) (*Controller, error)
  • func (c *Controller) Run(ctx context.Context) error

Variables

var ErrorCorrupted = fmt.Errorf("packet corrupted")

var ErrorTooShort = fmt.Errorf("packet too short")

Types

type Config

type Config struct {
	FailOpen                   bool // allow traffic if the controller is not available
	AdminNetworkPolicy         bool
	BaselineAdminNetworkPolicy bool
	QueueID                    int
	NodeName                   string
	NetfilterBug1766Fix        bool
	NFTableName                string // if other projects use this controllers they need to be able to use their own table name
}

func (*Config) Defaults

func (c *Config) Defaults() error

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller manages selector-based networkpolicy endpoints.

func NewController

func NewController(client clientset.Interface,
	networkpolicyInformer networkinginformers.NetworkPolicyInformer,
	namespaceInformer coreinformers.NamespaceInformer,
	podInformer coreinformers.PodInformer,
	nodeInformer coreinformers.NodeInformer,
	npaClient npaclient.Interface,
	adminNetworkPolicyInformer policyinformers.AdminNetworkPolicyInformer,
	baselineAdminNetworkPolicyInformer policyinformers.BaselineAdminNetworkPolicyInformer,
	config Config,
) (*Controller, error)

NewController returns a new *Controller.

func (*Controller) Run

func (c *Controller) Run(ctx context.Context) error

Run will not return until stopCh is closed. workers determines how many endpoints will be handled in parallel.