processor

type ByteRaster struct {
	ConfigPayLoad
	Data          []uint8
	Height, Width int
	OffX, OffY    int
	NoData        float64
	NameSpace     string
}

type ConcLimiter struct {
	*sync.WaitGroup
	Pool chan struct{}
}

type ConfigPayLoad struct {
	NameSpaces  []string
	ScaleParams ScaleParams
	Palette     *utils.Palette
	Mask        *utils.Mask
	ZoomLimit   float64
}

type DrillFileDescriptor struct {
	OffX, OffY     int
	CountX, CountY int
	NoData         float64
	Mask           *image.Gray
}

type DrillIndexer struct {
	Context    context.Context
	In         chan *GeoDrillRequest
	Out        chan *GeoDrillGranule
	Error      chan error
	APIAddress string
}

type DrillMerger struct {
	In    chan *DrillResult
	Out   chan string
	Error chan error
}

type DrillPipeline struct {
	Context  context.Context
	Error    chan error
	RPCAddrs []string
	APIAddr  string
}

type DrillResult struct {
	NameSpace string
	Dates     []time.Time
	Data      []*pb.TimeSeries
}

type FileCrawler struct {
	In    chan string
	Out   chan string
	Error chan error
	// contains filtered or unexported fields
}

type FileList struct {
	Files []string `json:"files"`
}

type FlexRaster struct {
	ConfigPayLoad
	Data          []byte
	Height, Width int
	OffX, OffY    int
	Type          string
	NoData        float64
	NameSpace     string
	TimeStamp     time.Time
	Polygon       string
}

type Float32Raster struct {
	ConfigPayLoad
	Data          []float32
	Height, Width int
	OffX, OffY    int
	NoData        float64
	NameSpace     string
}

type GDALDataset struct {
	DSName     string      `json:"ds_name"`
	ArrayType  string      `json:"array_type"`
	TimeStamps []time.Time `json:"timestamps"`
	Polygon    string      `json:"polygon"`
}

type GeoDrillGRPC struct {
	Context context.Context
	In      chan *GeoDrillGranule
	Out     chan *DrillResult
	Error   chan error
	Clients []string
}

type GeoDrillGranule struct {
	Path       string
	NameSpace  string
	RasterType string
	TimeStamps []time.Time
	Geometry   string
	CRS        string
}

type GeoDrillRequest struct {
	Geometry   string
	CRS        string
	Collection string
	NameSpaces []string
	StartTime  time.Time
	EndTime    time.Time
}

type GeoFile struct {
	FileName string        `json:"filename,omitempty"`
	Driver   string        `json:"file_type"`
	DataSets []GeoMetaData `json:"geo_metadata"`
}

type GeoInfoGRPC struct {
	Context context.Context
	In      chan string
	Out     chan *GeoFile
	Error   chan error
	Clients []string
}

type GeoMetaData struct {
	DataSetName  string         `json:"ds_name"`
	NameSpace    string         `json:"namespace,omitempty"`
	Type         string         `json:"array_type"`
	RasterCount  int32          `json:"raster_count"`
	TimeStamps   []time.Time    `json:"timestamps"`
	Heights      []float64      `json:"heights,omitempty"`
	Overviews    []*pb.Overview `json:"overviews,omitempty"`
	XSize        int32          `json:"x_size"`
	YSize        int32          `json:"y_size"`
	GeoTransform []float64      `json:"geotransform"`
	Polygon      string         `json:"polygon"`
	ProjWKT      string         `json:"proj_wkt"`
	Proj4        string         `json:"proj4"`
}

type GeoProcessor struct {
	Context    context.Context
	In         chan *GeoTileRequest
	Out        chan *ByteRaster
	Error      chan error
	APIAddress string
	RPCAddress string
}

type GeoRasterGRPC struct {
	Context context.Context
	In      chan *GeoTileGranule
	Out     chan *FlexRaster
	Error   chan error
	Client  string
}

type GeoTileGranule struct {
	ConfigPayLoad
	Path          string
	CRS           string
	BBox          []float64
	Height, Width int
	OffX, OffY    int
	NameSpace     string
	TimeStamps    []time.Time
	TimeStamp     time.Time
	Polygon       string
	RasterType    string
}

type GeoTileRequest struct {
	ConfigPayLoad
	Collection    string
	CRS           string
	BBox          []float64
	Height, Width int
	OffX, OffY    int
	StartTime     *time.Time
	EndTime       *time.Time
}

type InfoPipeline struct {
	Context context.Context
	Error   chan error
	RPCAdds []string
}

type Int16Raster struct {
	ConfigPayLoad
	Data          []int16
	Height, Width int
	OffX, OffY    int
	NoData        float64
	NameSpace     string
}

type JPGEncoder struct {
	In    chan *ByteRaster
	Out   chan []byte
	Error chan error
}

type JSONEncoder struct {
	In    chan *GeoFile
	Out   chan []byte
	Error chan error
}

type JSONPrinter struct {
	In    chan []byte
	Out   chan struct{}
	File  io.Writer
	Error chan error
}

type MetadataResponse struct {
	Files        []string      `json:"files"`
	GDALDatasets []GDALDataset `json:"gdal"`
}

type Overview struct {
	XSize int32 `json:"x_size"`
	YSize int32 `json:"y_size"`
}

type PNGEncoder struct {
	In    chan *ByteRaster
	Out   chan []byte
	Error chan error
}

type POSIXDescriptor struct {
	GID   uint32 `json:"gid"`
	Group string `json:"group"`
	UID   uint32 `json:"uid"`
	User  string `json:"user"`
	Size  int64  `json:"size"`
	Mode  string `json:"mode"`
	Type  string `json:"type"`
	INode uint64 `json:"inode"`
	MTime int64  `json:"mtime"`
	ATime int64  `json:"atime"`
	CTime int64  `json:"ctime"`
}

type PosixInfo struct {
	In    chan string
	Out   chan string
	Error chan error
}

type Raster interface {
	GetNoData() float64
}

type RasterMerger struct {
	In    chan *FlexRaster
	Out   chan Raster
	Error chan error
}

type RasterScaler struct {
	In    chan Raster
	Out   chan *ByteRaster
	Error chan error
}

type ScaleParams struct {
	Offset float64
	Scale  float64
	Clip   float64
}

type TileIndexer struct {
	Context    context.Context
	In         chan *GeoTileRequest
	Out        chan *GeoTileGranule
	Error      chan error
	APIAddress string
}

type TileInternalPipeline struct {
	Context    context.Context
	Error      chan error
	RPCAddress string
	APIAddress string
}

type TilePipeline struct {
	Context    context.Context
	Error      chan error
	RPCAddress string
	MASAddress string
}

type TileSplitter struct {
	Context context.Context
	In      chan *GeoTileRequest
	Out     chan *GeoTileRequest
	Error   chan error
}

type TimeSplitter struct {
	In       chan *GeoDrillRequest
	Out      chan *GeoDrillRequest
	Error    chan error
	YearStep int
}

type UInt16Raster struct {
	ConfigPayLoad
	Data          []uint16
	Height, Width int
	OffX, OffY    int
	NoData        float64
	NameSpace     string
}