worker

Documentation

Index

• Variables
• type AutoscalingPool
  • func NewPool(ctx context.Context, clientset kubernetes.Interface, conf config.Buildkit, ...) *AutoscalingPool
  • func (p *AutoscalingPool) Close()
  • func (p *AutoscalingPool) Get(ctx context.Context, owner string) (string, error)
  • func (p *AutoscalingPool) Release(ctx context.Context, addr string) error
• type Options
• type PodRequest
• type PodRequestResult
• type Pool
• type PoolOption
  • func EndpointWatchTimeoutSeconds(s int64) PoolOption
  • func Logger(log logr.Logger) PoolOption
  • func MaxIdleTime(d time.Duration) PoolOption
  • func SyncWaitTime(d time.Duration) PoolOption
• type Queue
  • func NewRequestQueue() *Queue
  • func (q *Queue) Dequeue() *PodRequest
  • func (q *Queue) Enqueue(req *PodRequest)
  • func (q *Queue) Len() int
  • func (q *Queue) Remove(req *PodRequest) bool
• type RequestQueue

Variables

var (
	ErrNoUnleasedPods = errors.New("no unleased pods found")
)

Types

type AutoscalingPool

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

func NewPool

func NewPool(
	ctx context.Context,
	clientset kubernetes.Interface,
	conf config.Buildkit,
	opts ...PoolOption,
) *AutoscalingPool

NewPool creates a new worker pool that can be used to lease buildkit workers for image builds.

func (*AutoscalingPool) Close

func (p *AutoscalingPool) Close()

Close shuts down the pool by terminating all background routines used to manage requests and garbage collection.

func (*AutoscalingPool) Get

func (p *AutoscalingPool) Get(ctx context.Context, owner string) (string, error)

Get a lease for a worker in the pool and return a routable address.

Adds "lease"/"manager-identity" metadata and removes "expiry-time". The worker will remain leased until the caller provides the address to Release().

func (*AutoscalingPool) Release

func (p *AutoscalingPool) Release(ctx context.Context, addr string) error

Release an address back into the worker pool.

Adds "expiry-time" and removes "lease"/"manager-identity" metadata. The underlying worker will be terminated after its expiry time has passed.

type Options

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

type PodRequest

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

type PodRequestResult

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

type Pool

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

type PoolOption

type PoolOption func(o Options) Options

func EndpointWatchTimeoutSeconds

func EndpointWatchTimeoutSeconds(s int64) PoolOption

func Logger

func Logger(log logr.Logger) PoolOption

func MaxIdleTime

func MaxIdleTime(d time.Duration) PoolOption

func SyncWaitTime

func SyncWaitTime(d time.Duration) PoolOption

type Queue

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

func NewRequestQueue

func NewRequestQueue() *Queue

func (*Queue) Dequeue

func (q *Queue) Dequeue() *PodRequest

func (*Queue) Enqueue

func (q *Queue) Enqueue(req *PodRequest)

func (*Queue) Len

func (q *Queue) Len() int

func (*Queue) Remove

func (q *Queue) Remove(req *PodRequest) bool

type RequestQueue

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