kubewatcher

Documentation

Index

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

Constants

const (
	SYNC requestType = iota
)

Functions

func MakeWatchSubscription

func MakeWatchSubscription(w *fission.Watch, kubeClient *kubernetes.Clientset, publisher publisher.Publisher) (*watchSubscription, error)

func Start

func Start(controllerUrl string, 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 []fission.Watch) error

type WatchSync

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

func MakeWatchSync

func MakeWatchSync(client *client.Client, kubeWatcher *KubeWatcher) *WatchSync