service

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2025 License: Apache-2.0 Imports: 52 Imported by: 0

Documentation

Overview

Package service is a generated GoMock package.

Index

Constants

View Source 
const (
	MaxRecordsPerListRequest = 1000
	MaxConcurrentAgents      = 15
)
View Source 
const CheckpointKind = "Checkpoint"

Variables

This section is empty.

Functions

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(ctx context.Context, 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 *api.ObjectMeta)

func StoreErrorToApiStatus added in v0.6.0 

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

Types

type AuthTokenProxy added in v1.0.0 

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

AuthTokenProxy handles OAuth2 token exchange by proxying to configured providers

func NewAuthTokenProxy added in v1.0.0 

func NewAuthTokenProxy(authN *authn.MultiAuth) *AuthTokenProxy

NewAuthTokenProxy creates a new auth token proxy

func (*AuthTokenProxy) ProxyTokenRequest added in v1.0.0 

func (p *AuthTokenProxy) ProxyTokenRequest(ctx context.Context, providerName string, tokenReq *api.TokenRequest) (*api.TokenResponse, int)

ProxyTokenRequest handles OAuth2 token exchange requests Returns TokenResponse and HTTP status code (200 for success, 400 for errors per OAuth2 spec)

type AuthUserInfoProxy added in v1.0.0 

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

AuthUserInfoProxy handles OIDC UserInfo requests by extracting identity from context

func NewAuthUserInfoProxy added in v1.0.0 

func NewAuthUserInfoProxy(authN common.AuthNMiddleware) *AuthUserInfoProxy

NewAuthUserInfoProxy creates a new auth userinfo proxy

func (*AuthUserInfoProxy) ProxyUserInfoRequest added in v1.0.0 

func (p *AuthUserInfoProxy) ProxyUserInfoRequest(ctx context.Context) (*api.UserInfoResponse, api.Status)

ProxyUserInfoRequest handles OIDC UserInfo requests by extracting the authenticated identity from context

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, workerClient worker_client.WorkerClient, 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, orgId uuid.UUID, event *api.Event)

CreateEvent creates an event in the store

func (*EventHandler) EmitFleetRolloutStartedEvent added in v0.9.0 

func (h *EventHandler) EmitFleetRolloutStartedEvent(ctx context.Context, orgId uuid.UUID, templateVersionName string, fleetName string, immediateRollout bool)

func (*EventHandler) HandleAuthProviderDeletedEvents added in v1.0.0 

func (h *EventHandler) HandleAuthProviderDeletedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)

HandleAuthProviderDeletedEvents handles auth provider deletion event emission logic

func (*EventHandler) HandleAuthProviderUpdatedEvents added in v1.0.0 

func (h *EventHandler) HandleAuthProviderUpdatedEvents(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, name string, oldResource, newResource interface{}, created bool, err error)

HandleAuthProviderUpdatedEvents handles auth provider update event emission logic

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

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

IdentityMapper handles mapping from identity information to database entities

func NewIdentityMapper added in v1.0.0 

func NewIdentityMapper(store store.Store, log logrus.FieldLogger) *IdentityMapper

NewIdentityMapper creates a new IdentityMapper instance

func (*IdentityMapper) GetUserOrganizations added in v1.0.0 

func (m *IdentityMapper) GetUserOrganizations(ctx context.Context, identity common.Identity) ([]*model.Organization, error)

GetUserOrganizations returns the organizations for a user based on their identity

func (*IdentityMapper) IsMemberOf added in v1.0.0 

func (m *IdentityMapper) IsMemberOf(ctx context.Context, identity common.Identity, orgID uuid.UUID) (bool, error)

IsMemberOf checks if a user is a member of a specific organization

func (*IdentityMapper) MapIdentityToDB added in v1.0.0 

func (m *IdentityMapper) MapIdentityToDB(ctx context.Context, identity common.Identity) ([]*model.Organization, error)

MapIdentityToDB maps identity information to database entities It ensures that organizations exist in the database and returns the mapped entities Note: Users are not stored in the database - only organizations are persisted

func (*IdentityMapper) Start added in v1.0.0 

func (m *IdentityMapper) Start(ctx context.Context)

Start starts the cache background cleanup and blocks until context is cancelled

func (*IdentityMapper) Stop added in v1.0.0 

func (m *IdentityMapper) Stop()

Stop stops the cache background cleanup

type MockService added in v0.10.0 

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

MockService is a mock of Service interface.

func NewMockService added in v0.10.0 

func NewMockService(ctrl *gomock.Controller) *MockService

NewMockService creates a new mock instance.

func (*MockService) ApproveEnrollmentRequest added in v0.10.0 

func (m *MockService) ApproveEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, approval v1beta1.EnrollmentRequestApproval) (*v1beta1.EnrollmentRequestApprovalStatus, v1beta1.Status)

ApproveEnrollmentRequest mocks base method.

func (*MockService) CountDevices added in v0.10.0 

func (m *MockService) CountDevices(ctx context.Context, orgId uuid.UUID, params v1beta1.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (int64, v1beta1.Status)

CountDevices mocks base method.

func (*MockService) CountDevicesByLabels added in v0.10.0 

func (m *MockService) CountDevicesByLabels(ctx context.Context, orgId uuid.UUID, params v1beta1.ListDevicesParams, annotationSelector *selector.AnnotationSelector, groupBy []string) ([]map[string]any, v1beta1.Status)

CountDevicesByLabels mocks base method.

func (*MockService) CreateAuthProvider added in v1.0.0 

func (m *MockService) CreateAuthProvider(ctx context.Context, orgId uuid.UUID, authProvider v1beta1.AuthProvider) (*v1beta1.AuthProvider, v1beta1.Status)

CreateAuthProvider mocks base method.

func (*MockService) CreateCertificateSigningRequest added in v0.10.0 

func (m *MockService) CreateCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, csr v1beta1.CertificateSigningRequest) (*v1beta1.CertificateSigningRequest, v1beta1.Status)

CreateCertificateSigningRequest mocks base method.

func (*MockService) CreateDevice added in v0.10.0 

func (m *MockService) CreateDevice(ctx context.Context, orgId uuid.UUID, device v1beta1.Device) (*v1beta1.Device, v1beta1.Status)

CreateDevice mocks base method.

func (*MockService) CreateEnrollmentRequest added in v0.10.0 

func (m *MockService) CreateEnrollmentRequest(ctx context.Context, orgId uuid.UUID, er v1beta1.EnrollmentRequest) (*v1beta1.EnrollmentRequest, v1beta1.Status)

CreateEnrollmentRequest mocks base method.

func (*MockService) CreateEvent added in v0.10.0 

func (m *MockService) CreateEvent(ctx context.Context, orgId uuid.UUID, event *v1beta1.Event)

CreateEvent mocks base method.

func (*MockService) CreateFleet added in v0.10.0 

func (m *MockService) CreateFleet(ctx context.Context, orgId uuid.UUID, fleet v1beta1.Fleet) (*v1beta1.Fleet, v1beta1.Status)

CreateFleet mocks base method.

func (*MockService) CreateRepository added in v0.10.0 

func (m *MockService) CreateRepository(ctx context.Context, orgId uuid.UUID, repo v1beta1.Repository) (*v1beta1.Repository, v1beta1.Status)

CreateRepository mocks base method.

func (*MockService) CreateResourceSync added in v0.10.0 

func (m *MockService) CreateResourceSync(ctx context.Context, orgId uuid.UUID, rs v1beta1.ResourceSync) (*v1beta1.ResourceSync, v1beta1.Status)

CreateResourceSync mocks base method.

func (*MockService) CreateTemplateVersion added in v0.10.0 

func (m *MockService) CreateTemplateVersion(ctx context.Context, orgId uuid.UUID, tv v1beta1.TemplateVersion, immediateRollout bool) (*v1beta1.TemplateVersion, v1beta1.Status)

CreateTemplateVersion mocks base method.

func (*MockService) DecommissionDevice added in v0.10.0 

func (m *MockService) DecommissionDevice(ctx context.Context, orgId uuid.UUID, name string, decom v1beta1.DeviceDecommission) (*v1beta1.Device, v1beta1.Status)

DecommissionDevice mocks base method.

func (*MockService) DeleteAuthProvider added in v1.0.0 

func (m *MockService) DeleteAuthProvider(ctx context.Context, orgId uuid.UUID, name string) v1beta1.Status

DeleteAuthProvider mocks base method.

func (*MockService) DeleteCertificateSigningRequest added in v0.10.0 

func (m *MockService) DeleteCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string) v1beta1.Status

DeleteCertificateSigningRequest mocks base method.

func (*MockService) DeleteDevice added in v0.10.0 

func (m *MockService) DeleteDevice(ctx context.Context, orgId uuid.UUID, name string) v1beta1.Status

DeleteDevice mocks base method.

func (*MockService) DeleteEnrollmentRequest added in v0.10.0 

func (m *MockService) DeleteEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string) v1beta1.Status

DeleteEnrollmentRequest mocks base method.

func (*MockService) DeleteEventsOlderThan added in v0.10.0 

func (m *MockService) DeleteEventsOlderThan(ctx context.Context, cutoffTime time.Time) (int64, v1beta1.Status)

DeleteEventsOlderThan mocks base method.

func (*MockService) DeleteFleet added in v0.10.0 

func (m *MockService) DeleteFleet(ctx context.Context, orgId uuid.UUID, name string) v1beta1.Status

DeleteFleet mocks base method.

func (*MockService) DeleteRepository added in v0.10.0 

func (m *MockService) DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) v1beta1.Status

DeleteRepository mocks base method.

func (*MockService) DeleteResourceSync added in v0.10.0 

func (m *MockService) DeleteResourceSync(ctx context.Context, orgId uuid.UUID, name string) v1beta1.Status

DeleteResourceSync mocks base method.

func (*MockService) DeleteTemplateVersion added in v0.10.0 

func (m *MockService) DeleteTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet, name string) v1beta1.Status

DeleteTemplateVersion mocks base method.

func (*MockService) EXPECT added in v0.10.0 

func (m *MockService) EXPECT() *MockServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockService) GetAuthConfig added in v1.0.0 

func (m *MockService) GetAuthConfig(ctx context.Context, authConfig *v1beta1.AuthConfig) (*v1beta1.AuthConfig, v1beta1.Status)

GetAuthConfig mocks base method.

func (*MockService) GetAuthProvider added in v1.0.0 

func (m *MockService) GetAuthProvider(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.AuthProvider, v1beta1.Status)

GetAuthProvider mocks base method.

func (*MockService) GetAuthProviderByAuthorizationUrl added in v1.0.0 

func (m *MockService) GetAuthProviderByAuthorizationUrl(ctx context.Context, orgId uuid.UUID, authorizationUrl string) (*v1beta1.AuthProvider, v1beta1.Status)

GetAuthProviderByAuthorizationUrl mocks base method.

func (*MockService) GetAuthProviderByIssuerAndClientId added in v1.0.0 

func (m *MockService) GetAuthProviderByIssuerAndClientId(ctx context.Context, orgId uuid.UUID, issuer, clientId string) (*v1beta1.AuthProvider, v1beta1.Status)

GetAuthProviderByIssuerAndClientId mocks base method.

func (*MockService) GetCertificateSigningRequest added in v0.10.0 

func (m *MockService) GetCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.CertificateSigningRequest, v1beta1.Status)

GetCertificateSigningRequest mocks base method.

func (*MockService) GetCheckpoint added in v0.10.0 

func (m *MockService) GetCheckpoint(ctx context.Context, consumer, key string) ([]byte, v1beta1.Status)

GetCheckpoint mocks base method.

func (*MockService) GetDatabaseTime added in v0.10.0 

func (m *MockService) GetDatabaseTime(ctx context.Context) (time.Time, v1beta1.Status)

GetDatabaseTime mocks base method.

func (*MockService) GetDevice added in v0.10.0 

func (m *MockService) GetDevice(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.Device, v1beta1.Status)

GetDevice mocks base method.

func (*MockService) GetDeviceCompletionCounts added in v0.10.0 

func (m *MockService) GetDeviceCompletionCounts(ctx context.Context, orgId uuid.UUID, owner, templateVersion string, updateTimeout *time.Duration) ([]v1beta1.DeviceCompletionCount, v1beta1.Status)

GetDeviceCompletionCounts mocks base method.

func (*MockService) GetDeviceLastSeen added in v0.10.0 

func (m *MockService) GetDeviceLastSeen(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.DeviceLastSeen, v1beta1.Status)

GetDeviceLastSeen mocks base method.

func (*MockService) GetDeviceRepositoryRefs added in v0.10.0 

func (m *MockService) GetDeviceRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.RepositoryList, v1beta1.Status)

GetDeviceRepositoryRefs mocks base method.

func (*MockService) GetDeviceStatus added in v0.10.0 

func (m *MockService) GetDeviceStatus(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.Device, v1beta1.Status)

GetDeviceStatus mocks base method.

func (*MockService) GetDevicesSummary added in v0.10.0 

func (m *MockService) GetDevicesSummary(ctx context.Context, orgId uuid.UUID, params v1beta1.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*v1beta1.DevicesSummary, v1beta1.Status)

GetDevicesSummary mocks base method.

func (*MockService) GetEnrollmentConfig added in v0.10.0 

func (m *MockService) GetEnrollmentConfig(ctx context.Context, orgId uuid.UUID, params v1beta1.GetEnrollmentConfigParams) (*v1beta1.EnrollmentConfig, v1beta1.Status)

GetEnrollmentConfig mocks base method.

func (*MockService) GetEnrollmentRequest added in v0.10.0 

func (m *MockService) GetEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.EnrollmentRequest, v1beta1.Status)

GetEnrollmentRequest mocks base method.

func (*MockService) GetEnrollmentRequestStatus added in v0.10.0 

func (m *MockService) GetEnrollmentRequestStatus(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.EnrollmentRequest, v1beta1.Status)

GetEnrollmentRequestStatus mocks base method.

func (*MockService) GetFleet added in v0.10.0 

func (m *MockService) GetFleet(ctx context.Context, orgId uuid.UUID, name string, params v1beta1.GetFleetParams) (*v1beta1.Fleet, v1beta1.Status)

GetFleet mocks base method.

func (*MockService) GetFleetRepositoryRefs added in v0.10.0 

func (m *MockService) GetFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.RepositoryList, v1beta1.Status)

GetFleetRepositoryRefs mocks base method.

func (*MockService) GetFleetStatus added in v0.10.0 

func (m *MockService) GetFleetStatus(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.Fleet, v1beta1.Status)

GetFleetStatus mocks base method.

func (*MockService) GetLatestTemplateVersion added in v0.10.0 

func (m *MockService) GetLatestTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet string) (*v1beta1.TemplateVersion, v1beta1.Status)

GetLatestTemplateVersion mocks base method.

func (*MockService) GetRenderedDevice added in v0.10.0 

func (m *MockService) GetRenderedDevice(ctx context.Context, orgId uuid.UUID, name string, params v1beta1.GetRenderedDeviceParams) (*v1beta1.Device, v1beta1.Status)

GetRenderedDevice mocks base method.

func (*MockService) GetRepository added in v0.10.0 

func (m *MockService) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.Repository, v1beta1.Status)

GetRepository mocks base method.

func (*MockService) GetRepositoryDeviceReferences added in v0.10.0 

func (m *MockService) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.DeviceList, v1beta1.Status)

GetRepositoryDeviceReferences mocks base method.

func (*MockService) GetRepositoryFleetReferences added in v0.10.0 

func (m *MockService) GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.FleetList, v1beta1.Status)

GetRepositoryFleetReferences mocks base method.

func (*MockService) GetResourceSync added in v0.10.0 

func (m *MockService) GetResourceSync(ctx context.Context, orgId uuid.UUID, name string) (*v1beta1.ResourceSync, v1beta1.Status)

GetResourceSync mocks base method.

func (*MockService) GetTemplateVersion added in v0.10.0 

func (m *MockService) GetTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet, name string) (*v1beta1.TemplateVersion, v1beta1.Status)

GetTemplateVersion mocks base method.

func (*MockService) ListAllAuthProviders added in v1.0.0 

func (m *MockService) ListAllAuthProviders(ctx context.Context, params v1beta1.ListAuthProvidersParams) (*v1beta1.AuthProviderList, v1beta1.Status)

ListAllAuthProviders mocks base method.

func (*MockService) ListAuthProviders added in v1.0.0 

func (m *MockService) ListAuthProviders(ctx context.Context, orgId uuid.UUID, params v1beta1.ListAuthProvidersParams) (*v1beta1.AuthProviderList, v1beta1.Status)

ListAuthProviders mocks base method.

func (*MockService) ListCertificateSigningRequests added in v0.10.0 

func (m *MockService) ListCertificateSigningRequests(ctx context.Context, orgId uuid.UUID, params v1beta1.ListCertificateSigningRequestsParams) (*v1beta1.CertificateSigningRequestList, v1beta1.Status)

ListCertificateSigningRequests mocks base method.

func (*MockService) ListDevices added in v0.10.0 

func (m *MockService) ListDevices(ctx context.Context, orgId uuid.UUID, params v1beta1.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*v1beta1.DeviceList, v1beta1.Status)

ListDevices mocks base method.

func (*MockService) ListDevicesByServiceCondition added in v0.10.0 

func (m *MockService) ListDevicesByServiceCondition(ctx context.Context, orgId uuid.UUID, conditionType, conditionStatus string, listParams store.ListParams) (*v1beta1.DeviceList, v1beta1.Status)

ListDevicesByServiceCondition mocks base method.

func (*MockService) ListDisconnectedDevices added in v1.0.0 

func (m *MockService) ListDisconnectedDevices(ctx context.Context, orgId uuid.UUID, params v1beta1.ListDevicesParams, cutoffTime time.Time) (*v1beta1.DeviceList, v1beta1.Status)

ListDisconnectedDevices mocks base method.

func (*MockService) ListDisruptionBudgetFleets added in v0.10.0 

func (m *MockService) ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (*v1beta1.FleetList, v1beta1.Status)

ListDisruptionBudgetFleets mocks base method.

func (*MockService) ListEnrollmentRequests added in v0.10.0 

func (m *MockService) ListEnrollmentRequests(ctx context.Context, orgId uuid.UUID, params v1beta1.ListEnrollmentRequestsParams) (*v1beta1.EnrollmentRequestList, v1beta1.Status)

ListEnrollmentRequests mocks base method.

func (*MockService) ListEvents added in v0.10.0 

func (m *MockService) ListEvents(ctx context.Context, orgId uuid.UUID, params v1beta1.ListEventsParams) (*v1beta1.EventList, v1beta1.Status)

ListEvents mocks base method.

func (*MockService) ListFleetRolloutDeviceSelection added in v0.10.0 

func (m *MockService) ListFleetRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (*v1beta1.FleetList, v1beta1.Status)

ListFleetRolloutDeviceSelection mocks base method.

func (*MockService) ListFleets added in v0.10.0 

func (m *MockService) ListFleets(ctx context.Context, orgId uuid.UUID, params v1beta1.ListFleetsParams) (*v1beta1.FleetList, v1beta1.Status)

ListFleets mocks base method.

func (*MockService) ListLabels added in v0.10.0 

func (m *MockService) ListLabels(ctx context.Context, orgId uuid.UUID, params v1beta1.ListLabelsParams) (*v1beta1.LabelList, v1beta1.Status)

ListLabels mocks base method.

func (*MockService) ListOrganizations added in v0.10.0 

func (m *MockService) ListOrganizations(ctx context.Context, params v1beta1.ListOrganizationsParams) (*v1beta1.OrganizationList, v1beta1.Status)

ListOrganizations mocks base method.

func (*MockService) ListRepositories added in v0.10.0 

func (m *MockService) ListRepositories(ctx context.Context, orgId uuid.UUID, params v1beta1.ListRepositoriesParams) (*v1beta1.RepositoryList, v1beta1.Status)

ListRepositories mocks base method.

func (*MockService) ListResourceSyncs added in v0.10.0 

func (m *MockService) ListResourceSyncs(ctx context.Context, orgId uuid.UUID, params v1beta1.ListResourceSyncsParams) (*v1beta1.ResourceSyncList, v1beta1.Status)

ListResourceSyncs mocks base method.

func (*MockService) ListTemplateVersions added in v0.10.0 

func (m *MockService) ListTemplateVersions(ctx context.Context, orgId uuid.UUID, fleet string, params v1beta1.ListTemplateVersionsParams) (*v1beta1.TemplateVersionList, v1beta1.Status)

ListTemplateVersions mocks base method.

func (*MockService) MarkDevicesRolloutSelection added in v0.10.0 

func (m *MockService) MarkDevicesRolloutSelection(ctx context.Context, orgId uuid.UUID, params v1beta1.ListDevicesParams, annotationSelector *selector.AnnotationSelector, limit *int) v1beta1.Status

MarkDevicesRolloutSelection mocks base method.

func (*MockService) OverwriteDeviceRepositoryRefs added in v0.10.0 

func (m *MockService) OverwriteDeviceRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) v1beta1.Status

OverwriteDeviceRepositoryRefs mocks base method.

func (*MockService) OverwriteFleetRepositoryRefs added in v0.10.0 

func (m *MockService) OverwriteFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) v1beta1.Status

OverwriteFleetRepositoryRefs mocks base method.

func (*MockService) PatchAuthProvider added in v1.0.0 

func (m *MockService) PatchAuthProvider(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.AuthProvider, v1beta1.Status)

PatchAuthProvider mocks base method.

func (*MockService) PatchCertificateSigningRequest added in v0.10.0 

func (m *MockService) PatchCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.CertificateSigningRequest, v1beta1.Status)

PatchCertificateSigningRequest mocks base method.

func (*MockService) PatchDevice added in v0.10.0 

func (m *MockService) PatchDevice(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.Device, v1beta1.Status)

PatchDevice mocks base method.

func (*MockService) PatchDeviceStatus added in v0.10.0 

func (m *MockService) PatchDeviceStatus(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.Device, v1beta1.Status)

PatchDeviceStatus mocks base method.

func (*MockService) PatchEnrollmentRequest added in v0.10.0 

func (m *MockService) PatchEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.EnrollmentRequest, v1beta1.Status)

PatchEnrollmentRequest mocks base method.

func (*MockService) PatchFleet added in v0.10.0 

func (m *MockService) PatchFleet(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.Fleet, v1beta1.Status)

PatchFleet mocks base method.

func (*MockService) PatchRepository added in v0.10.0 

func (m *MockService) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.Repository, v1beta1.Status)

PatchRepository mocks base method.

func (*MockService) PatchResourceSync added in v0.10.0 

func (m *MockService) PatchResourceSync(ctx context.Context, orgId uuid.UUID, name string, patch v1beta1.PatchRequest) (*v1beta1.ResourceSync, v1beta1.Status)

PatchResourceSync mocks base method.

func (*MockService) ReplaceAuthProvider added in v1.0.0 

func (m *MockService) ReplaceAuthProvider(ctx context.Context, orgId uuid.UUID, name string, authProvider v1beta1.AuthProvider) (*v1beta1.AuthProvider, v1beta1.Status)

ReplaceAuthProvider mocks base method.

func (*MockService) ReplaceCertificateSigningRequest added in v0.10.0 

func (m *MockService) ReplaceCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string, csr v1beta1.CertificateSigningRequest) (*v1beta1.CertificateSigningRequest, v1beta1.Status)

ReplaceCertificateSigningRequest mocks base method.

func (*MockService) ReplaceDevice added in v0.10.0 

func (m *MockService) ReplaceDevice(ctx context.Context, orgId uuid.UUID, name string, device v1beta1.Device, fieldsToUnset []string) (*v1beta1.Device, v1beta1.Status)

ReplaceDevice mocks base method.

func (*MockService) ReplaceDeviceStatus added in v0.10.0 

func (m *MockService) ReplaceDeviceStatus(ctx context.Context, orgId uuid.UUID, name string, device v1beta1.Device) (*v1beta1.Device, v1beta1.Status)

ReplaceDeviceStatus mocks base method.

func (*MockService) ReplaceEnrollmentRequest added in v0.10.0 

func (m *MockService) ReplaceEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, er v1beta1.EnrollmentRequest) (*v1beta1.EnrollmentRequest, v1beta1.Status)

ReplaceEnrollmentRequest mocks base method.

func (*MockService) ReplaceEnrollmentRequestStatus added in v0.10.0 

func (m *MockService) ReplaceEnrollmentRequestStatus(ctx context.Context, orgId uuid.UUID, name string, er v1beta1.EnrollmentRequest) (*v1beta1.EnrollmentRequest, v1beta1.Status)

ReplaceEnrollmentRequestStatus mocks base method.

func (*MockService) ReplaceFleet added in v0.10.0 

func (m *MockService) ReplaceFleet(ctx context.Context, orgId uuid.UUID, name string, fleet v1beta1.Fleet) (*v1beta1.Fleet, v1beta1.Status)

ReplaceFleet mocks base method.

func (*MockService) ReplaceFleetStatus added in v0.10.0 

func (m *MockService) ReplaceFleetStatus(ctx context.Context, orgId uuid.UUID, name string, fleet v1beta1.Fleet) (*v1beta1.Fleet, v1beta1.Status)

ReplaceFleetStatus mocks base method.

func (*MockService) ReplaceRepository added in v0.10.0 

func (m *MockService) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo v1beta1.Repository) (*v1beta1.Repository, v1beta1.Status)

ReplaceRepository mocks base method.

func (*MockService) ReplaceRepositoryStatusByError added in v0.10.0 

func (m *MockService) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, repository v1beta1.Repository, err error) (*v1beta1.Repository, v1beta1.Status)

ReplaceRepositoryStatusByError mocks base method.

func (*MockService) ReplaceResourceSync added in v0.10.0 

func (m *MockService) ReplaceResourceSync(ctx context.Context, orgId uuid.UUID, name string, rs v1beta1.ResourceSync) (*v1beta1.ResourceSync, v1beta1.Status)

ReplaceResourceSync mocks base method.

func (*MockService) ReplaceResourceSyncStatus added in v0.10.0 

func (m *MockService) ReplaceResourceSyncStatus(ctx context.Context, orgId uuid.UUID, name string, resourceSync v1beta1.ResourceSync) (*v1beta1.ResourceSync, v1beta1.Status)

ReplaceResourceSyncStatus mocks base method.

func (*MockService) ResumeDevices added in v0.10.0 

func (m *MockService) ResumeDevices(ctx context.Context, orgId uuid.UUID, request v1beta1.DeviceResumeRequest) (v1beta1.DeviceResumeResponse, v1beta1.Status)

ResumeDevices mocks base method.

func (*MockService) SetCheckpoint added in v0.10.0 

func (m *MockService) SetCheckpoint(ctx context.Context, consumer, key string, value []byte) v1beta1.Status

SetCheckpoint mocks base method.

func (*MockService) SetDeviceServiceConditions added in v0.10.0 

func (m *MockService) SetDeviceServiceConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []v1beta1.Condition) v1beta1.Status

SetDeviceServiceConditions mocks base method.

func (*MockService) SetOutOfDate added in v0.10.0 

func (m *MockService) SetOutOfDate(ctx context.Context, orgId uuid.UUID, owner string) error

SetOutOfDate mocks base method.

func (*MockService) UnmarkDevicesRolloutSelection added in v0.10.0 

func (m *MockService) UnmarkDevicesRolloutSelection(ctx context.Context, orgId uuid.UUID, fleetName string) v1beta1.Status

UnmarkDevicesRolloutSelection mocks base method.

func (*MockService) UpdateCertificateSigningRequestApproval added in v0.10.0 

func (m *MockService) UpdateCertificateSigningRequestApproval(ctx context.Context, orgId uuid.UUID, name string, csr v1beta1.CertificateSigningRequest) (*v1beta1.CertificateSigningRequest, v1beta1.Status)

UpdateCertificateSigningRequestApproval mocks base method.

func (*MockService) UpdateDevice added in v0.10.0 

func (m *MockService) UpdateDevice(ctx context.Context, orgId uuid.UUID, name string, device v1beta1.Device, fieldsToUnset []string) (*v1beta1.Device, error)

UpdateDevice mocks base method.

func (*MockService) UpdateDeviceAnnotations added in v0.10.0 

func (m *MockService) UpdateDeviceAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) v1beta1.Status

UpdateDeviceAnnotations mocks base method.

func (*MockService) UpdateFleetAnnotations added in v0.10.0 

func (m *MockService) UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) v1beta1.Status

UpdateFleetAnnotations mocks base method.

func (*MockService) UpdateFleetConditions added in v0.10.0 

func (m *MockService) UpdateFleetConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []v1beta1.Condition) v1beta1.Status

UpdateFleetConditions mocks base method.

func (*MockService) UpdateRenderedDevice added in v0.10.0 

func (m *MockService) UpdateRenderedDevice(ctx context.Context, orgId uuid.UUID, name, renderedConfig, renderedApplications, specHash string) v1beta1.Status

UpdateRenderedDevice mocks base method.

func (*MockService) UpdateServerSideDeviceStatus added in v0.10.0 

func (m *MockService) UpdateServerSideDeviceStatus(ctx context.Context, orgId uuid.UUID, name string) error

UpdateServerSideDeviceStatus mocks base method.

func (*MockService) UpdateServiceSideDeviceStatus added in v0.10.0 

func (m *MockService) UpdateServiceSideDeviceStatus(ctx context.Context, orgId uuid.UUID, device v1beta1.Device) bool

UpdateServiceSideDeviceStatus mocks base method.

type MockServiceMockRecorder added in v0.10.0 

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

MockServiceMockRecorder is the mock recorder for MockService.

func (*MockServiceMockRecorder) ApproveEnrollmentRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) ApproveEnrollmentRequest(ctx, orgId, name, approval any) *gomock.Call

ApproveEnrollmentRequest indicates an expected call of ApproveEnrollmentRequest.

func (*MockServiceMockRecorder) CountDevices added in v0.10.0 

func (mr *MockServiceMockRecorder) CountDevices(ctx, orgId, params, annotationSelector any) *gomock.Call

CountDevices indicates an expected call of CountDevices.

func (*MockServiceMockRecorder) CountDevicesByLabels added in v0.10.0 

func (mr *MockServiceMockRecorder) CountDevicesByLabels(ctx, orgId, params, annotationSelector, groupBy any) *gomock.Call

CountDevicesByLabels indicates an expected call of CountDevicesByLabels.

func (*MockServiceMockRecorder) CreateAuthProvider added in v1.0.0 

func (mr *MockServiceMockRecorder) CreateAuthProvider(ctx, orgId, authProvider any) *gomock.Call

CreateAuthProvider indicates an expected call of CreateAuthProvider.

func (*MockServiceMockRecorder) CreateCertificateSigningRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateCertificateSigningRequest(ctx, orgId, csr any) *gomock.Call

CreateCertificateSigningRequest indicates an expected call of CreateCertificateSigningRequest.

func (*MockServiceMockRecorder) CreateDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateDevice(ctx, orgId, device any) *gomock.Call

CreateDevice indicates an expected call of CreateDevice.

func (*MockServiceMockRecorder) CreateEnrollmentRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateEnrollmentRequest(ctx, orgId, er any) *gomock.Call

CreateEnrollmentRequest indicates an expected call of CreateEnrollmentRequest.

func (*MockServiceMockRecorder) CreateEvent added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateEvent(ctx, orgId, event any) *gomock.Call

CreateEvent indicates an expected call of CreateEvent.

func (*MockServiceMockRecorder) CreateFleet added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateFleet(ctx, orgId, fleet any) *gomock.Call

CreateFleet indicates an expected call of CreateFleet.

func (*MockServiceMockRecorder) CreateRepository added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateRepository(ctx, orgId, repo any) *gomock.Call

CreateRepository indicates an expected call of CreateRepository.

func (*MockServiceMockRecorder) CreateResourceSync added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateResourceSync(ctx, orgId, rs any) *gomock.Call

CreateResourceSync indicates an expected call of CreateResourceSync.

func (*MockServiceMockRecorder) CreateTemplateVersion added in v0.10.0 

func (mr *MockServiceMockRecorder) CreateTemplateVersion(ctx, orgId, tv, immediateRollout any) *gomock.Call

CreateTemplateVersion indicates an expected call of CreateTemplateVersion.

func (*MockServiceMockRecorder) DecommissionDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) DecommissionDevice(ctx, orgId, name, decom any) *gomock.Call

DecommissionDevice indicates an expected call of DecommissionDevice.

func (*MockServiceMockRecorder) DeleteAuthProvider added in v1.0.0 

func (mr *MockServiceMockRecorder) DeleteAuthProvider(ctx, orgId, name any) *gomock.Call

DeleteAuthProvider indicates an expected call of DeleteAuthProvider.

func (*MockServiceMockRecorder) DeleteCertificateSigningRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteCertificateSigningRequest(ctx, orgId, name any) *gomock.Call

DeleteCertificateSigningRequest indicates an expected call of DeleteCertificateSigningRequest.

func (*MockServiceMockRecorder) DeleteDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteDevice(ctx, orgId, name any) *gomock.Call

DeleteDevice indicates an expected call of DeleteDevice.

func (*MockServiceMockRecorder) DeleteEnrollmentRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteEnrollmentRequest(ctx, orgId, name any) *gomock.Call

DeleteEnrollmentRequest indicates an expected call of DeleteEnrollmentRequest.

func (*MockServiceMockRecorder) DeleteEventsOlderThan added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteEventsOlderThan(ctx, cutoffTime any) *gomock.Call

DeleteEventsOlderThan indicates an expected call of DeleteEventsOlderThan.

func (*MockServiceMockRecorder) DeleteFleet added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteFleet(ctx, orgId, name any) *gomock.Call

DeleteFleet indicates an expected call of DeleteFleet.

func (*MockServiceMockRecorder) DeleteRepository added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteRepository(ctx, orgId, name any) *gomock.Call

DeleteRepository indicates an expected call of DeleteRepository.

func (*MockServiceMockRecorder) DeleteResourceSync added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteResourceSync(ctx, orgId, name any) *gomock.Call

DeleteResourceSync indicates an expected call of DeleteResourceSync.

func (*MockServiceMockRecorder) DeleteTemplateVersion added in v0.10.0 

func (mr *MockServiceMockRecorder) DeleteTemplateVersion(ctx, orgId, fleet, name any) *gomock.Call

DeleteTemplateVersion indicates an expected call of DeleteTemplateVersion.

func (*MockServiceMockRecorder) GetAuthConfig added in v1.0.0 

func (mr *MockServiceMockRecorder) GetAuthConfig(ctx, authConfig any) *gomock.Call

GetAuthConfig indicates an expected call of GetAuthConfig.

func (*MockServiceMockRecorder) GetAuthProvider added in v1.0.0 

func (mr *MockServiceMockRecorder) GetAuthProvider(ctx, orgId, name any) *gomock.Call

GetAuthProvider indicates an expected call of GetAuthProvider.

func (*MockServiceMockRecorder) GetAuthProviderByAuthorizationUrl added in v1.0.0 

func (mr *MockServiceMockRecorder) GetAuthProviderByAuthorizationUrl(ctx, orgId, authorizationUrl any) *gomock.Call

GetAuthProviderByAuthorizationUrl indicates an expected call of GetAuthProviderByAuthorizationUrl.

func (*MockServiceMockRecorder) GetAuthProviderByIssuerAndClientId added in v1.0.0 

func (mr *MockServiceMockRecorder) GetAuthProviderByIssuerAndClientId(ctx, orgId, issuer, clientId any) *gomock.Call

GetAuthProviderByIssuerAndClientId indicates an expected call of GetAuthProviderByIssuerAndClientId.

func (*MockServiceMockRecorder) GetCertificateSigningRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) GetCertificateSigningRequest(ctx, orgId, name any) *gomock.Call

GetCertificateSigningRequest indicates an expected call of GetCertificateSigningRequest.

func (*MockServiceMockRecorder) GetCheckpoint added in v0.10.0 

func (mr *MockServiceMockRecorder) GetCheckpoint(ctx, consumer, key any) *gomock.Call

GetCheckpoint indicates an expected call of GetCheckpoint.

func (*MockServiceMockRecorder) GetDatabaseTime added in v0.10.0 

func (mr *MockServiceMockRecorder) GetDatabaseTime(ctx any) *gomock.Call

GetDatabaseTime indicates an expected call of GetDatabaseTime.

func (*MockServiceMockRecorder) GetDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) GetDevice(ctx, orgId, name any) *gomock.Call

GetDevice indicates an expected call of GetDevice.

func (*MockServiceMockRecorder) GetDeviceCompletionCounts added in v0.10.0 

func (mr *MockServiceMockRecorder) GetDeviceCompletionCounts(ctx, orgId, owner, templateVersion, updateTimeout any) *gomock.Call

GetDeviceCompletionCounts indicates an expected call of GetDeviceCompletionCounts.

func (*MockServiceMockRecorder) GetDeviceLastSeen added in v0.10.0 

func (mr *MockServiceMockRecorder) GetDeviceLastSeen(ctx, orgId, name any) *gomock.Call

GetDeviceLastSeen indicates an expected call of GetDeviceLastSeen.

func (*MockServiceMockRecorder) GetDeviceRepositoryRefs added in v0.10.0 

func (mr *MockServiceMockRecorder) GetDeviceRepositoryRefs(ctx, orgId, name any) *gomock.Call

GetDeviceRepositoryRefs indicates an expected call of GetDeviceRepositoryRefs.

func (*MockServiceMockRecorder) GetDeviceStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) GetDeviceStatus(ctx, orgId, name any) *gomock.Call

GetDeviceStatus indicates an expected call of GetDeviceStatus.

func (*MockServiceMockRecorder) GetDevicesSummary added in v0.10.0 

func (mr *MockServiceMockRecorder) GetDevicesSummary(ctx, orgId, params, annotationSelector any) *gomock.Call

GetDevicesSummary indicates an expected call of GetDevicesSummary.

func (*MockServiceMockRecorder) GetEnrollmentConfig added in v0.10.0 

func (mr *MockServiceMockRecorder) GetEnrollmentConfig(ctx, orgId, params any) *gomock.Call

GetEnrollmentConfig indicates an expected call of GetEnrollmentConfig.

func (*MockServiceMockRecorder) GetEnrollmentRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) GetEnrollmentRequest(ctx, orgId, name any) *gomock.Call

GetEnrollmentRequest indicates an expected call of GetEnrollmentRequest.

func (*MockServiceMockRecorder) GetEnrollmentRequestStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) GetEnrollmentRequestStatus(ctx, orgId, name any) *gomock.Call

GetEnrollmentRequestStatus indicates an expected call of GetEnrollmentRequestStatus.

func (*MockServiceMockRecorder) GetFleet added in v0.10.0 

func (mr *MockServiceMockRecorder) GetFleet(ctx, orgId, name, params any) *gomock.Call

GetFleet indicates an expected call of GetFleet.

func (*MockServiceMockRecorder) GetFleetRepositoryRefs added in v0.10.0 

func (mr *MockServiceMockRecorder) GetFleetRepositoryRefs(ctx, orgId, name any) *gomock.Call

GetFleetRepositoryRefs indicates an expected call of GetFleetRepositoryRefs.

func (*MockServiceMockRecorder) GetFleetStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) GetFleetStatus(ctx, orgId, name any) *gomock.Call

GetFleetStatus indicates an expected call of GetFleetStatus.

func (*MockServiceMockRecorder) GetLatestTemplateVersion added in v0.10.0 

func (mr *MockServiceMockRecorder) GetLatestTemplateVersion(ctx, orgId, fleet any) *gomock.Call

GetLatestTemplateVersion indicates an expected call of GetLatestTemplateVersion.

func (*MockServiceMockRecorder) GetRenderedDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) GetRenderedDevice(ctx, orgId, name, params any) *gomock.Call

GetRenderedDevice indicates an expected call of GetRenderedDevice.

func (*MockServiceMockRecorder) GetRepository added in v0.10.0 

func (mr *MockServiceMockRecorder) GetRepository(ctx, orgId, name any) *gomock.Call

GetRepository indicates an expected call of GetRepository.

func (*MockServiceMockRecorder) GetRepositoryDeviceReferences added in v0.10.0 

func (mr *MockServiceMockRecorder) GetRepositoryDeviceReferences(ctx, orgId, name any) *gomock.Call

GetRepositoryDeviceReferences indicates an expected call of GetRepositoryDeviceReferences.

func (*MockServiceMockRecorder) GetRepositoryFleetReferences added in v0.10.0 

func (mr *MockServiceMockRecorder) GetRepositoryFleetReferences(ctx, orgId, name any) *gomock.Call

GetRepositoryFleetReferences indicates an expected call of GetRepositoryFleetReferences.

func (*MockServiceMockRecorder) GetResourceSync added in v0.10.0 

func (mr *MockServiceMockRecorder) GetResourceSync(ctx, orgId, name any) *gomock.Call

GetResourceSync indicates an expected call of GetResourceSync.

func (*MockServiceMockRecorder) GetTemplateVersion added in v0.10.0 

func (mr *MockServiceMockRecorder) GetTemplateVersion(ctx, orgId, fleet, name any) *gomock.Call

GetTemplateVersion indicates an expected call of GetTemplateVersion.

func (*MockServiceMockRecorder) ListAllAuthProviders added in v1.0.0 

func (mr *MockServiceMockRecorder) ListAllAuthProviders(ctx, params any) *gomock.Call

ListAllAuthProviders indicates an expected call of ListAllAuthProviders.

func (*MockServiceMockRecorder) ListAuthProviders added in v1.0.0 

func (mr *MockServiceMockRecorder) ListAuthProviders(ctx, orgId, params any) *gomock.Call

ListAuthProviders indicates an expected call of ListAuthProviders.

func (*MockServiceMockRecorder) ListCertificateSigningRequests added in v0.10.0 

func (mr *MockServiceMockRecorder) ListCertificateSigningRequests(ctx, orgId, params any) *gomock.Call

ListCertificateSigningRequests indicates an expected call of ListCertificateSigningRequests.

func (*MockServiceMockRecorder) ListDevices added in v0.10.0 

func (mr *MockServiceMockRecorder) ListDevices(ctx, orgId, params, annotationSelector any) *gomock.Call

ListDevices indicates an expected call of ListDevices.

func (*MockServiceMockRecorder) ListDevicesByServiceCondition added in v0.10.0 

func (mr *MockServiceMockRecorder) ListDevicesByServiceCondition(ctx, orgId, conditionType, conditionStatus, listParams any) *gomock.Call

ListDevicesByServiceCondition indicates an expected call of ListDevicesByServiceCondition.

func (*MockServiceMockRecorder) ListDisconnectedDevices added in v1.0.0 

func (mr *MockServiceMockRecorder) ListDisconnectedDevices(ctx, orgId, params, cutoffTime any) *gomock.Call

ListDisconnectedDevices indicates an expected call of ListDisconnectedDevices.

func (*MockServiceMockRecorder) ListDisruptionBudgetFleets added in v0.10.0 

func (mr *MockServiceMockRecorder) ListDisruptionBudgetFleets(ctx, orgId any) *gomock.Call

ListDisruptionBudgetFleets indicates an expected call of ListDisruptionBudgetFleets.

func (*MockServiceMockRecorder) ListEnrollmentRequests added in v0.10.0 

func (mr *MockServiceMockRecorder) ListEnrollmentRequests(ctx, orgId, params any) *gomock.Call

ListEnrollmentRequests indicates an expected call of ListEnrollmentRequests.

func (*MockServiceMockRecorder) ListEvents added in v0.10.0 

func (mr *MockServiceMockRecorder) ListEvents(ctx, orgId, params any) *gomock.Call

ListEvents indicates an expected call of ListEvents.

func (*MockServiceMockRecorder) ListFleetRolloutDeviceSelection added in v0.10.0 

func (mr *MockServiceMockRecorder) ListFleetRolloutDeviceSelection(ctx, orgId any) *gomock.Call

ListFleetRolloutDeviceSelection indicates an expected call of ListFleetRolloutDeviceSelection.

func (*MockServiceMockRecorder) ListFleets added in v0.10.0 

func (mr *MockServiceMockRecorder) ListFleets(ctx, orgId, params any) *gomock.Call

ListFleets indicates an expected call of ListFleets.

func (*MockServiceMockRecorder) ListLabels added in v0.10.0 

func (mr *MockServiceMockRecorder) ListLabels(ctx, orgId, params any) *gomock.Call

ListLabels indicates an expected call of ListLabels.

func (*MockServiceMockRecorder) ListOrganizations added in v0.10.0 

func (mr *MockServiceMockRecorder) ListOrganizations(ctx, params any) *gomock.Call

ListOrganizations indicates an expected call of ListOrganizations.

func (*MockServiceMockRecorder) ListRepositories added in v0.10.0 

func (mr *MockServiceMockRecorder) ListRepositories(ctx, orgId, params any) *gomock.Call

ListRepositories indicates an expected call of ListRepositories.

func (*MockServiceMockRecorder) ListResourceSyncs added in v0.10.0 

func (mr *MockServiceMockRecorder) ListResourceSyncs(ctx, orgId, params any) *gomock.Call

ListResourceSyncs indicates an expected call of ListResourceSyncs.

func (*MockServiceMockRecorder) ListTemplateVersions added in v0.10.0 

func (mr *MockServiceMockRecorder) ListTemplateVersions(ctx, orgId, fleet, params any) *gomock.Call

ListTemplateVersions indicates an expected call of ListTemplateVersions.

func (*MockServiceMockRecorder) MarkDevicesRolloutSelection added in v0.10.0 

func (mr *MockServiceMockRecorder) MarkDevicesRolloutSelection(ctx, orgId, params, annotationSelector, limit any) *gomock.Call

MarkDevicesRolloutSelection indicates an expected call of MarkDevicesRolloutSelection.

func (*MockServiceMockRecorder) OverwriteDeviceRepositoryRefs added in v0.10.0 

func (mr *MockServiceMockRecorder) OverwriteDeviceRepositoryRefs(ctx, orgId, name any, repositoryNames ...any) *gomock.Call

OverwriteDeviceRepositoryRefs indicates an expected call of OverwriteDeviceRepositoryRefs.

func (*MockServiceMockRecorder) OverwriteFleetRepositoryRefs added in v0.10.0 

func (mr *MockServiceMockRecorder) OverwriteFleetRepositoryRefs(ctx, orgId, name any, repositoryNames ...any) *gomock.Call

OverwriteFleetRepositoryRefs indicates an expected call of OverwriteFleetRepositoryRefs.

func (*MockServiceMockRecorder) PatchAuthProvider added in v1.0.0 

func (mr *MockServiceMockRecorder) PatchAuthProvider(ctx, orgId, name, patch any) *gomock.Call

PatchAuthProvider indicates an expected call of PatchAuthProvider.

func (*MockServiceMockRecorder) PatchCertificateSigningRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) PatchCertificateSigningRequest(ctx, orgId, name, patch any) *gomock.Call

PatchCertificateSigningRequest indicates an expected call of PatchCertificateSigningRequest.

func (*MockServiceMockRecorder) PatchDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) PatchDevice(ctx, orgId, name, patch any) *gomock.Call

PatchDevice indicates an expected call of PatchDevice.

func (*MockServiceMockRecorder) PatchDeviceStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) PatchDeviceStatus(ctx, orgId, name, patch any) *gomock.Call

PatchDeviceStatus indicates an expected call of PatchDeviceStatus.

func (*MockServiceMockRecorder) PatchEnrollmentRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) PatchEnrollmentRequest(ctx, orgId, name, patch any) *gomock.Call

PatchEnrollmentRequest indicates an expected call of PatchEnrollmentRequest.

func (*MockServiceMockRecorder) PatchFleet added in v0.10.0 

func (mr *MockServiceMockRecorder) PatchFleet(ctx, orgId, name, patch any) *gomock.Call

PatchFleet indicates an expected call of PatchFleet.

func (*MockServiceMockRecorder) PatchRepository added in v0.10.0 

func (mr *MockServiceMockRecorder) PatchRepository(ctx, orgId, name, patch any) *gomock.Call

PatchRepository indicates an expected call of PatchRepository.

func (*MockServiceMockRecorder) PatchResourceSync added in v0.10.0 

func (mr *MockServiceMockRecorder) PatchResourceSync(ctx, orgId, name, patch any) *gomock.Call

PatchResourceSync indicates an expected call of PatchResourceSync.

func (*MockServiceMockRecorder) ReplaceAuthProvider added in v1.0.0 

func (mr *MockServiceMockRecorder) ReplaceAuthProvider(ctx, orgId, name, authProvider any) *gomock.Call

ReplaceAuthProvider indicates an expected call of ReplaceAuthProvider.

func (*MockServiceMockRecorder) ReplaceCertificateSigningRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceCertificateSigningRequest(ctx, orgId, name, csr any) *gomock.Call

ReplaceCertificateSigningRequest indicates an expected call of ReplaceCertificateSigningRequest.

func (*MockServiceMockRecorder) ReplaceDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceDevice(ctx, orgId, name, device, fieldsToUnset any) *gomock.Call

ReplaceDevice indicates an expected call of ReplaceDevice.

func (*MockServiceMockRecorder) ReplaceDeviceStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceDeviceStatus(ctx, orgId, name, device any) *gomock.Call

ReplaceDeviceStatus indicates an expected call of ReplaceDeviceStatus.

func (*MockServiceMockRecorder) ReplaceEnrollmentRequest added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceEnrollmentRequest(ctx, orgId, name, er any) *gomock.Call

ReplaceEnrollmentRequest indicates an expected call of ReplaceEnrollmentRequest.

func (*MockServiceMockRecorder) ReplaceEnrollmentRequestStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceEnrollmentRequestStatus(ctx, orgId, name, er any) *gomock.Call

ReplaceEnrollmentRequestStatus indicates an expected call of ReplaceEnrollmentRequestStatus.

func (*MockServiceMockRecorder) ReplaceFleet added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceFleet(ctx, orgId, name, fleet any) *gomock.Call

ReplaceFleet indicates an expected call of ReplaceFleet.

func (*MockServiceMockRecorder) ReplaceFleetStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceFleetStatus(ctx, orgId, name, fleet any) *gomock.Call

ReplaceFleetStatus indicates an expected call of ReplaceFleetStatus.

func (*MockServiceMockRecorder) ReplaceRepository added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceRepository(ctx, orgId, name, repo any) *gomock.Call

ReplaceRepository indicates an expected call of ReplaceRepository.

func (*MockServiceMockRecorder) ReplaceRepositoryStatusByError added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceRepositoryStatusByError(ctx, orgId, name, repository, err any) *gomock.Call

ReplaceRepositoryStatusByError indicates an expected call of ReplaceRepositoryStatusByError.

func (*MockServiceMockRecorder) ReplaceResourceSync added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceResourceSync(ctx, orgId, name, rs any) *gomock.Call

ReplaceResourceSync indicates an expected call of ReplaceResourceSync.

func (*MockServiceMockRecorder) ReplaceResourceSyncStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) ReplaceResourceSyncStatus(ctx, orgId, name, resourceSync any) *gomock.Call

ReplaceResourceSyncStatus indicates an expected call of ReplaceResourceSyncStatus.

func (*MockServiceMockRecorder) ResumeDevices added in v0.10.0 

func (mr *MockServiceMockRecorder) ResumeDevices(ctx, orgId, request any) *gomock.Call

ResumeDevices indicates an expected call of ResumeDevices.

func (*MockServiceMockRecorder) SetCheckpoint added in v0.10.0 

func (mr *MockServiceMockRecorder) SetCheckpoint(ctx, consumer, key, value any) *gomock.Call

SetCheckpoint indicates an expected call of SetCheckpoint.

func (*MockServiceMockRecorder) SetDeviceServiceConditions added in v0.10.0 

func (mr *MockServiceMockRecorder) SetDeviceServiceConditions(ctx, orgId, name, conditions any) *gomock.Call

SetDeviceServiceConditions indicates an expected call of SetDeviceServiceConditions.

func (*MockServiceMockRecorder) SetOutOfDate added in v0.10.0 

func (mr *MockServiceMockRecorder) SetOutOfDate(ctx, orgId, owner any) *gomock.Call

SetOutOfDate indicates an expected call of SetOutOfDate.

func (*MockServiceMockRecorder) UnmarkDevicesRolloutSelection added in v0.10.0 

func (mr *MockServiceMockRecorder) UnmarkDevicesRolloutSelection(ctx, orgId, fleetName any) *gomock.Call

UnmarkDevicesRolloutSelection indicates an expected call of UnmarkDevicesRolloutSelection.

func (*MockServiceMockRecorder) UpdateCertificateSigningRequestApproval added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateCertificateSigningRequestApproval(ctx, orgId, name, csr any) *gomock.Call

UpdateCertificateSigningRequestApproval indicates an expected call of UpdateCertificateSigningRequestApproval.

func (*MockServiceMockRecorder) UpdateDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateDevice(ctx, orgId, name, device, fieldsToUnset any) *gomock.Call

UpdateDevice indicates an expected call of UpdateDevice.

func (*MockServiceMockRecorder) UpdateDeviceAnnotations added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateDeviceAnnotations(ctx, orgId, name, annotations, deleteKeys any) *gomock.Call

UpdateDeviceAnnotations indicates an expected call of UpdateDeviceAnnotations.

func (*MockServiceMockRecorder) UpdateFleetAnnotations added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateFleetAnnotations(ctx, orgId, name, annotations, deleteKeys any) *gomock.Call

UpdateFleetAnnotations indicates an expected call of UpdateFleetAnnotations.

func (*MockServiceMockRecorder) UpdateFleetConditions added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateFleetConditions(ctx, orgId, name, conditions any) *gomock.Call

UpdateFleetConditions indicates an expected call of UpdateFleetConditions.

func (*MockServiceMockRecorder) UpdateRenderedDevice added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateRenderedDevice(ctx, orgId, name, renderedConfig, renderedApplications, specHash any) *gomock.Call

UpdateRenderedDevice indicates an expected call of UpdateRenderedDevice.

func (*MockServiceMockRecorder) UpdateServerSideDeviceStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateServerSideDeviceStatus(ctx, orgId, name any) *gomock.Call

UpdateServerSideDeviceStatus indicates an expected call of UpdateServerSideDeviceStatus.

func (*MockServiceMockRecorder) UpdateServiceSideDeviceStatus added in v0.10.0 

func (mr *MockServiceMockRecorder) UpdateServiceSideDeviceStatus(ctx, orgId, device any) *gomock.Call

UpdateServiceSideDeviceStatus indicates an expected call of UpdateServiceSideDeviceStatus.

type ProviderConfig added in v1.0.0 

type ProviderConfig struct {
	Issuer        string
	TokenEndpoint string
	ClientId      string
	UseBasicAuth  bool // If true, send client_id/client_secret as Basic Auth header instead of form data
}

ProviderConfig holds the configuration needed to proxy requests to an OAuth2 provider

type ProxyResult added in v1.0.0 

type ProxyResult struct {
	TokenResponse *api.TokenResponse
	StatusCode    int
}

ProxyResult holds the result of proxying a token request, including the upstream HTTP status

type Service added in v0.8.1 

type Service interface {
	// CertificateSigningRequest
	ListCertificateSigningRequests(ctx context.Context, orgId uuid.UUID, params api.ListCertificateSigningRequestsParams) (*api.CertificateSigningRequestList, api.Status)
	CreateCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
	DeleteCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string) api.Status
	GetCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string) (*api.CertificateSigningRequest, api.Status)
	PatchCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.CertificateSigningRequest, api.Status)
	ReplaceCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)
	UpdateCertificateSigningRequestApproval(ctx context.Context, orgId uuid.UUID, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)

	// Device
	CreateDevice(ctx context.Context, orgId uuid.UUID, device api.Device) (*api.Device, api.Status)
	ListDevices(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*api.DeviceList, api.Status)
	ListDevicesByServiceCondition(ctx context.Context, orgId uuid.UUID, conditionType string, conditionStatus string, listParams store.ListParams) (*api.DeviceList, api.Status)
	UpdateDevice(ctx context.Context, orgId uuid.UUID, name string, device api.Device, fieldsToUnset []string) (*api.Device, error)
	GetDevice(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, api.Status)
	ReplaceDevice(ctx context.Context, orgId uuid.UUID, name string, device api.Device, fieldsToUnset []string) (*api.Device, api.Status)
	DeleteDevice(ctx context.Context, orgId uuid.UUID, name string) api.Status
	GetDeviceStatus(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, api.Status)
	GetDeviceLastSeen(ctx context.Context, orgId uuid.UUID, name string) (*api.DeviceLastSeen, api.Status)
	ReplaceDeviceStatus(ctx context.Context, orgId uuid.UUID, name string, device api.Device) (*api.Device, api.Status)
	PatchDeviceStatus(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Device, api.Status)
	GetRenderedDevice(ctx context.Context, orgId uuid.UUID, name string, params api.GetRenderedDeviceParams) (*api.Device, api.Status)
	PatchDevice(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Device, api.Status)
	DecommissionDevice(ctx context.Context, orgId uuid.UUID, name string, decom api.DeviceDecommission) (*api.Device, api.Status)

	ResumeDevices(ctx context.Context, orgId uuid.UUID, request api.DeviceResumeRequest) (api.DeviceResumeResponse, api.Status)
	UpdateDeviceAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) api.Status
	UpdateRenderedDevice(ctx context.Context, orgId uuid.UUID, name, renderedConfig, renderedApplications, specHash string) api.Status
	SetDeviceServiceConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) api.Status
	OverwriteDeviceRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) api.Status
	GetDeviceRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, api.Status)
	CountDevices(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (int64, api.Status)
	UnmarkDevicesRolloutSelection(ctx context.Context, orgId uuid.UUID, fleetName string) api.Status
	MarkDevicesRolloutSelection(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector, limit *int) api.Status
	GetDeviceCompletionCounts(ctx context.Context, orgId uuid.UUID, owner string, templateVersion string, updateTimeout *time.Duration) ([]api.DeviceCompletionCount, api.Status)
	CountDevicesByLabels(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector, groupBy []string) ([]map[string]any, api.Status)
	GetDevicesSummary(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, annotationSelector *selector.AnnotationSelector) (*api.DevicesSummary, api.Status)
	UpdateServiceSideDeviceStatus(ctx context.Context, orgId uuid.UUID, device api.Device) bool
	SetOutOfDate(ctx context.Context, orgId uuid.UUID, owner string) error
	UpdateServerSideDeviceStatus(ctx context.Context, orgId uuid.UUID, name string) error
	ListDisconnectedDevices(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, cutoffTime time.Time) (*api.DeviceList, api.Status)

	// EnrollmentConfig
	GetEnrollmentConfig(ctx context.Context, orgId uuid.UUID, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status)

	//EnrollmentRequest
	CreateEnrollmentRequest(ctx context.Context, orgId uuid.UUID, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
	ListEnrollmentRequests(ctx context.Context, orgId uuid.UUID, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status)
	GetEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string) (*api.EnrollmentRequest, api.Status)
	ReplaceEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)
	PatchEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.EnrollmentRequest, api.Status)
	DeleteEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string) api.Status
	GetEnrollmentRequestStatus(ctx context.Context, orgId uuid.UUID, name string) (*api.EnrollmentRequest, api.Status)
	ApproveEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status)
	ReplaceEnrollmentRequestStatus(ctx context.Context, orgId uuid.UUID, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)

	// Fleet
	CreateFleet(ctx context.Context, orgId uuid.UUID, fleet api.Fleet) (*api.Fleet, api.Status)
	ListFleets(ctx context.Context, orgId uuid.UUID, params api.ListFleetsParams) (*api.FleetList, api.Status)
	GetFleet(ctx context.Context, orgId uuid.UUID, name string, params api.GetFleetParams) (*api.Fleet, api.Status)
	ReplaceFleet(ctx context.Context, orgId uuid.UUID, name string, fleet api.Fleet) (*api.Fleet, api.Status)
	DeleteFleet(ctx context.Context, orgId uuid.UUID, name string) api.Status
	GetFleetStatus(ctx context.Context, orgId uuid.UUID, name string) (*api.Fleet, api.Status)
	ReplaceFleetStatus(ctx context.Context, orgId uuid.UUID, name string, fleet api.Fleet) (*api.Fleet, api.Status)
	PatchFleet(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Fleet, api.Status)
	ListFleetRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (*api.FleetList, api.Status)
	ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (*api.FleetList, api.Status)
	UpdateFleetConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) api.Status
	UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) api.Status
	OverwriteFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) api.Status
	GetFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, api.Status)

	// Labels
	ListLabels(ctx context.Context, orgId uuid.UUID, params api.ListLabelsParams) (*api.LabelList, api.Status)

	// Repository
	CreateRepository(ctx context.Context, orgId uuid.UUID, repo api.Repository) (*api.Repository, api.Status)
	ListRepositories(ctx context.Context, orgId uuid.UUID, params api.ListRepositoriesParams) (*api.RepositoryList, api.Status)
	GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*api.Repository, api.Status)
	ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo api.Repository) (*api.Repository, api.Status)
	DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) api.Status
	PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Repository, api.Status)
	ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, repository api.Repository, err error) (*api.Repository, api.Status)
	GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (*api.FleetList, api.Status)
	GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*api.DeviceList, api.Status)

	// AuthProvider
	CreateAuthProvider(ctx context.Context, orgId uuid.UUID, authProvider api.AuthProvider) (*api.AuthProvider, api.Status)
	ListAuthProviders(ctx context.Context, orgId uuid.UUID, params api.ListAuthProvidersParams) (*api.AuthProviderList, api.Status)
	ListAllAuthProviders(ctx context.Context, params api.ListAuthProvidersParams) (*api.AuthProviderList, api.Status)
	GetAuthProvider(ctx context.Context, orgId uuid.UUID, name string) (*api.AuthProvider, api.Status)
	GetAuthProviderByIssuerAndClientId(ctx context.Context, orgId uuid.UUID, issuer string, clientId string) (*api.AuthProvider, api.Status)
	GetAuthProviderByAuthorizationUrl(ctx context.Context, orgId uuid.UUID, authorizationUrl string) (*api.AuthProvider, api.Status)
	ReplaceAuthProvider(ctx context.Context, orgId uuid.UUID, name string, authProvider api.AuthProvider) (*api.AuthProvider, api.Status)
	PatchAuthProvider(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.AuthProvider, api.Status)
	DeleteAuthProvider(ctx context.Context, orgId uuid.UUID, name string) api.Status

	// Auth
	GetAuthConfig(ctx context.Context, authConfig *api.AuthConfig) (*api.AuthConfig, api.Status)

	// ResourceSync
	CreateResourceSync(ctx context.Context, orgId uuid.UUID, rs api.ResourceSync) (*api.ResourceSync, api.Status)
	ListResourceSyncs(ctx context.Context, orgId uuid.UUID, params api.ListResourceSyncsParams) (*api.ResourceSyncList, api.Status)
	GetResourceSync(ctx context.Context, orgId uuid.UUID, name string) (*api.ResourceSync, api.Status)
	ReplaceResourceSync(ctx context.Context, orgId uuid.UUID, name string, rs api.ResourceSync) (*api.ResourceSync, api.Status)
	DeleteResourceSync(ctx context.Context, orgId uuid.UUID, name string) api.Status
	PatchResourceSync(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.ResourceSync, api.Status)
	ReplaceResourceSyncStatus(ctx context.Context, orgId uuid.UUID, name string, resourceSync api.ResourceSync) (*api.ResourceSync, api.Status)

	// TemplateVersion
	CreateTemplateVersion(ctx context.Context, orgId uuid.UUID, tv api.TemplateVersion, immediateRollout bool) (*api.TemplateVersion, api.Status)
	ListTemplateVersions(ctx context.Context, orgId uuid.UUID, fleet string, params api.ListTemplateVersionsParams) (*api.TemplateVersionList, api.Status)
	GetTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet string, name string) (*api.TemplateVersion, api.Status)
	DeleteTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet string, name string) api.Status
	GetLatestTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet string) (*api.TemplateVersion, api.Status)

	// Event
	CreateEvent(ctx context.Context, orgId uuid.UUID, event *api.Event)
	ListEvents(ctx context.Context, orgId uuid.UUID, 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, params api.ListOrganizationsParams) (*api.OrganizationList, api.Status)
}

func WrapWithTracing added in v0.8.1 

func WrapWithTracing(svc Service) Service

type ServiceHandler 

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

func NewServiceHandler 

func NewServiceHandler(store store.Store, workerClient worker_client.WorkerClient, 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, orgId uuid.UUID, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status)

func (*ServiceHandler) CountDevices added in v0.6.0 

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

func (*ServiceHandler) CountDevicesByLabels added in v0.6.0 

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

func (*ServiceHandler) CreateAuthProvider added in v1.0.0 

func (h *ServiceHandler) CreateAuthProvider(ctx context.Context, orgId uuid.UUID, authProvider api.AuthProvider) (*api.AuthProvider, api.Status)

func (*ServiceHandler) CreateCertificateSigningRequest 

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

func (*ServiceHandler) CreateDevice 

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

func (*ServiceHandler) CreateEnrollmentRequest 

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

func (*ServiceHandler) CreateEvent added in v0.7.0 

func (h *ServiceHandler) CreateEvent(ctx context.Context, orgId uuid.UUID, event *api.Event)

func (*ServiceHandler) CreateFleet 

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

func (*ServiceHandler) CreateRepository 

func (h *ServiceHandler) CreateRepository(ctx context.Context, orgId uuid.UUID, repository api.Repository) (*api.Repository, api.Status)

func (*ServiceHandler) CreateResourceSync 

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

func (*ServiceHandler) CreateTemplateVersion added in v0.6.0 

func (h *ServiceHandler) CreateTemplateVersion(ctx context.Context, orgId uuid.UUID, templateVersion api.TemplateVersion, immediateRollout bool) (*api.TemplateVersion, api.Status)

func (*ServiceHandler) DecommissionDevice added in v0.4.0 

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

func (*ServiceHandler) DeleteAuthProvider added in v1.0.0 

func (h *ServiceHandler) DeleteAuthProvider(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*ServiceHandler) DeleteCertificateSigningRequest 

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

func (*ServiceHandler) DeleteDevice 

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

func (*ServiceHandler) DeleteEnrollmentRequest 

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

func (*ServiceHandler) DeleteEventsOlderThan added in v0.7.0 

func (h *ServiceHandler) DeleteEventsOlderThan(ctx context.Context, cutoffTime time.Time) (int64, api.Status)

func (*ServiceHandler) DeleteFleet 

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

func (*ServiceHandler) DeleteRepository 

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

func (*ServiceHandler) DeleteResourceSync 

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

func (*ServiceHandler) DeleteTemplateVersion 

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

func (*ServiceHandler) GetAuthConfig added in v1.0.0 

func (h *ServiceHandler) GetAuthConfig(ctx context.Context, authConfig *api.AuthConfig) (*api.AuthConfig, api.Status)

GetAuthConfig returns the authentication configuration The auth config from the middleware already includes all static and dynamic providers

func (*ServiceHandler) GetAuthProvider added in v1.0.0 

func (h *ServiceHandler) GetAuthProvider(ctx context.Context, orgId uuid.UUID, name string) (*api.AuthProvider, api.Status)

func (*ServiceHandler) GetAuthProviderByAuthorizationUrl added in v1.0.0 

func (h *ServiceHandler) GetAuthProviderByAuthorizationUrl(ctx context.Context, orgId uuid.UUID, authorizationUrl string) (*api.AuthProvider, api.Status)

func (*ServiceHandler) GetAuthProviderByIssuerAndClientId added in v1.0.0 

func (h *ServiceHandler) GetAuthProviderByIssuerAndClientId(ctx context.Context, orgId uuid.UUID, issuer string, clientId string) (*api.AuthProvider, api.Status)

func (*ServiceHandler) GetCertificateSigningRequest added in v0.6.0 

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

func (*ServiceHandler) GetCheckpoint added in v0.9.0 

func (h *ServiceHandler) GetCheckpoint(ctx context.Context, consumer string, key string) ([]byte, api.Status)

func (*ServiceHandler) GetDatabaseTime added in v0.9.0 

func (h *ServiceHandler) GetDatabaseTime(ctx context.Context) (time.Time, api.Status)

func (*ServiceHandler) GetDevice added in v0.6.0 

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

func (*ServiceHandler) GetDeviceCompletionCounts added in v0.6.0 

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

func (*ServiceHandler) GetDeviceLastSeen added in v0.10.0 

func (h *ServiceHandler) GetDeviceLastSeen(ctx context.Context, orgId uuid.UUID, name string) (*api.DeviceLastSeen, api.Status)

func (*ServiceHandler) GetDeviceRepositoryRefs added in v0.6.0 

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

func (*ServiceHandler) GetDeviceStatus added in v0.6.0 

func (h *ServiceHandler) GetDeviceStatus(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, 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, orgId uuid.UUID, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status)

func (*ServiceHandler) GetEnrollmentRequest added in v0.6.0 

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

func (*ServiceHandler) GetEnrollmentRequestStatus added in v0.6.0 

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

func (*ServiceHandler) GetFleet added in v0.6.0 

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

func (*ServiceHandler) GetFleetRepositoryRefs added in v0.6.0 

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

func (*ServiceHandler) GetFleetStatus added in v0.6.0 

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

func (*ServiceHandler) GetLatestTemplateVersion added in v0.6.0 

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

func (*ServiceHandler) GetRenderedDevice added in v0.5.0 

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

func (*ServiceHandler) GetRepository added in v0.6.0 

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

func (*ServiceHandler) GetRepositoryDeviceReferences added in v0.6.0 

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

func (*ServiceHandler) GetRepositoryFleetReferences added in v0.6.0 

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

func (*ServiceHandler) GetResourceSync added in v0.6.0 

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

func (*ServiceHandler) GetTemplateVersion added in v0.6.0 

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

func (*ServiceHandler) ListAllAuthProviders added in v1.0.0 

func (h *ServiceHandler) ListAllAuthProviders(ctx context.Context, params api.ListAuthProvidersParams) (*api.AuthProviderList, api.Status)

func (*ServiceHandler) ListAuthProviders added in v1.0.0 

func (h *ServiceHandler) ListAuthProviders(ctx context.Context, orgId uuid.UUID, params api.ListAuthProvidersParams) (*api.AuthProviderList, api.Status)

func (*ServiceHandler) ListCertificateSigningRequests 

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

func (*ServiceHandler) ListDevices 

func (h *ServiceHandler) ListDevices(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, conditionType string, conditionStatus string, listParams store.ListParams) (*api.DeviceList, api.Status)

func (*ServiceHandler) ListDisconnectedDevices added in v1.0.0 

func (h *ServiceHandler) ListDisconnectedDevices(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, cutoffTime time.Time) (*api.DeviceList, api.Status)

func (*ServiceHandler) ListDisruptionBudgetFleets added in v0.6.0 

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

func (*ServiceHandler) ListEnrollmentRequests 

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

func (*ServiceHandler) ListEvents added in v0.7.0 

func (h *ServiceHandler) ListEvents(ctx context.Context, orgId uuid.UUID, params api.ListEventsParams) (*api.EventList, api.Status)

func (*ServiceHandler) ListFleetRolloutDeviceSelection added in v0.6.0 

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

func (*ServiceHandler) ListFleets 

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

func (*ServiceHandler) ListLabels added in v0.6.0 

func (h *ServiceHandler) ListLabels(ctx context.Context, orgId uuid.UUID, 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, params api.ListOrganizationsParams) (*api.OrganizationList, api.Status)

func (*ServiceHandler) ListRepositories 

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

func (*ServiceHandler) ListResourceSyncs added in v0.6.0 

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

func (*ServiceHandler) ListTemplateVersions 

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

func (*ServiceHandler) MarkDevicesRolloutSelection added in v0.6.0 

func (h *ServiceHandler) MarkDevicesRolloutSelection(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, name string, repositoryNames ...string) api.Status

func (*ServiceHandler) OverwriteFleetRepositoryRefs added in v0.6.0 

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

func (*ServiceHandler) PatchAuthProvider added in v1.0.0 

func (h *ServiceHandler) PatchAuthProvider(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.AuthProvider, api.Status)

func (*ServiceHandler) PatchCertificateSigningRequest 

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

func (*ServiceHandler) PatchDevice 

func (h *ServiceHandler) PatchDevice(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Device, api.Status)

func (*ServiceHandler) PatchEnrollmentRequest added in v0.4.0 

func (h *ServiceHandler) PatchEnrollmentRequest(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, 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, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Repository, api.Status)

func (*ServiceHandler) PatchResourceSync 

func (h *ServiceHandler) PatchResourceSync(ctx context.Context, orgId uuid.UUID, 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) PrepareDevicesAfterRestore added in v0.10.0 

func (h *ServiceHandler) PrepareDevicesAfterRestore(ctx context.Context) error

PrepareDevicesAfterRestore performs post-restoration preparation tasks for devices

func (*ServiceHandler) ReplaceAuthProvider added in v1.0.0 

func (h *ServiceHandler) ReplaceAuthProvider(ctx context.Context, orgId uuid.UUID, name string, authProvider api.AuthProvider) (*api.AuthProvider, api.Status)

func (*ServiceHandler) ReplaceCertificateSigningRequest 

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

func (*ServiceHandler) ReplaceDevice 

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

func (*ServiceHandler) ReplaceDeviceStatus 

func (h *ServiceHandler) ReplaceDeviceStatus(ctx context.Context, orgId uuid.UUID, name string, incomingDevice api.Device) (*api.Device, api.Status)

func (*ServiceHandler) ReplaceEnrollmentRequest 

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

func (*ServiceHandler) ReplaceEnrollmentRequestStatus 

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

func (*ServiceHandler) ReplaceFleet 

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

func (*ServiceHandler) ReplaceFleetStatus 

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

func (*ServiceHandler) ReplaceRepository 

func (h *ServiceHandler) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repository api.Repository) (*api.Repository, api.Status)

func (*ServiceHandler) ReplaceRepositoryStatusByError added in v0.9.0 

func (h *ServiceHandler) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, name string, repository api.Repository, err error) (*api.Repository, api.Status)

func (*ServiceHandler) ReplaceResourceSync 

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

func (*ServiceHandler) ReplaceResourceSyncStatus added in v0.6.0 

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

func (*ServiceHandler) ResumeDevices added in v0.10.0 

func (h *ServiceHandler) ResumeDevices(ctx context.Context, orgId uuid.UUID, request api.DeviceResumeRequest) (api.DeviceResumeResponse, api.Status)

func (*ServiceHandler) SetCheckpoint added in v0.9.0 

func (h *ServiceHandler) SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) api.Status

func (*ServiceHandler) SetDeviceServiceConditions added in v0.6.0 

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

func (*ServiceHandler) SetOutOfDate added in v0.10.0 

func (h *ServiceHandler) SetOutOfDate(ctx context.Context, orgId uuid.UUID, owner string) error

func (*ServiceHandler) UnmarkDevicesRolloutSelection added in v0.6.0 

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

func (*ServiceHandler) UpdateCertificateSigningRequestApproval added in v0.4.0 

func (h *ServiceHandler) UpdateCertificateSigningRequestApproval(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, 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, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) api.Status

func (*ServiceHandler) UpdateFleetAnnotations added in v0.6.0 

func (h *ServiceHandler) UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, name string, conditions []api.Condition) api.Status

func (*ServiceHandler) UpdateRenderedDevice added in v0.6.0 

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

func (*ServiceHandler) UpdateServerSideDeviceStatus added in v0.10.0 

func (h *ServiceHandler) UpdateServerSideDeviceStatus(ctx context.Context, orgId uuid.UUID, name string) error

func (*ServiceHandler) UpdateServiceSideDeviceStatus added in v0.6.0 

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

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, orgId uuid.UUID, name string, approval api.EnrollmentRequestApproval) (*api.EnrollmentRequestApprovalStatus, api.Status)

func (*TracedService) CountDevices added in v0.8.1 

func (t *TracedService) CountDevices(ctx context.Context, orgId uuid.UUID, p api.ListDevicesParams, sel *selector.AnnotationSelector) (int64, api.Status)

func (*TracedService) CountDevicesByLabels added in v0.8.1 

func (t *TracedService) CountDevicesByLabels(ctx context.Context, orgId uuid.UUID, p api.ListDevicesParams, sel *selector.AnnotationSelector, groupBy []string) ([]map[string]any, api.Status)

func (*TracedService) CreateAuthProvider added in v1.0.0 

func (t *TracedService) CreateAuthProvider(ctx context.Context, orgId uuid.UUID, authProvider api.AuthProvider) (*api.AuthProvider, api.Status)

--- AuthProvider ---

func (*TracedService) CreateCertificateSigningRequest added in v0.8.1 

func (t *TracedService) CreateCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)

func (*TracedService) CreateDevice added in v0.8.1 

func (t *TracedService) CreateDevice(ctx context.Context, orgId uuid.UUID, d api.Device) (*api.Device, api.Status)

--- Device ---

func (*TracedService) CreateEnrollmentRequest added in v0.8.1 

func (t *TracedService) CreateEnrollmentRequest(ctx context.Context, orgId uuid.UUID, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)

--- EnrollmentRequest ---

func (*TracedService) CreateEvent added in v0.8.1 

func (t *TracedService) CreateEvent(ctx context.Context, orgId uuid.UUID, event *api.Event)

--- Event ---

func (*TracedService) CreateFleet added in v0.8.1 

func (t *TracedService) CreateFleet(ctx context.Context, orgId uuid.UUID, fleet api.Fleet) (*api.Fleet, api.Status)

--- Fleet ---

func (*TracedService) CreateRepository added in v0.8.1 

func (t *TracedService) CreateRepository(ctx context.Context, orgId uuid.UUID, repo api.Repository) (*api.Repository, api.Status)

--- Repository ---

func (*TracedService) CreateResourceSync added in v0.8.1 

func (t *TracedService) CreateResourceSync(ctx context.Context, orgId uuid.UUID, rs api.ResourceSync) (*api.ResourceSync, api.Status)

--- ResourceSync ---

func (*TracedService) CreateTemplateVersion added in v0.8.1 

func (t *TracedService) CreateTemplateVersion(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, name string, decom api.DeviceDecommission) (*api.Device, api.Status)

func (*TracedService) DeleteAuthProvider added in v1.0.0 

func (t *TracedService) DeleteAuthProvider(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*TracedService) DeleteCertificateSigningRequest added in v0.8.1 

func (t *TracedService) DeleteCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*TracedService) DeleteDevice added in v0.8.1 

func (t *TracedService) DeleteDevice(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*TracedService) DeleteEnrollmentRequest added in v0.8.1 

func (t *TracedService) DeleteEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*TracedService) DeleteEventsOlderThan added in v0.8.1 

func (t *TracedService) DeleteEventsOlderThan(ctx context.Context, cutoffTime time.Time) (int64, api.Status)

func (*TracedService) DeleteFleet added in v0.8.1 

func (t *TracedService) DeleteFleet(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*TracedService) DeleteRepository added in v0.8.1 

func (t *TracedService) DeleteRepository(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*TracedService) DeleteResourceSync added in v0.8.1 

func (t *TracedService) DeleteResourceSync(ctx context.Context, orgId uuid.UUID, name string) api.Status

func (*TracedService) DeleteTemplateVersion added in v0.8.1 

func (t *TracedService) DeleteTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet string, name string) api.Status

func (*TracedService) GetAuthConfig added in v1.0.0 

func (t *TracedService) GetAuthConfig(ctx context.Context, authConfig *api.AuthConfig) (*api.AuthConfig, api.Status)

--- Auth ---

func (*TracedService) GetAuthProvider added in v1.0.0 

func (t *TracedService) GetAuthProvider(ctx context.Context, orgId uuid.UUID, name string) (*api.AuthProvider, api.Status)

func (*TracedService) GetAuthProviderByAuthorizationUrl added in v1.0.0 

func (t *TracedService) GetAuthProviderByAuthorizationUrl(ctx context.Context, orgId uuid.UUID, authorizationUrl string) (*api.AuthProvider, api.Status)

func (*TracedService) GetAuthProviderByIssuerAndClientId added in v1.0.0 

func (t *TracedService) GetAuthProviderByIssuerAndClientId(ctx context.Context, orgId uuid.UUID, issuer string, clientId string) (*api.AuthProvider, api.Status)

func (*TracedService) GetCertificateSigningRequest added in v0.8.1 

func (t *TracedService) GetCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, 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 (t *TracedService) GetDatabaseTime(ctx context.Context) (time.Time, api.Status)

func (*TracedService) GetDevice added in v0.8.1 

func (t *TracedService) GetDevice(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, api.Status)

func (*TracedService) GetDeviceCompletionCounts added in v0.8.1 

func (t *TracedService) GetDeviceCompletionCounts(ctx context.Context, orgId uuid.UUID, owner, version string, timeout *time.Duration) ([]api.DeviceCompletionCount, api.Status)

func (*TracedService) GetDeviceLastSeen added in v0.10.0 

func (t *TracedService) GetDeviceLastSeen(ctx context.Context, orgId uuid.UUID, name string) (*api.DeviceLastSeen, api.Status)

func (*TracedService) GetDeviceRepositoryRefs added in v0.8.1 

func (t *TracedService) GetDeviceRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, api.Status)

func (*TracedService) GetDeviceStatus added in v0.8.1 

func (t *TracedService) GetDeviceStatus(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, api.Status)

func (*TracedService) GetDevicesSummary added in v0.8.1 

func (t *TracedService) GetDevicesSummary(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, params api.GetEnrollmentConfigParams) (*api.EnrollmentConfig, api.Status)

--- EnrollmentConfig ---

func (*TracedService) GetEnrollmentRequest added in v0.8.1 

func (t *TracedService) GetEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string) (*api.EnrollmentRequest, api.Status)

func (*TracedService) GetEnrollmentRequestStatus added in v0.8.1 

func (t *TracedService) GetEnrollmentRequestStatus(ctx context.Context, orgId uuid.UUID, name string) (*api.EnrollmentRequest, api.Status)

func (*TracedService) GetFleet added in v0.8.1 

func (t *TracedService) GetFleet(ctx context.Context, orgId uuid.UUID, name string, params api.GetFleetParams) (*api.Fleet, api.Status)

func (*TracedService) GetFleetRepositoryRefs added in v0.8.1 

func (t *TracedService) GetFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, api.Status)

func (*TracedService) GetFleetStatus added in v0.8.1 

func (t *TracedService) GetFleetStatus(ctx context.Context, orgId uuid.UUID, name string) (*api.Fleet, api.Status)

func (*TracedService) GetLatestTemplateVersion added in v0.8.1 

func (t *TracedService) GetLatestTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet string) (*api.TemplateVersion, api.Status)

func (*TracedService) GetRenderedDevice added in v0.8.1 

func (t *TracedService) GetRenderedDevice(ctx context.Context, orgId uuid.UUID, name string, p api.GetRenderedDeviceParams) (*api.Device, api.Status)

func (*TracedService) GetRepository added in v0.8.1 

func (t *TracedService) GetRepository(ctx context.Context, orgId uuid.UUID, name string) (*api.Repository, api.Status)

func (*TracedService) GetRepositoryDeviceReferences added in v0.8.1 

func (t *TracedService) GetRepositoryDeviceReferences(ctx context.Context, orgId uuid.UUID, name string) (*api.DeviceList, api.Status)

func (*TracedService) GetRepositoryFleetReferences added in v0.8.1 

func (t *TracedService) GetRepositoryFleetReferences(ctx context.Context, orgId uuid.UUID, name string) (*api.FleetList, api.Status)

func (*TracedService) GetResourceSync added in v0.8.1 

func (t *TracedService) GetResourceSync(ctx context.Context, orgId uuid.UUID, name string) (*api.ResourceSync, api.Status)

func (*TracedService) GetTemplateVersion added in v0.8.1 

func (t *TracedService) GetTemplateVersion(ctx context.Context, orgId uuid.UUID, fleet string, name string) (*api.TemplateVersion, api.Status)

func (*TracedService) ListAllAuthProviders added in v1.0.0 

func (t *TracedService) ListAllAuthProviders(ctx context.Context, params api.ListAuthProvidersParams) (*api.AuthProviderList, api.Status)

func (*TracedService) ListAuthProviders added in v1.0.0 

func (t *TracedService) ListAuthProviders(ctx context.Context, orgId uuid.UUID, params api.ListAuthProvidersParams) (*api.AuthProviderList, api.Status)

func (*TracedService) ListCertificateSigningRequests added in v0.8.1 

func (t *TracedService) ListCertificateSigningRequests(ctx context.Context, orgId uuid.UUID, p api.ListCertificateSigningRequestsParams) (*api.CertificateSigningRequestList, api.Status)

--- CertificateSigningRequest ---

func (*TracedService) ListDevices added in v0.8.1 

func (t *TracedService) ListDevices(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, conditionType string, conditionStatus string, listParams store.ListParams) (*api.DeviceList, api.Status)

func (*TracedService) ListDisconnectedDevices added in v1.0.0 

func (t *TracedService) ListDisconnectedDevices(ctx context.Context, orgId uuid.UUID, params api.ListDevicesParams, cutoffTime time.Time) (*api.DeviceList, api.Status)

func (*TracedService) ListDisruptionBudgetFleets added in v0.8.1 

func (t *TracedService) ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (*api.FleetList, api.Status)

func (*TracedService) ListEnrollmentRequests added in v0.8.1 

func (t *TracedService) ListEnrollmentRequests(ctx context.Context, orgId uuid.UUID, params api.ListEnrollmentRequestsParams) (*api.EnrollmentRequestList, api.Status)

func (*TracedService) ListEvents added in v0.8.1 

func (t *TracedService) ListEvents(ctx context.Context, orgId uuid.UUID, params api.ListEventsParams) (*api.EventList, api.Status)

func (*TracedService) ListFleetRolloutDeviceSelection added in v0.8.1 

func (t *TracedService) ListFleetRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (*api.FleetList, api.Status)

func (*TracedService) ListFleets added in v0.8.1 

func (t *TracedService) ListFleets(ctx context.Context, orgId uuid.UUID, params api.ListFleetsParams) (*api.FleetList, api.Status)

func (*TracedService) ListLabels added in v0.8.1 

func (t *TracedService) ListLabels(ctx context.Context, orgId uuid.UUID, params api.ListLabelsParams) (*api.LabelList, api.Status)

--- Labels ---

func (*TracedService) ListOrganizations added in v0.9.0 

func (t *TracedService) ListOrganizations(ctx context.Context, params api.ListOrganizationsParams) (*api.OrganizationList, api.Status)

--- Organization ---

func (*TracedService) ListRepositories added in v0.8.1 

func (t *TracedService) ListRepositories(ctx context.Context, orgId uuid.UUID, params api.ListRepositoriesParams) (*api.RepositoryList, api.Status)

func (*TracedService) ListResourceSyncs added in v0.8.1 

func (t *TracedService) ListResourceSyncs(ctx context.Context, orgId uuid.UUID, params api.ListResourceSyncsParams) (*api.ResourceSyncList, api.Status)

func (*TracedService) ListTemplateVersions added in v0.8.1 

func (t *TracedService) ListTemplateVersions(ctx context.Context, orgId uuid.UUID, fleet string, params api.ListTemplateVersionsParams) (*api.TemplateVersionList, api.Status)

func (*TracedService) MarkDevicesRolloutSelection added in v0.8.1 

func (t *TracedService) MarkDevicesRolloutSelection(ctx context.Context, orgId uuid.UUID, p api.ListDevicesParams, sel *selector.AnnotationSelector, limit *int) api.Status

func (*TracedService) OverwriteDeviceRepositoryRefs added in v0.8.1 

func (t *TracedService) OverwriteDeviceRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, refs ...string) api.Status

func (*TracedService) OverwriteFleetRepositoryRefs added in v0.8.1 

func (t *TracedService) OverwriteFleetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) api.Status

func (*TracedService) PatchAuthProvider added in v1.0.0 

func (t *TracedService) PatchAuthProvider(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.AuthProvider, api.Status)

func (*TracedService) PatchCertificateSigningRequest added in v0.8.1 

func (t *TracedService) PatchCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.CertificateSigningRequest, api.Status)

func (*TracedService) PatchDevice added in v0.8.1 

func (t *TracedService) PatchDevice(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Device, api.Status)

func (*TracedService) PatchDeviceStatus added in v0.8.1 

func (t *TracedService) PatchDeviceStatus(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Device, api.Status)

func (*TracedService) PatchEnrollmentRequest added in v0.8.1 

func (t *TracedService) PatchEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.EnrollmentRequest, api.Status)

func (*TracedService) PatchFleet added in v0.8.1 

func (t *TracedService) PatchFleet(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Fleet, api.Status)

func (*TracedService) PatchRepository added in v0.8.1 

func (t *TracedService) PatchRepository(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.Repository, api.Status)

func (*TracedService) PatchResourceSync added in v0.8.1 

func (t *TracedService) PatchResourceSync(ctx context.Context, orgId uuid.UUID, name string, patch api.PatchRequest) (*api.ResourceSync, api.Status)

func (*TracedService) ReplaceAuthProvider added in v1.0.0 

func (t *TracedService) ReplaceAuthProvider(ctx context.Context, orgId uuid.UUID, name string, authProvider api.AuthProvider) (*api.AuthProvider, api.Status)

func (*TracedService) ReplaceCertificateSigningRequest added in v0.8.1 

func (t *TracedService) ReplaceCertificateSigningRequest(ctx context.Context, orgId uuid.UUID, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)

func (*TracedService) ReplaceDevice added in v0.8.1 

func (t *TracedService) ReplaceDevice(ctx context.Context, orgId uuid.UUID, name string, device api.Device, unset []string) (*api.Device, api.Status)

func (*TracedService) ReplaceDeviceStatus added in v0.8.1 

func (t *TracedService) ReplaceDeviceStatus(ctx context.Context, orgId uuid.UUID, name string, device api.Device) (*api.Device, api.Status)

func (*TracedService) ReplaceEnrollmentRequest added in v0.8.1 

func (t *TracedService) ReplaceEnrollmentRequest(ctx context.Context, orgId uuid.UUID, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)

func (*TracedService) ReplaceEnrollmentRequestStatus added in v0.8.1 

func (t *TracedService) ReplaceEnrollmentRequestStatus(ctx context.Context, orgId uuid.UUID, name string, er api.EnrollmentRequest) (*api.EnrollmentRequest, api.Status)

func (*TracedService) ReplaceFleet added in v0.8.1 

func (t *TracedService) ReplaceFleet(ctx context.Context, orgId uuid.UUID, name string, fleet api.Fleet) (*api.Fleet, api.Status)

func (*TracedService) ReplaceFleetStatus added in v0.8.1 

func (t *TracedService) ReplaceFleetStatus(ctx context.Context, orgId uuid.UUID, name string, fleet api.Fleet) (*api.Fleet, api.Status)

func (*TracedService) ReplaceRepository added in v0.8.1 

func (t *TracedService) ReplaceRepository(ctx context.Context, orgId uuid.UUID, name string, repo api.Repository) (*api.Repository, api.Status)

func (*TracedService) ReplaceRepositoryStatusByError added in v0.9.0 

func (t *TracedService) ReplaceRepositoryStatusByError(ctx context.Context, orgId uuid.UUID, 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, orgId uuid.UUID, name string, rs api.ResourceSync) (*api.ResourceSync, api.Status)

func (*TracedService) ReplaceResourceSyncStatus added in v0.8.1 

func (t *TracedService) ReplaceResourceSyncStatus(ctx context.Context, orgId uuid.UUID, name string, resourceSync api.ResourceSync) (*api.ResourceSync, api.Status)

func (*TracedService) ResumeDevices added in v0.10.0 

func (t *TracedService) ResumeDevices(ctx context.Context, orgId uuid.UUID, request api.DeviceResumeRequest) (api.DeviceResumeResponse, api.Status)

func (*TracedService) SetCheckpoint added in v0.9.0 

func (t *TracedService) SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) api.Status

func (*TracedService) SetDeviceServiceConditions added in v0.8.1 

func (t *TracedService) SetDeviceServiceConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) api.Status

func (*TracedService) SetOutOfDate added in v0.10.0 

func (t *TracedService) SetOutOfDate(ctx context.Context, orgId uuid.UUID, owner string) error

func (*TracedService) UnmarkDevicesRolloutSelection added in v0.8.1 

func (t *TracedService) UnmarkDevicesRolloutSelection(ctx context.Context, orgId uuid.UUID, fleetName string) api.Status

func (*TracedService) UpdateCertificateSigningRequestApproval added in v0.8.1 

func (t *TracedService) UpdateCertificateSigningRequestApproval(ctx context.Context, orgId uuid.UUID, name string, csr api.CertificateSigningRequest) (*api.CertificateSigningRequest, api.Status)

func (*TracedService) UpdateDevice added in v0.8.1 

func (t *TracedService) UpdateDevice(ctx context.Context, orgId uuid.UUID, name string, device api.Device, fieldsToUnset []string) (*api.Device, error)

func (*TracedService) UpdateDeviceAnnotations added in v0.8.1 

func (t *TracedService) UpdateDeviceAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) api.Status

func (*TracedService) UpdateFleetAnnotations added in v0.8.1 

func (t *TracedService) UpdateFleetAnnotations(ctx context.Context, orgId uuid.UUID, name string, annotations map[string]string, deleteKeys []string) api.Status

func (*TracedService) UpdateFleetConditions added in v0.8.1 

func (t *TracedService) UpdateFleetConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) api.Status

func (*TracedService) UpdateRenderedDevice added in v0.8.1 

func (t *TracedService) UpdateRenderedDevice(ctx context.Context, orgId uuid.UUID, name, renderedConfig, renderedApps, specHash string) api.Status

func (*TracedService) UpdateServerSideDeviceStatus added in v0.10.0 

func (t *TracedService) UpdateServerSideDeviceStatus(ctx context.Context, orgId uuid.UUID, name string) error

func (*TracedService) UpdateServiceSideDeviceStatus added in v0.8.1 

func (t *TracedService) UpdateServiceSideDeviceStatus(ctx context.Context, orgId uuid.UUID, 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.