kubewatcher

Documentation

Index

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

Constants

const (
	SYNC requestType = iota
)

Functions

func MakeWatchSubscription

func MakeWatchSubscription(w *crd.KubernetesWatchTrigger, kubeClient *kubernetes.Clientset, publisher publisher.Publisher) (*watchSubscription, error)

func Start

func Start(routerUrl string) error

Types

type KubeWatcher

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

func MakeKubeWatcher

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

func (*KubeWatcher) Sync

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

type WatchSync

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

func MakeWatchSync

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