aggregate

Documentation

Index

• func All(ctx context.Context, dataflow *models.Dataflow) error
• func CalculateChangesPerDays(ctx context.Context, changes *[]models.Change) (*[]models.ChangesPerDay, error)
• func CalculateIncidentsPerDays(ctx context.Context, incidents *[]models.Incident) (*[]models.IncidentsPerDay, error)
• func CalculatePipelineRunsPerDays(ctx context.Context, pipelineRuns *[]models.PipelineRun) (*[]models.PipelineRunsPerDay, error)
• func CreateChangesPerDays(ctx context.Context, channel chan error, repositoryID primitive.ObjectID, ...)
• func CreateIncidentsPerDays(ctx context.Context, channel chan error, deploymentID primitive.ObjectID)
• func CreatePipelineRunsPerDays(ctx context.Context, channel chan error, pipelineID primitive.ObjectID)

Functions

func All

func All(ctx context.Context, dataflow *models.Dataflow) error

All aggregates the data per day.

func CalculateChangesPerDays

func CalculateChangesPerDays(ctx context.Context, changes *[]models.Change) (*[]models.ChangesPerDay, error)

CalculateChangesPerDays calculates the changes per day. If no change is found for a date, no aggregate will be created for that date!

func CalculateIncidentsPerDays

func CalculateIncidentsPerDays(ctx context.Context, incidents *[]models.Incident) (*[]models.IncidentsPerDay, error)

CalculateIncidentsPerDays calculates the incidents per day. If no incident is found for a date, no aggregate will be created for that date!

func CalculatePipelineRunsPerDays

func CalculatePipelineRunsPerDays(ctx context.Context, pipelineRuns *[]models.PipelineRun) (*[]models.PipelineRunsPerDay, error)

CalculatePipelineRunsPerDays calculates the pipeline runs per day. If no pipeline run is found for a date, no aggregate will be created for that date!

func CreateChangesPerDays

func CreateChangesPerDays(ctx context.Context, channel chan error, repositoryID primitive.ObjectID, pipelineID primitive.ObjectID)

CreateChangesPerDays creates changes per days from commits and pipeline runs.

func CreateIncidentsPerDays

func CreateIncidentsPerDays(ctx context.Context, channel chan error, deploymentID primitive.ObjectID)

CreateIncidentsPerDays calculates and creates the incidents for each day.

func CreatePipelineRunsPerDays

func CreatePipelineRunsPerDays(ctx context.Context, channel chan error, pipelineID primitive.ObjectID)

CreatePipelineRunsPerDays calculates and creates the pipeline runs for each day.