agent

Documentation

Index

• func NewWorkerManager(mgrs *operatorutil.MgrList, chans *channel.CRChan, kubeClient kube.Client, ...) *workerManager
• type Cause
• type Spec
• type WorkerManager

Functions

func NewWorkerManager

func NewWorkerManager(
	mgrs *operatorutil.MgrList,
	chans *channel.CRChan,
	kubeClient kube.Client,
	helmClient helm.Client,
	appClient websocket.Client,
	cluster *kubernetes.Cluster,
	agentInitOps *model.AgentInitOptions,
	syncInterval time.Duration,
	statusSyncInterval time.Duration,
	gitTimeout time.Duration,
	gitConfig git.Config,
	controllerContext *agentsync.Context,
	wg *sync.WaitGroup,
	stop <-chan struct{},
	token string,
	platformCode string,
	syncAll bool,
	polarisConfig *config.Configuration,
	clearHelmHistory bool) *workerManager

Types

type Cause

type Cause struct {
	Message string
	User    string
}

How did this update get triggered?

type Spec

type Spec struct {
	Type  string      `json:"type"`
	Cause Cause       `json:"cause"`
	Spec  interface{} `json:"spec"`
}

A tagged union for all (both) kinds of update. The type is just so we know how to decode the rest of the struct.

type WorkerManager

type WorkerManager workerManager