kubernetes

Documentation

Index

• func GetAnnotation(m meta.ObjectMeta, name string) (string, bool)
• func IgnoreAlreadyExists(err error) error
• func IgnoreError(err error, handler func(error) bool) error
• func IgnoreNotFound(err error) error
• func IgnoreTimeout(err error) error
• func NewForConfig(cfg *rest.Config) (*client, error)
• func SetAnnotation(m meta.ObjectMeta, name, val string)
• type Config
• type FactoryGroup
  • func NewFactoryGroup(k Interface, coreRI, standsRI time.Duration) *FactoryGroup
  • func (fg *FactoryGroup) Start(interrupt <-chan struct{})
  • func (fg *FactoryGroup) WaitForCacheSync(interrupt <-chan struct{}) map[reflect.Type]bool
• type Interface
  • func NewForAccessType(accessType string) (Interface, error)
  • func NewForExternalCluster() (Interface, error)
  • func NewForInternalCluster() (Interface, error)
  • func NewForTest(env string) (Interface, error)
  • func NewPluginClient(clientGetter genericclioptions.RESTClientGetter) (Interface, error)
• type ListerGroup
  • func NewListerGroup(f *FactoryGroup) *ListerGroup

Functions

func GetAnnotation

func GetAnnotation(m meta.ObjectMeta, name string) (string, bool)

func IgnoreAlreadyExists

func IgnoreAlreadyExists(err error) error

func IgnoreError

func IgnoreError(err error, handler func(error) bool) error

func IgnoreNotFound

func IgnoreNotFound(err error) error

func IgnoreTimeout

func IgnoreTimeout(err error) error

func NewForConfig

func NewForConfig(cfg *rest.Config) (*client, error)

func SetAnnotation

func SetAnnotation(m meta.ObjectMeta, name, val string)

Types

type Config

type Config struct {
	AccessType string `env-required:"true" json:"access_type" env:"KUBE_ACCESS_TYPE"`
}

type FactoryGroup

type FactoryGroup struct {
	Core   core.SharedInformerFactory
	Stands stands.SharedInformerFactory
}

func NewFactoryGroup

func NewFactoryGroup(k Interface, coreRI, standsRI time.Duration) *FactoryGroup

func (*FactoryGroup) Start

func (fg *FactoryGroup) Start(interrupt <-chan struct{})

func (*FactoryGroup) WaitForCacheSync

func (fg *FactoryGroup) WaitForCacheSync(interrupt <-chan struct{}) map[reflect.Type]bool

type Interface

type Interface interface {
	CoreClient() corecs.Interface
	StandSchedulesClient() standscs.Interface
}

func NewForAccessType

func NewForAccessType(accessType string) (Interface, error)

func NewForExternalCluster

func NewForExternalCluster() (Interface, error)

func NewForInternalCluster

func NewForInternalCluster() (Interface, error)

func NewForTest

func NewForTest(env string) (Interface, error)

func NewPluginClient

func NewPluginClient(clientGetter genericclioptions.RESTClientGetter) (Interface, error)

type ListerGroup

type ListerGroup struct {
	Namespaces   core.NamespaceLister
	Deployments  apps.DeploymentLister
	StatefulSets apps.StatefulSetLister
	Stands       stands.StandSchedulePolicyLister
}

func NewListerGroup

func NewListerGroup(f *FactoryGroup) *ListerGroup