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
	BandExpr              *utils.BandExpressions
	ScaleParams           ScaleParams
	Palette               *utils.Palette
	Mask                  *utils.Mask
	ZoomLimit             float64
	PolygonSegments       int
	GrpcConcLimit         int
	PolygonSharcConcLimit int
	QueryLimit            int
	UserSrcGeoTransform   int
	UserSrcSRS            int
	NoReprojection        bool
	AxisMapping           int
	GrpcTileXSize         float64
	GrpcTileYSize         float64
	IndexTileXSize        float64
	IndexTileYSize        float64
	SpatialExtent         []float64
	IndexResLimit         float64
	MasQueryHint          string
	ReqRes                float64
	SRSCf                 int
	FusionUnscale         int
	MetricsCollector      *metrics.MetricsCollector
}

type DatasetAxis struct {
	Name               string    `json:"name"`
	Params             []float64 `json:"params"`
	Strides            []int     `json:"strides"`
	Shape              []int     `json:"shape"`
	Grid               string    `json:"grid"`
	IntersectionIdx    []int
	IntersectionValues []float64
	Order              int
	Aggregate          int
}

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
	IdentityTol float64
	DpTol       float64
	Approx      bool
}

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

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

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

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
	DataHeight, DataWidth int
	Height, Width         int
	OffX, OffY            int
	Type                  string
	NoData                float64
	NameSpace             string
	TimeStamp             float64
	Polygon               string
}

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

type GDALDataset struct {
	RawPath      string         `json:"file_path"`
	DSName       string         `json:"ds_name"`
	NameSpace    string         `json:"namespace"`
	ArrayType    string         `json:"array_type"`
	SRS          string         `json:"srs"`
	GeoTransform []float64      `json:"geo_transform"`
	TimeStamps   []time.Time    `json:"timestamps"`
	Polygon      string         `json:"polygon"`
	Means        []float64      `json:"means"`
	SampleCounts []int          `json:"sample_counts"`
	NoData       float64        `json:"nodata"`
	Axes         []*DatasetAxis `json:"axes"`
	GeoLocation  *GeoLocInfo    `json:"geo_loc"`
	IsOutRange   bool
}

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
	VRT              string
	Means            []float64
	SampleCounts     []int
	NoData           float64
	Approx           bool
	ClipUpper        float32
	ClipLower        float32
	RasterXSize      float64
	RasterYSize      float64
	GrpcConcLimit    int
	MetricsCollector *metrics.MetricsCollector
}

type GeoDrillRequest struct {
	Geometry         string
	CRS              string
	Collection       string
	NameSpaces       []string
	BandExpr         *utils.BandExpressions
	Mask             *utils.Mask
	VRTURL           string
	StartTime        time.Time
	EndTime          time.Time
	ClipUpper        float32
	ClipLower        float32
	RasterXSize      float64
	RasterYSize      float64
	GrpcConcLimit    int
	IndexTileXSize   float64
	IndexTileYSize   float64
	MetricsCollector *metrics.MetricsCollector
}

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 GeoLocInfo struct {
	XDSName     string `json:"x_ds_name"`
	XBand       int    `json:"x_band"`
	YDSName     string `json:"y_ds_name"`
	YBand       int    `json:"y_band"`
	LineOffset  int    `json:"line_offset"`
	PixelOffset int    `json:"pixel_offset"`
	LineStep    int    `json:"line_step"`
	PixelStep   int    `json:"pixel_step"`
}

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 GeoRasterGRPC struct {
	Context               context.Context
	In                    chan *GeoTileGranule
	Out                   chan []*FlexRaster
	Error                 chan error
	Clients               []string
	MaxGrpcRecvMsgSize    int
	PolygonShardConcLimit int
	MaxGrpcBufferSize     int
}

type GeoReqContext struct {
	Service    *utils.ServiceConfig
	Layer      *utils.Layer
	StyleLayer *utils.Layer
	GeoReq     *GeoTileRequest
	MASAddress string
}

type GeoTileAxis struct {
	Start        *float64
	End          *float64
	InValues     []float64
	Order        int
	Aggregate    int
	IdxSelectors []*GeoTileIdxSelector
}

type GeoTileGranule struct {
	ConfigPayLoad
	RawPath             string
	Path                string
	CRS                 string
	SrcSRS              string
	SrcGeoTransform     []float64
	BBox                []float64
	DstGeoTransform     []float64
	Height, Width       int
	RawHeight, RawWidth int
	OffX, OffY          int
	NameSpace           string
	VarNameSpace        string
	TimeStamp           float64
	BandIdx             int
	Polygon             string
	RasterType          string
	GeoLocation         *GeoLocInfo
}

type GeoTileIdxSelector struct {
	Start   *int
	End     *int
	Step    *int
	IsRange bool
	IsAll   bool
}

type GeoTileRequest struct {
	ConfigPayLoad
	Collection    string
	CRS           string
	BBox          []float64
	OrigBBox      []float64
	Height, Width int
	OffX, OffY    int
	StartTime     *time.Time
	EndTime       *time.Time
	Axes          map[string]*GeoTileAxis
	Overview      *utils.Layer
}

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 {
	Error        string         `json:"error"`
	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 {
	Context context.Context
	In      chan []*FlexRaster
	Out     chan []utils.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
	ColourScale int
}

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

type TilePipeline struct {
	Context               context.Context
	Error                 chan error
	RPCAddress            []string
	MaxGrpcRecvMsgSize    int
	PolygonShardConcLimit int
	MASAddress            string
	MaxGrpcBufferSize     int
	CurrentLayer          *utils.Layer
	DataSources           map[string]*utils.Config
}

type TiledResponse struct {
	IndexerID   int
	NumIndexers int
	IndexerTime time.Duration
	Metadata    *MetadataResponse
}

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
}