Versions in this module Expand all Collapse all v0 v0.7.1 Jul 25, 2023 v0.7.0 Jul 20, 2023 Changes in this version + type BackupManager interface + Backup func(ctx context.Context, backup *resource.Backup, resources []*resource.Resource) (*resource.BackupResult, error) + type BackupRepository interface + Create func(ctx context.Context, backup *resource.Backup) error + GetAll func(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Backup, error) + GetByID func(ctx context.Context, id resource.BackupID) (*resource.Backup, error) + type BackupService struct + func NewBackupService(repo BackupRepository, resources ResourceProvider, manager BackupManager, ...) *BackupService + func (s BackupService) Create(ctx context.Context, backup *resource.Backup) (*resource.BackupResult, error) + func (s BackupService) Get(ctx context.Context, backupID resource.BackupID) (*resource.Backup, error) + func (s BackupService) List(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Backup, error) + type DataStore interface + Backup func(context.Context, *resource.Backup, []*resource.Resource) (*resource.BackupResult, error) + BatchUpdate func(context.Context, []*resource.Resource) error + Create func(context.Context, *resource.Resource) error + GetURN func(res *resource.Resource) (string, error) + Update func(context.Context, *resource.Resource) error + Validate func(*resource.Resource) error + type DownstreamRefresher interface + RefreshResourceDownstream func(ctx context.Context, resourceURNs []job.ResourceURN, ...) error + type EventHandler interface + HandleEvent func(moderator.Event) + type ResourceManager interface + BatchUpdate func(ctx context.Context, store resource.Store, resources []*resource.Resource) error + CreateResource func(ctx context.Context, res *resource.Resource) error + GetURN func(res *resource.Resource) (string, error) + SyncResource func(ctx context.Context, res *resource.Resource) error + UpdateResource func(ctx context.Context, res *resource.Resource) error + Validate func(res *resource.Resource) error + type ResourceMgr struct + func NewResourceManager(repo ResourceStatusRepo, logger log.Logger) *ResourceMgr + func (m *ResourceMgr) Backup(ctx context.Context, details *resource.Backup, resources []*resource.Resource) (*resource.BackupResult, error) + func (m *ResourceMgr) BatchUpdate(ctx context.Context, store resource.Store, resources []*resource.Resource) error + func (m *ResourceMgr) CreateResource(ctx context.Context, res *resource.Resource) error + func (m *ResourceMgr) GetURN(res *resource.Resource) (string, error) + func (m *ResourceMgr) RegisterDatastore(store resource.Store, dataStore DataStore) + func (m *ResourceMgr) SyncResource(ctx context.Context, res *resource.Resource) error + func (m *ResourceMgr) UpdateResource(ctx context.Context, res *resource.Resource) error + func (m *ResourceMgr) Validate(res *resource.Resource) error + type ResourceProvider interface + GetResources func(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) ([]*resource.Resource, error) + type ResourceRepository interface + ChangeNamespace func(ctx context.Context, res *resource.Resource, newTenant tenant.Tenant) error + Create func(ctx context.Context, res *resource.Resource) error + GetResources func(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) ([]*resource.Resource, error) + ReadAll func(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Resource, error) + ReadByFullName func(ctx context.Context, tnnt tenant.Tenant, store resource.Store, fullName string) (*resource.Resource, error) + Update func(ctx context.Context, res *resource.Resource) error + type ResourceService struct + func NewResourceService(logger log.Logger, repo ResourceRepository, ...) *ResourceService + func (rs ResourceService) ChangeNamespace(ctx context.Context, datastore resource.Store, resourceFullName string, ...) error + func (rs ResourceService) Create(ctx context.Context, incoming *resource.Resource) error + func (rs ResourceService) Deploy(ctx context.Context, tnnt tenant.Tenant, store resource.Store, ...) error + func (rs ResourceService) Get(ctx context.Context, tnnt tenant.Tenant, store resource.Store, ...) (*resource.Resource, error) + func (rs ResourceService) GetAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Resource, error) + func (rs ResourceService) SyncResources(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) (*resource.SyncResponse, error) + func (rs ResourceService) Update(ctx context.Context, incoming *resource.Resource, logWriter writer.LogWriter) error + type ResourceStatusRepo interface + UpdateStatus func(ctx context.Context, res ...*resource.Resource) error + type TenantDetailsGetter interface + GetDetails func(ctx context.Context, tnnt tenant.Tenant) (*tenant.WithDetails, error)
Go to main page