kubewatcher

Documentation

Index

• Constants
• func MakeWatchSubscription(logger *zap.Logger, w *fv1.KubernetesWatchTrigger, ...) (*watchSubscription, error)
• func Start(logger *zap.Logger, routerUrl string) error
• type KubeWatcher
  • func MakeKubeWatcher(logger *zap.Logger, kubernetesClient *kubernetes.Clientset, ...) *KubeWatcher
  • func (kw *KubeWatcher) Sync(watches []fv1.KubernetesWatchTrigger) error
• type WatchSync
  • func MakeWatchSync(logger *zap.Logger, client *crd.FissionClient, kubeWatcher *KubeWatcher) *WatchSync

Constants

const (
	SYNC requestType = iota
)

Functions

func MakeWatchSubscription

func MakeWatchSubscription(logger *zap.Logger, w *fv1.KubernetesWatchTrigger, kubeClient *kubernetes.Clientset, publisher publisher.Publisher) (*watchSubscription, error)

func Start

func Start(logger *zap.Logger, routerUrl string) error

Types

type KubeWatcher

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

func MakeKubeWatcher

func MakeKubeWatcher(logger *zap.Logger, kubernetesClient *kubernetes.Clientset, publisher publisher.Publisher) *KubeWatcher

func (*KubeWatcher) Sync

func (kw *KubeWatcher) Sync(watches []fv1.KubernetesWatchTrigger) error

type WatchSync

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

func MakeWatchSync

func MakeWatchSync(logger *zap.Logger, client *crd.FissionClient, kubeWatcher *KubeWatcher) *WatchSync