worker

type Options struct {
	Log                 logr.Logger
	MaxIdleTime         time.Duration
	SyncWaitTime        time.Duration
	WatchTimeoutSeconds int64
}

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

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

type Pool interface {
	Get(ctx context.Context, owner string) (workerAddr string, err error)
	Release(ctx context.Context, workerAddr string) error
	Close()
}

type PoolOption func(o Options) Options

type RequestQueue interface {
	Enqueue(*PodRequest)
	Dequeue() *PodRequest
	Len() int
	Remove(*PodRequest) bool
}