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 ¶
func ErrDynamicClient ¶
func ErrPublish ¶
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 ¶
type RegisterInformer struct { pipeline.StepContext // contains filtered or unexported fields }
func (*RegisterInformer) Cancel ¶
func (ri *RegisterInformer) Cancel() error
Cancel - step interface
type StartInformers ¶
type StartInformers struct { pipeline.StepContext // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.