forked from databricks/databricks-sdk-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
impl.go
executable file
·121 lines (101 loc) · 3.99 KB
/
impl.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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT.
package jobs
import (
"context"
"net/http"
"github.com/xuxiaoshuo/databricks-sdk-go/client"
)
// unexported type that holds implementations of just Jobs API methods
type jobsImpl struct {
client *client.DatabricksClient
}
func (a *jobsImpl) CancelAllRuns(ctx context.Context, request CancelAllRuns) error {
path := "/api/2.1/jobs/runs/cancel-all"
err := a.client.Do(ctx, http.MethodPost, path, request, nil)
return err
}
func (a *jobsImpl) CancelRun(ctx context.Context, request CancelRun) error {
path := "/api/2.1/jobs/runs/cancel"
err := a.client.Do(ctx, http.MethodPost, path, request, nil)
return err
}
func (a *jobsImpl) Create(ctx context.Context, request CreateJob) (*CreateResponse, error) {
var createResponse CreateResponse
path := "/api/2.1/jobs/create"
err := a.client.Do(ctx, http.MethodPost, path, request, &createResponse)
return &createResponse, err
}
func (a *jobsImpl) Delete(ctx context.Context, request DeleteJob) error {
path := "/api/2.1/jobs/delete"
err := a.client.Do(ctx, http.MethodPost, path, request, nil)
return err
}
func (a *jobsImpl) DeleteRun(ctx context.Context, request DeleteRun) error {
path := "/api/2.1/jobs/runs/delete"
err := a.client.Do(ctx, http.MethodPost, path, request, nil)
return err
}
func (a *jobsImpl) ExportRun(ctx context.Context, request ExportRunRequest) (*ExportRunOutput, error) {
var exportRunOutput ExportRunOutput
path := "/api/2.1/jobs/runs/export"
err := a.client.Do(ctx, http.MethodGet, path, request, &exportRunOutput)
return &exportRunOutput, err
}
func (a *jobsImpl) Get(ctx context.Context, request GetJobRequest) (*Job, error) {
var job Job
path := "/api/2.1/jobs/get"
err := a.client.Do(ctx, http.MethodGet, path, request, &job)
return &job, err
}
func (a *jobsImpl) GetRun(ctx context.Context, request GetRunRequest) (*Run, error) {
var run Run
path := "/api/2.1/jobs/runs/get"
err := a.client.Do(ctx, http.MethodGet, path, request, &run)
return &run, err
}
func (a *jobsImpl) GetRunOutput(ctx context.Context, request GetRunOutputRequest) (*RunOutput, error) {
var runOutput RunOutput
path := "/api/2.1/jobs/runs/get-output"
err := a.client.Do(ctx, http.MethodGet, path, request, &runOutput)
return &runOutput, err
}
func (a *jobsImpl) List(ctx context.Context, request ListJobsRequest) (*ListJobsResponse, error) {
var listJobsResponse ListJobsResponse
path := "/api/2.1/jobs/list"
err := a.client.Do(ctx, http.MethodGet, path, request, &listJobsResponse)
return &listJobsResponse, err
}
func (a *jobsImpl) ListRuns(ctx context.Context, request ListRunsRequest) (*ListRunsResponse, error) {
var listRunsResponse ListRunsResponse
path := "/api/2.1/jobs/runs/list"
err := a.client.Do(ctx, http.MethodGet, path, request, &listRunsResponse)
return &listRunsResponse, err
}
func (a *jobsImpl) RepairRun(ctx context.Context, request RepairRun) (*RepairRunResponse, error) {
var repairRunResponse RepairRunResponse
path := "/api/2.1/jobs/runs/repair"
err := a.client.Do(ctx, http.MethodPost, path, request, &repairRunResponse)
return &repairRunResponse, err
}
func (a *jobsImpl) Reset(ctx context.Context, request ResetJob) error {
path := "/api/2.1/jobs/reset"
err := a.client.Do(ctx, http.MethodPost, path, request, nil)
return err
}
func (a *jobsImpl) RunNow(ctx context.Context, request RunNow) (*RunNowResponse, error) {
var runNowResponse RunNowResponse
path := "/api/2.1/jobs/run-now"
err := a.client.Do(ctx, http.MethodPost, path, request, &runNowResponse)
return &runNowResponse, err
}
func (a *jobsImpl) Submit(ctx context.Context, request SubmitRun) (*SubmitRunResponse, error) {
var submitRunResponse SubmitRunResponse
path := "/api/2.1/jobs/runs/submit"
err := a.client.Do(ctx, http.MethodPost, path, request, &submitRunResponse)
return &submitRunResponse, err
}
func (a *jobsImpl) Update(ctx context.Context, request UpdateJob) error {
path := "/api/2.1/jobs/update"
err := a.client.Do(ctx, http.MethodPost, path, request, nil)
return err
}