The highest tagged major version is
Documentation
¶
Index ¶
- type DBLayer
- func (dl *DBLayer) CreateBuild(ctx context.Context, req *lib.BuildRequest) (id gocql.UUID, err error)
- func (dl *DBLayer) DeleteBuild(ctx context.Context, id gocql.UUID) (err error)
- func (dl *DBLayer) GetBuildByID(ctx context.Context, id gocql.UUID) (bi *lib.BuildStatusResponse, err error)
- func (dl *DBLayer) GetBuildOutput(ctx context.Context, id gocql.UUID, column string) (output []lib.BuildEvent, err error)
- func (dl *DBLayer) SaveBuildOutput(ctx context.Context, id gocql.UUID, output []lib.BuildEvent, column string) (err error)
- func (dl *DBLayer) SetBuildCompletedTimestamp(ctx context.Context, id gocql.UUID) (err error)
- func (dl *DBLayer) SetBuildFlags(ctx context.Context, id gocql.UUID, flags map[string]bool) (err error)
- func (dl *DBLayer) SetBuildState(ctx context.Context, id gocql.UUID, state lib.BuildStatusResponse_BuildState) (err error)
- func (dl *DBLayer) SetBuildTimeMetric(ctx context.Context, id gocql.UUID, metric string) (err error)
- func (dl *DBLayer) SetDockerImageSizesMetric(ctx context.Context, id gocql.UUID, size int64, vsize int64) (err error)
- type DataLayer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DBLayer ¶
type DBLayer struct {
// contains filtered or unexported fields
}
DBLayer is an DataLayer instance that interacts with the Cassandra database
func NewDBLayer ¶
NewDBLayer returns a data layer object
func (*DBLayer) CreateBuild ¶
func (dl *DBLayer) CreateBuild(ctx context.Context, req *lib.BuildRequest) (id gocql.UUID, err error)
CreateBuild inserts a new build into the DB returning the ID
func (*DBLayer) DeleteBuild ¶
DeleteBuild removes a build from the DB. Only used in case of queue full when we can't actually do a build
func (*DBLayer) GetBuildByID ¶
func (dl *DBLayer) GetBuildByID(ctx context.Context, id gocql.UUID) (bi *lib.BuildStatusResponse, err error)
GetBuildByID fetches a build object from the DB
func (*DBLayer) GetBuildOutput ¶
func (dl *DBLayer) GetBuildOutput(ctx context.Context, id gocql.UUID, column string) (output []lib.BuildEvent, err error)
GetBuildOutput returns an array of stream events from the database
func (*DBLayer) SaveBuildOutput ¶
func (dl *DBLayer) SaveBuildOutput(ctx context.Context, id gocql.UUID, output []lib.BuildEvent, column string) (err error)
SaveBuildOutput serializes an array of stream events to the database
func (*DBLayer) SetBuildCompletedTimestamp ¶
SetBuildCompletedTimestamp sets the completed timestamp on a build to time.Now()
func (*DBLayer) SetBuildFlags ¶
func (dl *DBLayer) SetBuildFlags(ctx context.Context, id gocql.UUID, flags map[string]bool) (err error)
SetBuildFlags sets the boolean flags on the build object Caller must ensure that the flags passed in are valid
func (*DBLayer) SetBuildState ¶
func (dl *DBLayer) SetBuildState(ctx context.Context, id gocql.UUID, state lib.BuildStatusResponse_BuildState) (err error)
SetBuildState sets the state of a build
func (*DBLayer) SetBuildTimeMetric ¶
func (dl *DBLayer) SetBuildTimeMetric(ctx context.Context, id gocql.UUID, metric string) (err error)
SetBuildTimeMetric sets a build metric to time.Now() metric is the name of the column to update if metric is a *_completed column, it will also compute and persist the duration
type DataLayer ¶
type DataLayer interface {
CreateBuild(context.Context, *lib.BuildRequest) (gocql.UUID, error)
GetBuildByID(context.Context, gocql.UUID) (*lib.BuildStatusResponse, error)
SetBuildFlags(context.Context, gocql.UUID, map[string]bool) error
SetBuildCompletedTimestamp(context.Context, gocql.UUID) error
SetBuildState(context.Context, gocql.UUID, lib.BuildStatusResponse_BuildState) error
DeleteBuild(context.Context, gocql.UUID) error
SetBuildTimeMetric(context.Context, gocql.UUID, string) error
SetDockerImageSizesMetric(context.Context, gocql.UUID, int64, int64) error
SaveBuildOutput(context.Context, gocql.UUID, []lib.BuildEvent, string) error
GetBuildOutput(context.Context, gocql.UUID, string) ([]lib.BuildEvent, error)
}
DataLayer describes an object that interacts with the persistent data store
Source Files