postgres

Documentation

Index

• type PostgresTaskRepository
  • func NewPostgresTaskRepository(ctx context.Context) (*PostgresTaskRepository, error)
  • func (r *PostgresTaskRepository) Create(ctx context.Context, task *entities.Task) error
  • func (r *PostgresTaskRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *PostgresTaskRepository) FindAll(ctx context.Context, scope *entities.TaskScope) ([]*entities.Task, error)
  • func (r *PostgresTaskRepository) FindByID(ctx context.Context, id uuid.UUID, scope *entities.TaskScope) (*entities.Task, error)
  • func (r *PostgresTaskRepository) Update(ctx context.Context, task *entities.Task) error
• type PostgresTaskRunRepository
  • func NewPostgresTaskRunRepository(ctx context.Context) (*PostgresTaskRunRepository, error)
  • func (r *PostgresTaskRunRepository) Create(ctx context.Context, taskRun *entities.TaskRun) error
  • func (r *PostgresTaskRunRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *PostgresTaskRunRepository) FindAll(ctx context.Context) ([]*entities.TaskRun, error)
  • func (r *PostgresTaskRunRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.TaskRun, error)
  • func (r *PostgresTaskRunRepository) FindByTaskID(ctx context.Context, taskID uuid.UUID) ([]*entities.TaskRun, error)
  • func (r *PostgresTaskRunRepository) Update(ctx context.Context, taskRun *entities.TaskRun) error
• type PostgresUserRepository
  • func NewPostgresUserRepository(ctx context.Context) (*PostgresUserRepository, error)
  • func (r *PostgresUserRepository) Create(ctx context.Context, user *entities.User) error
  • func (r *PostgresUserRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *PostgresUserRepository) FindAll(ctx context.Context) ([]*entities.User, error)
  • func (r *PostgresUserRepository) FindByEmail(ctx context.Context, email string) (*entities.User, error)
  • func (r *PostgresUserRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.User, error)
  • func (r *PostgresUserRepository) Update(ctx context.Context, user *entities.User) error

Types

type PostgresTaskRepository

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

PostgresTaskRepository is a postgres task repository.

func NewPostgresTaskRepository

func NewPostgresTaskRepository(ctx context.Context) (*PostgresTaskRepository, error)

NewPostgresTaskRepository creates a new instance of PostgresTaskRepository.

func (*PostgresTaskRepository) Create

func (r *PostgresTaskRepository) Create(ctx context.Context, task *entities.Task) error

Create adds a new task to the repository.

func (*PostgresTaskRepository) Delete

func (r *PostgresTaskRepository) Delete(ctx context.Context, id uuid.UUID) error

Delete removes a task from the repository.

func (*PostgresTaskRepository) FindAll

func (r *PostgresTaskRepository) FindAll(ctx context.Context, scope *entities.TaskScope) ([]*entities.Task, error)

FindAll returns all tasks in the repository.

func (*PostgresTaskRepository) FindByID

func (r *PostgresTaskRepository) FindByID(ctx context.Context, id uuid.UUID, scope *entities.TaskScope) (*entities.Task, error)

FindByID returns the task with the specified ID.

func (*PostgresTaskRepository) Update

func (r *PostgresTaskRepository) Update(ctx context.Context, task *entities.Task) error

Update updates an existing task in the repository.

type PostgresTaskRunRepository

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

func NewPostgresTaskRunRepository

func NewPostgresTaskRunRepository(ctx context.Context) (*PostgresTaskRunRepository, error)

func (*PostgresTaskRunRepository) Create

func (r *PostgresTaskRunRepository) Create(ctx context.Context, taskRun *entities.TaskRun) error

func (*PostgresTaskRunRepository) Delete

func (r *PostgresTaskRunRepository) Delete(ctx context.Context, id uuid.UUID) error

func (*PostgresTaskRunRepository) FindAll

func (r *PostgresTaskRunRepository) FindAll(ctx context.Context) ([]*entities.TaskRun, error)

func (*PostgresTaskRunRepository) FindByID

func (r *PostgresTaskRunRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.TaskRun, error)

func (*PostgresTaskRunRepository) FindByTaskID

func (r *PostgresTaskRunRepository) FindByTaskID(ctx context.Context, taskID uuid.UUID) ([]*entities.TaskRun, error)

func (*PostgresTaskRunRepository) Update

func (r *PostgresTaskRunRepository) Update(ctx context.Context, taskRun *entities.TaskRun) error

type PostgresUserRepository

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

func NewPostgresUserRepository

func NewPostgresUserRepository(ctx context.Context) (*PostgresUserRepository, error)

func (*PostgresUserRepository) Create

func (r *PostgresUserRepository) Create(ctx context.Context, user *entities.User) error

func (*PostgresUserRepository) Delete

func (r *PostgresUserRepository) Delete(ctx context.Context, id uuid.UUID) error

func (*PostgresUserRepository) FindAll

func (r *PostgresUserRepository) FindAll(ctx context.Context) ([]*entities.User, error)

func (*PostgresUserRepository) FindByEmail

func (r *PostgresUserRepository) FindByEmail(ctx context.Context, email string) (*entities.User, error)

func (*PostgresUserRepository) FindByID

func (r *PostgresUserRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.User, error)

func (*PostgresUserRepository) Update

func (r *PostgresUserRepository) Update(ctx context.Context, user *entities.User) error