provider

Documentation

Overview

Package provider implements logic for allowing interaction with worker processes

Index

• type IProvider
• type WorkerProvider
  • func NewWorkerProvider(context context.ICoreAgentContext, exec executor.IExecutor) *WorkerProvider
  • func (w *WorkerProvider) KillAllWorkerProcesses()
  • func (w *WorkerProvider) Monitor(configs map[string]*model.WorkerConfig, pingResults []*message.Message)
  • func (w *WorkerProvider) Start(configs map[string]*model.WorkerConfig, pingResults []*message.Message)

Types

type IProvider

type IProvider interface {
	Start(map[string]*model.WorkerConfig, []*message.Message)
	Monitor(map[string]*model.WorkerConfig, []*message.Message)
	KillAllWorkerProcesses()
}

IProvider is the interface for check process status and starts the process if it's not running

type WorkerProvider

type WorkerProvider struct {
	sync.Mutex
	// contains filtered or unexported fields
}

WorkerProvider owns workerPool, it auto discovers the worker config and the running processes

func NewWorkerProvider

func NewWorkerProvider(context context.ICoreAgentContext, exec executor.IExecutor) *WorkerProvider

NewWorkerProvider creates worker provider instance

func (*WorkerProvider) KillAllWorkerProcesses

func (w *WorkerProvider) KillAllWorkerProcesses()

func (*WorkerProvider) Monitor

func (w *WorkerProvider) Monitor(configs map[string]*model.WorkerConfig, pingResults []*message.Message)

func (*WorkerProvider) Start

func (w *WorkerProvider) Start(configs map[string]*model.WorkerConfig, pingResults []*message.Message)

Start discovers the worker config and the running processes It starts a new process for the worker if the worker has no running process