Documentation
¶
Index ¶
- Constants
- type ArchivesHandler
- type CacheCreateHandler
- type CacheHandler
- type ChangeGroupsUpdateTokensHandler
- type ErrorResponse
- type ExecutorDeleteHandler
- type ExecutorStatusHandler
- type ExecutorTaskHandler
- type ExecutorTaskStatusHandler
- type ExecutorTasksHandler
- type ExportHandler
- type ImportHandler
- type LogsDeleteHandler
- type LogsHandler
- type MaintenanceModeHandler
- type RunActionsHandler
- type RunCreateHandler
- type RunEventsHandler
- type RunHandler
- type RunTaskActionsHandler
- type RunsHandler
Constants ¶
View Source
const ( DefaultRunsLimit = 25 MaxRunsLimit = 40 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArchivesHandler ¶
type ArchivesHandler struct {
// contains filtered or unexported fields
}
func NewArchivesHandler ¶
func NewArchivesHandler(logger *zap.Logger, ost *objectstorage.ObjStorage) *ArchivesHandler
func (*ArchivesHandler) ServeHTTP ¶
func (h *ArchivesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type CacheCreateHandler ¶
type CacheCreateHandler struct {
// contains filtered or unexported fields
}
func NewCacheCreateHandler ¶
func NewCacheCreateHandler(logger *zap.Logger, ost *objectstorage.ObjStorage) *CacheCreateHandler
func (*CacheCreateHandler) ServeHTTP ¶
func (h *CacheCreateHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type CacheHandler ¶
type CacheHandler struct {
// contains filtered or unexported fields
}
func NewCacheHandler ¶
func NewCacheHandler(logger *zap.Logger, ost *objectstorage.ObjStorage) *CacheHandler
func (*CacheHandler) ServeHTTP ¶
func (h *CacheHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ChangeGroupsUpdateTokensHandler ¶
type ChangeGroupsUpdateTokensHandler struct {
// contains filtered or unexported fields
}
func NewChangeGroupsUpdateTokensHandler ¶
func NewChangeGroupsUpdateTokensHandler(logger *zap.Logger, readDB *readdb.ReadDB) *ChangeGroupsUpdateTokensHandler
func (*ChangeGroupsUpdateTokensHandler) ServeHTTP ¶
func (h *ChangeGroupsUpdateTokensHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ErrorResponse ¶
type ErrorResponse struct {
Message string `json:"message"`
}
func ErrorResponseFromError ¶
func ErrorResponseFromError(err error) *ErrorResponse
type ExecutorDeleteHandler ¶
type ExecutorDeleteHandler struct {
// contains filtered or unexported fields
}
func NewExecutorDeleteHandler ¶
func NewExecutorDeleteHandler(logger *zap.Logger, ah *action.ActionHandler) *ExecutorDeleteHandler
func (*ExecutorDeleteHandler) ServeHTTP ¶
func (h *ExecutorDeleteHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ExecutorStatusHandler ¶
type ExecutorStatusHandler struct {
// contains filtered or unexported fields
}
func NewExecutorStatusHandler ¶
func NewExecutorStatusHandler(logger *zap.Logger, e *etcd.Store, ah *action.ActionHandler) *ExecutorStatusHandler
func (*ExecutorStatusHandler) ServeHTTP ¶
func (h *ExecutorStatusHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ExecutorTaskHandler ¶
type ExecutorTaskHandler struct {
// contains filtered or unexported fields
}
func NewExecutorTaskHandler ¶
func NewExecutorTaskHandler(logger *zap.Logger, ah *action.ActionHandler) *ExecutorTaskHandler
func (*ExecutorTaskHandler) ServeHTTP ¶
func (h *ExecutorTaskHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ExecutorTaskStatusHandler ¶
type ExecutorTaskStatusHandler struct {
// contains filtered or unexported fields
}
func NewExecutorTaskStatusHandler ¶
func NewExecutorTaskStatusHandler(e *etcd.Store, c chan<- *types.ExecutorTask) *ExecutorTaskStatusHandler
func (*ExecutorTaskStatusHandler) ServeHTTP ¶
func (h *ExecutorTaskStatusHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ExecutorTasksHandler ¶
type ExecutorTasksHandler struct {
// contains filtered or unexported fields
}
func NewExecutorTasksHandler ¶
func NewExecutorTasksHandler(logger *zap.Logger, ah *action.ActionHandler) *ExecutorTasksHandler
func (*ExecutorTasksHandler) ServeHTTP ¶
func (h *ExecutorTasksHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ExportHandler ¶ added in v0.2.0
type ExportHandler struct {
// contains filtered or unexported fields
}
func NewExportHandler ¶ added in v0.2.0
func NewExportHandler(logger *zap.Logger, ah *action.ActionHandler) *ExportHandler
func (*ExportHandler) ServeHTTP ¶ added in v0.2.0
func (h *ExportHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type ImportHandler ¶ added in v0.2.0
type ImportHandler struct {
// contains filtered or unexported fields
}
func NewImportHandler ¶ added in v0.2.0
func NewImportHandler(logger *zap.Logger, ah *action.ActionHandler) *ImportHandler
func (*ImportHandler) ServeHTTP ¶ added in v0.2.0
func (h *ImportHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type LogsDeleteHandler ¶ added in v0.4.0
type LogsDeleteHandler struct {
// contains filtered or unexported fields
}
func NewLogsDeleteHandler ¶ added in v0.4.0
func NewLogsDeleteHandler(logger *zap.Logger, e *etcd.Store, ost *objectstorage.ObjStorage, dm *datamanager.DataManager) *LogsDeleteHandler
func (*LogsDeleteHandler) ServeHTTP ¶ added in v0.4.0
func (h *LogsDeleteHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type LogsHandler ¶
type LogsHandler struct {
// contains filtered or unexported fields
}
func NewLogsHandler ¶
func NewLogsHandler(logger *zap.Logger, e *etcd.Store, ost *objectstorage.ObjStorage, dm *datamanager.DataManager) *LogsHandler
func (*LogsHandler) ServeHTTP ¶
func (h *LogsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type MaintenanceModeHandler ¶ added in v0.2.0
type MaintenanceModeHandler struct {
// contains filtered or unexported fields
}
func NewMaintenanceModeHandler ¶ added in v0.2.0
func NewMaintenanceModeHandler(logger *zap.Logger, ah *action.ActionHandler, e *etcd.Store) *MaintenanceModeHandler
func (*MaintenanceModeHandler) ServeHTTP ¶ added in v0.2.0
func (h *MaintenanceModeHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type RunActionsHandler ¶
type RunActionsHandler struct {
// contains filtered or unexported fields
}
func NewRunActionsHandler ¶
func NewRunActionsHandler(logger *zap.Logger, ah *action.ActionHandler) *RunActionsHandler
func (*RunActionsHandler) ServeHTTP ¶
func (h *RunActionsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type RunCreateHandler ¶
type RunCreateHandler struct {
// contains filtered or unexported fields
}
func NewRunCreateHandler ¶
func NewRunCreateHandler(logger *zap.Logger, ah *action.ActionHandler) *RunCreateHandler
func (*RunCreateHandler) ServeHTTP ¶
func (h *RunCreateHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type RunEventsHandler ¶
type RunEventsHandler struct {
// contains filtered or unexported fields
}
func NewRunEventsHandler ¶
func NewRunEventsHandler(logger *zap.Logger, e *etcd.Store, ost *objectstorage.ObjStorage, dm *datamanager.DataManager) *RunEventsHandler
func (*RunEventsHandler) ServeHTTP ¶
func (h *RunEventsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type RunHandler ¶
type RunHandler struct {
// contains filtered or unexported fields
}
func NewRunHandler ¶
func NewRunHandler(logger *zap.Logger, e *etcd.Store, dm *datamanager.DataManager, readDB *readdb.ReadDB) *RunHandler
func (*RunHandler) ServeHTTP ¶
func (h *RunHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type RunTaskActionsHandler ¶
type RunTaskActionsHandler struct {
// contains filtered or unexported fields
}
func NewRunTaskActionsHandler ¶
func NewRunTaskActionsHandler(logger *zap.Logger, ah *action.ActionHandler) *RunTaskActionsHandler
func (*RunTaskActionsHandler) ServeHTTP ¶
func (h *RunTaskActionsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
type RunsHandler ¶
type RunsHandler struct {
// contains filtered or unexported fields
}
func NewRunsHandler ¶
func NewRunsHandler(logger *zap.Logger, readDB *readdb.ReadDB) *RunsHandler
func (*RunsHandler) ServeHTTP ¶
func (h *RunsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
Source Files
Click to show internal directories.
Click to hide internal directories.