ek8s

Documentation

Index

• Constants
• type Component
  • func (c *Component) ListEndpoints(appName string) (pods []*v1.Endpoints, err error)
  • func (c *Component) ListPod(appName string) (pods []*v1.Pod, err error)
  • func (c *Component) NewWatcherApp(ctx context.Context, appName string, kind string) (app *WatcherApp, err error)
• type Config
  • func DefaultConfig() *Config
• type Container
  • func DefaultContainer() *Container
  • func Load(key string) *Container
  • func (c *Container) Build(options ...Option) *Component
• type KubernetesEvent
• type Option
  • func WithAddr(addr string) Option
  • func WithDebug(debug bool) Option
  • func WithDeploymentPrefix(deploymentPrefix string) Option
  • func WithNamespaces(namespaces []string) Option
  • func WithTLSClientConfigInsecure(insecure bool) Option
  • func WithToken(token string) Option
• type WatcherApp
  • func (c *WatcherApp) ProcessWorkItem(f func(info *KubernetesEvent) error) bool

Constants

const (
	KindPod       = "Pod"
	KindEndpoints = "Endpoints"
)

const PackageName = "component.ek8s"

Types

type Component

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

Component ...

func (*Component) ListEndpoints

func (c *Component) ListEndpoints(appName string) (pods []*v1.Endpoints, err error)

func (*Component) ListPod

func (c *Component) ListPod(appName string) (pods []*v1.Pod, err error)

func (*Component) NewWatcherApp

func (c *Component) NewWatcherApp(ctx context.Context, appName string, kind string) (app *WatcherApp, err error)

type Config

type Config struct {
	Addr                    string
	Debug                   bool
	Token                   string
	Namespaces              []string
	DeploymentPrefix        string // 命名前缀
	TLSClientConfigInsecure bool
}

Config ...

func DefaultConfig

func DefaultConfig() *Config

DefaultConfig 返回默认配置

type Container

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

func DefaultContainer

func DefaultContainer() *Container

func Load

func Load(key string) *Container

func (*Container) Build

func (c *Container) Build(options ...Option) *Component

Build ...

type KubernetesEvent

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

type Option

type Option func(c *Container)

Option 可选项

func WithAddr

func WithAddr(addr string) Option

func WithDebug

func WithDebug(debug bool) Option

func WithDeploymentPrefix

func WithDeploymentPrefix(deploymentPrefix string) Option

func WithNamespaces

func WithNamespaces(namespaces []string) Option

func WithTLSClientConfigInsecure

func WithTLSClientConfigInsecure(insecure bool) Option

func WithToken

func WithToken(token string) Option

type WatcherApp

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

func (*WatcherApp) ProcessWorkItem

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