tasks

Documentation

Index

• func FetchProjectJobLogData(ctx context.Context, glab *gitlab.Client, job types.Job) ([]types.Section, []types.Metric, error)
• func FetchProjectsJobsLogData(ctx context.Context, glab *gitlab.Client, jobs []types.Job) ([]types.Section, []types.Metric, error)
• func FetchProjectsMergeRequests(ctx context.Context, glab *gitlab.Client, projectIds []int64, ...) ([]types.MergeRequest, error)
• func FetchProjectsMergeRequestsNotes(ctx context.Context, glab *gitlab.Client, projectIds []int64, ...) ([]types.MergeRequestNoteEvent, error)
• func FetchProjectsPipelines(ctx context.Context, glab *gitlab.Client, projectIds []int64, ...) ([]types.Pipeline, error)
• func FetchProjectsPipelinesJobs(ctx context.Context, glab *gitlab.Client, projectIds []int64, ...) ([]types.Job, error)
• func FetchProjectsPipelinesTestReports(ctx context.Context, glab *gitlab.Client, pipelines []types.Pipeline) ([]types.TestReport, []types.TestSuite, []types.TestCase, error)
• type Controller
  • func NewController(glab *gitlab.Client, exp *exporter.Exporter, cfg ControllerConfig) *Controller
  • func (c *Controller) CatchUp(ctx context.Context) error
  • func (c *Controller) ResolveProjects(ctx context.Context) (int, error)
  • func (c *Controller) Run(ctx context.Context) error
• type ControllerConfig
• type ProjectSettings
• type ProjectsSettings
  • func (c ProjectsSettings) ExportLogData(id int64) bool
  • func (c ProjectsSettings) ExportMergeRequests(id int64) bool
  • func (c ProjectsSettings) ExportTestReports(id int64) bool
  • func (c ProjectsSettings) ExportTraces(id int64) bool

Functions

func FetchProjectJobLogData

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

func FetchProjectsJobsLogData

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

func FetchProjectsMergeRequests

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

func FetchProjectsMergeRequestsNotes

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

func FetchProjectsPipelines

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

func FetchProjectsPipelinesJobs

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

func FetchProjectsPipelinesTestReports

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

Types

type Controller

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

func NewController

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

func (*Controller) CatchUp

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

func (*Controller) ResolveProjects

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

func (*Controller) Run

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

type ControllerConfig

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

	MaxWorkers int64
}

type ProjectSettings

type ProjectSettings struct {
	Id       int64
	FullPath string

	Export config.ProjectExport

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

type ProjectsSettings

type ProjectsSettings map[int64]ProjectSettings

func (ProjectsSettings) ExportLogData

func (c ProjectsSettings) ExportLogData(id int64) bool

func (ProjectsSettings) ExportMergeRequests

func (c ProjectsSettings) ExportMergeRequests(id int64) bool

func (ProjectsSettings) ExportTestReports

func (c ProjectsSettings) ExportTestReports(id int64) bool

func (ProjectsSettings) ExportTraces

func (c ProjectsSettings) ExportTraces(id int64) bool