Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetSinkURI ¶
func GetSinkURI(dc dynamic.Interface, sink *corev1.ObjectReference, namespace string) (string, error)
GetSinkURI retrieves the sink URI from the object referenced by the given ObjectReference.
func NewController ¶
func NewController( logger *zap.SugaredLogger, kubeclientset kubernetes.Interface, dynamicClient dynamic.Interface, gcssourceclientset clientset.Interface, gcssourceInformer informers.GCSSourceInformer, pubsubclientset pubsubsourceclientset.Interface, pubsubsourceInformer pubsubsourceinformers.GcpPubSubSourceInformer, ) *controller.Impl
NewController returns a new gcssource controller
Types ¶
type Reconciler ¶
type Reconciler struct {
// Sugared logger is easier to use but is not as performant as the
// raw logger. In performance critical paths, call logger.Desugar()
// and use the returned raw logger instead. In addition to the
// performance benefits, raw logger also preserves type-safety at
// the expense of slightly greater verbosity.
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
Reconciler is the controller implementation for Gcssource resources
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.