repository

Documentation

Index

• type Repository
  • func New(rootCtx context.Context, conn *mongo.Client, databaseName string) (*Repository, error)
  • func (r *Repository) CommitByID(id string) (*ds.Commit, error)
  • func (r *Repository) CommitByProject(projectID int) ([]*ds.Commit, error)
  • func (r *Repository) MergeRequestByID(id int) (*ds.MergeRequest, error)
  • func (r *Repository) MergeRequestsByAuthor(authorID []int) ([]*ds.MergeRequest, error)
  • func (r *Repository) MergeRequestsByProject(projectID int) ([]*ds.MergeRequest, error)
  • func (r *Repository) MergeRequestsByReviewer(reviewerID []int) ([]*ds.MergeRequest, error)
  • func (r *Repository) PolicyMetadata(mr *ds.MergeRequest, team *ds.Team, policy ds.PolicyName) (bson.Raw, error)
  • func (r *Repository) Projects() ([]*ds.Project, error)
  • func (r *Repository) Teams() ([]*ds.Team, error)
  • func (r *Repository) UpdatePolicyMetadata(mr *ds.MergeRequest, team *ds.Team, policy ds.PolicyName, d bson.Raw) error
  • func (r *Repository) UpsertCommit(commit *ds.Commit) error
  • func (r *Repository) UpsertMergeRequest(mr *ds.MergeRequest) error
  • func (r *Repository) UserBySlackID(slackID string) (*ds.User, *ds.Team, error)

Types

type Repository

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

func New

func New(rootCtx context.Context, conn *mongo.Client, databaseName string) (*Repository, error)

func (*Repository) CommitByID

func (r *Repository) CommitByID(id string) (*ds.Commit, error)

func (*Repository) CommitByProject

func (r *Repository) CommitByProject(projectID int) ([]*ds.Commit, error)

func (*Repository) MergeRequestByID

func (r *Repository) MergeRequestByID(id int) (*ds.MergeRequest, error)

func (*Repository) MergeRequestsByAuthor

func (r *Repository) MergeRequestsByAuthor(authorID []int) ([]*ds.MergeRequest, error)

func (*Repository) MergeRequestsByProject

func (r *Repository) MergeRequestsByProject(projectID int) ([]*ds.MergeRequest, error)

func (*Repository) MergeRequestsByReviewer

func (r *Repository) MergeRequestsByReviewer(reviewerID []int) ([]*ds.MergeRequest, error)

func (*Repository) PolicyMetadata

func (r *Repository) PolicyMetadata(mr *ds.MergeRequest, team *ds.Team, policy ds.PolicyName) (bson.Raw, error)

func (*Repository) Projects

func (r *Repository) Projects() ([]*ds.Project, error)

func (*Repository) Teams

func (r *Repository) Teams() ([]*ds.Team, error)

func (*Repository) UpdatePolicyMetadata

func (r *Repository) UpdatePolicyMetadata(mr *ds.MergeRequest, team *ds.Team, policy ds.PolicyName, d bson.Raw) error

func (*Repository) UpsertCommit

func (r *Repository) UpsertCommit(commit *ds.Commit) error

func (*Repository) UpsertMergeRequest

func (r *Repository) UpsertMergeRequest(mr *ds.MergeRequest) error

func (*Repository) UserBySlackID

func (r *Repository) UserBySlackID(slackID string) (*ds.User, *ds.Team, error)