Documentation ¶
Index ¶
- Constants
- Variables
- func ErrCacheSync(name string, err error) error
- func ErrDynamicClient(name string, err error) error
- func ErrList(name string, err error) error
- func ErrPublish(name string, err error) error
- func New(log logger.Handler, informer dynamicinformer.DynamicSharedInformerFactory, ...) *pipeline.Pipeline
- type RegisterInformer
- type StartInformers
Constants ¶
View Source
const ( ErrListCode = "1001" ErrPublishCode = "1002" ErrDynamicClientCode = "1003" ErrCacheSyncCode = "1014" )
Variables ¶
View Source
var ( Name = internalconfig.PipelineNameKey GlobalDiscoveryStage = &pipeline.Stage{ Name: internalconfig.GlobalResourceKey, Concurrent: false, Steps: []pipeline.Step{}, } LocalDiscoveryStage = &pipeline.Stage{ Name: internalconfig.LocalResourceKey, Concurrent: false, Steps: []pipeline.Step{}, } StartInformersStage = &pipeline.Stage{ Name: "StartInformers", Concurrent: false, Steps: []pipeline.Step{}, } )
Functions ¶
func ErrCacheSync ¶ added in v0.5.0
func ErrDynamicClient ¶ added in v0.1.10
func ErrPublish ¶ added in v0.1.8
func New ¶
func New(log logger.Handler, informer dynamicinformer.DynamicSharedInformerFactory, broker broker.Handler, plConfigs map[string]internalconfig.PipelineConfigs, stopChan chan struct{}) *pipeline.Pipeline
Types ¶
type RegisterInformer ¶ added in v0.5.0
type RegisterInformer struct { pipeline.StepContext // contains filtered or unexported fields }
func (*RegisterInformer) Cancel ¶ added in v0.5.0
func (ri *RegisterInformer) Cancel() error
Cancel - step interface
func (*RegisterInformer) Exec ¶ added in v0.5.0
func (ri *RegisterInformer) Exec(request *pipeline.Request) *pipeline.Result
TODO: Find a way to respond when an informer has stopped for some reason unknown Exec - step interface
func (*RegisterInformer) GetEventHandlers ¶ added in v0.7.1
func (ri *RegisterInformer) GetEventHandlers() cache.ResourceEventHandlerFuncs
type StartInformers ¶ added in v0.5.0
type StartInformers struct { pipeline.StepContext // contains filtered or unexported fields }
func (*StartInformers) Cancel ¶ added in v0.5.0
func (si *StartInformers) Cancel() error
Cancel - step interface
Click to show internal directories.
Click to hide internal directories.