component

Documentation

Index

• 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)

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)