Documentation
¶
Index ¶
- func HandleError(s *client.Schemas, t func(http.ResponseWriter, *http.Request) error) http.Handler
- func InitAgent(s *Server)
- func ListenAndServe(provider model.PipelineProvider, errChan chan bool)
- func NewRouter(s *Server) *mux.Router
- func PingMsg() []byte
- func Preset(provider model.PipelineProvider)
- type Agent
- type ConnHolder
- type Server
- func (s *Server) ActivatePipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ApproveActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) CleanActivities(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) CleanPipelines(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) CreateActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) CreatePipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) DeActivatePipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) DeleteActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) DeletePipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) DenyActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ExportPipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) GetAccount(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) GetActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) GetCacheRepos(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) GetPipelineSetting(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) GetSCMSetting(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ListAccounts(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ListActivities(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ListActivitiesOfPipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ListEnvVars(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ListPipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ListPipelines(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ListSCMSetting(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) Oauth(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) RefreshRepos(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) RemoveAccount(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) RemoveSCMSetting(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) RerunActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) Reset(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) RunPipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) ServeStatusWS(w http.ResponseWriter, r *http.Request) error
- func (s *Server) ServeStepLog(w http.ResponseWriter, r *http.Request) error
- func (s *Server) ShareAccount(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) StepFinish(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) StepStart(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) StopActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) UnshareAccount(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) UpdateActivity(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) UpdateLastActivity(activity *model.Activity)
- func (s *Server) UpdatePipeline(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) UpdatePipelineSetting(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) UpdateSCMSetting(rw http.ResponseWriter, req *http.Request) error
- func (s *Server) Webhook(rw http.ResponseWriter, req *http.Request) error
- type WSMsg
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HandleError ¶
HandleError handle error from operation
func ListenAndServe ¶
func ListenAndServe(provider model.PipelineProvider, errChan chan bool)
func Preset ¶
func Preset(provider model.PipelineProvider)
Types ¶
type Agent ¶
type Agent struct {
Server *Server
// contains filtered or unexported fields
}
Component to hold schedulers and connholders
var GlobalAgent *Agent
func (*Agent) RunScheduler ¶
func (a *Agent) RunScheduler()
type ConnHolder ¶
type ConnHolder struct {
// contains filtered or unexported fields
}
func (*ConnHolder) DoRead ¶
func (c *ConnHolder) DoRead()
func (*ConnHolder) DoWrite ¶
func (c *ConnHolder) DoWrite(apiContext *api.ApiContext, uid string)
type Server ¶
type Server struct {
Provider model.PipelineProvider
SCManagers map[string]model.SCManager
}
Server rest api server
func NewServer ¶
func NewServer(provider model.PipelineProvider) *Server
func (*Server) ActivatePipeline ¶
func (*Server) ApproveActivity ¶
func (*Server) CleanActivities ¶
func (*Server) CleanPipelines ¶
func (*Server) CreateActivity ¶
CreateActivity Handler
func (*Server) CreatePipeline ¶
func (*Server) DeActivatePipeline ¶
func (*Server) DeleteActivity ¶
func (*Server) DeletePipeline ¶
func (*Server) DenyActivity ¶
func (*Server) ExportPipeline ¶
func (*Server) GetAccount ¶
func (*Server) GetActivity ¶
func (*Server) GetCacheRepos ¶
func (*Server) GetPipelineSetting ¶
Get pipelineSetting Handler
func (*Server) GetSCMSetting ¶
func (*Server) ListAccounts ¶
func (*Server) ListActivities ¶
List All Activities
func (*Server) ListActivitiesOfPipeline ¶
func (*Server) ListEnvVars ¶
list available env vars
func (*Server) ListPipeline ¶
func (*Server) ListPipelines ¶
ListPipelines query List of pipelines
func (*Server) ListSCMSetting ¶
func (*Server) RefreshRepos ¶
func (*Server) RemoveAccount ¶
func (*Server) RemoveSCMSetting ¶
func (*Server) RerunActivity ¶
func (*Server) RunPipeline ¶
func (*Server) ServeStatusWS ¶
func (*Server) ServeStepLog ¶
func (*Server) ShareAccount ¶
func (*Server) StepFinish ¶
func (*Server) StopActivity ¶
func (*Server) UnshareAccount ¶
func (*Server) UpdateActivity ¶
func (*Server) UpdateLastActivity ¶
update last activity info in the pipeline on activity changes
func (*Server) UpdatePipeline ¶
func (*Server) UpdatePipelineSetting ¶
func (*Server) UpdateSCMSetting ¶
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.