Documentation
¶
Index ¶
Constants ¶
View Source
const (
SYNC requestType = iota
)
Variables ¶
This section is empty.
Functions ¶
func MakeWatchSubscription ¶
func MakeWatchSubscription(w *crd.KubernetesWatchTrigger, kubeClient *kubernetes.Clientset, publisher publisher.Publisher) (*watchSubscription, 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
Source Files
Click to show internal directories.
Click to hide internal directories.