thingkube

Documentation

Index

• type K8sEvent
• type KubeBootstrap
  • func NewKubeBootstrap(namespace string, kinds []string, fieldSelector string, labelSelector string, ...) KubeBootstrap
• type KubeWatchMan
  • func NewKubeWatchMan(client *k8s.Client, eventsCh chan<- K8sEvent, ...) KubeWatchMan
• type KubernetesWatchMaker
  • func (m *KubernetesWatchMaker) MakeKubernetesWatch(spec watchapi.KubernetesWatchSpec) (*supervisor.Worker, error)

Types

type K8sEvent

type K8sEvent struct {
	WatchID   string
	Kind      string
	Resources []k8s.Resource
	Errors    []watt.Error
}

type KubeBootstrap

type KubeBootstrap interface {
	SaveError(message string)
	Work(*supervisor.Process) error
}

func NewKubeBootstrap

func NewKubeBootstrap(
	namespace string,
	kinds []string,
	fieldSelector string,
	labelSelector string,
	notify []chan<- K8sEvent,
	kubeAPIWatcher *k8s.Watcher,
) KubeBootstrap

type KubeWatchMan

type KubeWatchMan interface {
	Work(*supervisor.Process) error
	NumWatched() int
	WithWatched(func(map[string]*supervisor.Worker))
}

func NewKubeWatchMan

func NewKubeWatchMan(
	client *k8s.Client,
	eventsCh chan<- K8sEvent,
	watchesCh <-chan []watchapi.KubernetesWatchSpec,
) KubeWatchMan

type KubernetesWatchMaker

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

func (*KubernetesWatchMaker) MakeKubernetesWatch

func (m *KubernetesWatchMaker) MakeKubernetesWatch(spec watchapi.KubernetesWatchSpec) (*supervisor.Worker, error)