service

Documentation

Index

• type BackupManager
• type BackupRepository
• type BackupService
  • 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
• type DownstreamRefresher
• type EventHandler
• type ResourceManager
• type ResourceMgr
  • 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
• type ResourceRepository
• type ResourceService
  • 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
• type TenantDetailsGetter

Types

type BackupManager

type BackupManager interface {
	Backup(ctx context.Context, backup *resource.Backup, resources []*resource.Resource) (*resource.BackupResult, error)
}

type BackupRepository

type BackupRepository interface {
	GetByID(ctx context.Context, id resource.BackupID) (*resource.Backup, error)
	GetAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Backup, error)
	Create(ctx context.Context, backup *resource.Backup) error
}

type BackupService

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

func NewBackupService

func NewBackupService(repo BackupRepository, resources ResourceProvider, manager BackupManager, logger log.Logger) *BackupService

func (BackupService) Create

func (s BackupService) Create(ctx context.Context, backup *resource.Backup) (*resource.BackupResult, error)

func (BackupService) Get

func (s BackupService) Get(ctx context.Context, backupID resource.BackupID) (*resource.Backup, error)

func (BackupService) List

func (s BackupService) List(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Backup, error)

type DataStore

type DataStore interface {
	Create(context.Context, *resource.Resource) error
	Update(context.Context, *resource.Resource) error
	BatchUpdate(context.Context, []*resource.Resource) error
	Validate(*resource.Resource) error
	GetURN(res *resource.Resource) (string, error)
	Backup(context.Context, *resource.Backup, []*resource.Resource) (*resource.BackupResult, error)
}

type DownstreamRefresher

type DownstreamRefresher interface {
	RefreshResourceDownstream(ctx context.Context, resourceURNs []job.ResourceURN, logWriter writer.LogWriter) error
}

type EventHandler

type EventHandler interface {
	HandleEvent(moderator.Event)
}

type ResourceManager

type ResourceManager interface {
	CreateResource(ctx context.Context, res *resource.Resource) error
	UpdateResource(ctx context.Context, res *resource.Resource) error
	SyncResource(ctx context.Context, res *resource.Resource) error
	BatchUpdate(ctx context.Context, store resource.Store, resources []*resource.Resource) error
	Validate(res *resource.Resource) error
	GetURN(res *resource.Resource) (string, error)
}

type ResourceMgr

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

func NewResourceManager

func NewResourceManager(repo ResourceStatusRepo, logger log.Logger) *ResourceMgr

func (*ResourceMgr) Backup

func (m *ResourceMgr) Backup(ctx context.Context, details *resource.Backup, resources []*resource.Resource) (*resource.BackupResult, error)

func (*ResourceMgr) BatchUpdate

func (m *ResourceMgr) BatchUpdate(ctx context.Context, store resource.Store, resources []*resource.Resource) error

func (*ResourceMgr) CreateResource

func (m *ResourceMgr) CreateResource(ctx context.Context, res *resource.Resource) error

func (*ResourceMgr) GetURN

func (m *ResourceMgr) GetURN(res *resource.Resource) (string, error)

func (*ResourceMgr) RegisterDatastore

func (m *ResourceMgr) RegisterDatastore(store resource.Store, dataStore DataStore)

func (*ResourceMgr) SyncResource

func (m *ResourceMgr) SyncResource(ctx context.Context, res *resource.Resource) error

func (*ResourceMgr) UpdateResource

func (m *ResourceMgr) UpdateResource(ctx context.Context, res *resource.Resource) error

func (*ResourceMgr) Validate

func (m *ResourceMgr) Validate(res *resource.Resource) error

type ResourceProvider

type ResourceProvider interface {
	GetResources(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) ([]*resource.Resource, error)
}

type ResourceRepository

type ResourceRepository interface {
	Create(ctx context.Context, res *resource.Resource) error
	Update(ctx context.Context, res *resource.Resource) error
	ChangeNamespace(ctx context.Context, res *resource.Resource, newTenant tenant.Tenant) error
	ReadByFullName(ctx context.Context, tnnt tenant.Tenant, store resource.Store, fullName string) (*resource.Resource, error)
	ReadAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Resource, error)
	GetResources(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) ([]*resource.Resource, error)
}

type ResourceService

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

func NewResourceService

func NewResourceService(
	logger log.Logger,
	repo ResourceRepository, downstreamRefresher DownstreamRefresher, mgr ResourceManager,
	eventHandler EventHandler,
) *ResourceService

func (ResourceService) ChangeNamespace

func (rs ResourceService) ChangeNamespace(ctx context.Context, datastore resource.Store, resourceFullName string, oldTenant, newTenant tenant.Tenant) error

func (ResourceService) Create

func (rs ResourceService) Create(ctx context.Context, incoming *resource.Resource) error

func (ResourceService) Deploy

func (rs ResourceService) Deploy(ctx context.Context, tnnt tenant.Tenant, store resource.Store, incomings []*resource.Resource, logWriter writer.LogWriter) error

func (ResourceService) Get

func (rs ResourceService) Get(ctx context.Context, tnnt tenant.Tenant, store resource.Store, resourceFullName string) (*resource.Resource, error)

func (ResourceService) GetAll

func (rs ResourceService) GetAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Resource, error)

func (ResourceService) SyncResources

func (rs ResourceService) SyncResources(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) (*resource.SyncResponse, error)

func (ResourceService) Update

func (rs ResourceService) Update(ctx context.Context, incoming *resource.Resource, logWriter writer.LogWriter) error

type ResourceStatusRepo

type ResourceStatusRepo interface {
	UpdateStatus(ctx context.Context, res ...*resource.Resource) error
}

type TenantDetailsGetter

type TenantDetailsGetter interface {
	GetDetails(ctx context.Context, tnnt tenant.Tenant) (*tenant.WithDetails, error)
}