longrunningprovider

package

v0.0.0-...-0117b6e Latest Latest Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 11 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package longrunningprovider provides an interface to start/stop a worker process for long-running tasks.

This section is empty.

This section is empty.

This section is empty.

type IContainer interface {
	Start()
	Monitor()
	Stop(reboot.StopType)
}

IContainer is the interface for starting/terminating/watching worker

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

WorkerContainers contains list of running workers, it starts/terminates/watches workers

func NewWorkerContainer(
	context context.ICoreAgentContext,
	messageBus messagebus.IMessageBus) *WorkerContainer

NewWorkerContainer returns worker container

func (container *WorkerContainer) Monitor()

Monitor watches worker process, restarts the worker when receive worker exist signal

func (container *WorkerContainer) Start()

Start identifies and loads the worker configs and starts long running workers

func (container *WorkerContainer) Stop(stopType reboot.StopType)

Stop stops monitor and stop all the running workers

Path	Synopsis
datastore Package datastore provides interface to read and write json data from/to disk	Package datastore provides interface to read and write json data from/to disk
filesystem Package filesystem contains related functions from os, io, and io/ioutil packages	Package filesystem contains related functions from os, io, and io/ioutil packages
filesystem/mocks
mocks
discover Package discover finds worker configs for the core agent.	Package discover finds worker configs for the core agent.
mocks
mocks
model Package model contains data objects for long running container	Package model contains data objects for long running container
provider Package provider implements logic for allowing interaction with worker processes	Package provider implements logic for allowing interaction with worker processes
mocks