transport

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Jan 7, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Forbidden                      = "Forbidden"
	AuthorizationServerUnavailable = "Authorization server unavailable"
)

Variables

This section is empty.

Functions

func OrgIDFromContext added in v1.0.0

func OrgIDFromContext(ctx context.Context) uuid.UUID

OrgIDFromContext extracts the organization ID from the context. Falls back to the default organization ID if not present.

func SetParseFailureResponse

func SetParseFailureResponse(w http.ResponseWriter, err error)

func SetResponse

func SetResponse(w http.ResponseWriter, body any, status api.Status)

Types

type TransportHandler

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

func NewTransportHandler

func NewTransportHandler(serviceHandler service.Service, 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 added in v1.0.0

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 added in v1.0.0

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 added in v1.0.0

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) CreateAuthProvider added in v1.0.0

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 added in v1.0.0

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 added in v1.0.0

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) GetDeviceLastSeen added in v0.10.0

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

func (h *TransportHandler) GetEnrollmentConfig(w http.ResponseWriter, r *http.Request, params api.GetEnrollmentConfigParams)

(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

func (h *TransportHandler) GetFleet(w http.ResponseWriter, r *http.Request, name string, params api.GetFleetParams)

(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 api.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 added in v1.0.0

func (h *TransportHandler) ListAuthProviders(w http.ResponseWriter, r *http.Request, params api.ListAuthProvidersParams)

(GET /api/v1/authproviders)

func (*TransportHandler) ListCertificateSigningRequests

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

(GET /api/v1/certificatesigningrequests)

func (*TransportHandler) ListDevices

func (h *TransportHandler) ListDevices(w http.ResponseWriter, r *http.Request, params api.ListDevicesParams)

(GET /api/v1/devices)

func (*TransportHandler) ListEnrollmentRequests

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

(GET /api/v1/enrollmentrequests)

func (*TransportHandler) ListEvents added in v0.7.0

func (h *TransportHandler) ListEvents(w http.ResponseWriter, r *http.Request, params api.ListEventsParams)

(GET /api/v1/events)

func (*TransportHandler) ListFleets

func (h *TransportHandler) ListFleets(w http.ResponseWriter, r *http.Request, params api.ListFleetsParams)

(GET /api/v1/fleets)

func (*TransportHandler) ListLabels

func (h *TransportHandler) ListLabels(w http.ResponseWriter, r *http.Request, params api.ListLabelsParams)

(GET /api/v1/labels)

func (*TransportHandler) ListOrganizations added in v0.9.0

func (h *TransportHandler) ListOrganizations(w http.ResponseWriter, r *http.Request, params api.ListOrganizationsParams)

(GET /api/v1/organizations)

func (*TransportHandler) ListRepositories

func (h *TransportHandler) ListRepositories(w http.ResponseWriter, r *http.Request, params api.ListRepositoriesParams)

(GET /api/v1/repositories)

func (*TransportHandler) ListResourceSyncs

func (h *TransportHandler) ListResourceSyncs(w http.ResponseWriter, r *http.Request, params api.ListResourceSyncsParams)

(GET /api/v1/resourcesyncs)

func (*TransportHandler) ListTemplateVersions

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

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

func (*TransportHandler) PatchAuthProvider added in v1.0.0

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 added in v1.0.0

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) ResumeDevices added in v0.10.0

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

(POST /api/v1/deviceactions/resume)

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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