agent

Documentation

Index

• Constants
• func NewController(kubeclientset kubernetes.Interface, agentclientset clientset.Interface, ...) controller.Interface
• type Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

Constants

const (
	// SuccessSynced is used as part of the Event 'reason' when a Bar is synced
	SuccessSynced = "Synced"
	// ErrResourceExists is used as part of the Event 'reason' when a Bar fails
	// to sync due to a Deployment of the same name already existing.
	ErrResourceExists = "ErrResourceExists"

	// MessageResourceSynced is the message used for an Event fired when a Bar
	// is synced successfully
	MessageResourceSynced = "Bar synced successfully"
)

Functions

func NewController

func NewController(kubeclientset kubernetes.Interface, agentclientset clientset.Interface, kubernetesInformer kuberInformers.SharedInformerFactory, agentInformers informers.SharedInformerFactory) controller.Interface

Types

type Controller

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

这个是Agent工作负载编排的控制器 它的功能： - 创建流水线工作负载的Pod, 并保证工作负载的pod创建成功 - 再时间到了的时候销毁工作负载, 销毁工作负载时，这个工作负载应该是没有任何流水线正在运行的 - 记录工作负载的状态以及包含了那些流水线 - 到容器中执行命令，并且获取日志信息

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

执行控制器功能