worker

Documentation

Index

• type GitLabPuller
  • func NewGitLabPuller(pullPeriod time.Duration, after time.Time, gitlab GitlabClient, ...) (*GitLabPuller, error)
  • func (g *GitLabPuller) Close()
  • func (g *GitLabPuller) Run()
• type GitlabClient
• type MergeRequestHandler
• type NotificationService
• type Notifications
  • func NewNotificationsWorker(team *ds.Team, svc NotificationService, slack SlackClient) *Notifications
  • func (n *Notifications) Run()
• type Policy
• type SlackClient
• type SlackMessage
• type SlackWorker
  • func NewSlackWorker(svc NotificationService, r SlackWorkerRepository, slack SlackClient, ...) *SlackWorker
  • func (w *SlackWorker) Close()
  • func (w *SlackWorker) Run()
• type SlackWorkerRepository

Types

type GitLabPuller

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

func NewGitLabPuller

func NewGitLabPuller(pullPeriod time.Duration, after time.Time, gitlab GitlabClient, handler MergeRequestHandler, projectID int) (*GitLabPuller, error)

func (*GitLabPuller) Close

func (g *GitLabPuller) Close()

func (*GitLabPuller) Run

func (g *GitLabPuller) Run()

type GitlabClient

type GitlabClient interface {
	MergeRequestsByProject(projectID int, createdAfter time.Time) ([]*ds.MergeRequest, error)
}

type MergeRequestHandler

type MergeRequestHandler func(mr *ds.MergeRequest) error

type NotificationService

type NotificationService interface {
	GetAuthoredReviewedMRs(team *ds.Team, users []*ds.User) (authorToMR, reviewerToMR map[int][]*ds.MergeRequest, err error)
	UserNotification(user *ds.User, team *ds.Team, authorToMR, reviewerToMR map[int][]*ds.MergeRequest) (message string, err error)
	TeamNotification(team *ds.Team, authorToMR, reviewerToMR map[int][]*ds.MergeRequest) (message string, err error)
}

type Notifications

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

func NewNotificationsWorker

func NewNotificationsWorker(team *ds.Team, svc NotificationService, slack SlackClient) *Notifications

func (*Notifications) Run

func (n *Notifications) Run()

type Policy

type Policy interface {
	IsApproved(team *ds.Team, mr *ds.MergeRequest) bool
}

type SlackClient

type SlackClient interface {
	SendMessage(recipientID string, message string) error
}

type SlackMessage

type SlackMessage struct {
	RecipientID string
	Text        string
}

type SlackWorker

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

func NewSlackWorker

func NewSlackWorker(svc NotificationService, r SlackWorkerRepository, slack SlackClient, events chan ds.UserEvent) *SlackWorker

func (*SlackWorker) Close

func (w *SlackWorker) Close()

func (*SlackWorker) Run

func (w *SlackWorker) Run()

type SlackWorkerRepository

type SlackWorkerRepository interface {
	UserBySlackID(slackID string) (*ds.User, *ds.Team, error)
}