controller

Documentation

Overview

Copyright 2018 Microsoft. All rights reserved. MIT License

Index

• Variables
• type NetworkPolicyServer
  • func NewNetworkPolicyServer(config npmconfig.Config, informerFactory informers.SharedInformerFactory, ...) (*NetworkPolicyServer, error)
  • func (n *NetworkPolicyServer) GetAppVersion() string
  • func (n *NetworkPolicyServer) MarshalJSON() ([]byte, error)
  • func (n *NetworkPolicyServer) Start(config npmconfig.Config, stopCh <-chan struct{}) error

Variables

var (
	ErrInformerFactoryNil      = errors.New("informer factory is nil")
	ErrTransportManagerNil     = errors.New("transport manager is nil")
	ErrK8SServerVersionNil     = errors.New("k8s server version is nil")
	ErrDataplaneNotInitialized = errors.New("dataplane is not initialized")
)

Types

type NetworkPolicyServer

type NetworkPolicyServer struct {

	// Informers are the Kubernetes Informer
	// https://pkg.go.dev/k8s.io/client-go/informers
	models.Informers

	// Controllers for handling Kubernetes resource watcher events
	models.K8SControllersV2

	// Azure-specific variables
	models.AzureConfig
	// contains filtered or unexported fields
}

func NewNetworkPolicyServer

func NewNetworkPolicyServer(
	config npmconfig.Config,
	informerFactory informers.SharedInformerFactory,
	mgr *transport.EventsServer,
	dp dataplane.GenericDataplane,
	npmVersion string,
	k8sServerVersion *version.Info,
) (*NetworkPolicyServer, error)

func (*NetworkPolicyServer) GetAppVersion

func (n *NetworkPolicyServer) GetAppVersion() string

func (*NetworkPolicyServer) MarshalJSON

func (n *NetworkPolicyServer) MarshalJSON() ([]byte, error)

func (*NetworkPolicyServer) Start

func (n *NetworkPolicyServer) Start(config npmconfig.Config, stopCh <-chan struct{}) error