manager

type CloudManager interface {
	CreateCloud(*api.Cloud) (*api.Cloud, error)
	ListClouds() ([]api.Cloud, error)
	DeleteCloud(name string) error
	PingCloud(name string) error
	ListWorkers(name string, extendInfo string) ([]api.WorkerInstance, error)
}

type EventManager interface {
	GetEvent(id string) (*api.Event, error)
	SetEvent(event *api.Event) (*api.Event, error)
}

type PipelineManager interface {
	CreatePipeline(projectName string, pipeline *api.Pipeline) (*api.Pipeline, error)
	GetPipeline(projectName string, pipelineName string, recentCount, recentSuccessCount, recentFailedCount int) (*api.Pipeline, error)
	GetPipelineByID(id string) (*api.Pipeline, error)
	ListPipelines(projectName string, queryParams api.QueryParams, recentCount, recentSuccessCount, recentFailedCount int) ([]api.Pipeline, int, error)
	UpdatePipeline(projectName string, pipelineName string, newPipeline *api.Pipeline) (*api.Pipeline, error)
	DeletePipeline(projectName string, pipelineName string) error
	ClearPipelinesOfProject(projectName string) error
	GetStatistics(projectName, pipelineName string, start, end time.Time) (*api.PipelineStatusStats, error)
	FindSVNHooksPipelines(repoid string) ([]api.Pipeline, error)
}

type PipelineRecordManager interface {
	CreatePipelineRecord(pipelineRecord *api.PipelineRecord) (*api.PipelineRecord, error)
	GetPipelineRecord(pipelineRecordID string) (*api.PipelineRecord, error)
	ListPipelineRecords(projectName string, pipelineName string, queryParams api.QueryParams) ([]api.PipelineRecord, int, error)
	UpdatePipelineRecord(pipelineRecordID string, pipelineRecord *api.PipelineRecord) (*api.PipelineRecord, error)
	DeletePipelineRecord(pipelineRecordID string) error
	ClearPipelineRecordsOfPipeline(pipelineID string) error
	GetPipelineRecordLogs(pipelineRecordID, stage, task string) (string, error)
	GetPipelineRecordTestResult(pipelineRecordID, fileName string) (string, error)
	ListPipelineRecordTestResults(pipelineRecordID string) ([]*api.TestResult, int, error)
	GetPipelineRecordLogStream(pipelineRecordID, stage, task string, ws *websocket.Conn) error
	ReceivePipelineRecordLogStream(pipelineRecordID, stage, task string, ws *websocket.Conn) error
	ReceivePipelineRecordTestResult(pipelineRecordID, fileName string, reader io.Reader) error
}

type ProjectManager interface {
	CreateProject(project *api.Project) (*api.Project, error)
	GetProject(projectName string) (*api.Project, error)
	GetProjectByID(id string) (*api.Project, error)
	ListProjects(queryParams api.QueryParams) ([]api.Project, int, error)
	UpdateProject(projectName string, newProject *api.Project) (*api.Project, error)
	DeleteProject(projectName string) error
	ListRepos(projectName string) ([]api.Repository, error)
	ListBranches(projectName string, repo string) ([]string, error)
	ListTags(projectName string, repo string) ([]string, error)
	GetTemplateType(projectName string, repo string) (string, error)
	GetStatistics(projectName string, start, end time.Time) (*api.PipelineStatusStats, error)
}