consumers

Documentation

Index

• type AnalyzePR
  • func NewAnalyzePR(pf processors.PullProcessorFactory, log logutil.Log, ...) *AnalyzePR
  • func (c AnalyzePR) Consume(ctx context.Context, repoOwner, repoName string, isPrivateRepo bool, ...) error
• type AnalyzeRepo
  • func NewAnalyzeRepo(rpf *processors.RepoProcessorFactory, log logutil.Log, ...) *AnalyzeRepo
  • func (c AnalyzeRepo) Consume(ctx context.Context, ...) error

Types

type AnalyzePR

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

func NewAnalyzePR

func NewAnalyzePR(pf processors.PullProcessorFactory, log logutil.Log, errTracker apperrors.Tracker, cfg config.Config, ec *experiments.Checker) *AnalyzePR

func (AnalyzePR) Consume

func (c AnalyzePR) Consume(ctx context.Context, repoOwner, repoName string,
	isPrivateRepo bool, githubAccessToken string, pullRequestNumber int,
	apiRequestID string, userID uint, analysisGUID, commitSHA string) error

type AnalyzeRepo

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

func NewAnalyzeRepo

func NewAnalyzeRepo(rpf *processors.RepoProcessorFactory, log logutil.Log, errTracker apperrors.Tracker, cfg config.Config, ec *experiments.Checker) *AnalyzeRepo

func (AnalyzeRepo) Consume

func (c AnalyzeRepo) Consume(ctx context.Context, repoName, analysisGUID, branch, privateAccessToken, commitSHA string) error