informer

Documentation

Index

• type Factory
  • func NewInformerFactory(config *config.ListWatcherConfig) Factory
• type Handler
• type Informer
  • func NewInformer(listWatcher listwatcher.Interface) Informer
• type ResourceHandler
  • func (h *ResourceHandler) Check(obj interface{}) bool
  • func (h *ResourceHandler) Handle(obj interface{}) error

Types

type Factory

type Factory interface {
	ClusterAgentInformer(token string) Informer

	PipelineRunInformer(cond *pipeline.PipelineRunWatchCondition) Informer
	PipelineRunJobInformer(cond *pipeline.PipelineRunJobWatchCondition) Informer
	PipelineTriggerInformer(cond *pipeline.PipelineTriggerWatchCondition) Informer
	PipelineTriggerEventInformer(cond *pipeline.PipelineTriggerEventWatchCondition) Informer
	PipelineCodeCacheInformer(cond *pipeline.PipelineCodeCacheWatchCondition) Informer

	SpaceletInformer(cond *spacelet.SpaceletWatchCondition) Informer
}

func NewInformerFactory

func NewInformerFactory(config *config.ListWatcherConfig) Factory

type Handler

type Handler interface {
	Check(interface{}) bool
	Handle(interface{}) error
}

Handler informer监听到资源后，首先调用该处理器中的Check，判断是否需要处理 之后调用Handle进行处理

type Informer

type Informer interface {
	Run(stopCh <-chan struct{})
	AddHandler(Handler)
}

func NewInformer

func NewInformer(listWatcher listwatcher.Interface) Informer

type ResourceHandler

type ResourceHandler struct {
	CheckFunc  func(interface{}) bool
	HandleFunc func(interface{}) error
}

ResourceHandler 通用资源处理对象，也可以自定义对象，实现Handler接口

func (*ResourceHandler) Check

func (h *ResourceHandler) Check(obj interface{}) bool

func (*ResourceHandler) Handle

func (h *ResourceHandler) Handle(obj interface{}) error