executions

Documentation

Index

• type PaginateExecutionsParams
• type Service
  • func New(env *config.Env, dbgen *dbgen.Queries, ints *integration.Integration, ...) *Service
  • func (s *Service) CreateExecution(ctx context.Context, params dbgen.ExecutionsServiceCreateExecutionParams) (dbgen.Execution, error)
  • func (s *Service) GetExecution(ctx context.Context, id uuid.UUID) (dbgen.ExecutionsServiceGetExecutionRow, error)
  • func (s *Service) GetExecutionDownloadLinkOrPath(ctx context.Context, executionID uuid.UUID) (bool, string, error)
  • func (s *Service) GetExecutionsQty(ctx context.Context) (dbgen.ExecutionsServiceGetExecutionsQtyRow, error)
  • func (s *Service) ListBackupExecutions(ctx context.Context, backupID uuid.UUID) ([]dbgen.Execution, error)
  • func (s *Service) PaginateExecutions(ctx context.Context, params PaginateExecutionsParams) (paginateutil.PaginateResponse, []dbgen.ExecutionsServicePaginateExecutionsRow, ...)
  • func (s *Service) RunExecution(ctx context.Context, backupID uuid.UUID) error
  • func (s *Service) SoftDeleteExecution(ctx context.Context, executionID uuid.UUID) error
  • func (s *Service) SoftDeleteExpiredExecutions()
  • func (s *Service) UpdateExecution(ctx context.Context, params dbgen.ExecutionsServiceUpdateExecutionParams) (dbgen.Execution, error)

Types

type PaginateExecutionsParams

type PaginateExecutionsParams struct {
	Page              int
	Limit             int
	DatabaseFilter    uuid.NullUUID
	DestinationFilter uuid.NullUUID
	BackupFilter      uuid.NullUUID
}

type Service

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

func New

func New(
	env *config.Env, dbgen *dbgen.Queries, ints *integration.Integration,
	webhooksService *webhooks.Service,
) *Service

func (*Service) CreateExecution

func (s *Service) CreateExecution(
	ctx context.Context, params dbgen.ExecutionsServiceCreateExecutionParams,
) (dbgen.Execution, error)

func (*Service) GetExecution

func (s *Service) GetExecution(
	ctx context.Context, id uuid.UUID,
) (dbgen.ExecutionsServiceGetExecutionRow, error)

func (*Service) GetExecutionDownloadLinkOrPath

func (s *Service) GetExecutionDownloadLinkOrPath(
	ctx context.Context, executionID uuid.UUID,
) (bool, string, error)

GetExecutionDownloadLinkOrPath returns a download link for the file associated with the given execution. If the execution is stored locally, the link will be a file path.

Returns a boolean indicating if the file is locally stored and the download link/path.

func (*Service) GetExecutionsQty

func (s *Service) GetExecutionsQty(
	ctx context.Context,
) (dbgen.ExecutionsServiceGetExecutionsQtyRow, error)

func (*Service) ListBackupExecutions

func (s *Service) ListBackupExecutions(
	ctx context.Context, backupID uuid.UUID,
) ([]dbgen.Execution, error)

func (*Service) PaginateExecutions

func (s *Service) PaginateExecutions(
	ctx context.Context, params PaginateExecutionsParams,
) (paginateutil.PaginateResponse, []dbgen.ExecutionsServicePaginateExecutionsRow, error)

func (*Service) RunExecution

func (s *Service) RunExecution(ctx context.Context, backupID uuid.UUID) error

RunExecution runs a backup execution

func (*Service) SoftDeleteExecution

func (s *Service) SoftDeleteExecution(
	ctx context.Context, executionID uuid.UUID,
) error

func (*Service) SoftDeleteExpiredExecutions

func (s *Service) SoftDeleteExpiredExecutions()

func (*Service) UpdateExecution

func (s *Service) UpdateExecution(
	ctx context.Context, params dbgen.ExecutionsServiceUpdateExecutionParams,
) (dbgen.Execution, error)