controller

package
v0.0.0-...-4530474 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2022 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const MAX_RETRY int = 3

Variables

This section is empty.

Functions

func Start

func Start(client kubernetes.Interface, hzjclient hzjcs.Interface)

Types

type Controller

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

func (*Controller) HasSynced

func (c *Controller) HasSynced() bool

Implement cache.Controller interface

func (*Controller) LastSyncResourceVersion

func (c *Controller) LastSyncResourceVersion() string

Implement cache.Controller interface

func (*Controller) Process

func (c *Controller) Process(event Event) error

func (*Controller) Run

func (c *Controller) Run(chStop <-chan struct{})

Implement cache.Controller interface

type DefaultHandler

type DefaultHandler struct{}

default handler simply print out the pod's basic information

func (*DefaultHandler) Created

func (dh *DefaultHandler) Created(item interface{})

func (*DefaultHandler) Deleted

func (dh *DefaultHandler) Deleted(item interface{})

func (*DefaultHandler) Updated

func (dh *DefaultHandler) Updated(item interface{})

type Event

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

Sent to queue by informer if match the condition

type Handler

type Handler interface {
	Created(item interface{})
	Updated(item interface{})
	Deleted(item interface{})
}

type HzjHandler

type HzjHandler struct{}

print out type fufu's information

func (*HzjHandler) Created

func (hh *HzjHandler) Created(item interface{})

func (*HzjHandler) Deleted

func (hh *HzjHandler) Deleted(item interface{})

func (*HzjHandler) Updated

func (hh *HzjHandler) Updated(item interface{})

Jump to

Keyboard shortcuts

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