coordinator

package

v0.0.0-...-19ee04f Latest Latest Go to latest Published: Nov 12, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package coordinator takes care of coordination of intaking and distribution of tasks to agents.

This section is empty.

This section is empty.

This section is empty.

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

Coordinator takes and dispatches build requests.

func New(db *sqlx.DB, configuration models.Configuration) (context.Context, *Coordinator)

New creates a new coordinator

func (c *Coordinator) Enqueue(repoFullName, commitHash, commitMessage,
	sig string, body []byte) error

Enqueue puts a build into the building pipeline.

func (c *Coordinator) Error() error

Error returns the last found error.

func (c *Coordinator) GetLastBuildStatus(repoFullName string) models.Status

GetLastBuildStatus loads last known build status for a repository.

func (c *Coordinator) MarkComplete(build *models.Build) error

MarkComplete determines a build has completed and update its build information in the database.

func (c *Coordinator) MarkInProgress(build *models.Build) error

MarkInProgress determines a build has started and update its build information in the database.

func (c *Coordinator) Next(repoFullName string) <-chan *models.Build

Next returns a job pipe.

func (c *Coordinator) Wait() error

Wait returns when coordinator is done doing its works. Return any error found.