tasks

Documentation

Index

• Constants
• Variables
• func CollectCommitter(taskCtx core.SubTaskContext) errors.Error
• func ExtractCommitter(taskCtx core.SubTaskContext) errors.Error
• func NewIclaApiClient(taskCtx core.TaskContext) (*helper.ApiAsyncClient, errors.Error)
• type IclaApiParams
• type IclaOptions
• type IclaTaskData

Constants

const ENDPOINT = "https://people.apache.org/"

const RAW_COMMITTER_TABLE = "icla_committer"

Variables

var CollectCommitterMeta = core.SubTaskMeta{
	Name:             "CollectCommitter",
	EntryPoint:       CollectCommitter,
	EnabledByDefault: true,
	Description:      "Collect Committer data from Icla api",
}

var ExtractCommitterMeta = core.SubTaskMeta{
	Name:             "ExtractCommitter",
	EntryPoint:       ExtractCommitter,
	EnabledByDefault: true,
	Description:      "Extract raw data into tool layer table {{ .plugin_name }}_{{ .extractor_data_name }}",
}

Functions

func CollectCommitter

func CollectCommitter(taskCtx core.SubTaskContext) errors.Error

func ExtractCommitter

func ExtractCommitter(taskCtx core.SubTaskContext) errors.Error

func NewIclaApiClient

func NewIclaApiClient(taskCtx core.TaskContext) (*helper.ApiAsyncClient, errors.Error)

Types

type IclaApiParams

type IclaApiParams struct {
}

type IclaOptions

type IclaOptions struct {
	// TODO add some custom options here if necessary
	// options means some custom params required by plugin running.
	// Such As How many rows do your want
	// You can use it in sub tasks and you need pass it in main.go and pipelines.
	Tasks []string `json:"tasks,omitempty"`
}

type IclaTaskData

type IclaTaskData struct {
	Options   *IclaOptions
	ApiClient *helper.ApiAsyncClient
}