awsvpccni

package
v1.3.15-beta2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 17, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ClusterNetworkPolicyAPIVersion is the API version for AWS VPC CNI ClusterNetworkPolicy.
	ClusterNetworkPolicyAPIVersion = "networking.k8s.aws/v1alpha1"
	// ClusterNetworkPolicyName is the name of the policy created by the operator.
	ClusterNetworkPolicyName = "illumio-cloud-operator-flow-logging"
)
View Source
const DefaultPollInterval = 1 * time.Second

DefaultPollInterval is the default interval for polling logs (matches kubectl default).

Variables

This section is empty.

Functions

func EnsureFlowLoggingPolicy

func EnsureFlowLoggingPolicy(ctx context.Context, logger *zap.Logger, dynamicClient dynamic.Interface) error

EnsureFlowLoggingPolicy creates the ClusterNetworkPolicy for comprehensive flow logging. If the policy already exists, it returns nil (idempotent).

func IsCRDAvailable

func IsCRDAvailable(logger *zap.Logger, discoveryClient discovery.DiscoveryInterface) bool

IsCRDAvailable checks if the ClusterNetworkPolicy CRD is registered in the cluster.

Types

type Factory

type Factory struct {
	Logger       *zap.Logger
	FlowSink     collector.FlowSink
	K8sClient    kubernetes.Interface
	PollInterval time.Duration
}

Factory creates VPC CNI flow collector clients.

func (*Factory) NewCollector

func (f *Factory) NewCollector(_ context.Context) (flowCollector, error)

NewCollector creates a new VPC CNI flow collector.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL