issues

Documentation

Index

• func ReplaceGlobals(repository Repository) func()
• type PostgresRepository
  • func (r *PostgresRepository) ChangeState(key string, fromStates []models.IssueState, toState models.IssueState) error
  • func (r *PostgresRepository) ChangeStateBetweenDates(key string, fromStates []models.IssueState, toState models.IssueState, ...) error
  • func (r *PostgresRepository) CountByKeyByPage(key string) (int, error)
  • func (r *PostgresRepository) CountByStateByPage(issueStates []string) (int, error)
  • func (r *PostgresRepository) CountByStateByPageBySituationIDs(issueStates []string, situationIDs []int64) (int, error)
  • func (r *PostgresRepository) Create(issue models.Issue) (int64, error)
  • func (r *PostgresRepository) DeleteOldIssueDetections(ts time.Time) error
  • func (r *PostgresRepository) DeleteOldIssueResolutions(ts time.Time) error
  • func (r *PostgresRepository) DeleteOldIssues(ts time.Time) error
  • func (r *PostgresRepository) Get(id int64) (models.Issue, bool, error)
  • func (r *PostgresRepository) GetAll() (map[int64]models.Issue, error)
  • func (r *PostgresRepository) GetAllBySituationIDs(situationIDs []int64) (map[int64]models.Issue, error)
  • func (r *PostgresRepository) GetByKeyByPage(key string, options models.SearchOptions) ([]models.Issue, int, error)
  • func (r *PostgresRepository) GetByStateByPage(issueStates []string, options models.SearchOptions) ([]models.Issue, int, error)
  • func (r *PostgresRepository) GetByStateByPageBySituationIDs(issueStates []string, options models.SearchOptions, situationIDs []int64) ([]models.Issue, int, error)
  • func (r *PostgresRepository) GetByStates(issueStates []string) (map[int64]models.Issue, error)
  • func (r *PostgresRepository) GetByStatesBySituationIDs(issueStates []string, situationIDs []int64) (map[int64]models.Issue, error)
  • func (r *PostgresRepository) GetCloseToTimeoutByKey(key string, firstSituationTS time.Time) (map[int64]models.Issue, error)
  • func (r *PostgresRepository) GetOpenAndDraftIssuesByKey(key string) (map[int64]models.Issue, error)
  • func (r *PostgresRepository) Update(tx *sqlx.Tx, id int64, issue models.Issue, user users.User) error
  • func (r *PostgresRepository) UpdateComment(dbClient *sqlx.DB, id int64, comment string) error
• type Repository
  • func NewPostgresRepository(dbClient *sqlx.DB) Repository
  • func R() Repository

Functions

func ReplaceGlobals

func ReplaceGlobals(repository Repository) func()

ReplaceGlobals affect a new repository to the global repository singleton

Types

type PostgresRepository

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

PostgresRepository is a repository containing the Issue definition based on a PSQL database and implementing the repository interface

func (*PostgresRepository) ChangeState

func (r *PostgresRepository) ChangeState(key string, fromStates []models.IssueState, toState models.IssueState) error

ChangeState method used to change the issues state with key and created_date between from and to

func (*PostgresRepository) ChangeStateBetweenDates

func (r *PostgresRepository) ChangeStateBetweenDates(key string, fromStates []models.IssueState, toState models.IssueState, from time.Time, to time.Time) error

ChangeStateBetweenDates method used to change the issues state with key and created_date between from and to

func (*PostgresRepository) CountByKeyByPage

func (r *PostgresRepository) CountByKeyByPage(key string) (int, error)

CountByKeyByPage method used to count all issues

func (*PostgresRepository) CountByStateByPage

func (r *PostgresRepository) CountByStateByPage(issueStates []string) (int, error)

CountByStateByPage method used to count all issues

func (*PostgresRepository) CountByStateByPageBySituationIDs

func (r *PostgresRepository) CountByStateByPageBySituationIDs(issueStates []string, situationIDs []int64) (int, error)

CountByStateByPage method used to count all issues

func (*PostgresRepository) Create

func (r *PostgresRepository) Create(issue models.Issue) (int64, error)

Create method used to create an issue

func (*PostgresRepository) DeleteOldIssueDetections

func (r *PostgresRepository) DeleteOldIssueDetections(ts time.Time) error

DeleteOldIssueDetections deletes issue detections based on the provided timestamp

func (*PostgresRepository) DeleteOldIssueResolutions

func (r *PostgresRepository) DeleteOldIssueResolutions(ts time.Time) error

DeleteOldIssueResolutions deletes issue resolutions based on the provided timestamp

func (*PostgresRepository) DeleteOldIssues

func (r *PostgresRepository) DeleteOldIssues(ts time.Time) error

DeleteOldIssues deletes issues based on the provided timestamp

func (*PostgresRepository) Get

func (r *PostgresRepository) Get(id int64) (models.Issue, bool, error)

Get use to retrieve an issue by id

func (*PostgresRepository) GetAll

func (r *PostgresRepository) GetAll() (map[int64]models.Issue, error)

GetAll method used to get all issues

func (*PostgresRepository) GetAllBySituationIDs

func (r *PostgresRepository) GetAllBySituationIDs(situationIDs []int64) (map[int64]models.Issue, error)

func (*PostgresRepository) GetByKeyByPage

func (r *PostgresRepository) GetByKeyByPage(key string, options models.SearchOptions) ([]models.Issue, int, error)

Get used to get issues by key

func (*PostgresRepository) GetByStateByPage

func (r *PostgresRepository) GetByStateByPage(issueStates []string, options models.SearchOptions) ([]models.Issue, int, error)

GetByStateByPage method used to get all issues

func (*PostgresRepository) GetByStateByPageBySituationIDs

func (r *PostgresRepository) GetByStateByPageBySituationIDs(issueStates []string, options models.SearchOptions, situationIDs []int64) ([]models.Issue, int, error)

GetByStateByPage method used to get all issues

func (*PostgresRepository) GetByStates

func (r *PostgresRepository) GetByStates(issueStates []string) (map[int64]models.Issue, error)

GetByStates method used to get all issues for an user

func (*PostgresRepository) GetByStatesBySituationIDs

func (r *PostgresRepository) GetByStatesBySituationIDs(issueStates []string, situationIDs []int64) (map[int64]models.Issue, error)

GetByStates method used to get all issues for an user

func (*PostgresRepository) GetCloseToTimeoutByKey

func (r *PostgresRepository) GetCloseToTimeoutByKey(key string, firstSituationTS time.Time) (map[int64]models.Issue, error)

GetCloseToTimeoutByKey get all issues that belong to the same situation and their creation time are within the timeout duration

func (*PostgresRepository) GetOpenAndDraftIssuesByKey

func (r *PostgresRepository) GetOpenAndDraftIssuesByKey(key string) (map[int64]models.Issue, error)

GetOpenAndDraftIssuesByKey get all issues that belong to the same situation in 'open' or 'draft' states if existed

func (*PostgresRepository) Update

func (r *PostgresRepository) Update(tx *sqlx.Tx, id int64, issue models.Issue, user users.User) error

Update method used to update an issue

func (*PostgresRepository) UpdateComment

func (r *PostgresRepository) UpdateComment(dbClient *sqlx.DB, id int64, comment string) error

UpdateComment method used to update an issue

type Repository

type Repository interface {
	Get(id int64) (models.Issue, bool, error)
	Create(issue models.Issue) (int64, error)

	Update(tx *sqlx.Tx, id int64, issue models.Issue, user users.User) error
	UpdateComment(dbClient *sqlx.DB, id int64, comment string) error
	GetAll() (map[int64]models.Issue, error)
	GetAllBySituationIDs(situationIDs []int64) (map[int64]models.Issue, error)
	GetByStates(issueStates []string) (map[int64]models.Issue, error)
	GetByStatesBySituationIDs(issueStates []string, situationIDs []int64) (map[int64]models.Issue, error)
	GetByStateByPage(issuesStates []string, options models.SearchOptions) ([]models.Issue, int, error)
	GetByStateByPageBySituationIDs(issuesStates []string, options models.SearchOptions, situationIDs []int64) ([]models.Issue, int, error)
	GetByKeyByPage(key string, options models.SearchOptions) ([]models.Issue, int, error)

	GetCloseToTimeoutByKey(key string, firstSituationTS time.Time) (map[int64]models.Issue, error)
	GetOpenAndDraftIssuesByKey(key string) (map[int64]models.Issue, error)

	ChangeState(key string, fromStates []models.IssueState, toState models.IssueState) error
	ChangeStateBetweenDates(key string, fromStates []models.IssueState, toState models.IssueState, from time.Time, to time.Time) error

	DeleteOldIssues(ts time.Time) error
	DeleteOldIssueDetections(ts time.Time) error
	DeleteOldIssueResolutions(ts time.Time) error
}

Repository is a storage interface which can be implemented by multiple backend (in-memory map, sql database, in-memory cache, file system, ...) It allows standard CRUD operation on Issues

func NewPostgresRepository

func NewPostgresRepository(dbClient *sqlx.DB) Repository

NewPostgresRepository returns a new instance of PostgresRepository

func R

func R() Repository

R is used to access the global repository singleton