Documentation
¶
Index ¶
- Constants
- func ApiStatusToErr(status api.Status) error
- func ApplyJSONPatch[T any](ctx context.Context, obj T, newObj T, patchRequest api.PatchRequest, ...) error
- func DeviceVerificationCallback(ctx context.Context, before, after *api.Device) error
- func IsInternalRequest(ctx context.Context) bool
- func NilOutManagedObjectMetaProperties(om *api.ObjectMeta)
- func StoreErrorToApiStatus(err error, created bool, kind string, name *string) api.Status
- type EventHandler
- func (h *EventHandler) CreateEvent(ctx context.Context, event *api.Event)
- func (h *EventHandler) EmitFleetRolloutStartedEvent(ctx context.Context, templateVersionName string, fleetName string, ...)
- func (h *EventHandler) HandleCertificateSigningRequestUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)
- func (h *EventHandler) HandleDeviceDecommissionEvents(ctx context.Context, _ api.ResourceKind, _ uuid.UUID, name string, ...)
- func (h *EventHandler) HandleDeviceUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)
- func (h *EventHandler) HandleEnrollmentRequestApprovedEvents(ctx context.Context, resourceKind api.ResourceKind, _ uuid.UUID, name string, ...)
- func (h *EventHandler) HandleEnrollmentRequestUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)
- func (h *EventHandler) HandleFleetUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)
- func (h *EventHandler) HandleGenericResourceDeletedEvents(ctx context.Context, resourceKind api.ResourceKind, _ uuid.UUID, name string, ...)
- func (h *EventHandler) HandleRepositoryUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)
- func (h *EventHandler) HandleResourceSyncUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)
- func (h *EventHandler) HandleTemplateVersionUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)
- type Service
- type ServiceHandler
- func (h *ServiceHandler) ApproveEnrollmentRequest(ctx context.Context, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status)
- func (h *ServiceHandler) CountDevices(ctx context.Context, params api.ListDevicesParams, ...) (int64, api.Status)
- func (h *ServiceHandler) CountDevicesByLabels(ctx context.Context, params api.ListDevicesParams, ...) ([]map[string]any, api.Status)
- func (h *ServiceHandler) CreateCertificateSigningRequest(ctx context.Context, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
- func (h *ServiceHandler) CreateDevice(ctx context.Context, device api.Device) (*api.Device, api.Status)
- func (h *ServiceHandler) CreateEnrollmentRequest(ctx context.Context, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
- func (h *ServiceHandler) CreateEvent(ctx context.Context, event *api.Event)
- func (h *ServiceHandler) CreateFleet(ctx context.Context, fleet api.Fleet) (*api.Fleet, api.Status)
- func (h *ServiceHandler) CreateRepository(ctx context.Context, repository api.Repository) (*api.Repository, api.Status)
- func (h *ServiceHandler) CreateResourceSync(ctx context.Context, rs api.ResourceSync) (*api.ResourceSync, api.Status)
- func (h *ServiceHandler) CreateTemplateVersion(ctx context.Context, templateVersion api.TemplateVersion, ...) (*api.TemplateVersion, api.Status)
- func (h *ServiceHandler) DecommissionDevice(ctx context.Context, name string, decom api.DeviceDecommission) (*api.Device, api.Status)
- func (h *ServiceHandler) DeleteCertificateSigningRequest(ctx context.Context, name string) api.Status
- func (h *ServiceHandler) DeleteDevice(ctx context.Context, name string) api.Status
- func (h *ServiceHandler) DeleteEnrollmentRequest(ctx context.Context, name string) api.Status
- func (h *ServiceHandler) DeleteEventsOlderThan(ctx context.Context, cutoffTime time.Time) (int64, api.Status)
- func (h *ServiceHandler) DeleteFleet(ctx context.Context, name string) api.Status
- func (h *ServiceHandler) DeleteRepository(ctx context.Context, name string) api.Status
- func (h *ServiceHandler) DeleteResourceSync(ctx context.Context, name string) api.Status
- func (h *ServiceHandler) DeleteTemplateVersion(ctx context.Context, fleet string, name string) api.Status
- func (h *ServiceHandler) GetCertificateSigningRequest(ctx context.Context, name string) (*api.CertificateSigningRequest, api.Status)
- func (h *ServiceHandler) GetCheckpoint(ctx context.Context, consumer string, key string) ([]byte, api.Status)
- func (h *ServiceHandler) GetDatabaseTime(ctx context.Context) (time.Time, api.Status)
- func (h *ServiceHandler) GetDevice(ctx context.Context, name string) (*api.Device, api.Status)
- func (h *ServiceHandler) GetDeviceCompletionCounts(ctx context.Context, owner string, templateVersion string, ...) ([]api.DeviceCompletionCount, api.Status)
- func (h *ServiceHandler) GetDeviceRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)
- func (h *ServiceHandler) GetDeviceStatus(ctx context.Context, name string) (*api.Device, api.Status)
- func (h *ServiceHandler) GetDevicesSummary(ctx context.Context, params api.ListDevicesParams, ...) (*api.DevicesSummary, api.Status)
- func (h *ServiceHandler) GetEnrollmentConfig(ctx context.Context, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status)
- func (h *ServiceHandler) GetEnrollmentRequest(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)
- func (h *ServiceHandler) GetEnrollmentRequestStatus(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)
- func (h *ServiceHandler) GetFleet(ctx context.Context, name string, params api.GetFleetParams) (*api.Fleet, api.Status)
- func (h *ServiceHandler) GetFleetRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)
- func (h *ServiceHandler) GetFleetStatus(ctx context.Context, name string) (*api.Fleet, api.Status)
- func (h *ServiceHandler) GetLatestTemplateVersion(ctx context.Context, fleet string) (*api.TemplateVersion, api.Status)
- func (h *ServiceHandler) GetRenderedDevice(ctx context.Context, name string, params api.GetRenderedDeviceParams) (*api.Device, api.Status)
- func (h *ServiceHandler) GetRepository(ctx context.Context, name string) (*api.Repository, api.Status)
- func (h *ServiceHandler) GetRepositoryDeviceReferences(ctx context.Context, name string) (*api.DeviceList, api.Status)
- func (h *ServiceHandler) GetRepositoryFleetReferences(ctx context.Context, name string) (*api.FleetList, api.Status)
- func (h *ServiceHandler) GetResourceSync(ctx context.Context, name string) (*api.ResourceSync, api.Status)
- func (h *ServiceHandler) GetTemplateVersion(ctx context.Context, fleet string, name string) (*api.TemplateVersion, api.Status)
- func (h *ServiceHandler) ListCertificateSigningRequests(ctx context.Context, params api.ListCertificateSigningRequestsParams) (*api.CertificateSigningRequestList, api.Status)
- func (h *ServiceHandler) ListDevices(ctx context.Context, params api.ListDevicesParams, ...) (*api.DeviceList, api.Status)
- func (h *ServiceHandler) ListDevicesByServiceCondition(ctx context.Context, conditionType string, conditionStatus string, ...) (*api.DeviceList, api.Status)
- func (h *ServiceHandler) ListDisruptionBudgetFleets(ctx context.Context) (*api.FleetList, api.Status)
- func (h *ServiceHandler) ListEnrollmentRequests(ctx context.Context, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status)
- func (h *ServiceHandler) ListEvents(ctx context.Context, params api.ListEventsParams) (*api.EventList, api.Status)
- func (h *ServiceHandler) ListFleetRolloutDeviceSelection(ctx context.Context) (*api.FleetList, api.Status)
- func (h *ServiceHandler) ListFleets(ctx context.Context, params api.ListFleetsParams) (*api.FleetList, api.Status)
- func (h *ServiceHandler) ListLabels(ctx context.Context, params api.ListLabelsParams) (*api.LabelList, api.Status)
- func (h *ServiceHandler) ListOrganizations(ctx context.Context) (*api.OrganizationList, api.Status)
- func (h *ServiceHandler) ListRepositories(ctx context.Context, params api.ListRepositoriesParams) (*api.RepositoryList, api.Status)
- func (h *ServiceHandler) ListResourceSyncs(ctx context.Context, params api.ListResourceSyncsParams) (*api.ResourceSyncList, api.Status)
- func (h *ServiceHandler) ListTemplateVersions(ctx context.Context, fleet string, params api.ListTemplateVersionsParams) (*api.TemplateVersionList, api.Status)
- func (h *ServiceHandler) MarkDevicesRolloutSelection(ctx context.Context, params api.ListDevicesParams, ...) api.Status
- func (h *ServiceHandler) OverwriteDeviceRepositoryRefs(ctx context.Context, name string, repositoryNames ...string) api.Status
- func (h *ServiceHandler) OverwriteFleetRepositoryRefs(ctx context.Context, name string, repositoryNames ...string) api.Status
- func (h *ServiceHandler) PatchCertificateSigningRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.CertificateSigningRequest, api.Status)
- func (h *ServiceHandler) PatchDevice(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status)
- func (h *ServiceHandler) PatchDeviceStatus(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status)
- func (h *ServiceHandler) PatchEnrollmentRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.EnrollmentRequest, api.Status)
- func (h *ServiceHandler) PatchFleet(ctx context.Context, name string, patch api.PatchRequest) (*api.Fleet, api.Status)
- func (h *ServiceHandler) PatchRepository(ctx context.Context, name string, patch api.PatchRequest) (*api.Repository, api.Status)
- func (h *ServiceHandler) PatchResourceSync(ctx context.Context, name string, patch api.PatchRequest) (*api.ResourceSync, api.Status)
- func (h *ServiceHandler) ReplaceCertificateSigningRequest(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
- func (h *ServiceHandler) ReplaceDevice(ctx context.Context, name string, device api.Device, fieldsToUnset []string) (*api.Device, api.Status)
- func (h *ServiceHandler) ReplaceDeviceStatus(ctx context.Context, name string, incomingDevice api.Device) (*api.Device, api.Status)
- func (h *ServiceHandler) ReplaceEnrollmentRequest(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
- func (h *ServiceHandler) ReplaceEnrollmentRequestStatus(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
- func (h *ServiceHandler) ReplaceFleet(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status)
- func (h *ServiceHandler) ReplaceFleetStatus(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status)
- func (h *ServiceHandler) ReplaceRepository(ctx context.Context, name string, repository api.Repository) (*api.Repository, api.Status)
- func (h *ServiceHandler) ReplaceRepositoryStatusByError(ctx context.Context, name string, repository api.Repository, err error) (*api.Repository, api.Status)
- func (h *ServiceHandler) ReplaceResourceSync(ctx context.Context, name string, rs api.ResourceSync) (*api.ResourceSync, api.Status)
- func (h *ServiceHandler) ReplaceResourceSyncStatus(ctx context.Context, name string, resourceSync api.ResourceSync) (*api.ResourceSync, api.Status)
- func (h *ServiceHandler) SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) api.Status
- func (h *ServiceHandler) SetDeviceServiceConditions(ctx context.Context, name string, conditions []api.Condition) api.Status
- func (h *ServiceHandler) UnmarkDevicesRolloutSelection(ctx context.Context, fleetName string) api.Status
- func (h *ServiceHandler) UpdateCertificateSigningRequestApproval(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
- func (h *ServiceHandler) UpdateDevice(ctx context.Context, name string, device api.Device, fieldsToUnset []string) (*api.Device, error)
- func (h *ServiceHandler) UpdateDeviceAnnotations(ctx context.Context, name string, annotations map[string]string, ...) api.Status
- func (h *ServiceHandler) UpdateFleetAnnotations(ctx context.Context, name string, annotations map[string]string, ...) api.Status
- func (h *ServiceHandler) UpdateFleetConditions(ctx context.Context, name string, conditions []api.Condition) api.Status
- func (h *ServiceHandler) UpdateRenderedDevice(ctx context.Context, name, renderedConfig, renderedApplications string) api.Status
- func (h *ServiceHandler) UpdateServiceSideDeviceStatus(ctx context.Context, device api.Device) bool
- type TracedService
- func (t *TracedService) ApproveEnrollmentRequest(ctx context.Context, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status)
- func (t *TracedService) CountDevices(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector) (int64, api.Status)
- func (t *TracedService) CountDevicesByLabels(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector, ...) ([]map[string]any, api.Status)
- func (t *TracedService) CreateCertificateSigningRequest(ctx context.Context, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
- func (t *TracedService) CreateDevice(ctx context.Context, d api.Device) (*api.Device, api.Status)
- func (t *TracedService) CreateEnrollmentRequest(ctx context.Context, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
- func (t *TracedService) CreateEvent(ctx context.Context, event *api.Event)
- func (t *TracedService) CreateFleet(ctx context.Context, fleet api.Fleet) (*api.Fleet, api.Status)
- func (t *TracedService) CreateRepository(ctx context.Context, repo api.Repository) (*api.Repository, api.Status)
- func (t *TracedService) CreateResourceSync(ctx context.Context, rs api.ResourceSync) (*api.ResourceSync, api.Status)
- func (t *TracedService) CreateTemplateVersion(ctx context.Context, tv api.TemplateVersion, immediateRollout bool) (*api.TemplateVersion, api.Status)
- func (t *TracedService) DecommissionDevice(ctx context.Context, name string, decom api.DeviceDecommission) (*api.Device, api.Status)
- func (t *TracedService) DeleteCertificateSigningRequest(ctx context.Context, name string) api.Status
- func (t *TracedService) DeleteDevice(ctx context.Context, name string) api.Status
- func (t *TracedService) DeleteEnrollmentRequest(ctx context.Context, name string) api.Status
- func (t *TracedService) DeleteEventsOlderThan(ctx context.Context, cutoffTime time.Time) (int64, api.Status)
- func (t *TracedService) DeleteFleet(ctx context.Context, name string) api.Status
- func (t *TracedService) DeleteRepository(ctx context.Context, name string) api.Status
- func (t *TracedService) DeleteResourceSync(ctx context.Context, name string) api.Status
- func (t *TracedService) DeleteTemplateVersion(ctx context.Context, fleet string, name string) api.Status
- func (t *TracedService) GetCertificateSigningRequest(ctx context.Context, name string) (*api.CertificateSigningRequest, api.Status)
- func (t *TracedService) GetCheckpoint(ctx context.Context, consumer string, key string) ([]byte, api.Status)
- func (t *TracedService) GetDatabaseTime(ctx context.Context) (time.Time, api.Status)
- func (t *TracedService) GetDevice(ctx context.Context, name string) (*api.Device, api.Status)
- func (t *TracedService) GetDeviceCompletionCounts(ctx context.Context, owner, version string, timeout *time.Duration) ([]api.DeviceCompletionCount, api.Status)
- func (t *TracedService) GetDeviceRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)
- func (t *TracedService) GetDeviceStatus(ctx context.Context, name string) (*api.Device, api.Status)
- func (t *TracedService) GetDevicesSummary(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector) (*api.DevicesSummary, api.Status)
- func (t *TracedService) GetEnrollmentConfig(ctx context.Context, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status)
- func (t *TracedService) GetEnrollmentRequest(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)
- func (t *TracedService) GetEnrollmentRequestStatus(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)
- func (t *TracedService) GetFleet(ctx context.Context, name string, params api.GetFleetParams) (*api.Fleet, api.Status)
- func (t *TracedService) GetFleetRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)
- func (t *TracedService) GetFleetStatus(ctx context.Context, name string) (*api.Fleet, api.Status)
- func (t *TracedService) GetLatestTemplateVersion(ctx context.Context, fleet string) (*api.TemplateVersion, api.Status)
- func (t *TracedService) GetRenderedDevice(ctx context.Context, name string, p api.GetRenderedDeviceParams) (*api.Device, api.Status)
- func (t *TracedService) GetRepository(ctx context.Context, name string) (*api.Repository, api.Status)
- func (t *TracedService) GetRepositoryDeviceReferences(ctx context.Context, name string) (*api.DeviceList, api.Status)
- func (t *TracedService) GetRepositoryFleetReferences(ctx context.Context, name string) (*api.FleetList, api.Status)
- func (t *TracedService) GetResourceSync(ctx context.Context, name string) (*api.ResourceSync, api.Status)
- func (t *TracedService) GetTemplateVersion(ctx context.Context, fleet string, name string) (*api.TemplateVersion, api.Status)
- func (t *TracedService) ListCertificateSigningRequests(ctx context.Context, p api.ListCertificateSigningRequestsParams) (*api.CertificateSigningRequestList, api.Status)
- func (t *TracedService) ListDevices(ctx context.Context, params api.ListDevicesParams, ...) (*api.DeviceList, api.Status)
- func (t *TracedService) ListDevicesByServiceCondition(ctx context.Context, conditionType string, conditionStatus string, ...) (*api.DeviceList, api.Status)
- func (t *TracedService) ListDisruptionBudgetFleets(ctx context.Context) (*api.FleetList, api.Status)
- func (t *TracedService) ListEnrollmentRequests(ctx context.Context, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status)
- func (t *TracedService) ListEvents(ctx context.Context, params api.ListEventsParams) (*api.EventList, api.Status)
- func (t *TracedService) ListFleetRolloutDeviceSelection(ctx context.Context) (*api.FleetList, api.Status)
- func (t *TracedService) ListFleets(ctx context.Context, params api.ListFleetsParams) (*api.FleetList, api.Status)
- func (t *TracedService) ListLabels(ctx context.Context, params api.ListLabelsParams) (*api.LabelList, api.Status)
- func (t *TracedService) ListOrganizations(ctx context.Context) (*api.OrganizationList, api.Status)
- func (t *TracedService) ListRepositories(ctx context.Context, params api.ListRepositoriesParams) (*api.RepositoryList, api.Status)
- func (t *TracedService) ListResourceSyncs(ctx context.Context, params api.ListResourceSyncsParams) (*api.ResourceSyncList, api.Status)
- func (t *TracedService) ListTemplateVersions(ctx context.Context, fleet string, params api.ListTemplateVersionsParams) (*api.TemplateVersionList, api.Status)
- func (t *TracedService) MarkDevicesRolloutSelection(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector, ...) api.Status
- func (t *TracedService) OverwriteDeviceRepositoryRefs(ctx context.Context, name string, refs ...string) api.Status
- func (t *TracedService) OverwriteFleetRepositoryRefs(ctx context.Context, name string, repositoryNames ...string) api.Status
- func (t *TracedService) PatchCertificateSigningRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.CertificateSigningRequest, api.Status)
- func (t *TracedService) PatchDevice(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status)
- func (t *TracedService) PatchDeviceStatus(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status)
- func (t *TracedService) PatchEnrollmentRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.EnrollmentRequest, api.Status)
- func (t *TracedService) PatchFleet(ctx context.Context, name string, patch api.PatchRequest) (*api.Fleet, api.Status)
- func (t *TracedService) PatchRepository(ctx context.Context, name string, patch api.PatchRequest) (*api.Repository, api.Status)
- func (t *TracedService) PatchResourceSync(ctx context.Context, name string, patch api.PatchRequest) (*api.ResourceSync, api.Status)
- func (t *TracedService) ReplaceCertificateSigningRequest(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
- func (t *TracedService) ReplaceDevice(ctx context.Context, name string, device api.Device, unset []string) (*api.Device, api.Status)
- func (t *TracedService) ReplaceDeviceStatus(ctx context.Context, name string, device api.Device) (*api.Device, api.Status)
- func (t *TracedService) ReplaceEnrollmentRequest(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
- func (t *TracedService) ReplaceEnrollmentRequestStatus(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
- func (t *TracedService) ReplaceFleet(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status)
- func (t *TracedService) ReplaceFleetStatus(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status)
- func (t *TracedService) ReplaceRepository(ctx context.Context, name string, repo api.Repository) (*api.Repository, api.Status)
- func (t *TracedService) ReplaceRepositoryStatusByError(ctx context.Context, name string, repository api.Repository, err error) (*api.Repository, api.Status)
- func (t *TracedService) ReplaceResourceSync(ctx context.Context, name string, rs api.ResourceSync) (*api.ResourceSync, api.Status)
- func (t *TracedService) ReplaceResourceSyncStatus(ctx context.Context, name string, resourceSync api.ResourceSync) (*api.ResourceSync, api.Status)
- func (t *TracedService) SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) api.Status
- func (t *TracedService) SetDeviceServiceConditions(ctx context.Context, name string, conditions []api.Condition) api.Status
- func (t *TracedService) UnmarkDevicesRolloutSelection(ctx context.Context, fleetName string) api.Status
- func (t *TracedService) UpdateCertificateSigningRequestApproval(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
- func (t *TracedService) UpdateDevice(ctx context.Context, name string, device api.Device, fieldsToUnset []string) (*api.Device, error)
- func (t *TracedService) UpdateDeviceAnnotations(ctx context.Context, name string, annotations map[string]string, ...) api.Status
- func (t *TracedService) UpdateFleetAnnotations(ctx context.Context, name string, annotations map[string]string, ...) api.Status
- func (t *TracedService) UpdateFleetConditions(ctx context.Context, name string, conditions []api.Condition) api.Status
- func (t *TracedService) UpdateRenderedDevice(ctx context.Context, name, renderedConfig, renderedApps string) api.Status
- func (t *TracedService) UpdateServiceSideDeviceStatus(ctx context.Context, device api.Device) bool
Constants ¶
const CheckpointKind = "Checkpoint"
const DefaultEnrollmentCertExpirySeconds int32 = 60 * 60 * 24 * 7 // 7 days
const (
MaxRecordsPerListRequest = 1000
)
Variables ¶
This section is empty.
Functions ¶
func ApiStatusToErr ¶ added in v0.6.0
func ApplyJSONPatch ¶
func DeviceVerificationCallback ¶ added in v0.4.0
func IsInternalRequest ¶ added in v0.6.0
func NilOutManagedObjectMetaProperties ¶ added in v0.6.0
func NilOutManagedObjectMetaProperties(om *api.ObjectMeta)
Types ¶
type EventHandler ¶ added in v0.9.0
type EventHandler struct {
// contains filtered or unexported fields
}
EventHandler handles all event emission logic for the service
func NewEventHandler ¶ added in v0.9.0
func NewEventHandler(store store.Store, log logrus.FieldLogger) *EventHandler
NewEventHandler creates a new EventHandler instance
func (*EventHandler) CreateEvent ¶ added in v0.9.0
func (h *EventHandler) CreateEvent(ctx context.Context, event *api.Event)
CreateEvent creates an event in the store
func (*EventHandler) EmitFleetRolloutStartedEvent ¶ added in v0.9.0
func (*EventHandler) HandleCertificateSigningRequestUpdatedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleCertificateSigningRequestUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleCertificateSigningRequestUpdatedEvents handles certificate signing request update event emission logic
func (*EventHandler) HandleDeviceDecommissionEvents ¶ added in v0.9.0
func (h *EventHandler) HandleDeviceDecommissionEvents(ctx context.Context, _ api.ResourceKind, _ uuid.UUID, name string, _, _ interface{}, created bool, err error)
HandleDeviceDecommissionEvents handles device decommission event emission logic
func (*EventHandler) HandleDeviceUpdatedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleDeviceUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleDeviceUpdatedEvents handles all device-related event emission logic
func (*EventHandler) HandleEnrollmentRequestApprovedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleEnrollmentRequestApprovedEvents(ctx context.Context, resourceKind api.ResourceKind, _ uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleEnrollmentRequestApprovedEvents handles enrollment request approval event emission logic
func (*EventHandler) HandleEnrollmentRequestUpdatedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleEnrollmentRequestUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleEnrollmentRequestUpdatedEvents handles enrollment request update event emission logic
func (*EventHandler) HandleFleetUpdatedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleFleetUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleFleetUpdatedEvents handles all fleet-related event emission logic
func (*EventHandler) HandleGenericResourceDeletedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleGenericResourceDeletedEvents(ctx context.Context, resourceKind api.ResourceKind, _ uuid.UUID, name string, _, _ interface{}, created bool, err error)
HandleGenericResourceDeletedEvents handles generic resource deletion event emission logic
func (*EventHandler) HandleRepositoryUpdatedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleRepositoryUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleRepositoryUpdatedEvents handles repository update event emission logic
func (*EventHandler) HandleResourceSyncUpdatedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleResourceSyncUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleResourceSyncUpdatedEvents handles all resource sync-related event emission logic
func (*EventHandler) HandleTemplateVersionUpdatedEvents ¶ added in v0.9.0
func (h *EventHandler) HandleTemplateVersionUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)
HandleTemplateVersionUpdatedEvents handles template version update event emission logic
type Service ¶ added in v0.8.1
type Service interface { // CertificateSigningRequest ListCertificateSigningRequests(ctx context.Context, params api.ListCertificateSigningRequestsParams) (*api.CertificateSigningRequestList, api.Status) CreateCertificateSigningRequest(ctx context.Context, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status) DeleteCertificateSigningRequest(ctx context.Context, name string) api.Status GetCertificateSigningRequest(ctx context.Context, name string) (*api.CertificateSigningRequest, api.Status) PatchCertificateSigningRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.CertificateSigningRequest, api.Status) ReplaceCertificateSigningRequest(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status) UpdateCertificateSigningRequestApproval(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status) // Device CreateDevice(ctx context.Context, device api.Device) (*api.Device, api.Status) ListDevices(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*api.DeviceList, api.Status) ListDevicesByServiceCondition(ctx context.Context, conditionType string, conditionStatus string, listParams store.ListParams) (*api.DeviceList, api.Status) UpdateDevice(ctx context.Context, name string, device api.Device, fieldsToUnset []string) (*api.Device, error) GetDevice(ctx context.Context, name string) (*api.Device, api.Status) ReplaceDevice(ctx context.Context, name string, device api.Device, fieldsToUnset []string) (*api.Device, api.Status) DeleteDevice(ctx context.Context, name string) api.Status GetDeviceStatus(ctx context.Context, name string) (*api.Device, api.Status) ReplaceDeviceStatus(ctx context.Context, name string, device api.Device) (*api.Device, api.Status) PatchDeviceStatus(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status) GetRenderedDevice(ctx context.Context, name string, params api.GetRenderedDeviceParams) (*api.Device, api.Status) PatchDevice(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status) DecommissionDevice(ctx context.Context, name string, decom api.DeviceDecommission) (*api.Device, api.Status) UpdateDeviceAnnotations(ctx context.Context, name string, annotations map[string]string, deleteKeys []string) api.Status UpdateRenderedDevice(ctx context.Context, name, renderedConfig, renderedApplications string) api.Status SetDeviceServiceConditions(ctx context.Context, name string, conditions []api.Condition) api.Status OverwriteDeviceRepositoryRefs(ctx context.Context, name string, repositoryNames ...string) api.Status GetDeviceRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status) CountDevices(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (int64, api.Status) UnmarkDevicesRolloutSelection(ctx context.Context, fleetName string) api.Status MarkDevicesRolloutSelection(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector, limit *int) api.Status GetDeviceCompletionCounts(ctx context.Context, owner string, templateVersion string, updateTimeout *time.Duration) ([]api.DeviceCompletionCount, api.Status) CountDevicesByLabels(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector, groupBy []string) ([]map[string]any, api.Status) GetDevicesSummary(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*api.DevicesSummary, api.Status) UpdateServiceSideDeviceStatus(ctx context.Context, device api.Device) bool // EnrollmentConfig GetEnrollmentConfig(ctx context.Context, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status) //EnrollmentRequest CreateEnrollmentRequest(ctx context.Context, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status) ListEnrollmentRequests(ctx context.Context, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status) GetEnrollmentRequest(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status) ReplaceEnrollmentRequest(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status) PatchEnrollmentRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.EnrollmentRequest, api.Status) DeleteEnrollmentRequest(ctx context.Context, name string) api.Status GetEnrollmentRequestStatus(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status) ApproveEnrollmentRequest(ctx context.Context, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status) ReplaceEnrollmentRequestStatus(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status) // Fleet CreateFleet(ctx context.Context, fleet api.Fleet) (*api.Fleet, api.Status) ListFleets(ctx context.Context, params api.ListFleetsParams) (*api.FleetList, api.Status) GetFleet(ctx context.Context, name string, params api.GetFleetParams) (*api.Fleet, api.Status) ReplaceFleet(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status) DeleteFleet(ctx context.Context, name string) api.Status GetFleetStatus(ctx context.Context, name string) (*api.Fleet, api.Status) ReplaceFleetStatus(ctx context.Context, name string, fleet api.Fleet) (*api.Fleet, api.Status) PatchFleet(ctx context.Context, name string, patch api.PatchRequest) (*api.Fleet, api.Status) ListFleetRolloutDeviceSelection(ctx context.Context) (*api.FleetList, api.Status) ListDisruptionBudgetFleets(ctx context.Context) (*api.FleetList, api.Status) UpdateFleetConditions(ctx context.Context, name string, conditions []api.Condition) api.Status UpdateFleetAnnotations(ctx context.Context, name string, annotations map[string]string, deleteKeys []string) api.Status OverwriteFleetRepositoryRefs(ctx context.Context, name string, repositoryNames ...string) api.Status GetFleetRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status) // Labels ListLabels(ctx context.Context, params api.ListLabelsParams) (*api.LabelList, api.Status) // Repository CreateRepository(ctx context.Context, repo api.Repository) (*api.Repository, api.Status) ListRepositories(ctx context.Context, params api.ListRepositoriesParams) (*api.RepositoryList, api.Status) GetRepository(ctx context.Context, name string) (*api.Repository, api.Status) ReplaceRepository(ctx context.Context, name string, repo api.Repository) (*api.Repository, api.Status) DeleteRepository(ctx context.Context, name string) api.Status PatchRepository(ctx context.Context, name string, patch api.PatchRequest) (*api.Repository, api.Status) ReplaceRepositoryStatusByError(ctx context.Context, name string, repository api.Repository, err error) (*api.Repository, api.Status) GetRepositoryFleetReferences(ctx context.Context, name string) (*api.FleetList, api.Status) GetRepositoryDeviceReferences(ctx context.Context, name string) (*api.DeviceList, api.Status) // ResourceSync CreateResourceSync(ctx context.Context, rs api.ResourceSync) (*api.ResourceSync, api.Status) ListResourceSyncs(ctx context.Context, params api.ListResourceSyncsParams) (*api.ResourceSyncList, api.Status) GetResourceSync(ctx context.Context, name string) (*api.ResourceSync, api.Status) ReplaceResourceSync(ctx context.Context, name string, rs api.ResourceSync) (*api.ResourceSync, api.Status) DeleteResourceSync(ctx context.Context, name string) api.Status PatchResourceSync(ctx context.Context, name string, patch api.PatchRequest) (*api.ResourceSync, api.Status) ReplaceResourceSyncStatus(ctx context.Context, name string, resourceSync api.ResourceSync) (*api.ResourceSync, api.Status) // TemplateVersion CreateTemplateVersion(ctx context.Context, tv api.TemplateVersion, immediateRollout bool) (*api.TemplateVersion, api.Status) ListTemplateVersions(ctx context.Context, fleet string, params api.ListTemplateVersionsParams) (*api.TemplateVersionList, api.Status) GetTemplateVersion(ctx context.Context, fleet string, name string) (*api.TemplateVersion, api.Status) DeleteTemplateVersion(ctx context.Context, fleet string, name string) api.Status GetLatestTemplateVersion(ctx context.Context, fleet string) (*api.TemplateVersion, api.Status) // Event CreateEvent(ctx context.Context, event *api.Event) ListEvents(ctx context.Context, params api.ListEventsParams) (*api.EventList, api.Status) DeleteEventsOlderThan(ctx context.Context, cutoffTime time.Time) (int64, api.Status) // Checkpoint GetCheckpoint(ctx context.Context, consumer string, key string) ([]byte, api.Status) SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) api.Status GetDatabaseTime(ctx context.Context) (time.Time, api.Status) // Organization ListOrganizations(ctx context.Context) (*api.OrganizationList, api.Status) }
func WrapWithTracing ¶ added in v0.8.1
type ServiceHandler ¶
type ServiceHandler struct { *EventHandler // 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, tpmCAPaths []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 (*ServiceHandler) CreateEnrollmentRequest ¶
func (h *ServiceHandler) CreateEnrollmentRequest(ctx context.Context, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
func (*ServiceHandler) CreateEvent ¶ added in v0.7.0
func (h *ServiceHandler) CreateEvent(ctx context.Context, event *api.Event)
func (*ServiceHandler) CreateFleet ¶
func (*ServiceHandler) CreateRepository ¶
func (h *ServiceHandler) CreateRepository(ctx context.Context, repository 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, templateVersion 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 (*ServiceHandler) DeleteDevice ¶
func (*ServiceHandler) DeleteEnrollmentRequest ¶
func (*ServiceHandler) DeleteEventsOlderThan ¶ added in v0.7.0
func (*ServiceHandler) DeleteFleet ¶
func (*ServiceHandler) DeleteRepository ¶
func (*ServiceHandler) DeleteResourceSync ¶
func (*ServiceHandler) DeleteTemplateVersion ¶
func (*ServiceHandler) GetCertificateSigningRequest ¶ added in v0.6.0
func (h *ServiceHandler) GetCertificateSigningRequest(ctx context.Context, name string) (*api.CertificateSigningRequest, api.Status)
func (*ServiceHandler) GetCheckpoint ¶ added in v0.9.0
func (*ServiceHandler) GetDatabaseTime ¶ added in v0.9.0
func (*ServiceHandler) GetDeviceCompletionCounts ¶ added in v0.6.0
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 (*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 (*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) ListDevicesByServiceCondition ¶ added in v0.9.0
func (h *ServiceHandler) ListDevicesByServiceCondition(ctx context.Context, conditionType string, conditionStatus string, listParams store.ListParams) (*api.DeviceList, api.Status)
func (*ServiceHandler) ListDisruptionBudgetFleets ¶ added in v0.6.0
func (*ServiceHandler) ListEnrollmentRequests ¶
func (h *ServiceHandler) ListEnrollmentRequests(ctx context.Context, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status)
func (*ServiceHandler) ListEvents ¶ added in v0.7.0
func (h *ServiceHandler) ListEvents(ctx context.Context, params api.ListEventsParams) (*api.EventList, api.Status)
func (*ServiceHandler) ListFleetRolloutDeviceSelection ¶ added in v0.6.0
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) ListOrganizations ¶ added in v0.9.0
func (h *ServiceHandler) ListOrganizations(ctx context.Context) (*api.OrganizationList, api.Status)
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 (*ServiceHandler) OverwriteFleetRepositoryRefs ¶ added in v0.6.0
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)
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 (*ServiceHandler) ReplaceDeviceStatus ¶
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 (*ServiceHandler) ReplaceFleetStatus ¶
func (*ServiceHandler) ReplaceRepository ¶
func (h *ServiceHandler) ReplaceRepository(ctx context.Context, name string, repository api.Repository) (*api.Repository, api.Status)
func (*ServiceHandler) ReplaceRepositoryStatusByError ¶ added in v0.9.0
func (h *ServiceHandler) ReplaceRepositoryStatusByError(ctx context.Context, name string, repository api.Repository, err error) (*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) SetCheckpoint ¶ added in v0.9.0
func (*ServiceHandler) SetDeviceServiceConditions ¶ added in v0.6.0
func (*ServiceHandler) UnmarkDevicesRolloutSelection ¶ added in v0.6.0
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 (*ServiceHandler) UpdateDeviceAnnotations ¶ added in v0.6.0
func (*ServiceHandler) UpdateFleetAnnotations ¶ added in v0.6.0
func (*ServiceHandler) UpdateFleetConditions ¶ added in v0.6.0
func (*ServiceHandler) UpdateRenderedDevice ¶ added in v0.6.0
func (*ServiceHandler) UpdateServiceSideDeviceStatus ¶ added in v0.6.0
type TracedService ¶ added in v0.8.1
type TracedService struct {
// contains filtered or unexported fields
}
func (*TracedService) ApproveEnrollmentRequest ¶ added in v0.8.1
func (t *TracedService) ApproveEnrollmentRequest(ctx context.Context, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status)
func (*TracedService) CountDevices ¶ added in v0.8.1
func (t *TracedService) CountDevices(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector) (int64, api.Status)
func (*TracedService) CountDevicesByLabels ¶ added in v0.8.1
func (t *TracedService) CountDevicesByLabels(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector, groupBy []string) ([]map[string]any, api.Status)
func (*TracedService) CreateCertificateSigningRequest ¶ added in v0.8.1
func (t *TracedService) CreateCertificateSigningRequest(ctx context.Context, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
func (*TracedService) CreateDevice ¶ added in v0.8.1
--- Device ---
func (*TracedService) CreateEnrollmentRequest ¶ added in v0.8.1
func (t *TracedService) CreateEnrollmentRequest(ctx context.Context, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
--- EnrollmentRequest ---
func (*TracedService) CreateEvent ¶ added in v0.8.1
func (t *TracedService) CreateEvent(ctx context.Context, event *api.Event)
--- Event ---
func (*TracedService) CreateFleet ¶ added in v0.8.1
--- Fleet ---
func (*TracedService) CreateRepository ¶ added in v0.8.1
func (t *TracedService) CreateRepository(ctx context.Context, repo api.Repository) (*api.Repository, api.Status)
--- Repository ---
func (*TracedService) CreateResourceSync ¶ added in v0.8.1
func (t *TracedService) CreateResourceSync(ctx context.Context, rs api.ResourceSync) (*api.ResourceSync, api.Status)
--- ResourceSync ---
func (*TracedService) CreateTemplateVersion ¶ added in v0.8.1
func (t *TracedService) CreateTemplateVersion(ctx context.Context, tv api.TemplateVersion, immediateRollout bool) (*api.TemplateVersion, api.Status)
--- TemplateVersion ---
func (*TracedService) DecommissionDevice ¶ added in v0.8.1
func (t *TracedService) DecommissionDevice(ctx context.Context, name string, decom api.DeviceDecommission) (*api.Device, api.Status)
func (*TracedService) DeleteCertificateSigningRequest ¶ added in v0.8.1
func (*TracedService) DeleteDevice ¶ added in v0.8.1
func (*TracedService) DeleteEnrollmentRequest ¶ added in v0.8.1
func (*TracedService) DeleteEventsOlderThan ¶ added in v0.8.1
func (*TracedService) DeleteFleet ¶ added in v0.8.1
func (*TracedService) DeleteRepository ¶ added in v0.8.1
func (*TracedService) DeleteResourceSync ¶ added in v0.8.1
func (*TracedService) DeleteTemplateVersion ¶ added in v0.8.1
func (*TracedService) GetCertificateSigningRequest ¶ added in v0.8.1
func (t *TracedService) GetCertificateSigningRequest(ctx context.Context, name string) (*api.CertificateSigningRequest, api.Status)
func (*TracedService) GetCheckpoint ¶ added in v0.9.0
func (t *TracedService) GetCheckpoint(ctx context.Context, consumer string, key string) ([]byte, api.Status)
--- Checkpoint ---
func (*TracedService) GetDatabaseTime ¶ added in v0.9.0
func (*TracedService) GetDeviceCompletionCounts ¶ added in v0.8.1
func (t *TracedService) GetDeviceCompletionCounts(ctx context.Context, owner, version string, timeout *time.Duration) ([]api.DeviceCompletionCount, api.Status)
func (*TracedService) GetDeviceRepositoryRefs ¶ added in v0.8.1
func (t *TracedService) GetDeviceRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)
func (*TracedService) GetDeviceStatus ¶ added in v0.8.1
func (*TracedService) GetDevicesSummary ¶ added in v0.8.1
func (t *TracedService) GetDevicesSummary(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector) (*api.DevicesSummary, api.Status)
func (*TracedService) GetEnrollmentConfig ¶ added in v0.8.1
func (t *TracedService) GetEnrollmentConfig(ctx context.Context, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status)
--- EnrollmentConfig ---
func (*TracedService) GetEnrollmentRequest ¶ added in v0.8.1
func (t *TracedService) GetEnrollmentRequest(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)
func (*TracedService) GetEnrollmentRequestStatus ¶ added in v0.8.1
func (t *TracedService) GetEnrollmentRequestStatus(ctx context.Context, name string) (*api.EnrollmentRequest, api.Status)
func (*TracedService) GetFleet ¶ added in v0.8.1
func (t *TracedService) GetFleet(ctx context.Context, name string, params api.GetFleetParams) (*api.Fleet, api.Status)
func (*TracedService) GetFleetRepositoryRefs ¶ added in v0.8.1
func (t *TracedService) GetFleetRepositoryRefs(ctx context.Context, name string) (*api.RepositoryList, api.Status)
func (*TracedService) GetFleetStatus ¶ added in v0.8.1
func (*TracedService) GetLatestTemplateVersion ¶ added in v0.8.1
func (t *TracedService) GetLatestTemplateVersion(ctx context.Context, fleet string) (*api.TemplateVersion, api.Status)
func (*TracedService) GetRenderedDevice ¶ added in v0.8.1
func (t *TracedService) GetRenderedDevice(ctx context.Context, name string, p api.GetRenderedDeviceParams) (*api.Device, api.Status)
func (*TracedService) GetRepository ¶ added in v0.8.1
func (t *TracedService) GetRepository(ctx context.Context, name string) (*api.Repository, api.Status)
func (*TracedService) GetRepositoryDeviceReferences ¶ added in v0.8.1
func (t *TracedService) GetRepositoryDeviceReferences(ctx context.Context, name string) (*api.DeviceList, api.Status)
func (*TracedService) GetRepositoryFleetReferences ¶ added in v0.8.1
func (*TracedService) GetResourceSync ¶ added in v0.8.1
func (t *TracedService) GetResourceSync(ctx context.Context, name string) (*api.ResourceSync, api.Status)
func (*TracedService) GetTemplateVersion ¶ added in v0.8.1
func (t *TracedService) GetTemplateVersion(ctx context.Context, fleet string, name string) (*api.TemplateVersion, api.Status)
func (*TracedService) ListCertificateSigningRequests ¶ added in v0.8.1
func (t *TracedService) ListCertificateSigningRequests(ctx context.Context, p api.ListCertificateSigningRequestsParams) (*api.CertificateSigningRequestList, api.Status)
--- CertificateSigningRequest ---
func (*TracedService) ListDevices ¶ added in v0.8.1
func (t *TracedService) ListDevices(ctx context.Context, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*api.DeviceList, api.Status)
func (*TracedService) ListDevicesByServiceCondition ¶ added in v0.9.0
func (t *TracedService) ListDevicesByServiceCondition(ctx context.Context, conditionType string, conditionStatus string, listParams store.ListParams) (*api.DeviceList, api.Status)
func (*TracedService) ListDisruptionBudgetFleets ¶ added in v0.8.1
func (*TracedService) ListEnrollmentRequests ¶ added in v0.8.1
func (t *TracedService) ListEnrollmentRequests(ctx context.Context, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status)
func (*TracedService) ListEvents ¶ added in v0.8.1
func (t *TracedService) ListEvents(ctx context.Context, params api.ListEventsParams) (*api.EventList, api.Status)
func (*TracedService) ListFleetRolloutDeviceSelection ¶ added in v0.8.1
func (*TracedService) ListFleets ¶ added in v0.8.1
func (t *TracedService) ListFleets(ctx context.Context, params api.ListFleetsParams) (*api.FleetList, api.Status)
func (*TracedService) ListLabels ¶ added in v0.8.1
func (t *TracedService) ListLabels(ctx context.Context, params api.ListLabelsParams) (*api.LabelList, api.Status)
--- Labels ---
func (*TracedService) ListOrganizations ¶ added in v0.9.0
func (t *TracedService) ListOrganizations(ctx context.Context) (*api.OrganizationList, api.Status)
--- Organization ---
func (*TracedService) ListRepositories ¶ added in v0.8.1
func (t *TracedService) ListRepositories(ctx context.Context, params api.ListRepositoriesParams) (*api.RepositoryList, api.Status)
func (*TracedService) ListResourceSyncs ¶ added in v0.8.1
func (t *TracedService) ListResourceSyncs(ctx context.Context, params api.ListResourceSyncsParams) (*api.ResourceSyncList, api.Status)
func (*TracedService) ListTemplateVersions ¶ added in v0.8.1
func (t *TracedService) ListTemplateVersions(ctx context.Context, fleet string, params api.ListTemplateVersionsParams) (*api.TemplateVersionList, api.Status)
func (*TracedService) MarkDevicesRolloutSelection ¶ added in v0.8.1
func (t *TracedService) MarkDevicesRolloutSelection(ctx context.Context, p api.ListDevicesParams, sel *selector.AnnotationSelector, limit *int) api.Status
func (*TracedService) OverwriteDeviceRepositoryRefs ¶ added in v0.8.1
func (*TracedService) OverwriteFleetRepositoryRefs ¶ added in v0.8.1
func (*TracedService) PatchCertificateSigningRequest ¶ added in v0.8.1
func (t *TracedService) PatchCertificateSigningRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.CertificateSigningRequest, api.Status)
func (*TracedService) PatchDevice ¶ added in v0.8.1
func (t *TracedService) PatchDevice(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status)
func (*TracedService) PatchDeviceStatus ¶ added in v0.8.1
func (t *TracedService) PatchDeviceStatus(ctx context.Context, name string, patch api.PatchRequest) (*api.Device, api.Status)
func (*TracedService) PatchEnrollmentRequest ¶ added in v0.8.1
func (t *TracedService) PatchEnrollmentRequest(ctx context.Context, name string, patch api.PatchRequest) (*api.EnrollmentRequest, api.Status)
func (*TracedService) PatchFleet ¶ added in v0.8.1
func (t *TracedService) PatchFleet(ctx context.Context, name string, patch api.PatchRequest) (*api.Fleet, api.Status)
func (*TracedService) PatchRepository ¶ added in v0.8.1
func (t *TracedService) PatchRepository(ctx context.Context, name string, patch api.PatchRequest) (*api.Repository, api.Status)
func (*TracedService) PatchResourceSync ¶ added in v0.8.1
func (t *TracedService) PatchResourceSync(ctx context.Context, name string, patch api.PatchRequest) (*api.ResourceSync, api.Status)
func (*TracedService) ReplaceCertificateSigningRequest ¶ added in v0.8.1
func (t *TracedService) ReplaceCertificateSigningRequest(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
func (*TracedService) ReplaceDevice ¶ added in v0.8.1
func (*TracedService) ReplaceDeviceStatus ¶ added in v0.8.1
func (*TracedService) ReplaceEnrollmentRequest ¶ added in v0.8.1
func (t *TracedService) ReplaceEnrollmentRequest(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
func (*TracedService) ReplaceEnrollmentRequestStatus ¶ added in v0.8.1
func (t *TracedService) ReplaceEnrollmentRequestStatus(ctx context.Context, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
func (*TracedService) ReplaceFleet ¶ added in v0.8.1
func (*TracedService) ReplaceFleetStatus ¶ added in v0.8.1
func (*TracedService) ReplaceRepository ¶ added in v0.8.1
func (t *TracedService) ReplaceRepository(ctx context.Context, name string, repo api.Repository) (*api.Repository, api.Status)
func (*TracedService) ReplaceRepositoryStatusByError ¶ added in v0.9.0
func (t *TracedService) ReplaceRepositoryStatusByError(ctx context.Context, name string, repository api.Repository, err error) (*api.Repository, api.Status)
func (*TracedService) ReplaceResourceSync ¶ added in v0.8.1
func (t *TracedService) ReplaceResourceSync(ctx context.Context, name string, rs api.ResourceSync) (*api.ResourceSync, api.Status)
func (*TracedService) ReplaceResourceSyncStatus ¶ added in v0.8.1
func (t *TracedService) ReplaceResourceSyncStatus(ctx context.Context, name string, resourceSync api.ResourceSync) (*api.ResourceSync, api.Status)
func (*TracedService) SetCheckpoint ¶ added in v0.9.0
func (*TracedService) SetDeviceServiceConditions ¶ added in v0.8.1
func (*TracedService) UnmarkDevicesRolloutSelection ¶ added in v0.8.1
func (*TracedService) UpdateCertificateSigningRequestApproval ¶ added in v0.8.1
func (t *TracedService) UpdateCertificateSigningRequestApproval(ctx context.Context, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)