tasks

package
v0.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 20, 2025 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FetchProjectJobLogData added in v0.10.0

func FetchProjectJobLogData(ctx context.Context, glab *gitlab.Client, job types.Job) ([]types.Section, []types.Metric, error)

func FetchProjectPipelineJunitReports added in v0.12.0

func FetchProjectPipelineJunitReports(ctx context.Context, glab *gitlab.Client, projectPath string, pipelineIid string) ([]types.TestReport, []types.TestSuite, []types.TestCase, error)

func FetchProjectsJobsLogData added in v0.10.0

func FetchProjectsJobsLogData(ctx context.Context, glab *gitlab.Client, jobs []types.Job) ([]types.Section, []types.Metric, error)

func FetchProjectsMergeRequests added in v0.10.0

func FetchProjectsMergeRequests(ctx context.Context, glab *gitlab.Client, projectIds []int64, updatedAfter *time.Time, updatedBefore *time.Time) ([]types.MergeRequest, error)

func FetchProjectsMergeRequestsNotes added in v0.10.0

func FetchProjectsMergeRequestsNotes(ctx context.Context, glab *gitlab.Client, projectIds []int64, updatedAfter *time.Time, updatedBefore *time.Time) ([]types.MergeRequestNoteEvent, error)

func FetchProjectsPipelines added in v0.10.0

func FetchProjectsPipelines(ctx context.Context, glab *gitlab.Client, projectIds []int64, updatedAfter *time.Time, updatedBefore *time.Time) ([]types.Pipeline, error)

func FetchProjectsPipelinesJobs added in v0.10.0

func FetchProjectsPipelinesJobs(ctx context.Context, glab *gitlab.Client, projectIds []int64, updatedAfter *time.Time, updatedBefore *time.Time) ([]types.Job, error)

func FetchProjectsPipelinesJunitReports added in v0.12.0

func FetchProjectsPipelinesJunitReports(ctx context.Context, glab *gitlab.Client, projectPipelines map[string][]string) ([]types.TestReport, []types.TestSuite, []types.TestCase, error)

func FetchProjectsPipelinesTestReports added in v0.10.0

func FetchProjectsPipelinesTestReports(ctx context.Context, glab *gitlab.Client, pipelines []types.Pipeline) ([]types.TestReport, []types.TestSuite, []types.TestCase, error)

Types

type Controller added in v0.10.0

type Controller struct {
	GitLab   *gitlab.Client
	Exporter *exporter.Exporter
	// contains filtered or unexported fields
}

func NewController added in v0.10.0

func NewController(glab *gitlab.Client, exp *exporter.Exporter, cfg ControllerConfig) *Controller

func (*Controller) CatchUp added in v0.10.0

func (c *Controller) CatchUp(ctx context.Context) error

func (*Controller) ResolveProjects added in v0.10.0

func (c *Controller) ResolveProjects(ctx context.Context) (int, error)

func (*Controller) Run added in v0.10.0

func (c *Controller) Run(ctx context.Context) error

type ControllerConfig added in v0.10.0

type ControllerConfig struct {
	GitLab     config.GitLab
	Projects   []config.Project
	Namespaces []config.Namespace

	ResolveInterval time.Duration
	ExportInterval  time.Duration
	CatchUpInterval time.Duration
}

type ProjectSettings added in v0.10.0

type ProjectSettings struct {
	Id       int64
	FullPath string

	Export config.ProjectExport

	CatchUp struct {
		Enabled       bool
		UpdatedAfter  *time.Time
		UpdatedBefore *time.Time
	}
}

type ProjectsSettings added in v0.10.0

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

func (*ProjectsSettings) Add added in v0.11.0

func (ps *ProjectsSettings) Add(id int64, settings ProjectSettings) bool

func (*ProjectsSettings) Delete added in v0.11.0

func (ps *ProjectsSettings) Delete(id int64) bool

func (*ProjectsSettings) ExportJunitReports added in v0.12.0

func (ps *ProjectsSettings) ExportJunitReports(id int64) bool

func (*ProjectsSettings) ExportLogData added in v0.10.0

func (ps *ProjectsSettings) ExportLogData(id int64) bool

func (*ProjectsSettings) ExportMergeRequests added in v0.10.0

func (ps *ProjectsSettings) ExportMergeRequests(id int64) bool

func (*ProjectsSettings) ExportTestReports added in v0.10.0

func (ps *ProjectsSettings) ExportTestReports(id int64) bool

func (*ProjectsSettings) ExportTraces added in v0.10.0

func (ps *ProjectsSettings) ExportTraces(id int64) bool

func (*ProjectsSettings) GetBatches added in v0.11.0

func (ps *ProjectsSettings) GetBatches(size int, filter func(ProjectSettings) bool) [][]ProjectSettings

func (*ProjectsSettings) Len added in v0.11.0

func (ps *ProjectsSettings) Len() int

func (*ProjectsSettings) Set added in v0.11.0

func (ps *ProjectsSettings) Set(m map[int64]ProjectSettings)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL