service

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxRecordsPerListRequest        = 1000
	InternalRequestCtxKey    ctxKey = "internal_request"
	DelayDeviceRenderCtxKey  ctxKey = "delayDeviceRender"
)
View Source 
const ClientCertExpiryDays = 365
View Source 
const DefaultEnrollmentCertExpirySeconds int32 = 60 * 60 * 24 * 7 // 7 days

Variables

This section is empty.

Functions

func AddStatusIfNeeded added in v0.6.0 

func AddStatusIfNeeded(enrollmentRequest *api.EnrollmentRequest)

func ApiStatusToErr added in v0.6.0 

func ApiStatusToErr(status api.Status) error

func ApplyJSONPatch 

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

func DeviceVerificationCallback added in v0.4.0 

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

func IsInternalRequest added in v0.6.0 

func IsInternalRequest(ctx context.Context) bool

func NilOutManagedObjectMetaProperties added in v0.6.0 

func NilOutManagedObjectMetaProperties(om *v1alpha1.ObjectMeta)

func StoreErrorToApiStatus added in v0.6.0 

func StoreErrorToApiStatus(err error, created bool, kind string, name *string) api.Status

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.CAClient, log logrus.FieldLogger, agentEndpoint string, uiUrl string) *ServiceHandler

func (*ServiceHandler) ApproveEnrollmentRequest 

func (h *ServiceHandler) ApproveEnrollmentRequest(ctx context.Context, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status)

func (*ServiceHandler) CountDevices added in v0.6.0 

func (h *ServiceHandler) CountDevices(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (int64, api.Status)

func (*ServiceHandler) CountDevicesByLabels added in v0.6.0 

func (h *ServiceHandler) CountDevicesByLabels(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector, groupBy []string) ([]map[string]any, api.Status)

func (*ServiceHandler) CreateCertificateSigningRequest 

func (h *ServiceHandler) CreateCertificateSigningRequest(ctx context.Context, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)

func (*ServiceHandler) CreateDevice 

func (h *ServiceHandler) CreateDevice(ctx context.Context, device api.Device) (*api.Device, api.Status)

func (*ServiceHandler) CreateEnrollmentRequest 

func (h *ServiceHandler) CreateEnrollmentRequest(ctx context.Context, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)

func (*ServiceHandler) CreateFleet 

func (h *ServiceHandler) CreateFleet(ctx context.Context, fleet api.Fleet) (*api.Fleet, api.Status)

func (*ServiceHandler) CreateRepository 

func (h *ServiceHandler) CreateRepository(ctx context.Context, repo api.Repository) (*api.Repository, api.Status)

func (*ServiceHandler) CreateResourceSync 

func (h *ServiceHandler) CreateResourceSync(ctx context.Context, rs api.ResourceSync) (*api.ResourceSync, api.Status)

func (*ServiceHandler) CreateTemplateVersion added in v0.6.0 

func (h *ServiceHandler) CreateTemplateVersion(ctx context.Context, tv api.TemplateVersion, immediateRollout bool) (*api.TemplateVersion, api.Status)

func (*ServiceHandler) DecommissionDevice added in v0.4.0 

func (h *ServiceHandler) DecommissionDevice(ctx context.Context, name string, decom api.DeviceDecommission) (*api.Device, api.Status)

func (*ServiceHandler) DeleteCertificateSigningRequest 

func (h *ServiceHandler) DeleteCertificateSigningRequest(ctx context.Context, name string) api.Status

func (*ServiceHandler) DeleteCertificateSigningRequests 

func (h *ServiceHandler) DeleteCertificateSigningRequests(ctx context.Context) api.Status

func (*ServiceHandler) DeleteDevice 

func (h *ServiceHandler) DeleteDevice(ctx context.Context, name string) api.Status

func (*ServiceHandler) DeleteDevices 

func (h *ServiceHandler) DeleteDevices(ctx context.Context) api.Status

func (*ServiceHandler) DeleteEnrollmentRequest 

func (h *ServiceHandler) DeleteEnrollmentRequest(ctx context.Context, name string) api.Status

func (*ServiceHandler) DeleteEnrollmentRequests 

func (h *ServiceHandler) DeleteEnrollmentRequests(ctx context.Context) api.Status

func (*ServiceHandler) DeleteFleet 

func (h *ServiceHandler) DeleteFleet(ctx context.Context, name string) api.Status

func (*ServiceHandler) DeleteFleets 

func (h *ServiceHandler) DeleteFleets(ctx context.Context) api.Status

func (*ServiceHandler) DeleteRepositories 

func (h *ServiceHandler) DeleteRepositories(ctx context.Context) api.Status

func (*ServiceHandler) DeleteRepository 

func (h *ServiceHandler) DeleteRepository(ctx context.Context, name string) api.Status

func (*ServiceHandler) DeleteResourceSync 

func (h *ServiceHandler) DeleteResourceSync(ctx context.Context, name string) api.Status

func (*ServiceHandler) DeleteResourceSyncs 

func (h *ServiceHandler) DeleteResourceSyncs(ctx context.Context) api.Status

func (*ServiceHandler) DeleteTemplateVersion 

func (h *ServiceHandler) DeleteTemplateVersion(ctx context.Context, fleet string, name string) api.Status

func (*ServiceHandler) DeleteTemplateVersions 

func (h *ServiceHandler) DeleteTemplateVersions(ctx context.Context, fleet string) api.Status

func (*ServiceHandler) GetCertificateSigningRequest added in v0.6.0 

func (h *ServiceHandler) GetCertificateSigningRequest(ctx context.Context, name string) (*api.CertificateSigningRequest, api.Status)

func (*ServiceHandler) GetDevice added in v0.6.0 

func (h *ServiceHandler) GetDevice(ctx context.Context, name string) (*api.Device, api.Status)

func (*ServiceHandler) GetDeviceCompletionCounts added in v0.6.0 

func (h *ServiceHandler) GetDeviceCompletionCounts(ctx context.Context, owner string, templateVersion string, updateTimeout *time.Duration) ([]api.DeviceCompletionCount, api.Status)

func (*ServiceHandler) GetDeviceRepositoryRefs added in v0.6.0 

func (h *ServiceHandler) GetDeviceRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)

func (*ServiceHandler) GetDeviceStatus added in v0.6.0 

func (h *ServiceHandler) GetDeviceStatus(ctx context.Context, name string) (*api.Device, api.Status)

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

func (*ServiceHandler) GetDevicesSummary added in v0.6.0 

func (h *ServiceHandler) GetDevicesSummary(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*api.DevicesSummary, api.Status)

func (*ServiceHandler) GetEnrollmentConfig added in v0.4.0 

func (h *ServiceHandler) GetEnrollmentConfig(ctx context.Context, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status)

func (*ServiceHandler) GetEnrollmentRequest added in v0.6.0 

func (h *ServiceHandler) GetEnrollmentRequest(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)

func (*ServiceHandler) GetEnrollmentRequestStatus added in v0.6.0 

func (h *ServiceHandler) GetEnrollmentRequestStatus(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)

func (*ServiceHandler) GetFleet added in v0.6.0 

func (h *ServiceHandler) GetFleet(ctx context.Context, name string, params api.GetFleetParams) (*api.Fleet, api.Status)

func (*ServiceHandler) GetFleetRepositoryRefs added in v0.6.0 

func (h *ServiceHandler) GetFleetRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)

func (*ServiceHandler) GetFleetStatus added in v0.6.0 

func (h *ServiceHandler) GetFleetStatus(ctx context.Context, name string) (*api.Fleet, api.Status)

func (*ServiceHandler) GetLatestTemplateVersion added in v0.6.0 

func (h *ServiceHandler) GetLatestTemplateVersion(ctx context.Context, fleet string) (*api.TemplateVersion, api.Status)

func (*ServiceHandler) GetRenderedDevice added in v0.5.0 

func (h *ServiceHandler) GetRenderedDevice(ctx context.Context, name string, params api.GetRenderedDeviceParams) (*api.Device, api.Status)

func (*ServiceHandler) GetRepository added in v0.6.0 

func (h *ServiceHandler) GetRepository(ctx context.Context, name string) (*api.Repository, api.Status)

func (*ServiceHandler) GetRepositoryDeviceReferences added in v0.6.0 

func (h *ServiceHandler) GetRepositoryDeviceReferences(ctx context.Context, name string) (*api.DeviceList, api.Status)

func (*ServiceHandler) GetRepositoryFleetReferences added in v0.6.0 

func (h *ServiceHandler) GetRepositoryFleetReferences(ctx context.Context, name string) (*api.FleetList, api.Status)

func (*ServiceHandler) GetResourceSync added in v0.6.0 

func (h *ServiceHandler) GetResourceSync(ctx context.Context, name string) (*api.ResourceSync, api.Status)

func (*ServiceHandler) GetTemplateVersion added in v0.6.0 

func (h *ServiceHandler) GetTemplateVersion(ctx context.Context, fleet string, name string) (*api.TemplateVersion, api.Status)

func (*ServiceHandler) ListCertificateSigningRequests 

func (h *ServiceHandler) ListCertificateSigningRequests(ctx context.Context, params api.ListCertificateSigningRequestsParams) (*api.CertificateSigningRequestList, api.Status)

func (*ServiceHandler) ListDevices 

func (h *ServiceHandler) ListDevices(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*api.DeviceList, api.Status)

func (*ServiceHandler) ListDisruptionBudgetFleets added in v0.6.0 

func (h *ServiceHandler) ListDisruptionBudgetFleets(ctx context.Context) (*api.FleetList, api.Status)

func (*ServiceHandler) ListEnrollmentRequests 

func (h *ServiceHandler) ListEnrollmentRequests(ctx context.Context, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status)

func (*ServiceHandler) ListFleetRolloutDeviceSelection added in v0.6.0 

func (h *ServiceHandler) ListFleetRolloutDeviceSelection(ctx context.Context) (*api.FleetList, api.Status)

func (*ServiceHandler) ListFleets 

func (h *ServiceHandler) ListFleets(ctx context.Context, params api.ListFleetsParams) (*api.FleetList, api.Status)

func (*ServiceHandler) ListLabels added in v0.6.0 

func (h *ServiceHandler) ListLabels(ctx context.Context, params api.ListLabelsParams) (*api.LabelList, api.Status)

(GET /api/v1/labels)

func (*ServiceHandler) ListRepositories 

func (h *ServiceHandler) ListRepositories(ctx context.Context, params api.ListRepositoriesParams) (*api.RepositoryList, api.Status)

func (*ServiceHandler) ListResourceSyncs added in v0.6.0 

func (h *ServiceHandler) ListResourceSyncs(ctx context.Context, params api.ListResourceSyncsParams) (*api.ResourceSyncList, api.Status)

func (*ServiceHandler) ListTemplateVersions 

func (h *ServiceHandler) ListTemplateVersions(ctx context.Context, fleet string, params api.ListTemplateVersionsParams) (*api.TemplateVersionList, api.Status)

func (*ServiceHandler) MarkDevicesRolloutSelection added in v0.6.0 

func (h *ServiceHandler) MarkDevicesRolloutSelection(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector, limit *int) api.Status

func (*ServiceHandler) OverwriteDeviceRepositoryRefs added in v0.6.0 

func (h *ServiceHandler) OverwriteDeviceRepositoryRefs(ctx context.Context, name string, repositoryNames ...string) api.Status

func (*ServiceHandler) OverwriteFleetRepositoryRefs added in v0.6.0 

func (h *ServiceHandler) OverwriteFleetRepositoryRefs(ctx context.Context, name string, repositoryNames ...string) api.Status

func (*ServiceHandler) PatchCertificateSigningRequest 

func (h *ServiceHandler) PatchCertificateSigningRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.CertificateSigningRequest, api.Status)

func (*ServiceHandler) PatchDevice 

func (h *ServiceHandler) PatchDevice(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status)

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, name string, patch api.PatchRequest) (*api.Device, api.Status)

func (*ServiceHandler) PatchEnrollmentRequest added in v0.4.0 

func (h *ServiceHandler) PatchEnrollmentRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.EnrollmentRequest, api.Status)

Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) PatchFleet 

func (h *ServiceHandler) PatchFleet(ctx context.Context, name string, patch api.PatchRequest) (*api.Fleet, api.Status)

Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) PatchRepository 

func (h *ServiceHandler) PatchRepository(ctx context.Context, name string, patch api.PatchRequest) (*api.Repository, api.Status)

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, name string, patch api.PatchRequest) (*api.ResourceSync, api.Status)

Only metadata.labels and spec can be patched. If we try to patch other fields, HTTP 400 Bad Request is returned.

func (*ServiceHandler) ReplaceCertificateSigningRequest 

func (h *ServiceHandler) ReplaceCertificateSigningRequest(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)

func (*ServiceHandler) ReplaceDevice 

func (h *ServiceHandler) ReplaceDevice(ctx context.Context, name string, device api.Device, fieldsToUnset []string) (*api.Device, api.Status)

func (*ServiceHandler) ReplaceDeviceStatus 

func (h *ServiceHandler) ReplaceDeviceStatus(ctx context.Context, name string, device api.Device) (*api.Device, api.Status)

func (*ServiceHandler) ReplaceEnrollmentRequest 

func (h *ServiceHandler) ReplaceEnrollmentRequest(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)

func (*ServiceHandler) ReplaceEnrollmentRequestStatus 

func (h *ServiceHandler) ReplaceEnrollmentRequestStatus(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)

func (*ServiceHandler) ReplaceFleet 

func (h *ServiceHandler) ReplaceFleet(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status)

func (*ServiceHandler) ReplaceFleetStatus 

func (h *ServiceHandler) ReplaceFleetStatus(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status)

func (*ServiceHandler) ReplaceRepository 

func (h *ServiceHandler) ReplaceRepository(ctx context.Context, name string, repo api.Repository) (*api.Repository, api.Status)

func (*ServiceHandler) ReplaceRepositoryStatus added in v0.6.0 

func (h *ServiceHandler) ReplaceRepositoryStatus(ctx context.Context, name string, repository api.Repository) (*api.Repository, api.Status)

func (*ServiceHandler) ReplaceResourceSync 

func (h *ServiceHandler) ReplaceResourceSync(ctx context.Context, name string, rs api.ResourceSync) (*api.ResourceSync, api.Status)

func (*ServiceHandler) ReplaceResourceSyncStatus added in v0.6.0 

func (h *ServiceHandler) ReplaceResourceSyncStatus(ctx context.Context, name string, resourceSync api.ResourceSync) (*api.ResourceSync, api.Status)

func (*ServiceHandler) SetDeviceServiceConditions added in v0.6.0 

func (h *ServiceHandler) SetDeviceServiceConditions(ctx context.Context, name string, conditions []api.Condition) api.Status

func (*ServiceHandler) UnmarkDevicesRolloutSelection added in v0.6.0 

func (h *ServiceHandler) UnmarkDevicesRolloutSelection(ctx context.Context, fleetName string) api.Status

func (*ServiceHandler) UpdateCertificateSigningRequestApproval added in v0.4.0 

func (h *ServiceHandler) UpdateCertificateSigningRequestApproval(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)

NOTE: Approval currently also issues a certificate - this will change in the future based on policy

func (*ServiceHandler) UpdateDevice added in v0.6.0 

func (h *ServiceHandler) UpdateDevice(ctx context.Context, name string, device api.Device, fieldsToUnset []string) (*api.Device, error)

func (*ServiceHandler) UpdateDeviceAnnotations added in v0.6.0 

func (h *ServiceHandler) UpdateDeviceAnnotations(ctx context.Context, name string, annotations map[string]string, deleteKeys []string) api.Status

func (*ServiceHandler) UpdateDeviceSummaryStatusBatch added in v0.6.0 

func (h *ServiceHandler) UpdateDeviceSummaryStatusBatch(ctx context.Context, deviceNames []string, status api.DeviceSummaryStatusType, statusInfo string) api.Status

func (*ServiceHandler) UpdateFleetAnnotations added in v0.6.0 

func (h *ServiceHandler) UpdateFleetAnnotations(ctx context.Context, name string, annotations map[string]string, deleteKeys []string) api.Status

func (*ServiceHandler) UpdateFleetConditions added in v0.6.0 

func (h *ServiceHandler) UpdateFleetConditions(ctx context.Context, name string, conditions []api.Condition) api.Status

func (*ServiceHandler) UpdateRenderedDevice added in v0.6.0 

func (h *ServiceHandler) UpdateRenderedDevice(ctx context.Context, name, renderedConfig, renderedApplications string) api.Status

func (*ServiceHandler) UpdateServiceSideDeviceStatus added in v0.6.0 

func (h *ServiceHandler) UpdateServiceSideDeviceStatus(ctx context.Context, device api.Device) bool

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.