Import path: gitlab.soludian.com/soludian/fountain/libs/sd/k8s

k8s

import "gitlab.soludian.com/soludian/fountain/libs/sd/k8s"

Index

• Constants
• type KubernetesEvent
• type WatcherApp
  • func NewWatcherApp(ctx context.Context, clientSet *kubernetes.Clientset, namespaces []string, appName string, kind string, deploymentPrefix string) (app *WatcherApp, err error)
  • func (c *WatcherApp) ProcessWorkItem(f func(info *KubernetesEvent) error) bool

Constants

const (
    KDefaultRSync = 5 * time.Minute
)

type KubernetesEvent

type KubernetesEvent struct {
    IPs       []string
    EventType watch.EventType
}

type WatcherApp

type WatcherApp struct {
    *kubernetes.Clientset
    // contains filtered or unexported fields
}

func NewWatcherApp

func NewWatcherApp(ctx context.Context, clientSet *kubernetes.Clientset, namespaces []string, appName string, kind string, deploymentPrefix string) (app *WatcherApp, err error)

func (*WatcherApp) ProcessWorkItem

func (c *WatcherApp) ProcessWorkItem(f func(info *KubernetesEvent) error) bool

Generated by gomarkdoc