Documentation ¶
Index ¶
- Constants
- func HealthCheck(w http.ResponseWriter, r *http.Request)
- type AllScheduleResponse
- type BulkActionResponse
- type CreateAppData
- type CreateAppResponse
- type CreateConfigurationData
- type CreateConfigurationResponse
- type CreateScheduleData
- type CreateScheduleResponse
- type DeleteConfigurationData
- type DeleteConfigurationResponse
- type DeleteScheduleData
- type DeleteScheduleResponse
- type ErrorResponse
- type GetAppSchedulesData
- type GetAppSchedulesResponse
- type GetAppsData
- type GetAppsResponse
- type GetConfigurationData
- type GetConfigurationResponse
- type GetCronSchedulesResponse
- type GetPaginatedAppSchedulesData
- type GetPaginatedAppSchedulesResponse
- type GetPaginatedRunSchedulesData
- type GetPaginatedRunSchedulesResponse
- type GetScheduleData
- type GetScheduleResponse
- type GetScheduleRunsData
- type GetScheduleRunsResponse
- type HealthCheckResponse
- type NewScheduleResponse
- type Service
- func (s *Service) Activate(w http.ResponseWriter, r *http.Request)
- func (s *Service) ActivateApp(appId string) error
- func (s *Service) BulkAction(w http.ResponseWriter, r *http.Request)
- func (s *Service) CancelSchedule(w http.ResponseWriter, r *http.Request)
- func (s *Service) CreateConfiguration(w http.ResponseWriter, r *http.Request)
- func (s *Service) CreateSchedule(input sch.Schedule) (sch.Schedule, error)
- func (s *Service) Deactivate(w http.ResponseWriter, r *http.Request)
- func (s *Service) DeactivateApp(appId string) error
- func (s *Service) DeleteConfiguration(w http.ResponseWriter, r *http.Request)
- func (s *Service) DeleteSchedule(uuid string) (sch.Schedule, error)
- func (s *Service) ExecuteBulkAction(appId string, action store.ActionType, status store.Status, ...) error
- func (s *Service) FetchAppSchedules(appId string, timeRange dao.Range, size int64, status sch.Status, ...) ([]sch.Schedule, []byte, time.Time, error)
- func (s *Service) FetchApps(appId string) ([]store.App, error)
- func (s *Service) FetchCronRuns(uuid string, size int64, when string, pageState []byte) ([]sch.Schedule, []byte, error)
- func (s *Service) FetchCronSchedules(appId string, status sch.Status) ([]sch.Schedule, error)
- func (s *Service) Get(w http.ResponseWriter, r *http.Request)
- func (s *Service) GetAppSchedules(w http.ResponseWriter, r *http.Request)
- func (s *Service) GetApps(w http.ResponseWriter, r *http.Request)
- func (s *Service) GetConfiguration(w http.ResponseWriter, r *http.Request)
- func (s *Service) GetCronSchedules(w http.ResponseWriter, r *http.Request)
- func (s *Service) GetRuns(w http.ResponseWriter, r *http.Request)
- func (s *Service) GetSchedule(uuid string) (sch.Schedule, error)
- func (s *Service) Post(w http.ResponseWriter, r *http.Request)
- func (s *Service) Register(w http.ResponseWriter, r *http.Request)
- func (s *Service) RegisterApp(input store.App) (store.App, error)
- func (s *Service) UpdateConfiguration(w http.ResponseWriter, r *http.Request)
- type Status
- type UpdateAppActiveStatusData
- type UpdateAppActiveStatusResponse
- type UpdateConfigurationData
- type UpdateConfigurationResponse
Constants ¶
View Source
const ( Create action = "CREATE" Get action = "GET" GetRun action = "GET_RUNS" Delete action = "DELETE" GetAppSchedule action = "GET_APP_SCHEDULES" Reconcile action = "RECONCILE" GetCronSchedule action = "GET_CRON_SCHEDULE" )
View Source
const ( Success = constants.DOT + constants.Success Fail = constants.DOT + constants.Fail )
View Source
const MaxBulkActionPeriodInDays = 7
Variables ¶
This section is empty.
Functions ¶
func HealthCheck ¶
func HealthCheck(w http.ResponseWriter, r *http.Request)
Types ¶
type AllScheduleResponse ¶
type BulkActionResponse ¶
type CreateAppData ¶
type CreateAppData struct { AppId string `json:"appId"` Partitions uint32 `json:"partitions"` Active bool `json:"active"` Configuration s.Configuration `json:"configuration"` }
type CreateAppResponse ¶
type CreateAppResponse struct { Status Status `json:"status"` Data CreateAppData `json:"data"` }
type CreateConfigurationData ¶
type CreateConfigurationData struct { AppId string `json:"appId"` Configuration s.Configuration `json:"configuration"` }
type CreateConfigurationResponse ¶
type CreateConfigurationResponse struct { Status Status `json:"status"` Data CreateConfigurationData `json:"data"` }
type CreateScheduleData ¶
type CreateScheduleResponse ¶
type CreateScheduleResponse struct { Status Status `json:"status"` Data CreateScheduleData `json:"data"` }
type DeleteConfigurationData ¶
type DeleteConfigurationData struct { AppId string `json:"appId"` Configuration s.Configuration `json:"configuration"` }
type DeleteConfigurationResponse ¶
type DeleteConfigurationResponse struct { Status Status `json:"status"` Data DeleteConfigurationData `json:"data"` }
type DeleteScheduleData ¶
type DeleteScheduleResponse ¶
type DeleteScheduleResponse struct { Status Status `json:"status"` Data DeleteScheduleData `json:"data"` }
type ErrorResponse ¶
type ErrorResponse struct {
Errors []string `json:"errors"`
}
type GetAppSchedulesData ¶
type GetAppSchedulesResponse ¶
type GetAppSchedulesResponse struct { Status Status `json:"status"` Data GetAppSchedulesData `json:"data"` }
type GetAppsData ¶
type GetAppsResponse ¶
type GetAppsResponse struct { Status Status `json:"status"` Data GetAppsData `json:"data"` }
type GetConfigurationData ¶
type GetConfigurationData struct { AppId string `json:"appId"` Configuration s.Configuration `json:"configuration"` }
type GetConfigurationResponse ¶
type GetConfigurationResponse struct { Status Status `json:"status"` Data GetConfigurationData `json:"data"` }
type GetPaginatedAppSchedulesResponse ¶
type GetPaginatedAppSchedulesResponse struct { Status Status `json:"status"` Data GetPaginatedAppSchedulesData `json:"data"` }
type GetPaginatedRunSchedulesResponse ¶
type GetPaginatedRunSchedulesResponse struct { Status Status `json:"status"` Data GetPaginatedRunSchedulesData `json:"data"` }
type GetScheduleData ¶
type GetScheduleResponse ¶
type GetScheduleResponse struct { Status Status `json:"status"` Data GetScheduleData `json:"data"` }
type GetScheduleRunsData ¶
type GetScheduleRunsResponse ¶
type GetScheduleRunsResponse struct { Status Status `json:"status"` Data GetScheduleRunsData `json:"data"` }
type HealthCheckResponse ¶
type NewScheduleResponse ¶
type Service ¶
type Service struct { Config *c.Configuration Supervisor cluster.SupervisorHandler ClusterDao dao.ClusterDao ScheduleDao dao.ScheduleDao Monitor monitoring.Monitor }
func NewService ¶
func NewService(config *c.Configuration, supervisor cluster.SupervisorHandler, clusterDao dao.ClusterDao, scheduleDAO dao.ScheduleDao, monitor monitoring.Monitor) *Service
func (*Service) ActivateApp ¶
func (*Service) BulkAction ¶
func (s *Service) BulkAction(w http.ResponseWriter, r *http.Request)
func (*Service) CancelSchedule ¶
func (s *Service) CancelSchedule(w http.ResponseWriter, r *http.Request)
func (*Service) CreateConfiguration ¶
func (s *Service) CreateConfiguration(w http.ResponseWriter, r *http.Request)
func (*Service) CreateSchedule ¶
CreateSchedule createSchedule creates a new schedule
func (*Service) Deactivate ¶
func (s *Service) Deactivate(w http.ResponseWriter, r *http.Request)
func (*Service) DeactivateApp ¶
func (*Service) DeleteConfiguration ¶
func (s *Service) DeleteConfiguration(w http.ResponseWriter, r *http.Request)
func (*Service) DeleteSchedule ¶
func (*Service) ExecuteBulkAction ¶
func (*Service) FetchAppSchedules ¶
func (*Service) FetchCronRuns ¶
func (*Service) FetchCronSchedules ¶
func (*Service) GetAppSchedules ¶
func (s *Service) GetAppSchedules(w http.ResponseWriter, r *http.Request)
get all the schedules of an app based on time range and status
func (*Service) GetConfiguration ¶
func (s *Service) GetConfiguration(w http.ResponseWriter, r *http.Request)
func (*Service) GetCronSchedules ¶
func (s *Service) GetCronSchedules(w http.ResponseWriter, r *http.Request)
func (*Service) UpdateConfiguration ¶
func (s *Service) UpdateConfiguration(w http.ResponseWriter, r *http.Request)
type UpdateAppActiveStatusResponse ¶
type UpdateAppActiveStatusResponse struct { Status Status `json:"status"` Data UpdateAppActiveStatusData `json:"data"` }
type UpdateConfigurationData ¶
type UpdateConfigurationData struct { AppId string `json:"appId"` Configuration s.Configuration `json:"configuration"` }
type UpdateConfigurationResponse ¶
type UpdateConfigurationResponse struct { Status Status `json:"status"` Data UpdateConfigurationData `json:"data"` }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.