workflow

Documentation

Index

• type Workflow
  • func NewWorkflow(db db.WorkflowDBBackend, sceneQueue, tileQueue messaging.Publisher, ...) *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)

Types

type Workflow

type Workflow struct {
	db.WorkflowDBBackend
	// contains filtered or unexported fields
}

func NewWorkflow

func NewWorkflow(db db.WorkflowDBBackend, sceneQueue, tileQueue messaging.Publisher, catalog *catalog.Catalog) *Workflow

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

func (wf *Workflow) DeleteAOIHandler(w http.ResponseWriter, req *http.Request)

DeleteAOIHandler delete an aoi, its scenes and its tile (cannot be reverted)

func (*Workflow) Dot

func (wf *Workflow) Dot(ctx context.Context, aoi string, out io.Writer) error

func (*Workflow) FailScene

func (wf *Workflow) FailScene(ctx context.Context, scene db.Scene) error

func (*Workflow) FailSceneHandler

func (wf *Workflow) FailSceneHandler(w http.ResponseWriter, req *http.Request)

FailSceneHandler tags the scene and its tiles as FAILED

func (*Workflow) FailTile

func (wf *Workflow) FailTile(ctx context.Context, tile db.Tile, tx db.WorkflowTxBackend) error

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 (wf *Workflow) FinishScene(ctx context.Context, scene db.Scene) error

func (*Workflow) FinishTile

func (wf *Workflow) FinishTile(ctx context.Context, tile db.Tile) error

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

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

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) NewRouter

func (wf *Workflow) NewRouter() *mux.Router

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 (wf *Workflow) ResultHandler(ctx context.Context, result common.Result) error

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 (wf *Workflow) RetryScene(ctx context.Context, scene db.Scene) error

func (*Workflow) RetrySceneHandler

func (wf *Workflow) RetrySceneHandler(w http.ResponseWriter, req *http.Request)

RetrySceneHandler retries the scene if its status is RETRY

func (*Workflow) RetryTile

func (wf *Workflow) RetryTile(ctx context.Context, tile db.Tile) error

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

func (wf *Workflow) UpdateSceneData(ctx context.Context, sceneID int, data common.SceneAttrs) error

UpdateSceneData update the data of a scene

func (*Workflow) UpdateSceneDataHandler

func (wf *Workflow) UpdateSceneDataHandler(w http.ResponseWriter, req *http.Request)

UpdateSceneDataHandler update the data of a scene

func (*Workflow) UpdateSceneStatus

func (wf *Workflow) UpdateSceneStatus(ctx context.Context, id int, status common.Status, message *string, force bool) (bool, error)

func (*Workflow) UpdateTileData

func (wf *Workflow) UpdateTileData(ctx context.Context, tileID int, data common.TileAttrs) error

UpdateTileData update the data of a tile

func (*Workflow) UpdateTileDataHandler

func (wf *Workflow) UpdateTileDataHandler(w http.ResponseWriter, req *http.Request)

UpdateTileDataHandler update the data of a tile

func (*Workflow) UpdateTileStatus

func (wf *Workflow) UpdateTileStatus(ctx context.Context, id int, status common.Status, message *string, force bool) (bool, error)