worker

Documentation

Index

• Variables
• type Options
• type PodRequest
• type PodRequestResult
• type Pool
  • func NewPool(ctx context.Context, clientset kubernetes.Interface, conf config.Buildkit, ...) 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 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()
}

func NewPool

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

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

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
}