controller

Documentation

Index

• Constants
• func AddNetworkAttachmentDefinitionToObject(object *meta.ObjectMeta, name string)
• func GetObjectNetworkAttachmentDefinition(object *meta.ObjectMeta) ([]string, bool)
• func GetObjectNetworkNames(object *meta.ObjectMeta) ([]string, bool)
• func ObjectHasNetwork(object *meta.ObjectMeta, name string) bool
• func ObjectHasNetworkAttachmentDefinition(object *meta.ObjectMeta, name string) bool
• type Controller
  • func NewController(toolName string, cluster bool, namespace string, ...) *Controller
  • func (self *Controller) Run(concurrency uint, startup func()) error

Constants

const (
	NamePrefix        = "knap"
	PartOf            = "Knap"
	ManagedBy         = "Knap"
	OperatorImageName = "tliron/knap-operator"
)

Functions

func AddNetworkAttachmentDefinitionToObject

func AddNetworkAttachmentDefinitionToObject(object *meta.ObjectMeta, name string)

func GetObjectNetworkAttachmentDefinition

func GetObjectNetworkAttachmentDefinition(object *meta.ObjectMeta) ([]string, bool)

func GetObjectNetworkNames

func GetObjectNetworkNames(object *meta.ObjectMeta) ([]string, bool)

func ObjectHasNetwork

func ObjectHasNetwork(object *meta.ObjectMeta, name string) bool

func ObjectHasNetworkAttachmentDefinition

func ObjectHasNetworkAttachmentDefinition(object *meta.ObjectMeta, name string) bool

Types

type Controller

type Controller struct {
	Config      *restpkg.Config
	Kubernetes  kubernetes.Interface
	Knap        knapclientset.Interface
	REST        restpkg.Interface
	Client      *clientpkg.Client
	StopChannel <-chan struct{}

	Processors *kubernetesutil.Processors
	Events     record.EventRecorder

	KubernetesInformerFactory informers.SharedInformerFactory
	KnapInformerFactory       knapinformers.SharedInformerFactory

	Networks knaplisters.NetworkLister

	Context contextpkg.Context
	Log     commonlog.Logger
}

func NewController

func NewController(toolName string, cluster bool, namespace string, kubernetes kubernetes.Interface, apiExtensions apiextensionspkg.Interface, net netpkg.Interface, knap knapclientset.Interface, config *restpkg.Config, informerResyncPeriod time.Duration, stopChannel <-chan struct{}) *Controller

func (*Controller) Run

func (self *Controller) Run(concurrency uint, startup func()) error