transportv1beta1

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 21, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type TransportHandler

type TransportHandler struct {
	// contains filtered or unexported fields
}

TransportHandler holds one focused service interface field per resource type this transport version serves - see each per-resource file (device.go, fleet.go, etc.) for which field it uses. Fields not tied to a resource (authTokenProxy, authUserInfoProxy, authZ, authN) back the auth-adjacent, non-resource endpoints in auth_token.go/auth_userinfo.go/checkpermission.go.

func NewTransportHandler

func NewTransportHandler(
	authproviderSvc authprovider.Service,
	certificatesigningrequestSvc certificatesigningrequest.Service,
	deviceSvc device.Service,
	enrollmentrequestSvc enrollmentrequest.Service,
	eventSvc event.Service,
	fleetSvc fleet.Service,
	organizationSvc organization.Service,
	repositorySvc repository.Service,
	resourcesyncSvc resourcesync.Service,
	templateversionSvc templateversion.Service,
	converter convertv1beta1.Converter,
	authN common.AuthNMiddleware,
	authTokenProxy *service.AuthTokenProxy,
	authUserInfoProxy *service.AuthUserInfoProxy,
	authZ auth.AuthZMiddleware,
) *TransportHandler

func (*TransportHandler) ApproveEnrollmentRequest

func (h *TransportHandler) ApproveEnrollmentRequest(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/enrollmentrequests/{name}/approval)

func (*TransportHandler) AuthConfig

func (h *TransportHandler) AuthConfig(w http.ResponseWriter, r *http.Request)

AuthConfig returns the authentication configuration (GET /api/v1/auth/config)

func (*TransportHandler) AuthGetPermissions

func (h *TransportHandler) AuthGetPermissions(w http.ResponseWriter, r *http.Request)

AuthGetPermissions returns the list of available permissions for the authenticated user (GET /api/v1/auth/permissions)

func (*TransportHandler) AuthToken

func (h *TransportHandler) AuthToken(w http.ResponseWriter, r *http.Request, providername string)

AuthToken handles OAuth2 token exchange requests (POST /api/v1/auth/{providername}/token)

func (*TransportHandler) AuthUserInfo

func (h *TransportHandler) AuthUserInfo(w http.ResponseWriter, r *http.Request)

AuthUserInfo handles UserInfo requests (GET /api/v1/auth/userinfo)

func (*TransportHandler) AuthValidate

func (h *TransportHandler) AuthValidate(w http.ResponseWriter, r *http.Request, params api.AuthValidateParams)

AuthValidate validates an authentication token (GET /api/v1/auth/validate)

func (*TransportHandler) CheckRepositoryOciImage added in v1.2.0

func (h *TransportHandler) CheckRepositoryOciImage(w http.ResponseWriter, r *http.Request, name string)

(POST /api/v1/repositories/{name}/check-oci-image)

func (*TransportHandler) CheckRepositoryOciTag added in v1.2.0

func (h *TransportHandler) CheckRepositoryOciTag(w http.ResponseWriter, r *http.Request, name string)

(POST /api/v1/repositories/{name}/check-oci-tag)

func (*TransportHandler) CreateAuthProvider

func (h *TransportHandler) CreateAuthProvider(w http.ResponseWriter, r *http.Request)

(POST /api/v1/authproviders)

func (*TransportHandler) CreateCertificateSigningRequest

func (h *TransportHandler) CreateCertificateSigningRequest(w http.ResponseWriter, r *http.Request)

(POST /api/v1/certificatesigningrequests)

func (*TransportHandler) CreateDevice

func (h *TransportHandler) CreateDevice(w http.ResponseWriter, r *http.Request)

(POST /api/v1/devices)

func (*TransportHandler) CreateEnrollmentRequest

func (h *TransportHandler) CreateEnrollmentRequest(w http.ResponseWriter, r *http.Request)

(POST /api/v1/enrollmentrequests)

func (*TransportHandler) CreateFleet

func (h *TransportHandler) CreateFleet(w http.ResponseWriter, r *http.Request)

(POST /api/v1/fleets)

func (*TransportHandler) CreateRepository

func (h *TransportHandler) CreateRepository(w http.ResponseWriter, r *http.Request)

(POST /api/v1/repositories)

func (*TransportHandler) CreateResourceSync

func (h *TransportHandler) CreateResourceSync(w http.ResponseWriter, r *http.Request)

(POST /api/v1/resourcesyncs)

func (*TransportHandler) DecommissionDevice

func (h *TransportHandler) DecommissionDevice(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/devices/{name}/decommission)

func (*TransportHandler) DeleteAuthProvider

func (h *TransportHandler) DeleteAuthProvider(w http.ResponseWriter, r *http.Request, name string)

(DELETE /api/v1/authproviders/{name})

func (*TransportHandler) DeleteCertificateSigningRequest

func (h *TransportHandler) DeleteCertificateSigningRequest(w http.ResponseWriter, r *http.Request, name string)

(DELETE /api/v1/certificatesigningrequests/{name})

func (*TransportHandler) DeleteDevice

func (h *TransportHandler) DeleteDevice(w http.ResponseWriter, r *http.Request, name string)

(DELETE /api/v1/devices/{name})

func (*TransportHandler) DeleteEnrollmentRequest

func (h *TransportHandler) DeleteEnrollmentRequest(w http.ResponseWriter, r *http.Request, name string)

(DELETE /api/v1/enrollmentrequests/{name})

func (*TransportHandler) DeleteFleet

func (h *TransportHandler) DeleteFleet(w http.ResponseWriter, r *http.Request, name string)

(DELETE /api/v1/fleets/{name})

func (*TransportHandler) DeleteRepository

func (h *TransportHandler) DeleteRepository(w http.ResponseWriter, r *http.Request, name string)

(DELETE /api/v1/repositories/{name})

func (*TransportHandler) DeleteResourceSync

func (h *TransportHandler) DeleteResourceSync(w http.ResponseWriter, r *http.Request, name string)

(DELETE /api/v1/resourcesyncs/{name})

func (*TransportHandler) DeleteTemplateVersion

func (h *TransportHandler) DeleteTemplateVersion(w http.ResponseWriter, r *http.Request, fleet string, name string)

(DELETE /api/v1/fleets/{fleet}/templateVersions/{name})

func (*TransportHandler) GetAuthProvider

func (h *TransportHandler) GetAuthProvider(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/authproviders/{name})

func (*TransportHandler) GetCertificateSigningRequest

func (h *TransportHandler) GetCertificateSigningRequest(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/certificatesigningrequests/{name})

func (*TransportHandler) GetDevice

func (h *TransportHandler) GetDevice(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/devices/{name})

func (*TransportHandler) GetDeviceApplicationConsole added in v1.3.0

func (h *TransportHandler) GetDeviceApplicationConsole(w http.ResponseWriter, r *http.Request, _, _ string, _ api.GetDeviceApplicationConsoleParams)

func (*TransportHandler) GetDeviceConsole added in v1.3.0

func (h *TransportHandler) GetDeviceConsole(w http.ResponseWriter, r *http.Request, _ string)

GetDeviceConsole and GetDeviceApplicationConsole satisfy the server.Transport interface, which is generated from the OpenAPI spec that declares both WS paths. These stubs are unreachable at runtime: WebsocketHandler.RegisterRoutes (called from internal/api_server/server.go) mounts the real handler at /ws/v1/devices/{name}/console before the generated router, so requests are served by WebsocketHandler.HandleDeviceConsole. Similarly, the application console endpoint is mounted by AppConsoleHandler.RegisterRoutes in internal/remote_access_server/server.go, not by this stub.

func (*TransportHandler) GetDeviceLastSeen

func (h *TransportHandler) GetDeviceLastSeen(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/devices/{name}/lastseen)

func (*TransportHandler) GetDeviceStatus

func (h *TransportHandler) GetDeviceStatus(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/devices/{name}/status)

func (*TransportHandler) GetEnrollmentConfig

(GET /api/v1/enrollmentconfig)

func (*TransportHandler) GetEnrollmentRequest

func (h *TransportHandler) GetEnrollmentRequest(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/enrollmentrequests/{name})

func (*TransportHandler) GetEnrollmentRequestStatus

func (h *TransportHandler) GetEnrollmentRequestStatus(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/enrollmentrequests/{name}/status)

func (*TransportHandler) GetFleet

(GET /api/v1/fleets/{name})

func (*TransportHandler) GetFleetStatus

func (h *TransportHandler) GetFleetStatus(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/fleets/{name}/status)

func (*TransportHandler) GetRenderedDevice

func (h *TransportHandler) GetRenderedDevice(w http.ResponseWriter, r *http.Request, name string, params apiv1beta1.GetRenderedDeviceParams)

(GET /api/v1/devices/{name}/rendered)

func (*TransportHandler) GetRepository

func (h *TransportHandler) GetRepository(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/repositories/{name})

func (*TransportHandler) GetResourceSync

func (h *TransportHandler) GetResourceSync(w http.ResponseWriter, r *http.Request, name string)

(GET /api/v1/resourcesyncs/{name})

func (*TransportHandler) GetTemplateVersion

func (h *TransportHandler) GetTemplateVersion(w http.ResponseWriter, r *http.Request, fleet string, name string)

(GET /api/v1/fleets/{fleet}/templateVersions/{name})

func (*TransportHandler) GetVersion

func (h *TransportHandler) GetVersion(w http.ResponseWriter, r *http.Request)

(GET /api/version)

func (*TransportHandler) ListAuthProviders

(GET /api/v1/authproviders)

func (*TransportHandler) ListCertificateSigningRequests

func (h *TransportHandler) ListCertificateSigningRequests(w http.ResponseWriter, r *http.Request, params apiv1beta1.ListCertificateSigningRequestsParams)

(GET /api/v1/certificatesigningrequests)

func (*TransportHandler) ListDevices

(GET /api/v1/devices)

func (*TransportHandler) ListEnrollmentRequests

func (h *TransportHandler) ListEnrollmentRequests(w http.ResponseWriter, r *http.Request, params apiv1beta1.ListEnrollmentRequestsParams)

(GET /api/v1/enrollmentrequests)

func (*TransportHandler) ListEvents

(GET /api/v1/events)

func (*TransportHandler) ListFleets

(GET /api/v1/fleets)

func (*TransportHandler) ListLabels

(GET /api/v1/labels)

func (*TransportHandler) ListOrganizations

(GET /api/v1/organizations)

func (*TransportHandler) ListRepositories

(GET /api/v1/repositories)

func (*TransportHandler) ListResourceSyncs

(GET /api/v1/resourcesyncs)

func (*TransportHandler) ListTemplateVersions

func (h *TransportHandler) ListTemplateVersions(w http.ResponseWriter, r *http.Request, fleet string, params apiv1beta1.ListTemplateVersionsParams)

(GET api/v1/fleets/{fleet}/templateVersions)

func (*TransportHandler) PatchAuthProvider

func (h *TransportHandler) PatchAuthProvider(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/authproviders/{name})

func (*TransportHandler) PatchCertificateSigningRequest

func (h *TransportHandler) PatchCertificateSigningRequest(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/certificatesigningrequests/{name})

func (*TransportHandler) PatchDevice

func (h *TransportHandler) PatchDevice(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/devices/{name})

func (*TransportHandler) PatchDeviceStatus

func (h *TransportHandler) PatchDeviceStatus(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/devices/{name}/status)

func (*TransportHandler) PatchEnrollmentRequest

func (h *TransportHandler) PatchEnrollmentRequest(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/enrollmentrequests/{name})

func (*TransportHandler) PatchEnrollmentRequestStatus

func (h *TransportHandler) PatchEnrollmentRequestStatus(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/enrollmentrequests/{name}/status)

func (*TransportHandler) PatchFleet

func (h *TransportHandler) PatchFleet(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/fleets/{name})

func (*TransportHandler) PatchFleetStatus

func (h *TransportHandler) PatchFleetStatus(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/fleets/{name}/status)

func (*TransportHandler) PatchRepository

func (h *TransportHandler) PatchRepository(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/repositories/{name})

func (*TransportHandler) PatchResourceSync

func (h *TransportHandler) PatchResourceSync(w http.ResponseWriter, r *http.Request, name string)

(PATCH /api/v1/resourcesyncs/{name})

func (*TransportHandler) ReplaceAuthProvider

func (h *TransportHandler) ReplaceAuthProvider(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/authproviders/{name})

func (*TransportHandler) ReplaceCertificateSigningRequest

func (h *TransportHandler) ReplaceCertificateSigningRequest(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/certificatesigningrequests/{name})

func (*TransportHandler) ReplaceDevice

func (h *TransportHandler) ReplaceDevice(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/devices/{name})

func (*TransportHandler) ReplaceDeviceStatus

func (h *TransportHandler) ReplaceDeviceStatus(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/devices/{name}/status)

func (*TransportHandler) ReplaceEnrollmentRequest

func (h *TransportHandler) ReplaceEnrollmentRequest(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/enrollmentrequests/{name})

func (*TransportHandler) ReplaceEnrollmentRequestStatus

func (h *TransportHandler) ReplaceEnrollmentRequestStatus(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/enrollmentrequests/{name}/status)

func (*TransportHandler) ReplaceFleet

func (h *TransportHandler) ReplaceFleet(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/fleets/{name})

func (*TransportHandler) ReplaceFleetStatus

func (h *TransportHandler) ReplaceFleetStatus(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/fleets/{name}/status)

func (*TransportHandler) ReplaceRepository

func (h *TransportHandler) ReplaceRepository(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/repositories/{name})

func (*TransportHandler) ReplaceResourceSync

func (h *TransportHandler) ReplaceResourceSync(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/resourcesyncs/{name})

func (*TransportHandler) RestartDeviceApplication added in v1.3.0

func (h *TransportHandler) RestartDeviceApplication(w http.ResponseWriter, r *http.Request, name string, appName string)

(POST /api/v1/devices/{name}/applications/{appname}/actions/restart)

func (*TransportHandler) ResumeDevices

func (h *TransportHandler) ResumeDevices(w http.ResponseWriter, r *http.Request)

(POST /api/v1/deviceactions/resume)

func (*TransportHandler) SetParseFailureResponse

func (h *TransportHandler) SetParseFailureResponse(w http.ResponseWriter, err error)

SetParseFailureResponse writes an error response for JSON decode failures.

func (*TransportHandler) SetResponse

func (h *TransportHandler) SetResponse(w http.ResponseWriter, body any, status domain.Status)

SetResponse writes an HTTP response, converting domain.Status to the v1beta1 API Status via the handler's converter. For 2xx responses, body is encoded; for non-2xx, the converted status is encoded.

func (*TransportHandler) StartDeviceApplication added in v1.3.0

func (h *TransportHandler) StartDeviceApplication(w http.ResponseWriter, r *http.Request, name string, appName string)

(POST /api/v1/devices/{name}/applications/{appname}/actions/start)

func (*TransportHandler) StartFleetApplication added in v1.3.0

func (h *TransportHandler) StartFleetApplication(w http.ResponseWriter, r *http.Request, name string, appname string)

(POST /api/v1/fleets/{name}/applications/{appname}/actions/start)

func (*TransportHandler) StopDeviceApplication added in v1.3.0

func (h *TransportHandler) StopDeviceApplication(w http.ResponseWriter, r *http.Request, name string, appName string)

(POST /api/v1/devices/{name}/applications/{appname}/actions/stop)

func (*TransportHandler) StopFleetApplication added in v1.3.0

func (h *TransportHandler) StopFleetApplication(w http.ResponseWriter, r *http.Request, name string, appname string)

(POST /api/v1/fleets/{name}/applications/{appname}/actions/stop)

func (*TransportHandler) UpdateCertificateSigningRequestApproval

func (h *TransportHandler) UpdateCertificateSigningRequestApproval(w http.ResponseWriter, r *http.Request, name string)

(PUT /api/v1/certificatesigningrequests/{name}/approval)

type WebsocketHandler

type WebsocketHandler struct {
	// contains filtered or unexported fields
}

func NewWebsocketHandler

func NewWebsocketHandler(ca *crypto.CAClient, log logrus.FieldLogger, consoleSessionManager *console.ConsoleSessionManager) *WebsocketHandler

func (*WebsocketHandler) HandleDeviceConsole

func (h *WebsocketHandler) HandleDeviceConsole(w http.ResponseWriter, r *http.Request)

func (*WebsocketHandler) RegisterRoutes

func (h *WebsocketHandler) RegisterRoutes(r chi.Router)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL