ppsdb

Documentation

Overview

Package ppsdb contains the database schema that PPS uses.

Index

• Variables
• func Jobs(etcdClient *etcd.Client, etcdPrefix string) col.Collection
• func Pipelines(etcdClient *etcd.Client, etcdPrefix string) col.Collection

Variables

var (
	// JobsPipelineIndex maps pipeline to jobs started by the pipeline
	JobsPipelineIndex = col.Index{"Pipeline", false}

	// JobsInputIndex maps job inputs (repos + pipeline version) to output
	// commit. This is how we know if we need to start a job.
	JobsInputIndex = col.Index{"Input", false}

	// JobsInputsIndex maps 1.4.5 and earlier style job inputs (repos +
	// pipeline version) to output commit. This is how we know if we need
	// to start a job Needed for legacy compatibility.
	JobsInputsIndex = col.Index{"Inputs", false}

	// JobsOutputIndex maps job outputs to the job that create them.
	JobsOutputIndex = col.Index{"OutputCommit", false}
)

Functions

func Jobs

func Jobs(etcdClient *etcd.Client, etcdPrefix string) col.Collection

Jobs returns a Collection of jobs

func Pipelines

func Pipelines(etcdClient *etcd.Client, etcdPrefix string) col.Collection

Pipelines returns a Collection of pipelines