kubewatcher

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 12, 2017 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SYNC requestType = iota
)

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL