kubewatcher

Documentation

Index

• Constants
• func Start(controllerUrl string, routerUrl string) error
• type KubeWatcher
  • func MakeKubeWatcher(kubernetesClient *kubernetes.Clientset, publisher Publisher) *KubeWatcher
  • func (kw *KubeWatcher) Sync(watches []fission.Watch) error
• type Publisher
• type WatchSync
  • func MakeWatchSync(client *client.Client, kubeWatcher *KubeWatcher) *WatchSync
• type WebhookPublisher
  • func MakeWebhookPublisher(baseUrl string) *WebhookPublisher
  • func (p *WebhookPublisher) Publish(watchEvent watch.Event, url string)

Constants

const (
	SYNC requestType = iota
)

Functions

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) *KubeWatcher

func (*KubeWatcher) Sync

func (kw *KubeWatcher) Sync(watches []fission.Watch) error

type Publisher

type Publisher interface {
	// Publish an event to a "target".  Target's meaning depends on the
	// publisher: it's a URL in the case of a webhook publisher, or a queue
	// name in a queue-based publisher such as NATS.
	Publish(event watch.Event, target string)
}

type WatchSync

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

func MakeWatchSync

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

type WebhookPublisher

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

A webhook publisher for a single URL. Satisifies the Publisher interface.

func MakeWebhookPublisher

func MakeWebhookPublisher(baseUrl string) *WebhookPublisher

func (*WebhookPublisher) Publish

func (p *WebhookPublisher) Publish(watchEvent watch.Event, url string)