kubewatcher

Documentation

Index

• Constants
• func MakeWatchSubscription(w *tpr.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 []tpr.Kuberneteswatchtrigger) error
• type WatchSync
  • func MakeWatchSync(client *tpr.FissionClient, kubeWatcher *KubeWatcher) *WatchSync

Constants

const (
	SYNC requestType = iota
)

Functions

func MakeWatchSubscription

func MakeWatchSubscription(w *tpr.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 []tpr.Kuberneteswatchtrigger) error

type WatchSync

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

func MakeWatchSync

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