taskcontroller

type CancelHandler struct{}

type CancelMessage struct {
	Revoker      string `json:"revoker"`
	PipelineName string `json:"pipeline_name"`
	TaskID       int64  `json:"task_id"`
	ReqID        string `json:"req_id"`
}

type ControllerI interface {
	// Init initializes the controller.
	Init(ctx context.Context) error

	// Stop stops process logics.
	Stop(ctx context.Context) error
}

type ExecHandler struct {
	AckID       int
	TaskPlugins map[config.TaskType]plugins.Initiator
}

type HookPayload struct {
	Owner string `json:"owner,omitempty"`
	Repo  string `json:"repo,omitempty"`
	Ref   string `json:"ref,omitempty"`
	IsPr  bool   `json:"is_pr,omitempty"`
}

type Pool struct {
	Tasks []*Task
	// contains filtered or unexported fields
}

type StatsMessage struct {
	Agent            string `json:"agent"`
	MessagesReceived uint64 `json:"messages_received"`
	MessagesFinished uint64 `json:"messages_finished"`
	MessagesRequeued uint64 `json:"messages_requeued"`
	Connections      int    `json:"connections"`
	StartTime        int64  `json:"start_time"`
	UpdateTime       int64  `json:"update_time"`
}

type Task struct {
	//Status holds task status
	Status config.Status
	// Err holds an error that occurred during a task. Its
	// result is only meaningful after Run has been called
	// for the pool that holds it.
	Err error
	// contains filtered or unexported fields
}