tracker

Documentation

Index

• type Job
• type JobTracker
  • func NewContainerTracker() *JobTracker
  • func (t *JobTracker) Add(artifact graph.Artifact, c Job, namespace string)
  • func (t *JobTracker) AddJob(job *batchv1.Job)
  • func (t *JobTracker) ArtifactForContainer(id string) graph.Artifact
  • func (t *JobTracker) ContainerForImage(image string) (Job, bool)
  • func (t *JobTracker) DeployedContainers() map[string]Job
  • func (t *JobTracker) DeployedJobs() map[string]*batchv1.Job
  • func (t *JobTracker) Notifier() chan []string
  • func (t *JobTracker) Reset()

Types

type Job

type Job struct {
	Name string
	ID   string
}

type JobTracker

type JobTracker struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewContainerTracker

func NewContainerTracker() *JobTracker

NewContainerTracker creates a new ContainerTracker.

func (*JobTracker) Add

func (t *JobTracker) Add(artifact graph.Artifact, c Job, namespace string)

Add adds a container to the list.

func (*JobTracker) AddJob

func (t *JobTracker) AddJob(job *batchv1.Job)

Add adds a Job to the list.

func (*JobTracker) ArtifactForContainer

func (t *JobTracker) ArtifactForContainer(id string) graph.Artifact

func (*JobTracker) ContainerForImage

func (t *JobTracker) ContainerForImage(image string) (Job, bool)

ContainerIdForImage returns the deployed container created from the provided image, if it exists.

func (*JobTracker) DeployedContainers

func (t *JobTracker) DeployedContainers() map[string]Job

DeployedContainers returns the list of all containers deployed during this run.

func (*JobTracker) DeployedJobs

func (t *JobTracker) DeployedJobs() map[string]*batchv1.Job

DeployedJobs returns the list of all jobs deployed during this run.

func (*JobTracker) Notifier

func (t *JobTracker) Notifier() chan []string

Notifier returns the notifier channel for this tracker. Used by the log streamer to be notified when a new container is added to the tracker.

func (*JobTracker) Reset

func (t *JobTracker) Reset()

Reset resets the entire tracker when a new dev cycle starts.