Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WorkerShim ¶
func WorkerShim[T any](doer Doer[T], jobs <-chan T, done_jobs chan<- CompletedJob[T], cancel chan chan struct{})
Types ¶
type Builder ¶
TODO: rethink this interface. need a way to send status updates and cancel a build. At face value, I am thinking a status channel and a context.
type BuilderMessage ¶
type BuilderPusher ¶
type CompletedJob ¶
func (CompletedJob[T]) Ok ¶
func (p CompletedJob[T]) Ok() bool
type DefaultBuilder ¶
type DefaultBuilder struct {
// contains filtered or unexported fields
}
TODO: implement DefaultBuilder and DefaultBuilderPusher
func NewDefaultBuilder ¶
func NewDefaultBuilder(stream chan<- BuilderMessage) DefaultBuilder
func (DefaultBuilder) Build ¶
func (b DefaultBuilder) Build(job Job) error
func (DefaultBuilder) Cancel ¶
func (DefaultBuilder) Cancel(job Job)
func (DefaultBuilder) Do ¶
func (b DefaultBuilder) Do(job Job) error
type DefaultJob ¶
type DefaultJob struct {
// contains filtered or unexported fields
}
func (DefaultJob) Children ¶
func (j DefaultJob) Children() []Job
func (DefaultJob) FullName ¶
func (j DefaultJob) FullName() string
func (DefaultJob) Path ¶
func (j DefaultJob) Path() string
func (DefaultJob) Tag ¶
func (j DefaultJob) Tag() string
type DefaultJobFactory ¶
type DefaultJobFactory struct {
// contains filtered or unexported fields
}
func NewDefaultJobFactory ¶
func NewDefaultJobFactory(image_map image_map.ImageMapPair, tagger Tagger, registry string) *DefaultJobFactory
func (*DefaultJobFactory) GetChildren ¶
func (f *DefaultJobFactory) GetChildren(img image.ImagePair) []Job
func (DefaultJobFactory) GetFullName ¶
func (d DefaultJobFactory) GetFullName(img image.ImagePair) string
GetFullName returns the registry concatenated to the image name (i.e. {{registry/name}} ). if a registry is not present, only the image name is returned.
func (*DefaultJobFactory) JobsFromPaths ¶
func (f *DefaultJobFactory) JobsFromPaths(paths ...string) []Job
type DefaultTagger ¶
type DefaultTagger struct{}
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func NewManager() Manager
func (Manager) CancelBuilders ¶
func (Manager) CancelBuilders(cancelers []chan chan struct{})
func (Manager) StartBuilders ¶
Click to show internal directories.
Click to hide internal directories.