forked from concourse/concourse
/
team.go
107 lines (85 loc) · 4.6 KB
/
team.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package concourse
import (
"io"
"github.com/pf-qiu/concourse/v6/atc"
"github.com/pf-qiu/concourse/v6/go-concourse/concourse/internal"
)
//go:generate counterfeiter . Team
type Team interface {
Name() string
ID() int
Auth() atc.TeamAuth
ATCTeam() atc.Team
CreateOrUpdate(team atc.Team) (atc.Team, bool, bool, []ConfigWarning, error)
RenameTeam(teamName, name string) (bool, []ConfigWarning, error)
DestroyTeam(teamName string) error
Pipeline(pipelineRef atc.PipelineRef) (atc.Pipeline, bool, error)
PipelineBuilds(pipelineRef atc.PipelineRef, page Page) ([]atc.Build, Pagination, bool, error)
DeletePipeline(pipelineRef atc.PipelineRef) (bool, error)
PausePipeline(pipelineRef atc.PipelineRef) (bool, error)
ArchivePipeline(pipelineRef atc.PipelineRef) (bool, error)
UnpausePipeline(pipelineRef atc.PipelineRef) (bool, error)
ExposePipeline(pipelineRef atc.PipelineRef) (bool, error)
HidePipeline(pipelineRef atc.PipelineRef) (bool, error)
RenamePipeline(pipelineRef atc.PipelineRef, name string) (bool, []ConfigWarning, error)
ListPipelines() ([]atc.Pipeline, error)
PipelineConfig(pipelineRef atc.PipelineRef) (atc.Config, string, bool, error)
CreateOrUpdatePipelineConfig(pipelineRef atc.PipelineRef, configVersion string, passedConfig []byte, checkCredentials bool) (bool, bool, []ConfigWarning, error)
CreatePipelineBuild(pipelineRef atc.PipelineRef, plan atc.Plan) (atc.Build, error)
BuildInputsForJob(pipelineRef atc.PipelineRef, jobName string) ([]atc.BuildInput, bool, error)
Job(pipelineRef atc.PipelineRef, jobName string) (atc.Job, bool, error)
JobBuild(pipelineRef atc.PipelineRef, jobName, buildName string) (atc.Build, bool, error)
JobBuilds(pipelineRef atc.PipelineRef, jobName string, page Page) ([]atc.Build, Pagination, bool, error)
CreateJobBuild(pipelineRef atc.PipelineRef, jobName string) (atc.Build, error)
RerunJobBuild(pipelineRef atc.PipelineRef, jobName string, buildName string) (atc.Build, error)
ListJobs(pipelineRef atc.PipelineRef) ([]atc.Job, error)
ScheduleJob(pipelineRef atc.PipelineRef, jobName string) (bool, error)
PauseJob(pipelineRef atc.PipelineRef, jobName string) (bool, error)
UnpauseJob(pipelineRef atc.PipelineRef, jobName string) (bool, error)
ClearTaskCache(pipelineRef atc.PipelineRef, jobName string, stepName string, cachePath string) (int64, error)
Resource(pipelineRef atc.PipelineRef, resourceName string) (atc.Resource, bool, error)
ListResources(pipelineRef atc.PipelineRef) ([]atc.Resource, error)
VersionedResourceTypes(pipelineRef atc.PipelineRef) (atc.VersionedResourceTypes, bool, error)
ResourceVersions(pipelineRef atc.PipelineRef, resourceName string, page Page, filter atc.Version) ([]atc.ResourceVersion, Pagination, bool, error)
CheckResource(pipelineRef atc.PipelineRef, resourceName string, version atc.Version) (atc.Build, bool, error)
CheckResourceType(pipelineRef atc.PipelineRef, resourceTypeName string, version atc.Version) (atc.Build, bool, error)
DisableResourceVersion(pipelineRef atc.PipelineRef, resourceName string, resourceVersionID int) (bool, error)
EnableResourceVersion(pipelineRef atc.PipelineRef, resourceName string, resourceVersionID int) (bool, error)
PinResourceVersion(pipelineRef atc.PipelineRef, resourceName string, resourceVersionID int) (bool, error)
UnpinResource(pipelineRef atc.PipelineRef, resourceName string) (bool, error)
SetPinComment(pipelineRef atc.PipelineRef, resourceName string, comment string) (bool, error)
BuildsWithVersionAsInput(pipelineRef atc.PipelineRef, resourceName string, resourceVersionID int) ([]atc.Build, bool, error)
BuildsWithVersionAsOutput(pipelineRef atc.PipelineRef, resourceName string, resourceVersionID int) ([]atc.Build, bool, error)
ListContainers(queryList map[string]string) ([]atc.Container, error)
GetContainer(id string) (atc.Container, error)
ListVolumes() ([]atc.Volume, error)
CreateBuild(plan atc.Plan) (atc.Build, error)
Builds(page Page) ([]atc.Build, Pagination, error)
OrderingPipelines(pipelineRefs atc.OrderPipelinesRequest) error
CreateArtifact(io.Reader, string, []string) (atc.WorkerArtifact, error)
GetArtifact(int) (io.ReadCloser, error)
}
type team struct {
atcTeam atc.Team
connection internal.Connection //Deprecated
httpAgent internal.HTTPAgent
}
func (team *team) Name() string {
return team.atcTeam.Name
}
func (team *team) ID() int {
return team.atcTeam.ID
}
func (team *team) Auth() atc.TeamAuth {
return team.atcTeam.Auth
}
func (team *team) ATCTeam() atc.Team {
return team.atcTeam
}
func (client *client) Team(name string) Team {
return &team{
atcTeam: atc.Team{Name: name},
connection: client.connection,
httpAgent: client.httpAgent,
}
}