type go.pact.im/x/supervisor.Supervisor
19 uses
go.pact.im/x/supervisor (current package)
restart.go#L17: func (m *Supervisor[K, P]) restartInitial(ctx context.Context) {
restart.go#L23: func (m *Supervisor[K, P]) spawnRestartLoop(ctx context.Context) func() {
restart.go#L41: func (m *Supervisor[K, P]) restartLoop(ctx context.Context) {
restart.go#L62: func (m *Supervisor[K, P]) restart(ctx context.Context, wait time.Duration) error {
restart.go#L135: func (m *Supervisor[K, P]) restartProcessInBackground(ctx context.Context, pk K, r P) <-chan struct{} {
startstop.go#L13: func (m *Supervisor[K, P]) Start(ctx context.Context, pk K) (P, error) {
startstop.go#L24: func (m *Supervisor[K, P]) Stop(ctx context.Context, pk K) error {
startstop.go#L31: func (m *Supervisor[K, P]) Get(ctx context.Context, pk K) (P, error) {
startstop.go#L44: func (m *Supervisor[K, P]) Keys() []K {
supervisor.go#L19: type Supervisor[K comparable, P process.Runnable] struct {
supervisor.go#L76: func NewSupervisor[K comparable, P process.Runnable](t Table[K, P], o Options) *Supervisor[K, P] {
supervisor.go#L79: return &Supervisor[K, P]{
supervisor.go#L87: func (m *Supervisor[K, P]) Run(ctx context.Context, callback process.Callback) error {
supervisor.go#L129: func (m *Supervisor[K, P]) startProcessForKey(ctx context.Context, pk K) (*managedProcess[P], error) {
supervisor.go#L149: func (m *Supervisor[K, P]) startProcess(ctx context.Context, pk K, r P) (*managedProcess[P], error) {
supervisor.go#L164: func (m *Supervisor[K, P]) startProcessUnlocked(ctx context.Context, pk K, r P) (*managedProcess[P], error) {
supervisor.go#L181: func (m *Supervisor[K, P]) watchdog(pk K, p *managedProcess[P]) {
supervisor.go#L198: func (m *Supervisor[K, P]) stopProcess(ctx context.Context, pk K) error {
supervisor.go#L215: func (m *Supervisor[K, P]) stopAll(ctx context.Context) {