networkpolicy

Documentation

Index

• Constants
• Variables
• type CloudResourceNpTracker
• type InProgress
  • func (i *InProgress) Error() string
  • func (i *InProgress) String() string
• type NetworkPolicyController
• type NetworkPolicyReconciler
  • func (r *NetworkPolicyReconciler) ExternalEntityStart(_ context.Context) error
  • func (r *NetworkPolicyReconciler) GetNpTrackerIndexer() cache.Indexer
  • func (r *NetworkPolicyReconciler) LocalEvent(event watch.Event)
  • func (r *NetworkPolicyReconciler) Reconcile(_ context.Context, _ ctrl.Request) (ctrl.Result, error)
  • func (r *NetworkPolicyReconciler) SetupWithManager(mgr ctrl.Manager, antreaKubeconfig string) error
  • func (r *NetworkPolicyReconciler) Start(stop context.Context) error
• type PendingItem
• type PendingItemQueue
  • func NewPendingItemQueue(context interface{}, retryCount *int) *PendingItemQueue
  • func (q *PendingItemQueue) Add(id string, p PendingItem)
  • func (q *PendingItemQueue) CheckToRun(forceRetry bool)
  • func (q *PendingItemQueue) GetRetryCount(id string) int
  • func (q *PendingItemQueue) Has(id string) bool
  • func (q *PendingItemQueue) Remove(id string)
  • func (q *PendingItemQueue) Update(id string, checkRun bool, updates ...interface{}) error

Constants

const (
	NpTrackerIndexerByNamespace      = "Namespace"
	NpTrackerIndexerByNamespacedName = "NamespacedName"
)

const (
	InProgressStr = "in-progress"
	NoneStr       = "<none>"
)

const (
	NetworkPolicyStatusApplied      = "Applied"
	AppliedSecurityGroupDeleteError = "Detaching/Deleting security group %v: %v"
)

Variables

var (
	AntreaProtocolMap = map[antreanetworking.Protocol]int{
		antreanetworking.ProtocolTCP:  6,
		antreanetworking.ProtocolUDP:  17,
		antreanetworking.ProtocolSCTP: 132,
	}
)

Types

type CloudResourceNpTracker

type CloudResourceNpTracker struct {
	// CloudResource is a cloud resource.
	CloudResource cloudresource.CloudResource
	// NamespacedName of the cloud resource.
	NamespacedName types.NamespacedName

	// NpStatus map of network policy (ANP) name to their realization status.
	NpStatus map[string]*runtimev1alpha1.NetworkPolicyStatus
	// contains filtered or unexported fields
}

CloudResourceNpTracker tracks NetworkPolicies applied on cloud resource.

type InProgress

type InProgress struct{}

InProgress indicates a securityGroup operation is in progress.

func (*InProgress) Error

func (i *InProgress) Error() string

func (*InProgress) String

func (i *InProgress) String() string

type NetworkPolicyController

type NetworkPolicyController interface {
	LocalEvent(watch.Event)
}

type NetworkPolicyReconciler

type NetworkPolicyReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	Inventory inventory.Interface

	// CloudSyncInterval specifies the interval (in seconds) to be used for syncing cloud resources with controller.
	CloudSyncInterval int64
	// contains filtered or unexported fields
}

NetworkPolicyReconciler reconciles a NetworkPolicy object.

func (*NetworkPolicyReconciler) ExternalEntityStart

func (r *NetworkPolicyReconciler) ExternalEntityStart(_ context.Context) error

ExternalEntityStart performs the initialization of the controller. A controller is said to be initialized only when the dependent controllers are synced, and it keeps a count of pending CRs to be reconciled.

func (*NetworkPolicyReconciler) GetNpTrackerIndexer

func (r *NetworkPolicyReconciler) GetNpTrackerIndexer() cache.Indexer

func (*NetworkPolicyReconciler) LocalEvent

func (r *NetworkPolicyReconciler) LocalEvent(event watch.Event)

LocalEvent adds a network policy event from local stack.

func (*NetworkPolicyReconciler) Reconcile

func (r *NetworkPolicyReconciler) Reconcile(_ context.Context, _ ctrl.Request) (ctrl.Result, error)

Reconcile exists to cache ExternalEntities in shared informer.

func (*NetworkPolicyReconciler) SetupWithManager

func (r *NetworkPolicyReconciler) SetupWithManager(mgr ctrl.Manager, antreaKubeconfig string) error

SetupWithManager sets up NetworkPolicyReconciler with manager.

func (*NetworkPolicyReconciler) Start

func (r *NetworkPolicyReconciler) Start(stop context.Context) error

Start starts NetworkPolicyReconciler.

type PendingItem

type PendingItem interface {
	// RunPendingItem runs this pending item, it returns true if item
	// should be removed.
	RunPendingItem(id string, context interface{}) bool
	// UpdatePendingItem updates ths pending item, returns
	UpdatePendingItem(id string, context interface{}, updates ...interface{})
	// RunOrDeletePendingItem returns run as true, if this item can be run;
	// returns delete as true, if this item shall be removed.
	RunOrDeletePendingItem(id string, context interface{}) (run bool, delete bool)
	// ClearPendingState clears item state when removing item from pending queue.
	ClearPendingState()
}

type PendingItemQueue

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

func NewPendingItemQueue

func NewPendingItemQueue(context interface{}, retryCount *int) *PendingItemQueue

NewPendingItemQueue returns a new PendingItemQueue. If retryCount is not provided, item is removed if item.RunOrDeletePendingItem returns true; if retryCount is provided, item is also removed when item.RunPendingItem is called.

func (*PendingItemQueue) Add

func (q *PendingItemQueue) Add(id string, p PendingItem)

Add a pending item to queue.

func (*PendingItemQueue) CheckToRun

func (q *PendingItemQueue) CheckToRun(forceRetry bool)

CheckToRun check and run all items on queue.

func (*PendingItemQueue) GetRetryCount

func (q *PendingItemQueue) GetRetryCount(id string) int

GetRetryCount returns remaining retryCount of item if applicable.

func (*PendingItemQueue) Has

func (q *PendingItemQueue) Has(id string) bool

Has returns true if an item in the queue.

func (*PendingItemQueue) Remove

func (q *PendingItemQueue) Remove(id string)

Remove a pending item from queue.

func (*PendingItemQueue) Update

func (q *PendingItemQueue) Update(id string, checkRun bool, updates ...interface{}) error

Update item and check to run item.