jobsrepo

Documentation

Index

• type CJRepository
  • func NewConcreteJobsRepository(index bpindex.Index, logger boshlog.Logger) CJRepository
  • func (r CJRepository) Find(job bprel.Job) (JobRecord, bool, error)
  • func (r CJRepository) FindByReleaseJob(rec ReleaseJobRecord) (JobRecord, bool, error)
  • func (r CJRepository) Save(job bprel.Job, record JobRecord) error
• type CRPRepository
  • func NewConcreteRuntimePackagesRepository(index bpindex.Index, logger boshlog.Logger) CRPRepository
  • func (r CRPRepository) Find(rec ReleaseJobRecord) ([]bprel.Package, bool, error)
  • func (r CRPRepository) FindAll(rec ReleaseJobRecord) ([]bprel.Package, bool, error)
  • func (r CRPRepository) Save(rec ReleaseJobRecord, pkgs []bprel.Package) error
  • func (r CRPRepository) SaveAll(rec ReleaseJobRecord, pkgs []bprel.Package) error
• type CTTJRepository
  • func NewConcreteTemplateToJobRepository(index bpindex.Index, logger boshlog.Logger) CTTJRepository
  • func (r CTTJRepository) FindByTemplate(template bpdep.Template) (ReleaseJobRecord, bool, error)
  • func (r CTTJRepository) SaveForJob(release bprel.Release, job bprel.Job) (ReleaseJobRecord, error)
• type JobRecord
• type JobsRepository
• type ReleaseJobRecord
  • func (r ReleaseJobRecord) String() string
• type RuntimePackagesRepository
• type TemplateToJobRepository

Types

type CJRepository

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

func NewConcreteJobsRepository

func NewConcreteJobsRepository(
	index bpindex.Index,
	logger boshlog.Logger,
) CJRepository

func (CJRepository) Find

func (r CJRepository) Find(job bprel.Job) (JobRecord, bool, error)

func (CJRepository) FindByReleaseJob

func (r CJRepository) FindByReleaseJob(rec ReleaseJobRecord) (JobRecord, bool, error)

func (CJRepository) Save

func (r CJRepository) Save(job bprel.Job, record JobRecord) error

type CRPRepository

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

func NewConcreteRuntimePackagesRepository

func NewConcreteRuntimePackagesRepository(
	index bpindex.Index,
	logger boshlog.Logger,
) CRPRepository

func (CRPRepository) Find

func (r CRPRepository) Find(rec ReleaseJobRecord) ([]bprel.Package, bool, error)

func (CRPRepository) FindAll

func (r CRPRepository) FindAll(rec ReleaseJobRecord) ([]bprel.Package, bool, error)

func (CRPRepository) Save

func (r CRPRepository) Save(rec ReleaseJobRecord, pkgs []bprel.Package) error

func (CRPRepository) SaveAll

func (r CRPRepository) SaveAll(rec ReleaseJobRecord, pkgs []bprel.Package) error

type CTTJRepository

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

func NewConcreteTemplateToJobRepository

func NewConcreteTemplateToJobRepository(
	index bpindex.Index,
	logger boshlog.Logger,
) CTTJRepository

func (CTTJRepository) FindByTemplate

func (r CTTJRepository) FindByTemplate(template bpdep.Template) (ReleaseJobRecord, bool, error)

func (CTTJRepository) SaveForJob

func (r CTTJRepository) SaveForJob(release bprel.Release, job bprel.Job) (ReleaseJobRecord, error)

type JobRecord

type JobRecord struct {
	BlobID string
	SHA1   string
}

type JobsRepository

type JobsRepository interface {
	Find(bprel.Job) (JobRecord, bool, error)
	Save(bprel.Job, JobRecord) error

	FindByReleaseJob(ReleaseJobRecord) (JobRecord, bool, error)
}

JobsRepository maintains list of job source code as blobs

type ReleaseJobRecord

type ReleaseJobRecord struct {
	ReleaseName    string
	ReleaseVersion string

	JobName        string
	JobVersion     string
	JobFingerprint string
}

func (ReleaseJobRecord) String

func (r ReleaseJobRecord) String() string

type RuntimePackagesRepository

type RuntimePackagesRepository interface {
	Find(ReleaseJobRecord) ([]bprel.Package, bool, error)
	Save(ReleaseJobRecord, []bprel.Package) error

	// Keeps association between all possible packages for a job
	FindAll(ReleaseJobRecord) ([]bprel.Package, bool, error)
	SaveAll(ReleaseJobRecord, []bprel.Package) error
}

RuntimePackagesRepository maintains list of releases' packages

type TemplateToJobRepository

type TemplateToJobRepository interface {
	FindByTemplate(bpdep.Template) (ReleaseJobRecord, bool, error)
	SaveForJob(bprel.Release, bprel.Job) (ReleaseJobRecord, error)
}