tasks

Documentation

Index

• Constants
• Variables
• func CollectAccounts(taskCtx plugin.SubTaskContext) errors.Error
• func CollectJobs(taskCtx plugin.SubTaskContext) errors.Error
• func CollectPipelines(taskCtx plugin.SubTaskContext) errors.Error
• func CollectProjects(taskCtx plugin.SubTaskContext) errors.Error
• func CollectWorkflows(taskCtx plugin.SubTaskContext) errors.Error
• func ConvertAccounts(taskCtx plugin.SubTaskContext) errors.Error
• func ConvertJobs(taskCtx plugin.SubTaskContext) errors.Error
• func ConvertProjects(taskCtx plugin.SubTaskContext) errors.Error
• func ConvertWorkflows(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractAccounts(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractJobs(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractPipelines(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractProjects(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractWorkflows(taskCtx plugin.SubTaskContext) errors.Error
• func NewCircleciApiClient(taskCtx plugin.TaskContext, connection *models.CircleciConnection) (*api.ApiAsyncClient, errors.Error)
• type CircleciOptions
  • func DecodeAndValidateTaskOptions(options map[string]interface{}) (*CircleciOptions, errors.Error)
• type CircleciPageTokenResp
• type CircleciTaskData
  • func CreateRawDataSubTaskArgs(taskCtx plugin.SubTaskContext, rawTable string) (*api.RawDataSubTaskArgs, *CircleciTaskData)

Constants

const RAW_JOB_TABLE = "circleci_api_jobs"

const RAW_PIPELINE_TABLE = "circleci_api_pipelines"

const RAW_PROJECT_TABLE = "circleci_api_projects"

const RAW_USER_TABLE = "circleci_api_users"

const RAW_WORKFLOW_TABLE = "circleci_api_workflows"

Variables

var CollectAccountsMeta = plugin.SubTaskMeta{
	Name:             "collectAccounts",
	EntryPoint:       CollectAccounts,
	EnabledByDefault: true,
	Description:      "collect circleci accounts",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CROSS},
}

var CollectJobsMeta = plugin.SubTaskMeta{
	Name:             "collectJobs",
	EntryPoint:       CollectJobs,
	EnabledByDefault: true,
	Description:      "collect circleci jobs",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var CollectPipelinesMeta = plugin.SubTaskMeta{
	Name:             "collectPipelines",
	EntryPoint:       CollectPipelines,
	EnabledByDefault: true,
	Description:      "collect circleci pipelines",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var CollectProjectsMeta = plugin.SubTaskMeta{
	Name:             "collectProjects",
	EntryPoint:       CollectProjects,
	EnabledByDefault: false,
	Description:      "collect circleci projects",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var CollectWorkflowsMeta = plugin.SubTaskMeta{
	Name:             "collectWorkflows",
	EntryPoint:       CollectWorkflows,
	EnabledByDefault: true,
	Description:      "collect circleci workflows",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var ConvertAccountsMeta = plugin.SubTaskMeta{
	Name:             "convertAccounts",
	EntryPoint:       ConvertAccounts,
	EnabledByDefault: true,
	Description:      "convert circleci account",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CROSS},
}

var ConvertJobsMeta = plugin.SubTaskMeta{
	Name:             "convertJobs",
	EntryPoint:       ConvertJobs,
	EnabledByDefault: true,
	Description:      "convert circleci project",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var ConvertProjectsMeta = plugin.SubTaskMeta{
	Name:             "convertProjects",
	EntryPoint:       ConvertProjects,
	EnabledByDefault: true,
	Description:      "convert circleci project",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var ConvertWorkflowsMeta = plugin.SubTaskMeta{
	Name:             "convertWorkflows",
	EntryPoint:       ConvertWorkflows,
	EnabledByDefault: true,
	Description:      "convert circleci workflows",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var ExtractAccountsMeta = plugin.SubTaskMeta{
	Name:             "extractAccounts",
	EntryPoint:       ExtractAccounts,
	EnabledByDefault: true,
	Description:      "Extract raw workspace data into tool layer table _tool_circleci_accounts",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CROSS},
}

var ExtractJobsMeta = plugin.SubTaskMeta{
	Name:             "extractJobs",
	EntryPoint:       ExtractJobs,
	EnabledByDefault: true,
	Description:      "Extract raw workspace data into tool layer table _tool_circleci_jobs",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var ExtractPipelinesMeta = plugin.SubTaskMeta{
	Name:             "extractPipelines",
	EntryPoint:       ExtractPipelines,
	EnabledByDefault: true,
	Description:      "Extract raw workspace data into tool layer table _tool_circleci_pipelines",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var ExtractProjectsMeta = plugin.SubTaskMeta{
	Name:             "extractProjects",
	EntryPoint:       ExtractProjects,
	EnabledByDefault: false,
	Description:      "Extract raw workspace data into tool layer table _tool_circleci_projects",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

var ExtractWorkflowsMeta = plugin.SubTaskMeta{
	Name:             "extractWorkflows",
	EntryPoint:       ExtractWorkflows,
	EnabledByDefault: true,
	Description:      "Extract raw workspace data into tool layer table _tool_circleci_workflows",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CICD},
}

Functions

func CollectAccounts

func CollectAccounts(taskCtx plugin.SubTaskContext) errors.Error

func CollectJobs

func CollectJobs(taskCtx plugin.SubTaskContext) errors.Error

func CollectPipelines

func CollectPipelines(taskCtx plugin.SubTaskContext) errors.Error

func CollectProjects

func CollectProjects(taskCtx plugin.SubTaskContext) errors.Error

func CollectWorkflows

func CollectWorkflows(taskCtx plugin.SubTaskContext) errors.Error

func ConvertAccounts

func ConvertAccounts(taskCtx plugin.SubTaskContext) errors.Error

func ConvertJobs

func ConvertJobs(taskCtx plugin.SubTaskContext) errors.Error

func ConvertProjects

func ConvertProjects(taskCtx plugin.SubTaskContext) errors.Error

func ConvertWorkflows

func ConvertWorkflows(taskCtx plugin.SubTaskContext) errors.Error

func ExtractAccounts

func ExtractAccounts(taskCtx plugin.SubTaskContext) errors.Error

func ExtractJobs

func ExtractJobs(taskCtx plugin.SubTaskContext) errors.Error

func ExtractPipelines

func ExtractPipelines(taskCtx plugin.SubTaskContext) errors.Error

func ExtractProjects

func ExtractProjects(taskCtx plugin.SubTaskContext) errors.Error

func ExtractWorkflows

func ExtractWorkflows(taskCtx plugin.SubTaskContext) errors.Error

func NewCircleciApiClient

func NewCircleciApiClient(taskCtx plugin.TaskContext, connection *models.CircleciConnection) (*api.ApiAsyncClient, errors.Error)

Types

type CircleciOptions

type CircleciOptions struct {
	ConnectionId            uint64                      `json:"connectionId"`
	ProjectSlug             string                      `json:"projectSlug"`
	PageSize                uint64                      `mapstruct:"pageSize"`
	ScopeConfigId           uint64                      `json:"scopeConfigId" mapstructure:"scopeConfigId,omitempty"`
	ScopeConfig             *models.CircleciScopeConfig `json:"scopeConfig" mapstructure:"scopeConfig,omitempty"`
	helper.CollectorOptions `mapstructure:",squash"`
}

func DecodeAndValidateTaskOptions

func DecodeAndValidateTaskOptions(options map[string]interface{}) (*CircleciOptions, errors.Error)

type CircleciPageTokenResp

type CircleciPageTokenResp[T any] struct {
	Items         T      `json:"items"`
	NextPageToken string `json:"next_page_token"`
}

type CircleciTaskData

type CircleciTaskData struct {
	Options       *CircleciOptions
	ApiClient     *helper.ApiAsyncClient
	RegexEnricher *helper.RegexEnricher
	Project       *models.CircleciProject
}

func CreateRawDataSubTaskArgs

func CreateRawDataSubTaskArgs(taskCtx plugin.SubTaskContext, rawTable string) (*api.RawDataSubTaskArgs, *CircleciTaskData)