worker

Documentation

Index

• func ExecByKubernetes(w *workerManager, cmd *model.Packet) ([]*model.Packet, *model.Packet)
• func GetLogsByKubernetes(w *workerManager, cmd *model.Packet) ([]*model.Packet, *model.Packet)
• func NewResponseError(key string, cmdType string, err error) *model.Packet
• func NewResponseErrorWithCommit(key string, commit string, cmdType string, err error) *model.Packet
• func NewWorkerManager(chans *manager.CRChan, kubeClient kube.Client, helmClient helm.Client, ...) *workerManager
• type Cause
• type Spec

Functions

func ExecByKubernetes

func ExecByKubernetes(w *workerManager, cmd *model.Packet) ([]*model.Packet, *model.Packet)

func GetLogsByKubernetes

func GetLogsByKubernetes(w *workerManager, cmd *model.Packet) ([]*model.Packet, *model.Packet)

func NewResponseError

func NewResponseError(key string, cmdType string, err error) *model.Packet

func NewResponseErrorWithCommit

func NewResponseErrorWithCommit(key string, commit string, cmdType string, err error) *model.Packet

func NewWorkerManager

func NewWorkerManager(
	chans *manager.CRChan,
	kubeClient kube.Client,
	helmClient helm.Client,
	appClient ws.WebSocketClient,
	agentInitOps *model.AgentInitOptions,
	syncInterval time.Duration,
	statusSyncInterval time.Duration,
	gitTimeout time.Duration) *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.