redis

Documentation

Overview

Package redis handles our remote database layer.

Index

• type RedisDB
  • func New(hostname string, port int, password string, tlsEnabled bool, ...) (*RedisDB, error)
  • func NewWithClient(client *redis.Client, bucket string, globalBucket string) (*RedisDB, error)
  • func (r *RedisDB) CheckCommandLock(cmdName command.Name) (*command.Lock, error)
  • func (r *RedisDB) DeletePullStatus(pull models.PullRequest) error
  • func (r *RedisDB) GetLock(project models.Project, workspace string) (*models.ProjectLock, error)
  • func (r *RedisDB) GetPullStatus(pull models.PullRequest) (*models.PullStatus, error)
  • func (r *RedisDB) List() ([]models.ProjectLock, error)
  • func (r *RedisDB) LockCommand(cmdName command.Name, lockTime time.Time) (*command.Lock, error)
  • func (r *RedisDB) TryLock(newLock models.ProjectLock) (bool, models.ProjectLock, error)
  • func (r *RedisDB) Unlock(project models.Project, workspace string) (*models.ProjectLock, error)
  • func (r *RedisDB) UnlockByPull(repoFullName string, pullNum int) ([]models.ProjectLock, error)
  • func (r *RedisDB) UnlockCommand(cmdName command.Name) error
  • func (r *RedisDB) UpdateProjectStatus(pull models.PullRequest, workspace string, repoRelDir string, ...) error
  • func (r *RedisDB) UpdatePullWithResults(pull models.PullRequest, newResults []command.ProjectResult) (models.PullStatus, error)

Types

type RedisDB

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

Redis is a database using Redis 6

func New

func New(hostname string, port int, password string, tlsEnabled bool, insecureSkipVerify bool, db int) (*RedisDB, error)

func NewWithClient

func NewWithClient(client *redis.Client, bucket string, globalBucket string) (*RedisDB, error)

NewWithClient is used for testing.

func (*RedisDB) CheckCommandLock

func (r *RedisDB) CheckCommandLock(cmdName command.Name) (*command.Lock, error)

func (*RedisDB) DeletePullStatus

func (r *RedisDB) DeletePullStatus(pull models.PullRequest) error

func (*RedisDB) GetLock

func (r *RedisDB) GetLock(project models.Project, workspace string) (*models.ProjectLock, error)

GetLock returns a pointer to the lock for that project and workspace. If there is no lock, it returns a nil pointer.

func (*RedisDB) GetPullStatus

func (r *RedisDB) GetPullStatus(pull models.PullRequest) (*models.PullStatus, error)

func (*RedisDB) List

func (r *RedisDB) List() ([]models.ProjectLock, error)

List lists all current locks.

func (*RedisDB) LockCommand

func (r *RedisDB) LockCommand(cmdName command.Name, lockTime time.Time) (*command.Lock, error)

func (*RedisDB) TryLock

func (r *RedisDB) TryLock(newLock models.ProjectLock) (bool, models.ProjectLock, error)

TryLock attempts to create a new lock. If the lock is acquired, it will return true and the lock returned will be newLock. If the lock is not acquired, it will return false and the current lock that is preventing this lock from being acquired.

func (*RedisDB) Unlock

func (r *RedisDB) Unlock(project models.Project, workspace string) (*models.ProjectLock, error)

Unlock attempts to unlock the project and workspace. If there is no lock, then it will return a nil pointer. If there is a lock, then it will delete it, and then return a pointer to the deleted lock.

func (*RedisDB) UnlockByPull

func (r *RedisDB) UnlockByPull(repoFullName string, pullNum int) ([]models.ProjectLock, error)

UnlockByPull deletes all locks associated with that pull request and returns them.

func (*RedisDB) UnlockCommand

func (r *RedisDB) UnlockCommand(cmdName command.Name) error

func (*RedisDB) UpdateProjectStatus

func (r *RedisDB) UpdateProjectStatus(pull models.PullRequest, workspace string, repoRelDir string, newStatus models.ProjectPlanStatus) error

UpdatePullWithResults updates pull's status with the latest project results. It returns the new PullStatus object.

func (*RedisDB) UpdatePullWithResults

func (r *RedisDB) UpdatePullWithResults(pull models.PullRequest, newResults []command.ProjectResult) (models.PullStatus, error)