service

Documentation

Index

• type Service
  • func New() (s *Service)
  • func (s *Service) BuildContributors(repos []*model.Repo) (err error)
  • func (s *Service) Close()
  • func (s *Service) CollectWachatUsers(c context.Context) (err error)
  • func (s *Service) HandleBuildContributors(c context.Context, repo *model.RepoInfo) (err error)
  • func (s *Service) HandleGitlabComment(c context.Context, event *model.HookComment) (err error)
  • func (s *Service) MergeRequest(c context.Context, event *model.HookMR) (err error)
  • func (s *Service) Ping(c context.Context) (err error)
  • func (s *Service) PipelineChanged(c context.Context, event *model.HookPipeline) (err error)
  • func (s *Service) ReportMRRoleInfo(c context.Context, authBranch string, event *model.HookMR) (err error)
  • func (s *Service) ReportSuperRoleInfo(c context.Context, superUsers []string, event *model.HookMR) (err error)
  • func (s *Service) ShowMRRoleInfo(c context.Context, authBranch string, repo *model.Repo, event *model.HookMR) (err error)
  • func (s *Service) SyncContacts(c context.Context) (err error)
  • func (s *Service) Wait()

Types

type Service

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

Service biz service def.

func New

func New() (s *Service)

New a DirService and return.

func (*Service) BuildContributors

func (s *Service) BuildContributors(repos []*model.Repo) (err error)

BuildContributors ...

func (*Service) Close

func (s *Service) Close()

Close close all dao.

func (*Service) CollectWachatUsers

func (s *Service) CollectWachatUsers(c context.Context) (err error)

CollectWachatUsers send required wechat visible users stored in memcache by email

func (*Service) HandleBuildContributors

func (s *Service) HandleBuildContributors(c context.Context, repo *model.RepoInfo) (err error)

HandleBuildContributors ...

func (*Service) HandleGitlabComment

func (s *Service) HandleGitlabComment(c context.Context, event *model.HookComment) (err error)

HandleGitlabComment handle comment webhook

func (*Service) MergeRequest

func (s *Service) MergeRequest(c context.Context, event *model.HookMR) (err error)

MergeRequest ...

func (*Service) Ping

func (s *Service) Ping(c context.Context) (err error)

Ping check dao health.

func (*Service) PipelineChanged

func (s *Service) PipelineChanged(c context.Context, event *model.HookPipeline) (err error)

PipelineChanged handle pipeline changed webhook

func (*Service) ReportMRRoleInfo

func (s *Service) ReportMRRoleInfo(c context.Context, authBranch string, event *model.HookMR) (err error)

ReportMRRoleInfo ...

func (*Service) ReportSuperRoleInfo

func (s *Service) ReportSuperRoleInfo(c context.Context, superUsers []string, event *model.HookMR) (err error)

ReportSuperRoleInfo ...

func (*Service) ShowMRRoleInfo

func (s *Service) ShowMRRoleInfo(c context.Context, authBranch string, repo *model.Repo, event *model.HookMR) (err error)

ShowMRRoleInfo ...

func (*Service) SyncContacts

func (s *Service) SyncContacts(c context.Context) (err error)

SyncContacts sync the wechat contacts

func (*Service) Wait

func (s *Service) Wait()

Wait wait all closed.