component

Documentation

Index

• Variables
• type BuildDispatcherComponent
  • func BuildDispatcher(cfg config.Buildkit, pool worker.Pool, nr *newrelic.Application, ...) *BuildDispatcherComponent
  • func (c *BuildDispatcherComponent) GetReadyCondition() string
  • func (c *BuildDispatcherComponent) Initialize(ctx *core.Context, _ *ctrl.Builder) error
  • func (c *BuildDispatcherComponent) Reconcile(ctx *core.Context) (ctrl.Result, error)
• type DeleteBroadcastComponent
  • func DeleteBroadcaster(ch chan<- client.ObjectKey) *DeleteBroadcastComponent
  • func (c *DeleteBroadcastComponent) Reconcile(ctx *core.Context) (ctrl.Result, error)
• type ImageBuildGC
  • func (gc *ImageBuildGC) GC(ctx context.Context) error
  • func (gc *ImageBuildGC) Start(ctx context.Context) error

Variables

var (
	ErrMissingNamespaces = errors.New("no namespaces specified")
	ErrInvalidNamespace  = errors.New("invalid namespace name")
)

Types

type BuildDispatcherComponent

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

func BuildDispatcher

func BuildDispatcher(
	cfg config.Buildkit,
	pool worker.Pool,
	nr *newrelic.Application,
	ch <-chan client.ObjectKey,
) *BuildDispatcherComponent

func (*BuildDispatcherComponent) GetReadyCondition

func (c *BuildDispatcherComponent) GetReadyCondition() string

func (*BuildDispatcherComponent) Initialize

func (c *BuildDispatcherComponent) Initialize(ctx *core.Context, _ *ctrl.Builder) error

func (*BuildDispatcherComponent) Reconcile

func (c *BuildDispatcherComponent) Reconcile(ctx *core.Context) (ctrl.Result, error)

type DeleteBroadcastComponent

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

func DeleteBroadcaster

func DeleteBroadcaster(ch chan<- client.ObjectKey) *DeleteBroadcastComponent

func (*DeleteBroadcastComponent) Reconcile

func (c *DeleteBroadcastComponent) Reconcile(ctx *core.Context) (ctrl.Result, error)

type ImageBuildGC

type ImageBuildGC struct {
	HistoryLimit int
	Client       client.Client
	Namespaces   []string
}

func (*ImageBuildGC) GC

func (gc *ImageBuildGC) GC(ctx context.Context) error

func (*ImageBuildGC) Start

func (gc *ImageBuildGC) Start(ctx context.Context) error