external

Documentation

Index

• func GetCustomClientSet() *customClient.Clientset
• func GetCustomInformerFactory() customeInformers.SharedInformerFactory
• func GetK8sClientSet() *kubernetes.Clientset
• func GetKubeInformerFactory() informers.SharedInformerFactory
• func Init(inCluster bool)
• func InitInformers()
• type Controller
  • func NewController(ctx context.Context, k8sClientSet kubernetes.Interface, ...) *Controller
  • func (c *Controller) Run(ctx context.Context, workers int) error

Functions

func GetCustomClientSet

func GetCustomClientSet() *customClient.Clientset

GetCustomClientSet return custom clientset

func GetCustomInformerFactory

func GetCustomInformerFactory() customeInformers.SharedInformerFactory

GetCustomInformerFactory return custom informer factory

func GetK8sClientSet

func GetK8sClientSet() *kubernetes.Clientset

GetK8sClientSet return k8s clientset

func GetKubeInformerFactory

func GetKubeInformerFactory() informers.SharedInformerFactory

GetKubeInformerFactory return k8s informer factory

func Init

func Init(inCluster bool)

Init 初始化

func InitInformers

func InitInformers()

InitInformers 初始化informers

Types

type Controller

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

Controller 自定义实现的Controller

func NewController

func NewController(
	ctx context.Context,
	k8sClientSet kubernetes.Interface,
	customClientSet customClient.Interface,
	k8sInformer appsinformers.DeploymentInformer,
	informer customInformers.RedisInformer) *Controller

NewController 自定义的创建controller的函数

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, workers int) error

Run controller执行