infraoperator

package

v1.10.1 Latest Latest Go to latest Published: Jan 22, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Checker interface {
	// Check should block until all underlying services reported their status
	Check(ctx context.Context) error
}

Checker interface is used for live-checks in background processed

type Operator struct {
	// contains filtered or unexported fields
}

func (o *Operator) AddService(ctx context.Context, service interface{}) error

AddService starts the service and puts it under operator's control. returns service's start error

func (o *Operator) Check(ctx context.Context) map[interface{}]error

Check does a live-check on all services. Returns map with

key = service reference
value = service stop errors

func (o *Operator) RemoveService(ctx context.Context, service interface{}) error

RemoveService stops service and removes it service from operator's control. returns service's stop error

func (o *Operator) StopAll(ctx context.Context) map[interface{}]error

StopAll removes all checks and stops all services.

type Starter interface {
	// Start should block until all underlying services are started
	Start(ctx context.Context) error
}

Starter interface is used to start background processes

type Stopper interface {
	// Stop should block until all underlying services are stopped
	Stop(ctx context.Context) error
}

Stopper interface is used to stop background processed