Book a Demo!
CoCalc Logo Icon
StoreFeaturesDocsShareSupportNewsAboutPoliciesSign UpSign In
gitpod-io
GitHub Repository: gitpod-io/gitpod
Path: blob/main/components/public-api/go/v1/v1connect/workspace.proxy.connect.go
2501 views
1
// Copyright (c) 2025 Gitpod GmbH. All rights reserved.
2
// Licensed under the GNU Affero General Public License (AGPL).
3
// See License.AGPL.txt in the project root for license information.
4
5
// Code generated by protoc-proxy-gen. DO NOT EDIT.
6
7
package v1connect
8
9
import (
10
context "context"
11
connect_go "github.com/bufbuild/connect-go"
12
v1 "github.com/gitpod-io/gitpod/components/public-api/go/v1"
13
)
14
15
var _ WorkspaceServiceHandler = (*ProxyWorkspaceServiceHandler)(nil)
16
17
type ProxyWorkspaceServiceHandler struct {
18
Client v1.WorkspaceServiceClient
19
UnimplementedWorkspaceServiceHandler
20
}
21
22
func (s *ProxyWorkspaceServiceHandler) GetWorkspace(ctx context.Context, req *connect_go.Request[v1.GetWorkspaceRequest]) (*connect_go.Response[v1.GetWorkspaceResponse], error) {
23
resp, err := s.Client.GetWorkspace(ctx, req.Msg)
24
if err != nil {
25
// TODO(milan): Convert to correct status code
26
return nil, err
27
}
28
29
return connect_go.NewResponse(resp), nil
30
}
31
32
func (s *ProxyWorkspaceServiceHandler) ListWorkspaces(ctx context.Context, req *connect_go.Request[v1.ListWorkspacesRequest]) (*connect_go.Response[v1.ListWorkspacesResponse], error) {
33
resp, err := s.Client.ListWorkspaces(ctx, req.Msg)
34
if err != nil {
35
// TODO(milan): Convert to correct status code
36
return nil, err
37
}
38
39
return connect_go.NewResponse(resp), nil
40
}
41
42
func (s *ProxyWorkspaceServiceHandler) ListWorkspaceSessions(ctx context.Context, req *connect_go.Request[v1.ListWorkspaceSessionsRequest]) (*connect_go.Response[v1.ListWorkspaceSessionsResponse], error) {
43
resp, err := s.Client.ListWorkspaceSessions(ctx, req.Msg)
44
if err != nil {
45
// TODO(milan): Convert to correct status code
46
return nil, err
47
}
48
49
return connect_go.NewResponse(resp), nil
50
}
51
52
func (s *ProxyWorkspaceServiceHandler) CreateAndStartWorkspace(ctx context.Context, req *connect_go.Request[v1.CreateAndStartWorkspaceRequest]) (*connect_go.Response[v1.CreateAndStartWorkspaceResponse], error) {
53
resp, err := s.Client.CreateAndStartWorkspace(ctx, req.Msg)
54
if err != nil {
55
// TODO(milan): Convert to correct status code
56
return nil, err
57
}
58
59
return connect_go.NewResponse(resp), nil
60
}
61
62
func (s *ProxyWorkspaceServiceHandler) StartWorkspace(ctx context.Context, req *connect_go.Request[v1.StartWorkspaceRequest]) (*connect_go.Response[v1.StartWorkspaceResponse], error) {
63
resp, err := s.Client.StartWorkspace(ctx, req.Msg)
64
if err != nil {
65
// TODO(milan): Convert to correct status code
66
return nil, err
67
}
68
69
return connect_go.NewResponse(resp), nil
70
}
71
72
func (s *ProxyWorkspaceServiceHandler) UpdateWorkspace(ctx context.Context, req *connect_go.Request[v1.UpdateWorkspaceRequest]) (*connect_go.Response[v1.UpdateWorkspaceResponse], error) {
73
resp, err := s.Client.UpdateWorkspace(ctx, req.Msg)
74
if err != nil {
75
// TODO(milan): Convert to correct status code
76
return nil, err
77
}
78
79
return connect_go.NewResponse(resp), nil
80
}
81
82
func (s *ProxyWorkspaceServiceHandler) StopWorkspace(ctx context.Context, req *connect_go.Request[v1.StopWorkspaceRequest]) (*connect_go.Response[v1.StopWorkspaceResponse], error) {
83
resp, err := s.Client.StopWorkspace(ctx, req.Msg)
84
if err != nil {
85
// TODO(milan): Convert to correct status code
86
return nil, err
87
}
88
89
return connect_go.NewResponse(resp), nil
90
}
91
92
func (s *ProxyWorkspaceServiceHandler) DeleteWorkspace(ctx context.Context, req *connect_go.Request[v1.DeleteWorkspaceRequest]) (*connect_go.Response[v1.DeleteWorkspaceResponse], error) {
93
resp, err := s.Client.DeleteWorkspace(ctx, req.Msg)
94
if err != nil {
95
// TODO(milan): Convert to correct status code
96
return nil, err
97
}
98
99
return connect_go.NewResponse(resp), nil
100
}
101
102
func (s *ProxyWorkspaceServiceHandler) ListWorkspaceClasses(ctx context.Context, req *connect_go.Request[v1.ListWorkspaceClassesRequest]) (*connect_go.Response[v1.ListWorkspaceClassesResponse], error) {
103
resp, err := s.Client.ListWorkspaceClasses(ctx, req.Msg)
104
if err != nil {
105
// TODO(milan): Convert to correct status code
106
return nil, err
107
}
108
109
return connect_go.NewResponse(resp), nil
110
}
111
112
func (s *ProxyWorkspaceServiceHandler) ParseContextURL(ctx context.Context, req *connect_go.Request[v1.ParseContextURLRequest]) (*connect_go.Response[v1.ParseContextURLResponse], error) {
113
resp, err := s.Client.ParseContextURL(ctx, req.Msg)
114
if err != nil {
115
// TODO(milan): Convert to correct status code
116
return nil, err
117
}
118
119
return connect_go.NewResponse(resp), nil
120
}
121
122
func (s *ProxyWorkspaceServiceHandler) GetWorkspaceDefaultImage(ctx context.Context, req *connect_go.Request[v1.GetWorkspaceDefaultImageRequest]) (*connect_go.Response[v1.GetWorkspaceDefaultImageResponse], error) {
123
resp, err := s.Client.GetWorkspaceDefaultImage(ctx, req.Msg)
124
if err != nil {
125
// TODO(milan): Convert to correct status code
126
return nil, err
127
}
128
129
return connect_go.NewResponse(resp), nil
130
}
131
132
func (s *ProxyWorkspaceServiceHandler) SendHeartBeat(ctx context.Context, req *connect_go.Request[v1.SendHeartBeatRequest]) (*connect_go.Response[v1.SendHeartBeatResponse], error) {
133
resp, err := s.Client.SendHeartBeat(ctx, req.Msg)
134
if err != nil {
135
// TODO(milan): Convert to correct status code
136
return nil, err
137
}
138
139
return connect_go.NewResponse(resp), nil
140
}
141
142
func (s *ProxyWorkspaceServiceHandler) GetWorkspaceOwnerToken(ctx context.Context, req *connect_go.Request[v1.GetWorkspaceOwnerTokenRequest]) (*connect_go.Response[v1.GetWorkspaceOwnerTokenResponse], error) {
143
resp, err := s.Client.GetWorkspaceOwnerToken(ctx, req.Msg)
144
if err != nil {
145
// TODO(milan): Convert to correct status code
146
return nil, err
147
}
148
149
return connect_go.NewResponse(resp), nil
150
}
151
152
func (s *ProxyWorkspaceServiceHandler) GetWorkspaceEditorCredentials(ctx context.Context, req *connect_go.Request[v1.GetWorkspaceEditorCredentialsRequest]) (*connect_go.Response[v1.GetWorkspaceEditorCredentialsResponse], error) {
153
resp, err := s.Client.GetWorkspaceEditorCredentials(ctx, req.Msg)
154
if err != nil {
155
// TODO(milan): Convert to correct status code
156
return nil, err
157
}
158
159
return connect_go.NewResponse(resp), nil
160
}
161
162
func (s *ProxyWorkspaceServiceHandler) CreateWorkspaceSnapshot(ctx context.Context, req *connect_go.Request[v1.CreateWorkspaceSnapshotRequest]) (*connect_go.Response[v1.CreateWorkspaceSnapshotResponse], error) {
163
resp, err := s.Client.CreateWorkspaceSnapshot(ctx, req.Msg)
164
if err != nil {
165
// TODO(milan): Convert to correct status code
166
return nil, err
167
}
168
169
return connect_go.NewResponse(resp), nil
170
}
171
172
func (s *ProxyWorkspaceServiceHandler) WaitForWorkspaceSnapshot(ctx context.Context, req *connect_go.Request[v1.WaitForWorkspaceSnapshotRequest]) (*connect_go.Response[v1.WaitForWorkspaceSnapshotResponse], error) {
173
resp, err := s.Client.WaitForWorkspaceSnapshot(ctx, req.Msg)
174
if err != nil {
175
// TODO(milan): Convert to correct status code
176
return nil, err
177
}
178
179
return connect_go.NewResponse(resp), nil
180
}
181
182
func (s *ProxyWorkspaceServiceHandler) UpdateWorkspacePort(ctx context.Context, req *connect_go.Request[v1.UpdateWorkspacePortRequest]) (*connect_go.Response[v1.UpdateWorkspacePortResponse], error) {
183
resp, err := s.Client.UpdateWorkspacePort(ctx, req.Msg)
184
if err != nil {
185
// TODO(milan): Convert to correct status code
186
return nil, err
187
}
188
189
return connect_go.NewResponse(resp), nil
190
}
191
192