service

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2025 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Forbidden                      = "Forbidden"
	AuthorizationServerUnavailable = "Authorization server unavailable"
)
View Source 
const ClientCertExpiryDays = 365
View Source 
const DefaultEnrollmentCertExpirySeconds int32 = 60 * 60 * 24 * 7 // 7 days

Variables

This section is empty.

Functions

func ApplyJSONPatch 

func ApplyJSONPatch[T any](ctx context.Context, obj T, newObj T, patchRequest v1alpha1.PatchRequest, objPath string) error

func DeviceVerificationCallback added in v0.4.0 

func DeviceVerificationCallback(before, after *api.Device) error

func FleetFromReader 

func FleetFromReader(r io.Reader) (*api.Fleet, error)

func TemplateVersionFromReader 

func TemplateVersionFromReader(r io.Reader) (*api.TemplateVersion, error)

Types

type ServiceHandler 

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

func NewServiceHandler 

func NewServiceHandler(store store.Store, callbackManager tasks_client.CallbackManager, kvStore kvstore.KVStore, ca *crypto.CA, log logrus.FieldLogger, agentEndpoint string, uiUrl string) *ServiceHandler

func (*ServiceHandler) ApproveEnrollmentRequest 

func (h *ServiceHandler) ApproveEnrollmentRequest(ctx context.Context, request server.ApproveEnrollmentRequestRequestObject) (server.ApproveEnrollmentRequestResponseObject, error)

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

func (*ServiceHandler) AuthConfig 

func (h *ServiceHandler) AuthConfig(ctx context.Context, request server.AuthConfigRequestObject) (server.AuthConfigResponseObject, error)

(GET /api/v1/auth/config)

func (*ServiceHandler) AuthValidate 

func (h *ServiceHandler) AuthValidate(ctx context.Context, request server.AuthValidateRequestObject) (server.AuthValidateResponseObject, error)

(GET /api/v1/auth/validate)

func (*ServiceHandler) CreateCertificateSigningRequest 

func (h *ServiceHandler) CreateCertificateSigningRequest(ctx context.Context, request server.CreateCertificateSigningRequestRequestObject) (server.CreateCertificateSigningRequestResponseObject, error)

(POST /api/v1/certificatesigningrequests)

func (*ServiceHandler) CreateDevice 

func (h *ServiceHandler) CreateDevice(ctx context.Context, request server.CreateDeviceRequestObject) (server.CreateDeviceResponseObject, error)

(POST /api/v1/devices)

func (*ServiceHandler) CreateEnrollmentRequest 

func (h *ServiceHandler) CreateEnrollmentRequest(ctx context.Context, request server.CreateEnrollmentRequestRequestObject) (server.CreateEnrollmentRequestResponseObject, error)

(POST /api/v1/enrollmentrequests)

func (*ServiceHandler) CreateFleet 

func (h *ServiceHandler) CreateFleet(ctx context.Context, request server.CreateFleetRequestObject) (server.CreateFleetResponseObject, error)

(POST /api/v1/fleets)

func (*ServiceHandler) CreateRepository 

func (h *ServiceHandler) CreateRepository(ctx context.Context, request server.CreateRepositoryRequestObject) (server.CreateRepositoryResponseObject, error)

(POST /api/v1/repositories)

func (*ServiceHandler) CreateResourceSync 

func (h *ServiceHandler) CreateResourceSync(ctx context.Context, request server.CreateResourceSyncRequestObject) (server.CreateResourceSyncResponseObject, error)

(POST /api/v1/resourcesyncs)

func (*ServiceHandler) DecommissionDevice added in v0.4.0 

func (h *ServiceHandler) DecommissionDevice(ctx context.Context, request server.DecommissionDeviceRequestObject) (server.DecommissionDeviceResponseObject, error)

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

func (*ServiceHandler) DeleteCertificateSigningRequest 

func (h *ServiceHandler) DeleteCertificateSigningRequest(ctx context.Context, request server.DeleteCertificateSigningRequestRequestObject) (server.DeleteCertificateSigningRequestResponseObject, error)

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

func (*ServiceHandler) DeleteCertificateSigningRequests 

func (h *ServiceHandler) DeleteCertificateSigningRequests(ctx context.Context, request server.DeleteCertificateSigningRequestsRequestObject) (server.DeleteCertificateSigningRequestsResponseObject, error)

(DELETE /api/v1/certificatesigningrequests)

func (*ServiceHandler) DeleteDevice 

func (h *ServiceHandler) DeleteDevice(ctx context.Context, request server.DeleteDeviceRequestObject) (server.DeleteDeviceResponseObject, error)

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

func (*ServiceHandler) DeleteDevices 

func (h *ServiceHandler) DeleteDevices(ctx context.Context, request server.DeleteDevicesRequestObject) (server.DeleteDevicesResponseObject, error)

(DELETE /api/v1/devices)

func (*ServiceHandler) DeleteEnrollmentRequest 

func (h *ServiceHandler) DeleteEnrollmentRequest(ctx context.Context, request server.DeleteEnrollmentRequestRequestObject) (server.DeleteEnrollmentRequestResponseObject, error)

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

func (*ServiceHandler) DeleteEnrollmentRequests 

func (h *ServiceHandler) DeleteEnrollmentRequests(ctx context.Context, request server.DeleteEnrollmentRequestsRequestObject) (server.DeleteEnrollmentRequestsResponseObject, error)

(DELETE /api/v1/enrollmentrequests)

func (*ServiceHandler) DeleteFleet 

func (h *ServiceHandler) DeleteFleet(ctx context.Context, request server.DeleteFleetRequestObject) (server.DeleteFleetResponseObject, error)

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

func (*ServiceHandler) DeleteFleets 

func (h *ServiceHandler) DeleteFleets(ctx context.Context, request server.DeleteFleetsRequestObject) (server.DeleteFleetsResponseObject, error)

(DELETE /api/v1/fleets)

func (*ServiceHandler) DeleteRepositories 

func (h *ServiceHandler) DeleteRepositories(ctx context.Context, request server.DeleteRepositoriesRequestObject) (server.DeleteRepositoriesResponseObject, error)

(DELETE /api/v1/repositories)

func (*ServiceHandler) DeleteRepository 

func (h *ServiceHandler) DeleteRepository(ctx context.Context, request server.DeleteRepositoryRequestObject) (server.DeleteRepositoryResponseObject, error)

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

func (*ServiceHandler) DeleteResourceSync 

func (h *ServiceHandler) DeleteResourceSync(ctx context.Context, request server.DeleteResourceSyncRequestObject) (server.DeleteResourceSyncResponseObject, error)

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

func (*ServiceHandler) DeleteResourceSyncs 

func (h *ServiceHandler) DeleteResourceSyncs(ctx context.Context, request server.DeleteResourceSyncsRequestObject) (server.DeleteResourceSyncsResponseObject, error)

(DELETE /api/v1/resourcesyncs)

func (*ServiceHandler) DeleteTemplateVersion 

func (h *ServiceHandler) DeleteTemplateVersion(ctx context.Context, request server.DeleteTemplateVersionRequestObject) (server.DeleteTemplateVersionResponseObject, error)

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

func (*ServiceHandler) DeleteTemplateVersions 

func (h *ServiceHandler) DeleteTemplateVersions(ctx context.Context, request server.DeleteTemplateVersionsRequestObject) (server.DeleteTemplateVersionsResponseObject, error)

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

func (*ServiceHandler) GetEnrollmentConfig added in v0.4.0 

func (h *ServiceHandler) GetEnrollmentConfig(ctx context.Context, request server.GetEnrollmentConfigRequestObject) (server.GetEnrollmentConfigResponseObject, error)

(GET /api/v1/enrollmentconfig)

func (*ServiceHandler) GetRenderedDeviceSpec 

func (h *ServiceHandler) GetRenderedDeviceSpec(ctx context.Context, request server.GetRenderedDeviceSpecRequestObject) (server.GetRenderedDeviceSpecResponseObject, error)

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

func (*ServiceHandler) GetVersion added in v0.4.0 

func (h *ServiceHandler) GetVersion(ctx context.Context, request server.GetVersionRequestObject) (server.GetVersionResponseObject, error)

(GET /api/version)

func (*ServiceHandler) ListCertificateSigningRequests 

func (h *ServiceHandler) ListCertificateSigningRequests(ctx context.Context, request server.ListCertificateSigningRequestsRequestObject) (server.ListCertificateSigningRequestsResponseObject, error)

(GET /api/v1/certificatesigningrequests)

func (*ServiceHandler) ListDevices 

func (h *ServiceHandler) ListDevices(ctx context.Context, request server.ListDevicesRequestObject) (server.ListDevicesResponseObject, error)

(GET /api/v1/devices)

func (*ServiceHandler) ListEnrollmentRequests 

func (h *ServiceHandler) ListEnrollmentRequests(ctx context.Context, request server.ListEnrollmentRequestsRequestObject) (server.ListEnrollmentRequestsResponseObject, error)

(GET /api/v1/enrollmentrequests)

func (*ServiceHandler) ListFleets 

func (h *ServiceHandler) ListFleets(ctx context.Context, request server.ListFleetsRequestObject) (server.ListFleetsResponseObject, error)

(GET /api/v1/fleets)

func (*ServiceHandler) ListRepositories 

func (h *ServiceHandler) ListRepositories(ctx context.Context, request server.ListRepositoriesRequestObject) (server.ListRepositoriesResponseObject, error)

(GET /api/v1/repositories)

func (*ServiceHandler) ListResourceSync 

func (h *ServiceHandler) ListResourceSync(ctx context.Context, request server.ListResourceSyncRequestObject) (server.ListResourceSyncResponseObject, error)

(GET /api/v1/resourcesyncs)

func (*ServiceHandler) ListTemplateVersions 

func (h *ServiceHandler) ListTemplateVersions(ctx context.Context, request server.ListTemplateVersionsRequestObject) (server.ListTemplateVersionsResponseObject, error)

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

func (*ServiceHandler) PatchCertificateSigningRequest 

func (h *ServiceHandler) PatchCertificateSigningRequest(ctx context.Context, request server.PatchCertificateSigningRequestRequestObject) (server.PatchCertificateSigningRequestResponseObject, error)

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

func (*ServiceHandler) PatchDevice 

func (h *ServiceHandler) PatchDevice(ctx context.Context, request server.PatchDeviceRequestObject) (server.PatchDeviceResponseObject, error)

(PATCH /api/v1/devices/{name}) Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) PatchDeviceStatus added in v0.4.0 

func (h *ServiceHandler) PatchDeviceStatus(ctx context.Context, request server.PatchDeviceStatusRequestObject) (server.PatchDeviceStatusResponseObject, error)

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

func (*ServiceHandler) PatchEnrollmentRequest added in v0.4.0 

func (h *ServiceHandler) PatchEnrollmentRequest(ctx context.Context, request server.PatchEnrollmentRequestRequestObject) (server.PatchEnrollmentRequestResponseObject, error)

(PATCH /api/v1/enrollmentrequests/{name}) Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) PatchEnrollmentRequestStatus added in v0.4.0 

func (h *ServiceHandler) PatchEnrollmentRequestStatus(ctx context.Context, request server.PatchEnrollmentRequestStatusRequestObject) (server.PatchEnrollmentRequestStatusResponseObject, error)

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

func (*ServiceHandler) PatchFleet 

func (h *ServiceHandler) PatchFleet(ctx context.Context, request server.PatchFleetRequestObject) (server.PatchFleetResponseObject, error)

(PATCH /api/v1/fleets/{name}) Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) PatchFleetStatus added in v0.4.0 

func (h *ServiceHandler) PatchFleetStatus(ctx context.Context, request server.PatchFleetStatusRequestObject) (server.PatchFleetStatusResponseObject, error)

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

func (*ServiceHandler) PatchRepository 

func (h *ServiceHandler) PatchRepository(ctx context.Context, request server.PatchRepositoryRequestObject) (server.PatchRepositoryResponseObject, error)

(PATCH /api/v1/repositories/{name}) Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) PatchResourceSync 

func (h *ServiceHandler) PatchResourceSync(ctx context.Context, request server.PatchResourceSyncRequestObject) (server.PatchResourceSyncResponseObject, error)

(PATCH /api/v1/resourcesyncs/{name}) Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) ReadCertificateSigningRequest 

func (h *ServiceHandler) ReadCertificateSigningRequest(ctx context.Context, request server.ReadCertificateSigningRequestRequestObject) (server.ReadCertificateSigningRequestResponseObject, error)

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

func (*ServiceHandler) ReadDevice 

func (h *ServiceHandler) ReadDevice(ctx context.Context, request server.ReadDeviceRequestObject) (server.ReadDeviceResponseObject, error)

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

func (*ServiceHandler) ReadDeviceStatus 

func (h *ServiceHandler) ReadDeviceStatus(ctx context.Context, request server.ReadDeviceStatusRequestObject) (server.ReadDeviceStatusResponseObject, error)

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

func (*ServiceHandler) ReadEnrollmentRequest 

func (h *ServiceHandler) ReadEnrollmentRequest(ctx context.Context, request server.ReadEnrollmentRequestRequestObject) (server.ReadEnrollmentRequestResponseObject, error)

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

func (*ServiceHandler) ReadEnrollmentRequestStatus 

func (h *ServiceHandler) ReadEnrollmentRequestStatus(ctx context.Context, request server.ReadEnrollmentRequestStatusRequestObject) (server.ReadEnrollmentRequestStatusResponseObject, error)

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

func (*ServiceHandler) ReadFleet 

func (h *ServiceHandler) ReadFleet(ctx context.Context, request server.ReadFleetRequestObject) (server.ReadFleetResponseObject, error)

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

func (*ServiceHandler) ReadFleetStatus 

func (h *ServiceHandler) ReadFleetStatus(ctx context.Context, request server.ReadFleetStatusRequestObject) (server.ReadFleetStatusResponseObject, error)

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

func (*ServiceHandler) ReadRepository 

func (h *ServiceHandler) ReadRepository(ctx context.Context, request server.ReadRepositoryRequestObject) (server.ReadRepositoryResponseObject, error)

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

func (*ServiceHandler) ReadResourceSync 

func (h *ServiceHandler) ReadResourceSync(ctx context.Context, request server.ReadResourceSyncRequestObject) (server.ReadResourceSyncResponseObject, error)

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

func (*ServiceHandler) ReadTemplateVersion 

func (h *ServiceHandler) ReadTemplateVersion(ctx context.Context, request server.ReadTemplateVersionRequestObject) (server.ReadTemplateVersionResponseObject, error)

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

func (*ServiceHandler) ReplaceCertificateSigningRequest 

func (h *ServiceHandler) ReplaceCertificateSigningRequest(ctx context.Context, request server.ReplaceCertificateSigningRequestRequestObject) (server.ReplaceCertificateSigningRequestResponseObject, error)

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

func (*ServiceHandler) ReplaceDevice 

func (h *ServiceHandler) ReplaceDevice(ctx context.Context, request server.ReplaceDeviceRequestObject) (server.ReplaceDeviceResponseObject, error)

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

func (*ServiceHandler) ReplaceDeviceStatus 

func (h *ServiceHandler) ReplaceDeviceStatus(ctx context.Context, request server.ReplaceDeviceStatusRequestObject) (server.ReplaceDeviceStatusResponseObject, error)

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

func (*ServiceHandler) ReplaceEnrollmentRequest 

func (h *ServiceHandler) ReplaceEnrollmentRequest(ctx context.Context, request server.ReplaceEnrollmentRequestRequestObject) (server.ReplaceEnrollmentRequestResponseObject, error)

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

func (*ServiceHandler) ReplaceEnrollmentRequestStatus 

func (h *ServiceHandler) ReplaceEnrollmentRequestStatus(ctx context.Context, request server.ReplaceEnrollmentRequestStatusRequestObject) (server.ReplaceEnrollmentRequestStatusResponseObject, error)

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

func (*ServiceHandler) ReplaceFleet 

func (h *ServiceHandler) ReplaceFleet(ctx context.Context, request server.ReplaceFleetRequestObject) (server.ReplaceFleetResponseObject, error)

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

func (*ServiceHandler) ReplaceFleetStatus 

func (h *ServiceHandler) ReplaceFleetStatus(ctx context.Context, request server.ReplaceFleetStatusRequestObject) (server.ReplaceFleetStatusResponseObject, error)

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

func (*ServiceHandler) ReplaceRepository 

func (h *ServiceHandler) ReplaceRepository(ctx context.Context, request server.ReplaceRepositoryRequestObject) (server.ReplaceRepositoryResponseObject, error)

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

func (*ServiceHandler) ReplaceResourceSync 

func (h *ServiceHandler) ReplaceResourceSync(ctx context.Context, request server.ReplaceResourceSyncRequestObject) (server.ReplaceResourceSyncResponseObject, error)

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

func (*ServiceHandler) RequestConsole 

func (h *ServiceHandler) RequestConsole(ctx context.Context, request server.RequestConsoleRequestObject) (server.RequestConsoleResponseObject, error)

TODO(majopela): remove this request handler and API call once the UI is migrated to the new websocket API

func (*ServiceHandler) UpdateCertificateSigningRequestApproval added in v0.4.0 

func (h *ServiceHandler) UpdateCertificateSigningRequestApproval(ctx context.Context, request server.UpdateCertificateSigningRequestApprovalRequestObject) (server.UpdateCertificateSigningRequestApprovalResponseObject, error)

(PUT /api/v1/certificatesigningrequests/{name}/approval) NOTE: Approval currently also issues a certificate - this will change in the future based on policy

type WebsocketHandler added in v0.4.0 

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

func NewWebsocketHandler added in v0.4.0 

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

func (*WebsocketHandler) HandleDeviceConsole added in v0.4.0 

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

func (*WebsocketHandler) RegisterRoutes added in v0.4.0 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.