boltdb

package

v0.0.0-...-863ebf7 Latest Latest Go to latest Published: Jul 5, 2020 License: Apache-2.0 Imports: 10 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

This section is empty.

This section is empty.

This section is empty.

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

BoltDB has a connection to the database and implements the needed interfaces.

func New(path string) (*BoltDB, func() error, error)

New creates a new BoltDB instance

func (bdb *BoltDB) CreateDeployment(pipeline signalcd.Pipeline) (signalcd.Deployment, error)

CreateDeployment creates a new Deployment from a Pipeline

func (bdb *BoltDB) CreatePipeline(p signalcd.Pipeline) (signalcd.Pipeline, error)

CreatePipeline saves a Pipeline and returns the saved Pipeline

func (bdb *BoltDB) GetCurrentDeployment() (signalcd.Deployment, error)

GetCurrentDeployment gets the current Deployment

func (bdb *BoltDB) GetPipeline(id string) (signalcd.Pipeline, error)

GetPipeline gets a Pipeline by its ID

func (bdb *BoltDB) ListDeployments() ([]signalcd.Deployment, error)

ListDeployments lists all Deployments

func (bdb *BoltDB) ListPipelines() ([]signalcd.Pipeline, error)

ListPipelines returns a list of Pipelines

func (bdb *BoltDB) SaveStepLogs(ctx context.Context, deployment, step int64, logs []byte) error

SaveStepLogs saves the logs for a Deployment step by its number

func (bdb *BoltDB) UpdateDeploymentStatus(deploymentNumber int64, step int64, agent string, phase signalcd.Phase) (signalcd.Deployment, error)

type Events struct {
	*BoltDB
	// contains filtered or unexported fields
}

Events wraps BoltDB to publish updated structs

func NewEvents(db *BoltDB, events *signalcd.Events) *Events

NewEvents creates a new BoltDB wrapper that publishes events

func (e *Events) CreateDeployment(pipeline signalcd.Pipeline) (signalcd.Deployment, error)

CreateDeployment wraps the underlying BoltDB func to publish successfully created Deployments

func (e *Events) UpdateDeploymentStatus(deploymentNumber int64, step int64, agent string, phase signalcd.Phase) (signalcd.Deployment, error)