tasks

Documentation

Index

• Constants
• Variables
• func CollectApiBuilds(taskCtx core.SubTaskContext) error
• func CollectApiJobs(taskCtx core.SubTaskContext) error
• func CollectApiStages(taskCtx core.SubTaskContext) error
• func ConvertBuilds(taskCtx core.SubTaskContext) error
• func ConvertBuildsToCICD(taskCtx core.SubTaskContext) error
• func ConvertJobs(taskCtx core.SubTaskContext) error
• func ConvertStages(taskCtx core.SubTaskContext) error
• func CreateApiClient(taskCtx core.TaskContext, connection *models.JenkinsConnection) (*helper.ApiAsyncClient, error)
• func EnrichApiBuilds(taskCtx core.SubTaskContext) error
• func ExtractApiBuilds(taskCtx core.SubTaskContext) error
• func ExtractApiJobs(taskCtx core.SubTaskContext) error
• func ExtractApiStages(taskCtx core.SubTaskContext) error
• type JenkinsApiParams
• type JenkinsBuildWithRepo
• type JenkinsBuildWithRepoStage
• type JenkinsOptions
  • func DecodeAndValidateTaskOptions(options map[string]interface{}) (*JenkinsOptions, error)
• type JenkinsTaskData
• type SimpleBuild
• type SimpleJob

Constants

const RAW_BUILD_TABLE = "jenkins_api_builds"

const RAW_JOB_TABLE = "jenkins_api_jobs"

const RAW_STAGE_TABLE = "jenkins_api_stages"

Variables

var CollectApiBuildsMeta = core.SubTaskMeta{
	Name:             "collectApiBuilds",
	EntryPoint:       CollectApiBuilds,
	EnabledByDefault: true,
	Description:      "Collect builds data from jenkins api",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var CollectApiJobsMeta = core.SubTaskMeta{
	Name:             "collectApiJobs",
	EntryPoint:       CollectApiJobs,
	EnabledByDefault: true,
	Description:      "Collect jobs data from jenkins api",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var CollectApiStagesMeta = core.SubTaskMeta{
	Name:             "collectApiStages",
	EntryPoint:       CollectApiStages,
	EnabledByDefault: true,
	Description:      "Collect stages data from jenkins api",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var ConvertBuildsMeta = core.SubTaskMeta{
	Name:             "convertBuilds",
	EntryPoint:       ConvertBuilds,
	EnabledByDefault: true,
	Description:      "Convert tool layer table jenkins_builds into  domain layer table builds",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var ConvertBuildsToCICDMeta = core.SubTaskMeta{
	Name:             "convertBuildsToCICD",
	EntryPoint:       ConvertBuildsToCICD,
	EnabledByDefault: true,
	Description:      "convert builds to cicd",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var ConvertJobsMeta = core.SubTaskMeta{
	Name:             "convertJobs",
	EntryPoint:       ConvertJobs,
	EnabledByDefault: true,
	Description:      "Convert tool layer table jenkins_jobs into  domain layer table jobs",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var ConvertStagesMeta = core.SubTaskMeta{
	Name:             "convertStages",
	EntryPoint:       ConvertStages,
	EnabledByDefault: true,
	Description:      "convert jenkins_stages",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var EnrichApiBuildsMeta = core.SubTaskMeta{
	Name:             "enrichApiBuilds",
	EntryPoint:       EnrichApiBuilds,
	EnabledByDefault: true,
	Description:      "Enrich  jenkins_builds",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var ExtractApiBuildsMeta = core.SubTaskMeta{
	Name:             "extractApiBuilds",
	EntryPoint:       ExtractApiBuilds,
	EnabledByDefault: true,
	Description:      "Extract raw builds data into tool layer table jenkins_builds",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var ExtractApiJobsMeta = core.SubTaskMeta{
	Name:             "extractApiJobs",
	EntryPoint:       ExtractApiJobs,
	EnabledByDefault: true,
	Description:      "Extract raw jobs data into tool layer table jenkins_jobs",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

var ExtractApiStagesMeta = core.SubTaskMeta{
	Name:             "extractApiStages",
	EntryPoint:       ExtractApiStages,
	EnabledByDefault: true,
	Description:      "Extract raw stages data into tool layer table jenkins_stages",
	DomainTypes:      []string{core.DOMAIN_TYPE_CICD},
}

Functions

func CollectApiBuilds

func CollectApiBuilds(taskCtx core.SubTaskContext) error

func CollectApiJobs

func CollectApiJobs(taskCtx core.SubTaskContext) error

func CollectApiStages

func CollectApiStages(taskCtx core.SubTaskContext) error

func ConvertBuilds

func ConvertBuilds(taskCtx core.SubTaskContext) error

func ConvertBuildsToCICD

func ConvertBuildsToCICD(taskCtx core.SubTaskContext) error

func ConvertJobs

func ConvertJobs(taskCtx core.SubTaskContext) error

func ConvertStages

func ConvertStages(taskCtx core.SubTaskContext) error

func CreateApiClient

func CreateApiClient(taskCtx core.TaskContext, connection *models.JenkinsConnection) (*helper.ApiAsyncClient, error)

func EnrichApiBuilds

func EnrichApiBuilds(taskCtx core.SubTaskContext) error

func ExtractApiBuilds

func ExtractApiBuilds(taskCtx core.SubTaskContext) error

func ExtractApiJobs

func ExtractApiJobs(taskCtx core.SubTaskContext) error

func ExtractApiStages

func ExtractApiStages(taskCtx core.SubTaskContext) error

Types

type JenkinsApiParams

type JenkinsApiParams struct {
	ConnectionId uint64
}

type JenkinsBuildWithRepo

type JenkinsBuildWithRepo struct {
	// collected fields
	ConnectionId      uint64    `gorm:"primaryKey"`
	Duration          float64   // build time
	DisplayName       string    `gorm:"type:varchar(255)"` // "#7"
	EstimatedDuration float64   // EstimatedDuration
	Number            int64     `gorm:"primaryKey"`
	Result            string    // Result
	Timestamp         int64     // start time
	StartTime         time.Time // convered by timestamp
	CommitSha         string    `gorm:"type:varchar(255)"`
	Type              string    `gorm:"index;type:varchar(255)"`
	Class             string    `gorm:"index;type:varchar(255)" `
	TriggeredBy       string    `gorm:"type:varchar(255)"`
	Building          bool
	Branch            string `gorm:"type:varchar(255)"`
	RepoUrl           string `gorm:"type:varchar(255)"`
	HasStages         bool
	common.NoPKModel
}

type JenkinsBuildWithRepoStage

type JenkinsBuildWithRepoStage struct {
	// collected fields
	ConnectionId        uint64 `gorm:"primaryKey"`
	ID                  string `json:"id" gorm:"primaryKey;type:varchar(255)"`
	Name                string `json:"name" gorm:"type:varchar(255)"`
	ExecNode            string `json:"execNode" gorm:"type:varchar(255)"`
	CommitSha           string `gorm:"type:varchar(255)"`
	Result              string // Result
	Status              string `json:"status" gorm:"type:varchar(255)"`
	StartTimeMillis     int64  `json:"startTimeMillis"`
	DurationMillis      int    `json:"durationMillis"`
	PauseDurationMillis int    `json:"pauseDurationMillis"`
	Type                string `gorm:"index;type:varchar(255)"`
	BuildName           string `gorm:"primaryKey;type:varchar(255)"`
	Branch              string `gorm:"type:varchar(255)"`
	RepoUrl             string `gorm:"type:varchar(255)"`
	common.NoPKModel
}

type JenkinsOptions

type JenkinsOptions struct {
	ConnectionId uint64 `json:"connectionId"`
	Since        string
	Tasks        []string `json:"tasks,omitempty"`
}

func DecodeAndValidateTaskOptions

func DecodeAndValidateTaskOptions(options map[string]interface{}) (*JenkinsOptions, error)

type JenkinsTaskData

type JenkinsTaskData struct {
	Options    *JenkinsOptions
	ApiClient  *helper.ApiAsyncClient
	Connection *models.JenkinsConnection
	Since      *time.Time
}

type SimpleBuild

type SimpleBuild struct {
	JobName     string
	Number      string
	DisplayName string
}

type SimpleJob

type SimpleJob struct {
	Name string
	Path string
}