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.