Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDynamicSource ¶
func NewDynamicSource(cfg DynamicSourceConfig) *dynamicInformerSource
Types ¶
type DynamicSourceConfig ¶
type DynamicSourceConfig struct {
// DynamicInformerFactory is the dynamicinformer.DynamicSharedInformerFactory
// that is used to generate the informers configured on this sources startup.
// If you use a dynamicinformer.DynamicSharedInformerFactory that you've
// used previously, it must not have been used to start a new informer for
// the same GVR. You can not start or configure an informer that has already
// been started, even after it has been stopped. Reusing an informer factory
// may result in attempting to configure and start an informer that has
// already been started.
DynamicInformerFactory dynamicinformer.DynamicSharedInformerFactory
// GVR is the GroupVersionResource that this source is responsible
// for creating and configuring an informer for
GVR schema.GroupVersionResource
// Owner is the client.Object that owns the managed content that this
// source will be creating an informer to react to events for. This
// field is used to attempt to requeue the owning client.Object for
// reconciliation on a watch error after a previously successful sync
Owner client.Object
// Handler is the handler.EventHandler that is used to react to events
// received by the configured source
Handler handler.EventHandler
// Predicates are the predicate.Predicate functions used to determine
// if a triggered event should be reacted to
Predicates []predicate.Predicate
// OnPostSyncError is the callback function that is used when the source
// initially synced successfully and later encountered an error
OnPostSyncError func(context.Context)
}
Click to show internal directories.
Click to hide internal directories.