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 ErrWriteOutput(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" ErrWriteOutputCode = "1015" )
Variables ¶
View Source
var Name = internalconfig.PipelineNameKey
Functions ¶
func ErrCacheSync ¶
func ErrDynamicClient ¶
func ErrPublish ¶
func ErrWriteOutput ¶
func New ¶
func New( log logger.Handler, informer dynamicinformer.DynamicSharedInformerFactory, ow output.Writer, plConfigs map[string]internalconfig.PipelineConfigs, stopChan chan struct{}, clusterID string, outputFiltration internalconfig.OutputFiltrationContainer, ) *pipeline.Pipeline
Types ¶
type RegisterInformer ¶
type RegisterInformer struct {
pipeline.StepContext
// contains filtered or unexported fields
}
func (*RegisterInformer) Cancel ¶
func (ri *RegisterInformer) Cancel() error
Cancel - step interface
func (*RegisterInformer) Exec ¶
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 ¶
func (ri *RegisterInformer) GetEventHandlers() cache.ResourceEventHandlerFuncs
type StartInformers ¶
type StartInformers struct {
pipeline.StepContext
// contains filtered or unexported fields
}
func (*StartInformers) Exec ¶
func (si *StartInformers) Exec(request *pipeline.Request) *pipeline.Result
Exec starts the registered informers, then blocks until their caches have primed. The order is load-bearing: DynamicSharedInformerFactory.WaitForCacheSync only waits on informers that have already been started, so Start must run first. Calling WaitForCacheSync before Start makes it a no-op, so discovery proceeds against unprimed caches and reports an empty or partial cluster snapshot. WaitForCacheSync unblocks once every started informer has synced, or early if stopChan is closed (shutdown or resync).
Source Files
Click to show internal directories.
Click to hide internal directories.