namespace

Documentation

Index

• func RegisterNewControllerFunc(newFunc NewControllerFunc)
• type BaseController
  • func (b BaseController) Namespace() string
  • func (b BaseController) ProcessImageEvent(eventservice.ImageEvent)
• type Controller
  • func NewAggregationController(namespace string, k8sClient kubernetes.Interface) Controller
• type NamespaceController
  • func NewNamespaceController(informers informers.InformerFactory, client kubernetes.Interface, ...) *NamespaceController
  • func (n *NamespaceController) ImageEventHandlerFunc(event eventservice.ImageEvent)
  • func (n *NamespaceController) Start(ctx context.Context) error
• type NewControllerFunc

Functions

func RegisterNewControllerFunc

func RegisterNewControllerFunc(newFunc NewControllerFunc)

RegisterNewControllerFunc

Types

type BaseController

type BaseController struct {
	NameSpace string
}

BaseController empty implementation

func (BaseController) Namespace

func (b BaseController) Namespace() string

func (BaseController) ProcessImageEvent

func (b BaseController) ProcessImageEvent(eventservice.ImageEvent)

type Controller

type Controller interface {
	// return the namespace of the current controller
	Namespace() string
	Run()
	Stop()
	ProcessImageEvent(event eventservice.ImageEvent)
}

Controller Listens for resources in the current namespace

func NewAggregationController

func NewAggregationController(namespace string, k8sClient kubernetes.Interface) Controller

type NamespaceController

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

NamespaceController namespace 控制器，根据 namespace 的 labels 判断是否启动 AggregationController

func NewNamespaceController

func NewNamespaceController(informers informers.InformerFactory, client kubernetes.Interface, imageEventCollect eventservice.ImageEventCollect) *NamespaceController

func (*NamespaceController) ImageEventHandlerFunc

func (n *NamespaceController) ImageEventHandlerFunc(event eventservice.ImageEvent)

ImageEventHandlerFunc update the deployment container image based on event.

func (*NamespaceController) Start

func (n *NamespaceController) Start(ctx context.Context) error

type NewControllerFunc

type NewControllerFunc func(namespace string, k8sClient kubernetes.Interface, namespaceInformerFactory informers.InformerFactory) Controller