store

Dec 21, 2025

Changes in this version

+ const ConstraintAuthProviderOAuth2Unique

+ const ConstraintAuthProviderOIDCUnique

+ type AuthProvider interface

+ Count func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ CountByOrg func(ctx context.Context, orgId *uuid.UUID) ([]CountByOrgResult, error)

+ Create func(ctx context.Context, orgId uuid.UUID, authProvider *api.AuthProvider, ...) (*api.AuthProvider, error)

+ CreateOrUpdate func(ctx context.Context, orgId uuid.UUID, authProvider *api.AuthProvider, ...) (*api.AuthProvider, bool, error)

+ CreateWithFromAPI func(ctx context.Context, orgId uuid.UUID, authProvider *api.AuthProvider, ...) (*api.AuthProvider, error)

+ Delete func(ctx context.Context, orgId uuid.UUID, name string, eventCallback EventCallback) error

+ Get func(ctx context.Context, orgId uuid.UUID, name string) (*api.AuthProvider, error)

+ GetAuthProviderByAuthorizationUrl func(ctx context.Context, orgId uuid.UUID, authorizationUrl string) (*api.AuthProvider, error)

+ GetAuthProviderByIssuerAndClientId func(ctx context.Context, orgId uuid.UUID, issuer string, clientId string) (*api.AuthProvider, error)

+ InitialMigration func(ctx context.Context) error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.AuthProviderList, error)

+ ListAll func(ctx context.Context, listParams ListParams) (*api.AuthProviderList, error)

+ Update func(ctx context.Context, orgId uuid.UUID, authProvider *api.AuthProvider, ...) (*api.AuthProvider, error)

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, resource *api.AuthProvider, ...) (*api.AuthProvider, error)

+ func NewAuthProvider(db *gorm.DB, log logrus.FieldLogger) AuthProvider

+ type AuthProviderStore struct

+ func (s *AuthProviderStore) Count(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ func (s *AuthProviderStore) CountByOrg(ctx context.Context, orgId *uuid.UUID) ([]CountByOrgResult, error)

+ func (s *AuthProviderStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.AuthProvider, ...) (*api.AuthProvider, error)

+ func (s *AuthProviderStore) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *api.AuthProvider, ...) (*api.AuthProvider, bool, error)

+ func (s *AuthProviderStore) CreateWithFromAPI(ctx context.Context, orgId uuid.UUID, resource *api.AuthProvider, fromAPI bool, ...) (*api.AuthProvider, error)

+ func (s *AuthProviderStore) Delete(ctx context.Context, orgId uuid.UUID, name string, eventCallback EventCallback) error

+ func (s *AuthProviderStore) Get(ctx context.Context, orgId uuid.UUID, name string) (*api.AuthProvider, error)

+ func (s *AuthProviderStore) GetAuthProviderByAuthorizationUrl(ctx context.Context, orgId uuid.UUID, authorizationUrl string) (*api.AuthProvider, error)

+ func (s *AuthProviderStore) GetAuthProviderByIssuerAndClientId(ctx context.Context, orgId uuid.UUID, issuer string, clientId string) (*api.AuthProvider, error)

+ func (s *AuthProviderStore) InitialMigration(ctx context.Context) error

+ func (s *AuthProviderStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.AuthProviderList, error)

+ func (s *AuthProviderStore) ListAll(ctx context.Context, listParams ListParams) (*api.AuthProviderList, error)

+ func (s *AuthProviderStore) Update(ctx context.Context, orgId uuid.UUID, resource *api.AuthProvider, ...) (*api.AuthProvider, error)

+ func (s *AuthProviderStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.AuthProvider, ...) (*api.AuthProvider, error)

type DataStore

+ func (s *DataStore) AuthProvider() AuthProvider

type Device

+ ListDisconnected func(ctx context.Context, orgId uuid.UUID, listParams ListParams, ...) (*api.DeviceList, error)

type DeviceStore

+ func (s *DeviceStore) ListDisconnected(ctx context.Context, orgId uuid.UUID, listParams ListParams, ...) (*api.DeviceList, error)

type Organization

+ ListByIDs func(ctx context.Context, ids []string) ([]*model.Organization, error)

type OrganizationStore

+ func (s *OrganizationStore) ListByIDs(ctx context.Context, ids []string) ([]*model.Organization, error)

type Store

+ AuthProvider func() AuthProvider

Oct 24, 2025

Changes in this version

+ type CountByOrgAndStatusResult struct

+ Count int64

+ Fleet string

+ OrgID string

+ Status string

+ type CountByOrgResult struct

+ Count int64

+ OrgID string

+ type CountByResourceSyncOrgAndStatusResult struct

+ Count int64

+ OrgID string

+ Status string

+ type CountByRolloutStatusResult struct

+ Count int64

+ OrgID string

+ Status string

type DataStore

+ func (s *DataStore) CheckHealth(ctx context.Context) error

type Device

+ CountByOrgAndStatus func(ctx context.Context, orgId *uuid.UUID, statusType DeviceStatusType, ...) ([]CountByOrgAndStatusResult, error)

+ GetAllDeviceNames func(ctx context.Context, orgId uuid.UUID) ([]string, error)

+ GetLastSeen func(ctx context.Context, orgId uuid.UUID, name string) (*time.Time, error)

+ GetWithoutServiceConditions func(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, error)

+ Healthcheck func(ctx context.Context, orgId uuid.UUID, names []string) error

+ PrepareDevicesAfterRestore func(ctx context.Context) (int64, error)

+ ProcessAwaitingReconnectAnnotation func(ctx context.Context, orgId uuid.UUID, deviceName string, ...) (bool, error)

+ RemoveConflictPausedAnnotation func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, []string, error)

+ SetOutOfDate func(ctx context.Context, orgId uuid.UUID, owner string) error

+ type DeviceStatusType string

+ const DeviceStatusTypeApplication

+ const DeviceStatusTypeSummary

+ const DeviceStatusTypeUpdate

+ func (d DeviceStatusType) String() string

+ func (d DeviceStatusType) Validate() error

type DeviceStore

+ func (s *DeviceStore) CountByOrgAndStatus(ctx context.Context, orgId *uuid.UUID, statusType DeviceStatusType, ...) ([]CountByOrgAndStatusResult, error)

+ func (s *DeviceStore) GetAllDeviceNames(ctx context.Context, orgId uuid.UUID) ([]string, error)

+ func (s *DeviceStore) GetLastSeen(ctx context.Context, orgId uuid.UUID, name string) (*time.Time, error)

+ func (s *DeviceStore) GetWithoutServiceConditions(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, error)

+ func (s *DeviceStore) Healthcheck(ctx context.Context, orgId uuid.UUID, names []string) error

+ func (s *DeviceStore) PrepareDevicesAfterRestore(ctx context.Context) (int64, error)

+ func (s *DeviceStore) ProcessAwaitingReconnectAnnotation(ctx context.Context, orgId uuid.UUID, deviceName string, ...) (bool, error)

+ func (s *DeviceStore) RemoveConflictPausedAnnotation(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, []string, error)

+ func (s *DeviceStore) SetOutOfDate(ctx context.Context, orgId uuid.UUID, owner string) error

type EnrollmentRequest

+ CreateWithFromAPI func(ctx context.Context, orgId uuid.UUID, req *api.EnrollmentRequest, fromAPI bool, ...) (*api.EnrollmentRequest, error)

+ PrepareEnrollmentRequestsAfterRestore func(ctx context.Context) (int64, error)

type EnrollmentRequestStore

+ func (s *EnrollmentRequestStore) CreateWithFromAPI(ctx context.Context, orgId uuid.UUID, resource *api.EnrollmentRequest, ...) (*api.EnrollmentRequest, error)

+ func (s *EnrollmentRequestStore) PrepareEnrollmentRequestsAfterRestore(ctx context.Context) (int64, error)

type Fleet

+ CountByRolloutStatus func(ctx context.Context, orgId *uuid.UUID, _ *string) ([]CountByRolloutStatusResult, error)

type FleetStore

+ func (s *FleetStore) CountByRolloutStatus(ctx context.Context, orgId *uuid.UUID, _ *string) ([]CountByRolloutStatusResult, error)

type Organization

+ ListByExternalIDs func(ctx context.Context, externalIDs []string) ([]*model.Organization, error)

+ UpsertMany func(ctx context.Context, orgs []*model.Organization) ([]*model.Organization, error)

type OrganizationStore

+ func (s *OrganizationStore) ListByExternalIDs(ctx context.Context, externalIDs []string) ([]*model.Organization, error)

+ func (s *OrganizationStore) UpsertMany(ctx context.Context, orgs []*model.Organization) ([]*model.Organization, error)

+ type RemoveOwnerCallback func(ctx context.Context, tx *gorm.DB, orgId uuid.UUID, owner string) error

type Repository

+ Count func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ CountByOrg func(ctx context.Context, orgId *uuid.UUID) ([]CountByOrgResult, error)

type RepositoryStore

+ func (s *RepositoryStore) Count(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ func (s *RepositoryStore) CountByOrg(ctx context.Context, orgId *uuid.UUID) ([]CountByOrgResult, error)

type ResourceSync

+ Count func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ CountByOrgAndStatus func(ctx context.Context, orgId *uuid.UUID, status *string) ([]CountByResourceSyncOrgAndStatusResult, error)

type ResourceSyncStore

+ func (s *ResourceSyncStore) Count(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ func (s *ResourceSyncStore) CountByOrgAndStatus(ctx context.Context, orgId *uuid.UUID, status *string) ([]CountByResourceSyncOrgAndStatusResult, error)

type Store

+ CheckHealth func(context.Context) error

Aug 10, 2025

Changes in this version

+ func CallEventCallback(resourceKind api.ResourceKind, log logrus.FieldLogger) ...

+ func InitMigrationDB(cfg *config.Config, log *logrus.Logger) (*gorm.DB, error)

+ func SafeEventCallback(log logrus.FieldLogger, callback func())

+ type Checkpoint interface

+ Get func(ctx context.Context, consumer string, key string) ([]byte, error)

+ GetDatabaseTime func(ctx context.Context) (time.Time, error)

+ InitialMigration func(ctx context.Context) error

+ Set func(ctx context.Context, consumer string, key string, value []byte) error

+ func NewCheckpoint(db *gorm.DB, log logrus.FieldLogger) Checkpoint

+ type CheckpointStore struct

+ func (s *CheckpointStore) Get(ctx context.Context, consumer string, key string) ([]byte, error)

+ func (s *CheckpointStore) GetDatabaseTime(ctx context.Context) (time.Time, error)

+ func (s *CheckpointStore) InitialMigration(ctx context.Context) error

+ func (s *CheckpointStore) Set(ctx context.Context, consumer string, key string, value []byte) error

type DataStore

+ func (s *DataStore) Checkpoint() Checkpoint

+ func (s *DataStore) Organization() Organization

+ func (s *DataStore) RunMigrationWithMigrationUser(ctx context.Context, cfg *config.Config, log *logrus.Logger) error

+ func (s *DataStore) RunMigrations(ctx context.Context) error

type Device

+ ListDevicesByServiceCondition func(ctx context.Context, orgId uuid.UUID, conditionType string, ...) (*api.DeviceList, error)

type DeviceStore

+ func (s *DeviceStore) ListDevicesByServiceCondition(ctx context.Context, orgId uuid.UUID, conditionType string, ...) (*api.DeviceList, error)

+ type EventCallback func(ctx context.Context, resourceKind api.ResourceKind, orgId uuid.UUID, ...)

+ type EventCallbackCaller func(ctx context.Context, callbackEvent EventCallback, orgId uuid.UUID, name string, ...)

+ type Organization interface

+ Create func(ctx context.Context, org *model.Organization) (*model.Organization, error)

+ GetByID func(ctx context.Context, id uuid.UUID) (*model.Organization, error)

+ InitialMigration func(ctx context.Context) error

+ List func(ctx context.Context) ([]*model.Organization, error)

+ func NewOrganization(db *gorm.DB) Organization

+ type OrganizationStore struct

+ func (s *OrganizationStore) Create(ctx context.Context, org *model.Organization) (*model.Organization, error)

+ func (s *OrganizationStore) GetByID(ctx context.Context, id uuid.UUID) (*model.Organization, error)

+ func (s *OrganizationStore) InitialMigration(ctx context.Context) error

+ func (s *OrganizationStore) List(ctx context.Context) ([]*model.Organization, error)

+ type ServiceConditionsCallback func(ctx context.Context, orgId uuid.UUID, device *api.Device, ...)

type Store

+ Checkpoint func() Checkpoint

+ Organization func() Organization

+ RunMigrations func(context.Context) error

Jul 15, 2025

Changes in this version

+ const SortAsc

+ const SortByCreatedAt

+ const SortByName

+ const SortDesc

+ func BuildContinueString(names []string, count int64) *string

+ func NewTraceContextEnforcer() gorm.Plugin

+ func WithBypassSpanCheck(ctx context.Context) context.Context

type Continue

+ Names []string

type ListParams

+ SortColumns []SortColumn

+ SortOrder *SortOrder

+ type SortColumn string

May 8, 2025

Changes in this version

type DataStore

+ func (s *DataStore) Event() Event

+ type Event interface

+ Create func(ctx context.Context, orgId uuid.UUID, event *api.Event) error

+ DeleteOlderThan func(ctx context.Context, cutoffTime time.Time) (int64, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.EventList, error)

+ func NewEvent(db *gorm.DB, log logrus.FieldLogger) Event

+ type EventStore struct

+ func (s *EventStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.Event) error

+ func (s *EventStore) DeleteOlderThan(ctx context.Context, cutoffTime time.Time) (int64, error)

+ func (s *EventStore) InitialMigration() error

+ func (s *EventStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.EventList, error)

type ListQueryOption

+ func WithSortDirective(sortDirective *string) ListQueryOption

type Store

+ Event func() Event

Apr 23, 2025

Changes in this version

type Repository

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, resource *api.Repository) (*api.Repository, error)

type RepositoryStore

+ func (s *RepositoryStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.Repository) (*api.Repository, error)

type ResourceSync

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, resource *api.ResourceSync) (*api.ResourceSync, error)

type ResourceSyncStore

+ func (s *ResourceSyncStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.ResourceSync) (*api.ResourceSync, error)

Feb 26, 2025

Changes in this version

type Device

+ Labels func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (api.DeviceLabelList, error)

type DeviceStore

+ func (s *DeviceStore) Labels(ctx context.Context, orgId uuid.UUID, listParams ListParams) (api.DeviceLabelList, error)

+ type ListQueryOption func(*listQuery)

+ func WithSelectorResolver(resolver selector.Resolver) ListQueryOption

Feb 5, 2025

Changes in this version

+ type CompletionCount struct

+ Count int64

+ SameRenderedVersion bool

+ SameTemplateVersion bool

+ UpdateTimedOut bool

+ UpdatingReason api.UpdateState

type Device

+ CompletionCounts func(ctx context.Context, orgId uuid.UUID, owner string, templateVersion string, ...) ([]CompletionCount, error)

+ Count func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ CountByLabels func(ctx context.Context, orgId uuid.UUID, listParams ListParams, groupBy []string, ...) ([]map[string]any, error)

+ MarkRolloutSelection func(ctx context.Context, orgId uuid.UUID, listParams ListParams, limit *int) error

+ UnmarkRolloutSelection func(ctx context.Context, orgId uuid.UUID, fleetName string) error

type DeviceStore

+ func (s *DeviceStore) CompletionCounts(ctx context.Context, orgId uuid.UUID, owner string, templateVersion string, ...) ([]CompletionCount, error)

+ func (s *DeviceStore) Count(ctx context.Context, orgId uuid.UUID, listParams ListParams) (int64, error)

+ func (s *DeviceStore) CountByLabels(ctx context.Context, orgId uuid.UUID, listParams ListParams, groupBy []string, ...) ([]map[string]any, error)

+ func (s *DeviceStore) MarkRolloutSelection(ctx context.Context, orgId uuid.UUID, listParams ListParams, limit *int) error

+ func (s *DeviceStore) UnmarkRolloutSelection(ctx context.Context, orgId uuid.UUID, fleetName string) error

+ type DeviceStoreValidationCallback func(before *api.Device, after *api.Device) error

type EnrollmentRequest

+ Update func(ctx context.Context, orgId uuid.UUID, req *api.EnrollmentRequest) (*api.EnrollmentRequest, error)

type EnrollmentRequestStore

+ func (s *EnrollmentRequestStore) Update(ctx context.Context, orgId uuid.UUID, resource *api.EnrollmentRequest) (*api.EnrollmentRequest, error)

type Fleet

+ ListDisruptionBudgetFleets func(ctx context.Context, orgId uuid.UUID) (*api.FleetList, error)

+ ListRolloutDeviceSelection func(ctx context.Context, orgId uuid.UUID) (*api.FleetList, error)

type FleetStore

+ func (s *FleetStore) ListDisruptionBudgetFleets(ctx context.Context, orgId uuid.UUID) (*api.FleetList, error)

+ func (s *FleetStore) ListRolloutDeviceSelection(ctx context.Context, orgId uuid.UUID) (*api.FleetList, error)

+ type GenericStore struct

+ IntegrationTestCreateOrUpdateCallback IntegrationTestCallback

+ func NewGenericStore[P extInt[M], M Model, A any, AL any](db *gorm.DB, log logrus.FieldLogger, apiToModelPtr func(*A) (P, error), ...) *GenericStore[P, M, A, AL]

+ func (s *GenericStore[P, M, A, AL]) Create(ctx context.Context, orgId uuid.UUID, resource *A, ...) (*A, error)

+ func (s *GenericStore[P, M, A, AL]) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *A, fieldsToUnset []string, ...) (*A, bool, error)

+ func (s *GenericStore[P, M, A, AL]) Delete(ctx context.Context, resource M, ...) error

+ func (s *GenericStore[P, M, A, AL]) DeleteAll(ctx context.Context, orgId uuid.UUID, callback func(orgId uuid.UUID)) error

+ func (s *GenericStore[P, M, A, AL]) Get(ctx context.Context, orgId uuid.UUID, name string) (*A, error)

+ func (s *GenericStore[P, M, A, AL]) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*AL, error)

+ func (s *GenericStore[P, M, A, AL]) Update(ctx context.Context, orgId uuid.UUID, resource *A, fieldsToUnset []string, ...) (*A, error)

+ func (s *GenericStore[P, M, A, AL]) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *A) (*A, error)

type GetOption

+ func GetWithDeviceSummary(val bool) GetOption

type ListOption

+ func ListWithDevicesSummary(val bool) ListOption

type ListParams

+ AnnotationSelector *selector.AnnotationSelector

+ LabelSelector *selector.LabelSelector

+ type Model interface

+ type Resource struct

+ Name string

+ OrgID string

+ Table string

type TemplateVersion

+ GetLatest func(ctx context.Context, orgId uuid.UUID, fleet string) (*api.TemplateVersion, error)

type TemplateVersionStore

+ func (s *TemplateVersionStore) GetLatest(ctx context.Context, orgId uuid.UUID, fleet string) (*api.TemplateVersion, error)

Nov 11, 2024

Changes in this version

+ func AnnotationsMatchExpressionsQuery(query *gorm.DB, matchExpressions api.MatchExpressions) (*gorm.DB, error)

+ func ErrorFromGormError(err error) error

+ func LabelMatchExpressionsQuery(query *gorm.DB, matchExpressions api.MatchExpressions) (*gorm.DB, error)

+ func ListQuery(model any) *listQuery

type Device

+ Summary func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.DevicesSummary, error)

type DeviceStore

+ func (s *DeviceStore) Summary(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.DevicesSummary, error)

type ListParams

+ AnnotationsMatchExpressions v1alpha1.MatchExpressions

+ FieldSelector fields.Selector

+ LabelMatchExpressions v1alpha1.MatchExpressions

+ SortBy *SortField

+ type SortField struct

+ FieldName selector.SelectorFieldName

+ Order v1alpha1.SortOrder

+ type SortOrder string

type StatusCount

+ Category string

+ StatusSummary string

+ type StatusCountList []StatusCount

+ func CountStatusList(ctx context.Context, query *gorm.DB, status ...string) (StatusCountList, error)

+ func (s StatusCountList) List(status string) map[string]int64

Sep 3, 2024

Changes in this version

+ func FieldFilterSelectionQuery(query *gorm.DB, fieldMap map[string][]string) *gorm.DB

type CertificateSigningRequest

+ Update func(ctx context.Context, orgId uuid.UUID, req *api.CertificateSigningRequest) (*api.CertificateSigningRequest, error)

type CertificateSigningRequestStore

+ func (s *CertificateSigningRequestStore) Update(ctx context.Context, orgId uuid.UUID, resource *api.CertificateSigningRequest) (*api.CertificateSigningRequest, error)

+ type CreateOrUpdateMode string

+ const ModeCreateOnly

+ const ModeCreateOrUpdate

+ const ModeUpdateOnly

type Device

+ Update func(ctx context.Context, orgId uuid.UUID, device *api.Device, ...) (*api.Device, error)

type DeviceStore

+ func (s *DeviceStore) Update(ctx context.Context, orgId uuid.UUID, resource *api.Device, ...) (*api.Device, error)

type Fleet

+ Update func(ctx context.Context, orgId uuid.UUID, fleet *api.Fleet, ...) (*api.Fleet, error)

type FleetStore

+ func (s *FleetStore) Update(ctx context.Context, orgId uuid.UUID, resource *api.Fleet, ...) (*api.Fleet, error)

type Repository

+ Update func(ctx context.Context, orgId uuid.UUID, repository *api.Repository, ...) (*api.Repository, error)

type RepositoryStore

+ func (s *RepositoryStore) Update(ctx context.Context, orgId uuid.UUID, resource *api.Repository, ...) (*api.Repository, error)

type ResourceSync

+ Update func(ctx context.Context, orgId uuid.UUID, resourceSync *api.ResourceSync) (*api.ResourceSync, error)

type ResourceSyncStore

+ func (s *ResourceSyncStore) Update(ctx context.Context, orgId uuid.UUID, resource *api.ResourceSync) (*api.ResourceSync, error)

Aug 20, 2024

Changes in this version

+ var CurrentContinueVersion = 1

+ var MaxRecordsPerListRequest = 1000

+ var NullOrgId = uuid.MustParse("00000000-0000-0000-0000-000000000000")

+ func AddPaginationToQuery(query *gorm.DB, limit int, cont *Continue) *gorm.DB

+ func BuildBaseListQuery(query *gorm.DB, orgId uuid.UUID, listParams ListParams) *gorm.DB

+ func CloseDB(db *gorm.DB)

+ func CountRemainingItems(query *gorm.DB, lastItemName string) int64

+ func DeleteTestDB(log *logrus.Logger, cfg *config.Config, store Store, dbName string)

+ func GetNonNilFieldsFromResource(resource model.Resource) []string

+ func InitDB(cfg *config.Config, log *logrus.Logger) (*gorm.DB, error)

+ func LabelSelectionQuery(query *gorm.DB, labels map[string]string, inverse bool) *gorm.DB

+ func StatusFilterSelectionQuery(query *gorm.DB, fieldMap map[string][]string) *gorm.DB

+ type CertificateSigningRequest interface

+ Create func(ctx context.Context, orgId uuid.UUID, req *api.CertificateSigningRequest) (*api.CertificateSigningRequest, error)

+ CreateOrUpdate func(ctx context.Context, orgId uuid.UUID, ...) (*api.CertificateSigningRequest, bool, error)

+ Delete func(ctx context.Context, orgId uuid.UUID, name string) error

+ DeleteAll func(ctx context.Context, orgId uuid.UUID) error

+ Get func(ctx context.Context, orgId uuid.UUID, name string) (*api.CertificateSigningRequest, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.CertificateSigningRequestList, error)

+ UpdateConditions func(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) error

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, ...) (*api.CertificateSigningRequest, error)

+ func NewCertificateSigningRequest(db *gorm.DB, log logrus.FieldLogger) CertificateSigningRequest

+ type CertificateSigningRequestStore struct

+ func (s *CertificateSigningRequestStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.CertificateSigningRequest) (*api.CertificateSigningRequest, error)

+ func (s *CertificateSigningRequestStore) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *api.CertificateSigningRequest) (*api.CertificateSigningRequest, bool, error)

+ func (s *CertificateSigningRequestStore) Delete(ctx context.Context, orgId uuid.UUID, name string) error

+ func (s *CertificateSigningRequestStore) DeleteAll(ctx context.Context, orgId uuid.UUID) error

+ func (s *CertificateSigningRequestStore) Get(ctx context.Context, orgId uuid.UUID, name string) (*api.CertificateSigningRequest, error)

+ func (s *CertificateSigningRequestStore) InitialMigration() error

+ func (s *CertificateSigningRequestStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.CertificateSigningRequestList, error)

+ func (s *CertificateSigningRequestStore) UpdateConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) error

+ func (s *CertificateSigningRequestStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.CertificateSigningRequest) (*api.CertificateSigningRequest, error)

+ type Continue struct

+ Count int64

+ Name string

+ Version int

+ func ParseContinueString(contStr *string) (*Continue, error)

+ type DataStore struct

+ func (s *DataStore) CertificateSigningRequest() CertificateSigningRequest

+ func (s *DataStore) Close() error

+ func (s *DataStore) Device() Device

+ func (s *DataStore) EnrollmentRequest() EnrollmentRequest

+ func (s *DataStore) Fleet() Fleet

+ func (s *DataStore) InitialMigration() error

+ func (s *DataStore) Repository() Repository

+ func (s *DataStore) ResourceSync() ResourceSync

+ func (s *DataStore) TemplateVersion() TemplateVersion

+ type Device interface

+ Create func(ctx context.Context, orgId uuid.UUID, device *api.Device, ...) (*api.Device, error)

+ CreateOrUpdate func(ctx context.Context, orgId uuid.UUID, device *api.Device, ...) (*api.Device, bool, error)

+ Delete func(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ DeleteAll func(ctx context.Context, orgId uuid.UUID, callback DeviceStoreAllDeletedCallback) error

+ Get func(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, error)

+ GetRendered func(ctx context.Context, orgId uuid.UUID, name string, ...) (*api.RenderedDeviceSpec, error)

+ GetRepositoryRefs func(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.DeviceList, error)

+ OverwriteRepositoryRefs func(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) error

+ SetIntegrationTestCreateOrUpdateCallback func(IntegrationTestCallback)

+ SetServiceConditions func(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) error

+ UpdateAnnotations func(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ UpdateRendered func(ctx context.Context, orgId uuid.UUID, name string, rendered string) error

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, device *api.Device) (*api.Device, error)

+ UpdateSummaryStatusBatch func(ctx context.Context, orgId uuid.UUID, deviceNames []string, ...) error

+ func NewDevice(db *gorm.DB, log logrus.FieldLogger) Device

+ type DeviceStore struct

+ IntegrationTestCreateOrUpdateCallback IntegrationTestCallback

+ func (s *DeviceStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.Device, ...) (*api.Device, error)

+ func (s *DeviceStore) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *api.Device, ...) (*api.Device, bool, error)

+ func (s *DeviceStore) Delete(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ func (s *DeviceStore) DeleteAll(ctx context.Context, orgId uuid.UUID, callback DeviceStoreAllDeletedCallback) error

+ func (s *DeviceStore) Get(ctx context.Context, orgId uuid.UUID, name string) (*api.Device, error)

+ func (s *DeviceStore) GetRendered(ctx context.Context, orgId uuid.UUID, name string, ...) (*api.RenderedDeviceSpec, error)

+ func (s *DeviceStore) GetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, error)

+ func (s *DeviceStore) InitialMigration() error

+ func (s *DeviceStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.DeviceList, error)

+ func (s *DeviceStore) OverwriteRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) error

+ func (s *DeviceStore) SetIntegrationTestCreateOrUpdateCallback(c IntegrationTestCallback)

+ func (s *DeviceStore) SetServiceConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) error

+ func (s *DeviceStore) UpdateAnnotations(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ func (s *DeviceStore) UpdateRendered(ctx context.Context, orgId uuid.UUID, name string, rendered string) error

+ func (s *DeviceStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.Device) (*api.Device, error)

+ func (s *DeviceStore) UpdateSummaryStatusBatch(ctx context.Context, orgId uuid.UUID, deviceNames []string, ...) error

+ type DeviceStoreAllDeletedCallback func(orgId uuid.UUID)

+ type DeviceStoreCallback func(before *model.Device, after *model.Device)

+ type EnrollmentRequest interface

+ Create func(ctx context.Context, orgId uuid.UUID, req *api.EnrollmentRequest) (*api.EnrollmentRequest, error)

+ CreateOrUpdate func(ctx context.Context, orgId uuid.UUID, enrollmentrequest *api.EnrollmentRequest) (*api.EnrollmentRequest, bool, error)

+ Delete func(ctx context.Context, orgId uuid.UUID, name string) error

+ DeleteAll func(ctx context.Context, orgId uuid.UUID) error

+ Get func(ctx context.Context, orgId uuid.UUID, name string) (*api.EnrollmentRequest, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.EnrollmentRequestList, error)

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, enrollmentrequest *api.EnrollmentRequest) (*api.EnrollmentRequest, error)

+ func NewEnrollmentRequest(db *gorm.DB, log logrus.FieldLogger) EnrollmentRequest

+ type EnrollmentRequestStore struct

+ func (s *EnrollmentRequestStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.EnrollmentRequest) (*api.EnrollmentRequest, error)

+ func (s *EnrollmentRequestStore) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *api.EnrollmentRequest) (*api.EnrollmentRequest, bool, error)

+ func (s *EnrollmentRequestStore) Delete(ctx context.Context, orgId uuid.UUID, name string) error

+ func (s *EnrollmentRequestStore) DeleteAll(ctx context.Context, orgId uuid.UUID) error

+ func (s *EnrollmentRequestStore) Get(ctx context.Context, orgId uuid.UUID, name string) (*api.EnrollmentRequest, error)

+ func (s *EnrollmentRequestStore) InitialMigration() error

+ func (s *EnrollmentRequestStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.EnrollmentRequestList, error)

+ func (s *EnrollmentRequestStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.EnrollmentRequest) (*api.EnrollmentRequest, error)

+ type Fleet interface

+ Create func(ctx context.Context, orgId uuid.UUID, fleet *api.Fleet, ...) (*api.Fleet, error)

+ CreateOrUpdate func(ctx context.Context, orgId uuid.UUID, fleet *api.Fleet, ...) (*api.Fleet, bool, error)

+ CreateOrUpdateMultiple func(ctx context.Context, orgId uuid.UUID, callback FleetStoreCallback, ...) error

+ Delete func(ctx context.Context, orgId uuid.UUID, callback FleetStoreCallback, ...) error

+ DeleteAll func(ctx context.Context, orgId uuid.UUID, callback FleetStoreAllDeletedCallback) error

+ Get func(ctx context.Context, orgId uuid.UUID, name string, opts ...GetOption) (*api.Fleet, error)

+ GetRepositoryRefs func(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams, ...) (*api.FleetList, error)

+ ListIgnoreOrg func() ([]model.Fleet, error)

+ OverwriteRepositoryRefs func(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) error

+ UnsetOwner func(ctx context.Context, tx *gorm.DB, orgId uuid.UUID, owner string) error

+ UnsetOwnerByKind func(ctx context.Context, tx *gorm.DB, orgId uuid.UUID, resourceKind string) error

+ UpdateAnnotations func(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ UpdateConditions func(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) error

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, fleet *api.Fleet) (*api.Fleet, error)

+ UpdateStatusMultiple func(ctx context.Context, orgId uuid.UUID, fleets ...*api.Fleet) error

+ func NewFleet(db *gorm.DB, log logrus.FieldLogger) Fleet

+ type FleetStore struct

+ func (s *FleetStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.Fleet, ...) (*api.Fleet, error)

+ func (s *FleetStore) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *api.Fleet, ...) (*api.Fleet, bool, error)

+ func (s *FleetStore) CreateOrUpdateMultiple(ctx context.Context, orgId uuid.UUID, callback FleetStoreCallback, ...) error

+ func (s *FleetStore) Delete(ctx context.Context, orgId uuid.UUID, callback FleetStoreCallback, ...) error

+ func (s *FleetStore) DeleteAll(ctx context.Context, orgId uuid.UUID, callback FleetStoreAllDeletedCallback) error

+ func (s *FleetStore) Get(ctx context.Context, orgId uuid.UUID, name string, opts ...GetOption) (*api.Fleet, error)

+ func (s *FleetStore) GetRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.RepositoryList, error)

+ func (s *FleetStore) InitialMigration() error

+ func (s *FleetStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams, ...) (*api.FleetList, error)

+ func (s *FleetStore) ListIgnoreOrg() ([]model.Fleet, error)

+ func (s *FleetStore) OverwriteRepositoryRefs(ctx context.Context, orgId uuid.UUID, name string, repositoryNames ...string) error

+ func (s *FleetStore) UnsetOwner(ctx context.Context, tx *gorm.DB, orgId uuid.UUID, owner string) error

+ func (s *FleetStore) UnsetOwnerByKind(ctx context.Context, tx *gorm.DB, orgId uuid.UUID, resourceKind string) error

+ func (s *FleetStore) UpdateAnnotations(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ func (s *FleetStore) UpdateConditions(ctx context.Context, orgId uuid.UUID, name string, conditions []api.Condition) error

+ func (s *FleetStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.Fleet) (*api.Fleet, error)

+ func (s *FleetStore) UpdateStatusMultiple(ctx context.Context, orgId uuid.UUID, resources ...*api.Fleet) error

+ type FleetStoreAllDeletedCallback func(orgId uuid.UUID)

+ type FleetStoreCallback func(before *model.Fleet, after *model.Fleet)

+ type GetOption func(*getOptions)

+ func WithSummary(val bool) GetOption

+ type IntegrationTestCallback func()

+ type ListOption func(*listOptions)

+ func WithDeviceCount(val bool) ListOption

+ type ListParams struct

+ Continue *Continue

+ Filter map[string][]string

+ FleetName *string

+ InvertLabels *bool

+ Labels map[string]string

+ Limit int

+ Owners []string

+ type Repository interface

+ Create func(ctx context.Context, orgId uuid.UUID, repository *api.Repository, ...) (*api.Repository, error)

+ CreateOrUpdate func(ctx context.Context, orgId uuid.UUID, repository *api.Repository, ...) (*api.Repository, bool, error)

+ Delete func(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ DeleteAll func(ctx context.Context, orgId uuid.UUID, ...) error

+ Get func(ctx context.Context, orgId uuid.UUID, name string) (*api.Repository, error)

+ GetDeviceRefs func(ctx context.Context, orgId uuid.UUID, name string) (*api.DeviceList, error)

+ GetFleetRefs func(ctx context.Context, orgId uuid.UUID, name string) (*api.FleetList, error)

+ GetInternal func(ctx context.Context, orgId uuid.UUID, name string) (*model.Repository, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.RepositoryList, error)

+ ListIgnoreOrg func() ([]model.Repository, error)

+ UpdateStatusIgnoreOrg func(repository *model.Repository) error

+ func NewRepository(db *gorm.DB, log logrus.FieldLogger) Repository

+ type RepositoryStore struct

+ func (s *RepositoryStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.Repository, ...) (*api.Repository, error)

+ func (s *RepositoryStore) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *api.Repository, ...) (*api.Repository, bool, error)

+ func (s *RepositoryStore) Delete(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ func (s *RepositoryStore) DeleteAll(ctx context.Context, orgId uuid.UUID, ...) error

+ func (s *RepositoryStore) Get(ctx context.Context, orgId uuid.UUID, name string) (*api.Repository, error)

+ func (s *RepositoryStore) GetDeviceRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.DeviceList, error)

+ func (s *RepositoryStore) GetFleetRefs(ctx context.Context, orgId uuid.UUID, name string) (*api.FleetList, error)

+ func (s *RepositoryStore) GetInternal(ctx context.Context, orgId uuid.UUID, name string) (*model.Repository, error)

+ func (s *RepositoryStore) InitialMigration() error

+ func (s *RepositoryStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.RepositoryList, error)

+ func (s *RepositoryStore) ListIgnoreOrg() ([]model.Repository, error)

+ func (s *RepositoryStore) UpdateStatusIgnoreOrg(resource *model.Repository) error

+ type RepositoryStoreAllDeletedCallback func(uuid.UUID)

+ type RepositoryStoreCallback func(*model.Repository)

+ type ResourceSync interface

+ Create func(ctx context.Context, orgId uuid.UUID, resourceSync *api.ResourceSync) (*api.ResourceSync, error)

+ CreateOrUpdate func(ctx context.Context, orgId uuid.UUID, resourceSync *api.ResourceSync) (*api.ResourceSync, bool, error)

+ Delete func(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ DeleteAll func(ctx context.Context, orgId uuid.UUID, ...) error

+ Get func(ctx context.Context, orgId uuid.UUID, name string) (*api.ResourceSync, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.ResourceSyncList, error)

+ ListIgnoreOrg func() ([]model.ResourceSync, error)

+ UpdateStatusIgnoreOrg func(resourceSync *model.ResourceSync) error

+ func NewResourceSync(db *gorm.DB, log logrus.FieldLogger) ResourceSync

+ type ResourceSyncStore struct

+ func (s *ResourceSyncStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.ResourceSync) (*api.ResourceSync, error)

+ func (s *ResourceSyncStore) CreateOrUpdate(ctx context.Context, orgId uuid.UUID, resource *api.ResourceSync) (*api.ResourceSync, bool, error)

+ func (s *ResourceSyncStore) Delete(ctx context.Context, orgId uuid.UUID, name string, ...) error

+ func (s *ResourceSyncStore) DeleteAll(ctx context.Context, orgId uuid.UUID, ...) error

+ func (s *ResourceSyncStore) Get(ctx context.Context, orgId uuid.UUID, name string) (*api.ResourceSync, error)

+ func (s *ResourceSyncStore) InitialMigration() error

+ func (s *ResourceSyncStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.ResourceSyncList, error)

+ func (s *ResourceSyncStore) ListIgnoreOrg() ([]model.ResourceSync, error)

+ func (s *ResourceSyncStore) UpdateStatusIgnoreOrg(resource *model.ResourceSync) error

+ type StatusCount struct

+ Count int

+ Status string

+ type Store interface

+ CertificateSigningRequest func() CertificateSigningRequest

+ Close func() error

+ Device func() Device

+ EnrollmentRequest func() EnrollmentRequest

+ Fleet func() Fleet

+ InitialMigration func() error

+ Repository func() Repository

+ ResourceSync func() ResourceSync

+ TemplateVersion func() TemplateVersion

+ func NewStore(db *gorm.DB, log logrus.FieldLogger) Store

+ func PrepareDBForUnitTests(log *logrus.Logger) (Store, *config.Config, string, *gorm.DB)

+ type TemplateVersion interface

+ Create func(ctx context.Context, orgId uuid.UUID, templateVersion *api.TemplateVersion, ...) (*api.TemplateVersion, error)

+ Delete func(ctx context.Context, orgId uuid.UUID, fleet string, name string) error

+ DeleteAll func(ctx context.Context, orgId uuid.UUID, fleet *string) error

+ Get func(ctx context.Context, orgId uuid.UUID, fleet string, name string) (*api.TemplateVersion, error)

+ GetNewestValid func(ctx context.Context, orgId uuid.UUID, fleet string) (*api.TemplateVersion, error)

+ InitialMigration func() error

+ List func(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.TemplateVersionList, error)

+ UpdateStatus func(ctx context.Context, orgId uuid.UUID, resource *api.TemplateVersion, ...) error

+ func NewTemplateVersion(db *gorm.DB, log logrus.FieldLogger) TemplateVersion

+ type TemplateVersionStore struct

+ func (s *TemplateVersionStore) Create(ctx context.Context, orgId uuid.UUID, resource *api.TemplateVersion, ...) (*api.TemplateVersion, error)

+ func (s *TemplateVersionStore) Delete(ctx context.Context, orgId uuid.UUID, fleet string, name string) error

+ func (s *TemplateVersionStore) DeleteAll(ctx context.Context, orgId uuid.UUID, fleet *string) error

+ func (s *TemplateVersionStore) Get(ctx context.Context, orgId uuid.UUID, fleet string, name string) (*api.TemplateVersion, error)

+ func (s *TemplateVersionStore) GetNewestValid(ctx context.Context, orgId uuid.UUID, fleet string) (*api.TemplateVersion, error)

+ func (s *TemplateVersionStore) InitialMigration() error

+ func (s *TemplateVersionStore) List(ctx context.Context, orgId uuid.UUID, listParams ListParams) (*api.TemplateVersionList, error)

+ func (s *TemplateVersionStore) UpdateStatus(ctx context.Context, orgId uuid.UUID, resource *api.TemplateVersion, ...) error

+ type TemplateVersionStoreCallback func(tv *model.TemplateVersion)