Please consider using the original work at github.com/bndr/gojenkins instead of this customized fork.
The fork was created to customize the original package quickly for personal use.
Modifications include:
- Adds a
Depth
property to various response objects to control the amount of data the client gets back.
Jenkins is the most popular Open Source Continuous Integration system. This Library will help you interact with Jenkins in a more developer-friendly way.
These are some of the features that are currently implemented:
- Get information on test-results of completed/failed build
- Ability to query Nodes, and manipulate them. Start, Stop, set Offline.
- Ability to query Jobs, and manipulate them.
- Get Plugins, Builds, Artifacts, Fingerprints
- Validate Fingerprints of Artifacts
- Get Current Queue, Cancel Tasks
- etc. For all methods go to GoDoc Reference.
go get github.com/carflo/gojenkins
import "github.com/carflo/gojenkins"
jenkins := gojenkins.CreateJenkins(nil, "http://localhost:8080/", "admin", "admin")
// Provide CA certificate if server is using self-signed certificate
// caCert, _ := ioutil.ReadFile("/tmp/ca.crt")
// jenkins.Requester.CACert = caCert
_, err := jenkins.Init()
if err != nil {
panic("Something Went Wrong")
}
build, err := jenkins.GetJob("job_name")
if err != nil {
panic("Job Does Not Exist")
}
lastSuccessBuild, err := build.GetLastSuccessfulBuild()
if err != nil {
panic("Last SuccessBuild does not exist")
}
duration := lastSuccessBuild.GetDuration()
job, err := jenkins.GetJob("jobname")
if err != nil {
panic("Job does not exist")
}
job.Rename("SomeotherJobName")
configString := `<?xml version='1.0' encoding='UTF-8'?>
<project>
<actions/>
<description></description>
<keepDependencies>false</keepDependencies>
<properties/>
<scm class="hudson.scm.NullSCM"/>
<canRoam>true</canRoam>
<disabled>false</disabled>
<blockBuildWhenDownstreamBuilding>false</blockBuildWhenDownstreamBuilding>
<blockBuildWhenUpstreamBuilding>false</blockBuildWhenUpstreamBuilding>
<triggers class="vector"/>
<concurrentBuild>false</concurrentBuild>
<builders/>
<publishers/>
<buildWrappers/>
</project>`
j.CreateJob(configString, "someNewJobsName")
API Reference: https://godoc.org/github.com/carflo/gojenkins
For all of the examples below first create a jenkins object
import "github.com/carflo/gojenkins"
jenkins, _ := gojenkins.CreateJenkins(nil, "http://localhost:8080/", "admin", "admin").Init()
or if you don't need authentication:
jenkins, _ := gojenkins.CreateJenkins(nil, "http://localhost:8080/").Init()
you can also specify your own http.Client
(for instance, providing your own SSL configurations):
client := &http.Client{ ... }
jenkins, := gojenkins.CreateJenkins(client, "http://localhost:8080/").Init()
By default, gojenkins
will use the http.DefaultClient
if none is passed into the CreateJenkins()
function.
nodes := jenkins.GetAllNodes()
for _, node := range nodes {
// Fetch Node Data
node.Poll()
if node.IsOnline() {
fmt.Println("Node is Online")
}
}
jobName := "someJob"
builds, err := jenkins.GetAllBuildIds(jobName)
if err != nil {
panic(err)
}
for _, build := range builds {
buildId := build.Number
data, err := jenkins.GetBuild(jobName, buildId)
if err != nil {
panic(err)
}
if "SUCCESS" == data.GetResult() {
fmt.Println("This build succeeded")
}
}
// Get Last Successful/Failed/Stable Build for a Job
job, err := jenkins.GetJob("someJob")
if err != nil {
panic(err)
}
job.GetLastSuccessfulBuild()
job.GetLastStableBuild()
tasks := jenkins.GetQueue()
for _, task := range tasks {
fmt.Println(task.GetWhy())
}
view, err := jenkins.CreateView("test_view", gojenkins.LIST_VIEW)
if err != nil {
panic(err)
}
status, err := view.AddJob("jobName")
if status != nil {
fmt.Println("Job has been added to view")
}
// Create parent folder
pFolder, err := jenkins.CreateFolder("parentFolder")
if err != nil {
panic(err)
}
// Create child folder in parent folder
cFolder, err := jenkins.CreateFolder("childFolder", pFolder.GetName())
if err != nil {
panic(err)
}
// Create job in child folder
configString := `<?xml version='1.0' encoding='UTF-8'?>
<project>
<actions/>
<description></description>
<keepDependencies>false</keepDependencies>
<properties/>
<scm class="hudson.scm.NullSCM"/>
<canRoam>true</canRoam>
<disabled>false</disabled>
<blockBuildWhenDownstreamBuilding>false</blockBuildWhenDownstreamBuilding>
<blockBuildWhenUpstreamBuilding>false</blockBuildWhenUpstreamBuilding>
<triggers class="vector"/>
<concurrentBuild>false</concurrentBuild>
<builders/>
<publishers/>
<buildWrappers/>
</project>`
job, err := jenkins.CreateJobInFolder(configString, "jobInFolder", pFolder.GetName(), cFolder.GetName())
if err != nil {
panic(err)
}
if job != nil {
fmt.Println("Job has been created in child folder")
}
job, _ := jenkins.GetJob("job")
build, _ := job.GetBuild(1)
artifacts := build.GetArtifacts()
for _, a := range artifacts {
a.SaveToDir("/tmp")
}
job, _ := jenkins.GetJob("job")
job.Poll()
build, _ := job.getBuild(1)
build.Poll()
For more information see https://www.jenkins.io/doc/book/using/remote-access-api/#RemoteaccessAPI-Depthcontrol
job, _ := jenkins.GetJob("job")
job.Depth = 2
job.Poll()
build, _ := job.getBuild(1)
build.Depth = 1
build.Poll()
go test
Please contribute to the original work at github.com/bndr/gojenkins
Although the basic features are implemented there are many optional features that are on the todo list.
- Kerberos Authentication
- CLI Tool
- Rewrite some (all?) iterators with channels
Apache License 2.0