darkkirb/harness-drone
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

organizing build file

Browse source
This commit is contained in:
Brad Rydzewski 2015-04-30 20:59:22 -07:00
parent 4e61464225
commit a0c7b3f768
1 changed files with 11 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
datastore/bolt/build.go
View file

@ -70,6 +70,17 @@ func (db *DB) BuildLast(repo string) (*common.Build, error) {
return build, err return build, err
} }
// BuildAgent gets the agent that is currently executing
// a build. If no agent exists ErrKeyNotFound is returned.
func (db *DB) BuildAgent(repo string, build int) (*common.Agent, error) {
key := []byte(repo + "/" + strconv.Itoa(build))
agent := &common.Agent{}
err := db.View(func(t *bolt.Tx) error {
return get(t, bucketBuildAgent, key, agent)
})
return agent, err
}
// SetBuild inserts or updates a build for the named // SetBuild inserts or updates a build for the named
// repository. The build number is incremented and // repository. The build number is incremented and
// assigned to the provided build. // assigned to the provided build.
@ -113,17 +124,6 @@ func (db *DB) SetBuild(repo string, build *common.Build) error {
}) })
} }
// SetStatus inserts a new build status for the
// named repository and build number. If the status already
// exists an error is returned.
func (db *DB) SetStatus(repo string, build int, status *common.Status) error {
key := []byte(repo + "/" + strconv.Itoa(build) + "/" + status.Context)
return db.Update(func(t *bolt.Tx) error {
return update(t, bucketBuildStatus, key, status)
})
}
// Experimental // Experimental
func (db *DB) SetBuildState(repo string, build *common.Build) error { func (db *DB) SetBuildState(repo string, build *common.Build) error {
key := []byte(repo + "/" + strconv.Itoa(build.Number)) key := []byte(repo + "/" + strconv.Itoa(build.Number))
@ -193,12 +193,3 @@ func (db *DB) DelBuildAgent(repo string, build int) error {
return delete(t, bucketBuildAgent, key) return delete(t, bucketBuildAgent, key)
}) })
} }
func (db *DB) BuildAgent(repo string, build int) (*common.Agent, error) {
key := []byte(repo + "/" + strconv.Itoa(build))
agent := &common.Agent{}
err := db.View(func(t *bolt.Tx) error {
return get(t, bucketBuildAgent, key, agent)
})
return agent, err
}