Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KubeBootstrap ¶
type KubeBootstrap interface { SaveError(message string) Work(*supervisor.Process) error }
func NewKubeBootstrap ¶
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)
Click to show internal directories.
Click to hide internal directories.