Source File
	startstop.go

Belonging Package
	go.pact.im/x/supervisor

package supervisor

import (
	"context"

	"go.pact.im/x/process"
)

// Start starts the process with the given key from the table. It returns
// ErrNotRunning if the supervisor is not running and ErrProcessExists if the
// process already exists. Otherwise it returns an error from process
// initialization.
func (m *Supervisor[K, P]) Start(ctx context.Context, pk K) (P, error) {
	p, err := m.startProcessForKey(ctx, pk)
	if err != nil {
		var zero P
		return zero, err
	}
	return p.proc, nil
}

// Stop stops the process with the given key. It returns ErrProcessNotFound if
// the process does not exist, and an error from running the process otherwise.
func (m *Supervisor[K, P]) Stop(ctx context.Context, pk K) error {
	return m.stopProcess(ctx, pk)
}

// Get returns a running process or either a ErrProcessNotFound error if the
// process does not exist or ErrProcessNotRunning is the process exists but is
// not running.
func (m *Supervisor[K, P]) Get(ctx context.Context, pk K) (P, error) {
	p, ok := m.processes.Load(pk)
	if !ok || p == nil {
		var zero P
		return zero, ErrProcessNotFound
	}
	if p.State() != process.StateRunning {
		return p.proc, ErrProcessNotRunning
	}
	return p.proc, nil
}

// Keys returns a list of all process keys.
func (m *Supervisor[K, P]) Keys() []K {
	var keys []K

	m.processes.Range(func(pk K, _ *managedProcess[P]) bool {
		keys = append(keys, pk)
		return true
	})
	return keys
}

The pages are generated with Golds v0.4.9. (GOOS=linux GOARCH=amd64)