graph

type Arg interface{}

type ArgConfig string // arg from config

type ArgFixed string // fixed arg

type ArgIn struct {
	Input     int               `json:"tile_index"` // Index of input [0, 1, 2]
	Layer     service.Layer     `json:"layer"`
	Extension service.Extension `json:"extension"`
}

type ArgJSON struct {
	Arg
}

type ArgOut struct {
	service.Layer `json:"layer"`
	Extension     service.Extension `json:"extension"`
}

type ArgTile string // arg from tile info

type CmdLogFilter struct {
	// contains filtered or unexported fields
}

type DType int32

type DockerConfig struct {
	Envs             []string
	RegistryServer   string // "https://eu.gcr.io" for gcs
	RegistryUserName string // _json_key for gcs
	RegistryPassword string // service account for gcs
	VolumesToMount   string // List of volumes to mount (comma separated)
}

type DockerLogFilter struct {
	// contains filtered or unexported fields
}

type DockerManager interface {
	Process(ctx context.Context, cmd, workdir string, args []string, envs []string) error
}

type File struct {
	Layer     service.Layer     `json:"layer"`
	Extension service.Extension `json:"extension"`
}

type GraphConfig map[string]string

type GraphEnvs []string

type InFile struct {
	File
	Condition TileCondition `json:"condition"`
}

type LogFilter interface {
	log.Filter
	// WrapError wraps the error with additionnal information from the logs
	WrapError(err error) error
}

type Option interface {
	// contains filtered or unexported methods
}

type OutFile struct {
	File

	DType     DType         `json:"datatype"`
	NoData    float64       `json:"nodata"`
	Min       float64       `json:"min_value"`
	Max       float64       `json:"max_value"`
	ExtMin    float64       `json:"ext_min_value"`
	ExtMax    float64       `json:"ext_max_value"`
	Exponent  float64       `json:"exponent"` // JSON default: 1
	Nbands    int           `json:"nbands"`   // JSON default: 1
	Action    OutFileAction `json:"action"`
	Condition TileCondition `json:"condition"` // JSON default: pass
	// contains filtered or unexported fields
}

type OutFileAction int32

type ProcessingGraph struct {
	InFiles [3][]InFile
	// contains filtered or unexported fields
}

type ProcessingGraphJSON struct {
	Config   map[string]string `json:"config"`
	Envs     []string          `json:"envs,omitempty"`
	Steps    []ProcessingStep  `json:"processing_steps"`
	InFiles  [3][]InFile       `json:"in_files"`
	OutFiles [][]OutFile       `json:"out_files"`
}

type ProcessingStep struct {
	Engine    string // Python or Snap
	Command   string
	Args      map[string]Arg
	Condition TileCondition
}

type PythonLogFilter struct {
	// contains filtered or unexported fields
}

type SNAPLogFilter struct {
	// contains filtered or unexported fields
}

type TileCondition struct {
	Name string
	Pass func([]common.Tile, *File) bool
}