Documentation
¶
Index ¶
- func Advanced(ctx context.Context, dataflow *models.Dataflow) error
- func All(ctx context.Context, dataflow *models.Dataflow) error
- func CalculateChanges(ctx context.Context, commits *[]models.Commit, ...) (*[]models.Change, error)
- func CalculateIncidents(ctx context.Context, deployment *models.Deployment, alerts *[]models.Alert) (*[]models.Incident, error)
- func CreateChanges(ctx context.Context, repositoryID primitive.ObjectID, ...) error
- func CreateIncidents(ctx context.Context, deployment *models.Deployment, alerts *[]models.Alert) error
- func GetFirstCommits(ctx context.Context, repositoryID primitive.ObjectID, ...) (*[]models.Commit, error)
- func ImportAlerts(ctx context.Context, deployment *models.Deployment) (*[]models.Alert, error)
- func ImportChanges(ctx context.Context, channel chan error, repositoryID primitive.ObjectID, ...)
- func ImportCommits(ctx context.Context, channel chan error, repository *models.Repository)
- func ImportIncidents(ctx context.Context, channel chan error, deployment *models.Deployment)
- func ImportPipelineRuns(ctx context.Context, channel chan error, pipeline *models.Pipeline)
- func Raw(ctx context.Context, dataflow *models.Dataflow) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Advanced ¶
Advanced gets and persists advanced historical data based on raw data for each defined source in a Dataflow.
func CalculateChanges ¶
func CalculateChanges(ctx context.Context, commits *[]models.Commit, pipelineRuns *[]models.PipelineRun) (*[]models.Change, error)
CalculateChanges calculates the changes from commits and pipeline runs.
func CalculateIncidents ¶
func CalculateIncidents(ctx context.Context, deployment *models.Deployment, alerts *[]models.Alert) (*[]models.Incident, error)
CalculateIncidents calculates the incidents for a given deployment.
func CreateChanges ¶
func CreateChanges(ctx context.Context, repositoryID primitive.ObjectID, pipelineID primitive.ObjectID) error
CreateChanges creates changes from commits and pipeline runs.
func CreateIncidents ¶
func CreateIncidents(ctx context.Context, deployment *models.Deployment, alerts *[]models.Alert) error
CreateIncidents calculates and creates the incidents for a given deployment.
func GetFirstCommits ¶
func GetFirstCommits(ctx context.Context, repositoryID primitive.ObjectID, pipelineRuns *[]models.PipelineRun) (*[]models.Commit, error)
GetFirstCommits returns the first commit of a change.
func ImportAlerts ¶
ImportAlerts gets the historical raw alert data.
func ImportChanges ¶
func ImportChanges(ctx context.Context, channel chan error, repositoryID primitive.ObjectID, pipelineID primitive.ObjectID)
ImportChanges gets and persists advanced historical data based on raw data for each defined source in a Dataflow.
func ImportCommits ¶
func ImportCommits(ctx context.Context, channel chan error, repository *models.Repository)
ImportCommits gets and persists historical data for each commit in a repository.
func ImportIncidents ¶
func ImportIncidents(ctx context.Context, channel chan error, deployment *models.Deployment)
ImportIncidents gets and persists historical data for each incident of a deployment. However, this functions does not persist the raw alerts, but rather aggregates them already to incidents. This is because the raw alerts are not relevant for the user, but the incidents are.
func ImportPipelineRuns ¶
ImportPipelineRuns gets and persists historical data for each run of a pipeline.
Types ¶
This section is empty.
Source Files