Documentation ¶
Index ¶
- type Workflow
- func (wf *Workflow) CreateAOIHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) CreateSceneHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) DeleteAOIHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) Dot(ctx context.Context, aoi string, out io.Writer) error
- func (wf *Workflow) FailScene(ctx context.Context, scene db.Scene) error
- func (wf *Workflow) FailSceneHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) FailTile(ctx context.Context, tile db.Tile, tx db.WorkflowTxBackend) error
- func (wf *Workflow) FailTileHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) FinishScene(ctx context.Context, scene db.Scene) error
- func (wf *Workflow) FinishTile(ctx context.Context, tile db.Tile) error
- func (wf *Workflow) ForceSceneStatusHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) ForceTileStatusHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) GetAOIStatusHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) GetSceneHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) GetStatus(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) GetTileHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) IngestScene(ctx context.Context, aoi string, scene common.SceneToIngest) (int, error)
- func (wf *Workflow) ListAOITilesHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) ListAOIsHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) ListLeafTilesHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) ListRootTilesHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) ListSceneTilesHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) ListScenesHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) NewRouter() *mux.Router
- func (wf *Workflow) PrintDotHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) ResultHandler(ctx context.Context, result common.Result) error
- func (wf *Workflow) RetryAOIHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) RetryScene(ctx context.Context, scene db.Scene) error
- func (wf *Workflow) RetrySceneHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) RetryTile(ctx context.Context, tile db.Tile) error
- func (wf *Workflow) RetryTileHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) UpdateSceneData(ctx context.Context, sceneID int, data common.SceneAttrs) error
- func (wf *Workflow) UpdateSceneDataHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) UpdateSceneStatus(ctx context.Context, id int, status common.Status, message *string, force bool) (bool, error)
- func (wf *Workflow) UpdateTileData(ctx context.Context, tileID int, data common.TileAttrs) error
- func (wf *Workflow) UpdateTileDataHandler(w http.ResponseWriter, req *http.Request)
- func (wf *Workflow) UpdateTileStatus(ctx context.Context, id int, status common.Status, message *string, force bool) (bool, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Workflow ¶
type Workflow struct { db.WorkflowDBBackend // contains filtered or unexported fields }
func NewWorkflow ¶
func (*Workflow) CreateAOIHandler ¶
func (wf *Workflow) CreateAOIHandler(w http.ResponseWriter, req *http.Request)
CreateAOIHandler creates a new aoi
func (*Workflow) CreateSceneHandler ¶
func (wf *Workflow) CreateSceneHandler(w http.ResponseWriter, req *http.Request)
CreateSceneHandler creates a new scene
func (*Workflow) DeleteAOIHandler ¶ added in v1.0.0
func (wf *Workflow) DeleteAOIHandler(w http.ResponseWriter, req *http.Request)
DeleteAOIHandler delete an aoi, its scenes and its tile (cannot be reverted)
func (*Workflow) FailSceneHandler ¶
func (wf *Workflow) FailSceneHandler(w http.ResponseWriter, req *http.Request)
FailSceneHandler tags the scene and its tiles as FAILED
func (*Workflow) FailTileHandler ¶
func (wf *Workflow) FailTileHandler(w http.ResponseWriter, req *http.Request)
FailTileHandler tags the tile as FAILED and updates the graph
func (*Workflow) FinishScene ¶
func (*Workflow) FinishTile ¶
func (*Workflow) ForceSceneStatusHandler ¶
func (wf *Workflow) ForceSceneStatusHandler(w http.ResponseWriter, req *http.Request)
ForceSceneStatusHandler set the scene status and updates the graph
func (*Workflow) ForceTileStatusHandler ¶
func (wf *Workflow) ForceTileStatusHandler(w http.ResponseWriter, req *http.Request)
ForceTileStatusHandler set the tile status and updates the graph
func (*Workflow) GetAOIStatusHandler ¶
func (wf *Workflow) GetAOIStatusHandler(w http.ResponseWriter, req *http.Request)
GetAOIStatusHandler returns infos on the aoi
func (*Workflow) GetSceneHandler ¶
func (wf *Workflow) GetSceneHandler(w http.ResponseWriter, req *http.Request)
GetSceneHandler retrieves a scene
func (*Workflow) GetStatus ¶ added in v1.0.0
func (wf *Workflow) GetStatus(w http.ResponseWriter, req *http.Request)
GetStatus returns ok
func (*Workflow) GetTileHandler ¶
func (wf *Workflow) GetTileHandler(w http.ResponseWriter, req *http.Request)
GetTileHandler retrieves the tile
func (*Workflow) IngestScene ¶
func (wf *Workflow) IngestScene(ctx context.Context, aoi string, scene common.SceneToIngest) (int, error)
IngestScene adds a new scene to the workflow and starts the processing Return id of the scene
func (*Workflow) ListAOITilesHandler ¶
func (wf *Workflow) ListAOITilesHandler(w http.ResponseWriter, req *http.Request)
ListAOITilesHandler lists the tiles of the scene
func (*Workflow) ListAOIsHandler ¶ added in v1.0.0
func (wf *Workflow) ListAOIsHandler(w http.ResponseWriter, req *http.Request)
ListAOIsHandler returns the list of aois
func (*Workflow) ListLeafTilesHandler ¶
func (wf *Workflow) ListLeafTilesHandler(w http.ResponseWriter, req *http.Request)
ListLeaftTilesHandler lists all the tiles of the AOI that are the previous of no tile (leaf)
func (*Workflow) ListRootTilesHandler ¶
func (wf *Workflow) ListRootTilesHandler(w http.ResponseWriter, req *http.Request)
ListRootTilesHandler lists all the tiles of the AOI that have no ref tile (root)
func (*Workflow) ListSceneTilesHandler ¶
func (wf *Workflow) ListSceneTilesHandler(w http.ResponseWriter, req *http.Request)
ListSceneTilesHandler lists the tiles of the scene
func (*Workflow) ListScenesHandler ¶
func (wf *Workflow) ListScenesHandler(w http.ResponseWriter, req *http.Request)
ListScenesHandler lists the scenes of the aoi If status is provided, filter only the scenes with the given status
func (*Workflow) PrintDotHandler ¶
func (wf *Workflow) PrintDotHandler(w http.ResponseWriter, req *http.Request)
PrintDotHandler returns a xdot-representation of the graph
func (*Workflow) ResultHandler ¶
func (*Workflow) RetryAOIHandler ¶
func (wf *Workflow) RetryAOIHandler(w http.ResponseWriter, req *http.Request)
RetryAOIHandler retries all the scenes and tiles with the status 'RETRY' (and also 'PENDING' if force=true)
func (*Workflow) RetryScene ¶
func (*Workflow) RetrySceneHandler ¶
func (wf *Workflow) RetrySceneHandler(w http.ResponseWriter, req *http.Request)
RetrySceneHandler retries the scene if its status is RETRY
func (*Workflow) RetryTileHandler ¶
func (wf *Workflow) RetryTileHandler(w http.ResponseWriter, req *http.Request)
RetryTileHandler retries the tile if its status is RETRY
func (*Workflow) UpdateSceneData ¶ added in v1.0.0
UpdateSceneData update the data of a scene
func (*Workflow) UpdateSceneDataHandler ¶ added in v1.0.0
func (wf *Workflow) UpdateSceneDataHandler(w http.ResponseWriter, req *http.Request)
UpdateSceneDataHandler update the data of a scene
func (*Workflow) UpdateSceneStatus ¶
func (*Workflow) UpdateTileData ¶ added in v1.0.0
UpdateTileData update the data of a tile
func (*Workflow) UpdateTileDataHandler ¶ added in v1.0.0
func (wf *Workflow) UpdateTileDataHandler(w http.ResponseWriter, req *http.Request)
UpdateTileDataHandler update the data of a tile