resource

Documentation

Index

• func FromModelToResource(r *Resource) (*resource.Resource, error)
• type Backup
  • func NewBackup(b *resource.Backup) Backup
  • func (b Backup) ToResourceBackup() (*resource.Backup, error)
• type BackupRepository
  • func NewBackupRepository(pool *pgxpool.Pool) *BackupRepository
  • func (repo BackupRepository) Create(ctx context.Context, resourceBackup *resource.Backup) error
  • func (repo BackupRepository) GetAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Backup, error)
  • func (repo BackupRepository) GetByID(ctx context.Context, id resource.BackupID) (*resource.Backup, error)
• type Change
• type ChangeLog
  • func FromChangelogRow(row pgx.Row) (*ChangeLog, error)
• type Repository
  • func NewRepository(pool *pgxpool.Pool) *Repository
  • func (r Repository) ChangeNamespace(ctx context.Context, res *resource.Resource, newTenant tenant.Tenant) error
  • func (r Repository) Create(ctx context.Context, resourceModel *resource.Resource) error
  • func (r Repository) Delete(ctx context.Context, resourceModel *resource.Resource) error
  • func (r Repository) GetChangelogs(ctx context.Context, projectName tenant.ProjectName, ...) ([]*resource.ChangeLog, error)
  • func (r Repository) GetResources(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) ([]*resource.Resource, error)
  • func (r Repository) ReadAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store, onlyActive bool) ([]*resource.Resource, error)
  • func (r Repository) ReadByFullName(ctx context.Context, tnnt tenant.Tenant, store resource.Store, fullName string, ...) (*resource.Resource, error)
  • func (r Repository) ReadByURN(ctx context.Context, tnnt tenant.Tenant, urn resource.URN) (*resource.Resource, error)
  • func (r Repository) Update(ctx context.Context, resourceModel *resource.Resource) error
  • func (r Repository) UpdateStatus(ctx context.Context, resources ...*resource.Resource) error
• type Resource
  • func FromResourceToModel(r *resource.Resource) *Resource

Functions

func FromModelToResource

func FromModelToResource(r *Resource) (*resource.Resource, error)

Types

type Backup

type Backup struct {
	ID uuid.UUID

	Store         string
	ProjectName   string
	NamespaceName string

	Description   string
	ResourceNames pq.StringArray

	Config map[string]string

	CreatedAt time.Time
	UpdatedAt time.Time
}

func NewBackup

func NewBackup(b *resource.Backup) Backup

func (Backup) ToResourceBackup

func (b Backup) ToResourceBackup() (*resource.Backup, error)

type BackupRepository

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

func NewBackupRepository

func NewBackupRepository(pool *pgxpool.Pool) *BackupRepository

func (BackupRepository) Create

func (repo BackupRepository) Create(ctx context.Context, resourceBackup *resource.Backup) error

func (BackupRepository) GetAll

func (repo BackupRepository) GetAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Backup, error)

func (BackupRepository) GetByID

func (repo BackupRepository) GetByID(ctx context.Context, id resource.BackupID) (*resource.Backup, error)

type Change

type Change struct {
	Property string `json:"attribute_name"`
	Diff     string `json:"diff"`
}

type ChangeLog

type ChangeLog struct {
	Change []Change
	Type   string
	Time   time.Time
}

func FromChangelogRow

func FromChangelogRow(row pgx.Row) (*ChangeLog, error)

type Repository

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

func NewRepository

func NewRepository(pool *pgxpool.Pool) *Repository

func (Repository) ChangeNamespace

func (r Repository) ChangeNamespace(ctx context.Context, res *resource.Resource, newTenant tenant.Tenant) error

func (Repository) Create

func (r Repository) Create(ctx context.Context, resourceModel *resource.Resource) error

func (Repository) Delete

func (r Repository) Delete(ctx context.Context, resourceModel *resource.Resource) error

func (Repository) GetChangelogs

func (r Repository) GetChangelogs(ctx context.Context, projectName tenant.ProjectName, resourceName resource.Name) ([]*resource.ChangeLog, error)

func (Repository) GetResources

func (r Repository) GetResources(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) ([]*resource.Resource, error)

func (Repository) ReadAll

func (r Repository) ReadAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store, onlyActive bool) ([]*resource.Resource, error)

func (Repository) ReadByFullName

func (r Repository) ReadByFullName(ctx context.Context, tnnt tenant.Tenant, store resource.Store, fullName string, onlyActive bool) (*resource.Resource, error)

func (Repository) ReadByURN

func (r Repository) ReadByURN(ctx context.Context, tnnt tenant.Tenant, urn resource.URN) (*resource.Resource, error)

func (Repository) Update

func (r Repository) Update(ctx context.Context, resourceModel *resource.Resource) error

func (Repository) UpdateStatus

func (r Repository) UpdateStatus(ctx context.Context, resources ...*resource.Resource) error

type Resource

type Resource struct {
	ID uuid.UUID

	FullName string
	Kind     string
	Store    string

	ProjectName   string
	NamespaceName string

	Metadata json.RawMessage
	Spec     map[string]any

	URN string

	Status string

	CreatedAt time.Time
	UpdatedAt time.Time
}

func FromResourceToModel

func FromResourceToModel(r *resource.Resource) *Resource