internal

Documentation

Index

• func MaybeTriggerBisectionWorkflow(ctx workflow.Context, input *workflows.MaybeTriggerBisectionParam) (*workflows.MaybeTriggerBisectionResult, error)
• func ParsePinpointCommit(pinpoint_commit *pinpoint_proto.Commit) (*culprit_proto.Commit, error)
• func ProcessCulpritWorkflow(ctx workflow.Context, input *workflows.ProcessCulpritParam) (*workflows.ProcessCulpritResult, error)
• type AnomalyGroupServiceActivity
  • func (agsa *AnomalyGroupServiceActivity) FindTopAnomalies(ctx context.Context, anomalygroupServiceUrl string, ...) (*pb.FindTopAnomaliesResponse, error)
  • func (agsa *AnomalyGroupServiceActivity) LoadAnomalyGroupByID(ctx context.Context, anomalygroupServiceUrl string, ...) (*pb.LoadAnomalyGroupByIDResponse, error)
  • func (agsa *AnomalyGroupServiceActivity) UpdateAnomalyGroup(ctx context.Context, anomalygroupServiceUrl string, ...) (*pb.UpdateAnomalyGroupResponse, error)
• type CulpritServiceActivity
  • func (csa *CulpritServiceActivity) NotifyUserOfAnomaly(ctx context.Context, culpritServiceUrl string, ...) (*pb.NotifyUserOfAnomalyResponse, error)
  • func (csa *CulpritServiceActivity) NotifyUserOfCulprit(ctx context.Context, culpritServiceUrl string, ...) (*pb.NotifyUserOfCulpritResponse, error)
  • func (csa *CulpritServiceActivity) PeristCulprit(ctx context.Context, culpritServiceUrl string, req *pb.PersistCulpritRequest) (*pb.PersistCulpritResponse, error)
• type GerritServiceActivity
  • func (gsa *GerritServiceActivity) GetCommitRevision(ctx context.Context, commitPostion int64) (string, error)

Functions

func MaybeTriggerBisectionWorkflow

func MaybeTriggerBisectionWorkflow(ctx workflow.Context, input *workflows.MaybeTriggerBisectionParam) (*workflows.MaybeTriggerBisectionResult, error)

MaybeTriggerBisectionWorkflow is the entry point for the workflow which handles anomaly group processing. It is responsible for triggering a bisection if the anomalygroup's group action = BISECT. If group action = REPORT, files a bug notifying user of the anomalies.

func ParsePinpointCommit

func ParsePinpointCommit(pinpoint_commit *pinpoint_proto.Commit) (*culprit_proto.Commit, error)

ParsePinpointCommit parse a single pinpoint commit type into culprit commit type. We assume pinpoint_culprit.repository in a format like:

https://{host}/{project}.git

func ProcessCulpritWorkflow

func ProcessCulpritWorkflow(ctx workflow.Context, input *workflows.ProcessCulpritParam) (*workflows.ProcessCulpritResult, error)

Handles processing of identified culprits. Stores culprit data in a persistant storage and notifies users accordingly.

Types

type AnomalyGroupServiceActivity

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

func (*AnomalyGroupServiceActivity) FindTopAnomalies

func (agsa *AnomalyGroupServiceActivity) FindTopAnomalies(ctx context.Context, anomalygroupServiceUrl string, req *pb.FindTopAnomaliesRequest) (*pb.FindTopAnomaliesResponse, error)

func (*AnomalyGroupServiceActivity) LoadAnomalyGroupByID

func (agsa *AnomalyGroupServiceActivity) LoadAnomalyGroupByID(ctx context.Context, anomalygroupServiceUrl string, req *pb.LoadAnomalyGroupByIDRequest) (*pb.LoadAnomalyGroupByIDResponse, error)

func (*AnomalyGroupServiceActivity) UpdateAnomalyGroup

func (agsa *AnomalyGroupServiceActivity) UpdateAnomalyGroup(ctx context.Context, anomalygroupServiceUrl string, req *pb.UpdateAnomalyGroupRequest) (*pb.UpdateAnomalyGroupResponse, error)

type CulpritServiceActivity

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

func (*CulpritServiceActivity) NotifyUserOfAnomaly

func (csa *CulpritServiceActivity) NotifyUserOfAnomaly(ctx context.Context, culpritServiceUrl string, req *pb.NotifyUserOfAnomalyRequest) (*pb.NotifyUserOfAnomalyResponse, error)

func (*CulpritServiceActivity) NotifyUserOfCulprit

func (csa *CulpritServiceActivity) NotifyUserOfCulprit(ctx context.Context, culpritServiceUrl string, req *pb.NotifyUserOfCulpritRequest) (*pb.NotifyUserOfCulpritResponse, error)

func (*CulpritServiceActivity) PeristCulprit

func (csa *CulpritServiceActivity) PeristCulprit(ctx context.Context, culpritServiceUrl string, req *pb.PersistCulpritRequest) (*pb.PersistCulpritResponse, error)

type GerritServiceActivity

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

func (*GerritServiceActivity) GetCommitRevision

func (gsa *GerritServiceActivity) GetCommitRevision(ctx context.Context, commitPostion int64) (string, error)