pipelines

Documentation

Index

• Constants
• type Pipeline
• type Service
  • func NewService(db database.Database) Service

Constants

const Collection database.Collection = "pipelines"

const CollectionRuns database.Collection = "pipeline_runs"

const CollectionVersions database.Collection = "pipeline_versions"

Types

type Pipeline

type Pipeline struct {
	sdk.Pipeline `json:",inline" bson:",inline"`
	ProviderId   string `json:"providerId" bson:"providerId"`
}

type Service

type Service interface {
	EnsureIndices() error

	ListPipelinesPaginated(perPage int, page int) (sdk.PipelinePage, error)
	GetPipeline(id string) (sdk.Pipeline, error)
	ListPipelineRuns(id string, fromIncl time.Time, toExcl time.Time) (sdk.PipelineStatusList, error)
	ListPipelineRunsLimit(id string, toExcl time.Time, limit int) (sdk.PipelineStatusList, error)
	ListPipelineVersions(id string, fromIncl time.Time, toExcl time.Time) (sdk.PipelineVersionList, error)
	UpdatePipelines(providerId string, pipelines []sdk.Pipeline) error
	AddPipelineRuns(providerId string, runs sdk.PipelineStatusList) error
	AddPipelineVersions(providerId string, versions sdk.PipelineVersionList) error
}

func NewService

func NewService(db database.Database) Service