kubewatcher

Documentation

Index

• func MakeWatchSubscription(ctx context.Context, logger *zap.Logger, w *fv1.KubernetesWatchTrigger, ...) (*watchSubscription, error)
• func Start(ctx context.Context, clientGen crd.ClientGeneratorInterface, ...) error
• type KubeWatcher
  • func MakeKubeWatcher(ctx context.Context, logger *zap.Logger, kubernetesClient kubernetes.Interface, ...) *KubeWatcher
• type WatchSync
  • func MakeWatchSync(ctx context.Context, logger *zap.Logger, client versioned.Interface, ...) (*WatchSync, error)
  • func (ws *WatchSync) KubeWatcherEventHandlers(ctx context.Context) error
  • func (ws *WatchSync) Run(ctx context.Context)

Functions

func MakeWatchSubscription

func MakeWatchSubscription(ctx context.Context, logger *zap.Logger, w *fv1.KubernetesWatchTrigger, kubeClient kubernetes.Interface, publisher publisher.Publisher) (*watchSubscription, error)

func Start

func Start(ctx context.Context, clientGen crd.ClientGeneratorInterface, logger *zap.Logger, routerUrl string) error

Types

type KubeWatcher

type KubeWatcher struct {
	// contains filtered or unexported fields
}

func MakeKubeWatcher

func MakeKubeWatcher(ctx context.Context, logger *zap.Logger, kubernetesClient kubernetes.Interface, publisher publisher.Publisher) *KubeWatcher

type WatchSync

type WatchSync struct {
	// contains filtered or unexported fields
}

func MakeWatchSync

func MakeWatchSync(ctx context.Context, logger *zap.Logger, client versioned.Interface, kubeWatcher *KubeWatcher) (*WatchSync, error)

func (*WatchSync) KubeWatcherEventHandlers

func (ws *WatchSync) KubeWatcherEventHandlers(ctx context.Context) error

func (*WatchSync) Run

func (ws *WatchSync) Run(ctx context.Context)