agent

Documentation

Index

• type AgentController
  • func NewAgentController() *AgentController
  • func (c *AgentController) PollingJob(ctx context.Context)
  • func (c *AgentController) RunJob(ctx context.Context)
  • func (c *AgentController) RunSingleJob(ctx context.Context, job *types.ZadigJobTask) error
  • func (c *AgentController) Start(ctx context.Context)
  • func (c *AgentController) StopPollingJob()
  • func (c *AgentController) StopRunJob()

Types

type AgentController

type AgentController struct {
	Client               *network.ZadigClient
	JobChan              chan *types.ZadigJobTask
	StopPollingJobChan   chan struct{}
	StopRunJobChan       chan struct{}
	Concurrency          int
	ConcurrencyBlockTime int
	CurrentJobNum        int
	WorkingDirectory     string
}

func NewAgentController

func NewAgentController() *AgentController

func (*AgentController) PollingJob

func (c *AgentController) PollingJob(ctx context.Context)

func (*AgentController) RunJob

func (c *AgentController) RunJob(ctx context.Context)

func (*AgentController) RunSingleJob

func (c *AgentController) RunSingleJob(ctx context.Context, job *types.ZadigJobTask) error

func (*AgentController) Start

func (c *AgentController) Start(ctx context.Context)

func (*AgentController) StopPollingJob

func (c *AgentController) StopPollingJob()

func (*AgentController) StopRunJob

func (c *AgentController) StopRunJob()