workerpool

package

v1.1.0 Latest Latest Go to latest Published: Feb 25, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Registry tracks workers by heartbeat lease.

func New(ttl time.Duration) *Registry

func (r *Registry) EvictExpired(now time.Time) []Worker

func (r *Registry) Heartbeat(id string) bool

func (r *Registry) Register(id, addr string)

func (r *Registry) SetState(id string, state WorkerState) bool

func (r *Registry) Snapshot() []Worker

type Worker struct {
	ID          string
	Addr        string
	State       WorkerState
	LastSeen    time.Time
	LeaseExpire time.Time
}

Worker is an in-memory lease entry for one runtime worker.

type WorkerState string

WorkerState captures current scheduler view for one worker.

const (
	WorkerIdle    WorkerState = "idle"
	WorkerBusy    WorkerState = "busy"
	WorkerUnknown WorkerState = "unknown"
)