processor

package

Go to main page

Versions in this module

v1

v1.9.3

Aug 31, 2021

v1.9.2

Jul 28, 2021

v1.9.1

Jul 16, 2021

v1.9.0

May 9, 2021

Changes in this version

+ const DefaultMASConcQuery

+ const DefaultMASMaxConnsPerHost

type GeoTileRequest

+ Overview *utils.Layer

type TilePipeline

+ func (dp *TilePipeline) HasFiles(geoReq *GeoTileRequest, verbose bool) bool

v1.8.1

Apr 19, 2021

v1.8.0

Feb 19, 2021

v1.7.2

Aug 24, 2020

Changes in this version

+ const DecileNamespace

+ const DefaultMaxLogLength

+ const DrillTargetSRS

+ const ISOFormat

+ const SizeofFloat32

+ const SizeofInt16

+ const SizeofUint16

+ func BBox2Geot(width, height int, bbox []float64) []float64

+ func BBox2WKT(bbox []float64) string

+ func ComputeMask(mask *utils.Mask, data []byte, rType string) (out []bool, err error)

+ func ComputeReprojectionExtent(ctx context.Context, geoReq *GeoTileRequest, masAddress string, ...) (int, int, error)

+ func GetFeatureInfo(ctx context.Context, params utils.WMSParams, conf *utils.Config, ...) (string, error)

+ func GradientRGBAPalette(palette *utils.Palette) ([]color.RGBA, error)

+ func InterpolateColor(a, b color.RGBA, i, sectionLength int) color.RGBA

+ func InterpolateUint8(a, b uint8, i, sectionLength int) uint8

+ func MergeMaskedRaster(r *FlexRaster, canvasMap map[string]*FlexRaster, mask []bool) (err error)

+ func ProcessRasterStack(rasterStack map[float64][]*FlexRaster, maskMap map[float64][]bool, ...) (map[string]*FlexRaster, error)

+ type ByteRaster struct

+ Data []uint8

+ Height int

+ NameSpace string

+ NoData float64

+ OffX int

+ OffY int

+ Width int

+ func (br *ByteRaster) GetNoData() float64

+ type ConcLimiter struct

+ Pool chan struct{}

+ func NewConcLimiter(cLevel int) *ConcLimiter

+ func (c *ConcLimiter) Decrease()

+ func (c *ConcLimiter) Increase()

+ type ConfigPayLoad struct

+ AxisMapping int

+ BandExpr *utils.BandExpressions

+ FusionUnscale int

+ GrpcConcLimit int

+ GrpcTileXSize float64

+ GrpcTileYSize float64

+ IndexResLimit float64

+ IndexTileXSize float64

+ IndexTileYSize float64

+ MasQueryHint string

+ Mask *utils.Mask

+ MetricsCollector *metrics.MetricsCollector

+ NameSpaces []string

+ NoReprojection bool

+ Palette *utils.Palette

+ PolygonSegments int

+ PolygonSharcConcLimit int

+ QueryLimit int

+ ReqRes float64

+ SRSCf int

+ ScaleParams ScaleParams

+ SpatialExtent []float64

+ UserSrcGeoTransform int

+ UserSrcSRS int

+ ZoomLimit float64

+ type DatasetAxis struct

+ Aggregate int

+ Grid string

+ IntersectionIdx []int

+ IntersectionValues []float64

+ Name string

+ Order int

+ Params []float64

+ Shape []int

+ Strides []int

+ type DrillFileDescriptor struct

+ CountX int

+ CountY int

+ Mask *image.Gray

+ NoData float64

+ OffX int

+ OffY int

+ type DrillIndexer struct

+ APIAddress string

+ Approx bool

+ Context context.Context

+ DpTol float64

+ Error chan error

+ IdentityTol float64

+ In chan *GeoDrillRequest

+ Out chan *GeoDrillGranule

+ func NewDrillIndexer(ctx context.Context, apiAddr string, identityTol float64, dpTol float64, ...) *DrillIndexer

+ func (p *DrillIndexer) Run(verbose bool)

+ type DrillMerger struct

+ Context context.Context

+ Error chan error

+ In chan *DrillResult

+ Out chan string

+ func NewDrillMerger(ctx context.Context, errChan chan error) *DrillMerger

+ func (dm *DrillMerger) Run(suffix string, namespaces []string, templateFileName string, ...)

+ type DrillPipeline struct

+ APIAddr string

+ Context context.Context

+ DpTol float64

+ Error chan error

+ IdentityTol float64

+ RPCAddrs []string

+ func InitDrillPipeline(ctx context.Context, apiAddr string, rpcAddrs []string, identityTol float64, ...) *DrillPipeline

+ func (dp *DrillPipeline) Process(geoReq GeoDrillRequest, suffix string, templateFileName string, ...) chan string

+ type DrillResult struct

+ Data []*pb.TimeSeries

+ Dates []time.Time

+ NameSpace string

+ NoData float64

+ type FileCrawler struct

+ Error chan error

+ In chan string

+ Out chan string

+ func NewFileCrawler(rootPath string, contains *regexp.Regexp, errChan chan error) *FileCrawler

+ func (fc *FileCrawler) Run()

+ type FileList struct

+ Files []string

+ type FlexRaster struct

+ Data []byte

+ DataHeight int

+ DataWidth int

+ Height int

+ NameSpace string

+ NoData float64

+ OffX int

+ OffY int

+ Polygon string

+ TimeStamp float64

+ Type string

+ Width int

+ type Float32Raster struct

+ Data []float32

+ Height int

+ NameSpace string

+ NoData float64

+ OffX int

+ OffY int

+ Width int

+ func (f32 *Float32Raster) GetNoData() float64

+ type GDALDataset struct

+ ArrayType string

+ Axes []*DatasetAxis

+ DSName string

+ GeoLocation *GeoLocInfo

+ GeoTransform []float64

+ IsOutRange bool

+ Means []float64

+ NameSpace string

+ NoData float64

+ Polygon string

+ RawPath string

+ SRS string

+ SampleCounts []int

+ TimeStamps []time.Time

+ type GeoDrillGRPC struct

+ Clients []string

+ Context context.Context

+ Error chan error

+ In chan *GeoDrillGranule

+ Out chan *DrillResult

+ func NewDrillGRPC(ctx context.Context, serverAddress []string, errChan chan error) *GeoDrillGRPC

+ func (gi *GeoDrillGRPC) Run(bandStrides int, decileCount int, pixelCount int, verbose bool)

+ type GeoDrillGranule struct

+ Approx bool

+ CRS string

+ ClipLower float32

+ ClipUpper float32

+ Geometry string

+ GrpcConcLimit int

+ Means []float64

+ MetricsCollector *metrics.MetricsCollector

+ NameSpace string

+ NoData float64

+ Path string

+ RasterType string

+ RasterXSize float64

+ RasterYSize float64

+ SampleCounts []int

+ TimeStamps []time.Time

+ VRT string

+ type GeoDrillRequest struct

+ BandExpr *utils.BandExpressions

+ CRS string

+ ClipLower float32

+ ClipUpper float32

+ Collection string

+ EndTime time.Time

+ Geometry string

+ GrpcConcLimit int

+ IndexTileXSize float64

+ IndexTileYSize float64

+ Mask *utils.Mask

+ MetricsCollector *metrics.MetricsCollector

+ NameSpaces []string

+ RasterXSize float64

+ RasterYSize float64

+ StartTime time.Time

+ VRTURL string

+ type GeoFile struct

+ DataSets []GeoMetaData

+ Driver string

+ FileName string

+ type GeoInfoGRPC struct

+ Clients []string

+ Context context.Context

+ Error chan error

+ In chan string

+ Out chan *GeoFile

+ func NewInfoGRPC(ctx context.Context, serverAddress []string, errChan chan error) *GeoInfoGRPC

+ func (gi *GeoInfoGRPC) Run()

+ type GeoLocInfo struct

+ LineOffset int

+ LineStep int

+ PixelOffset int

+ PixelStep int

+ XBand int

+ XDSName string

+ YBand int

+ YDSName string

+ type GeoMetaData struct

+ DataSetName string

+ GeoTransform []float64

+ Heights []float64

+ NameSpace string

+ Overviews []*pb.Overview

+ Polygon string

+ Proj4 string

+ ProjWKT string

+ RasterCount int32

+ TimeStamps []time.Time

+ Type string

+ XSize int32

+ YSize int32

+ type GeoRasterGRPC struct

+ Clients []string

+ Context context.Context

+ Error chan error

+ In chan *GeoTileGranule

+ MaxGrpcBufferSize int

+ MaxGrpcRecvMsgSize int

+ Out chan []*FlexRaster

+ PolygonShardConcLimit int

+ func NewRasterGRPC(ctx context.Context, serverAddress []string, maxGrpcRecvMsgSize int, ...) *GeoRasterGRPC

+ func (gi *GeoRasterGRPC) Run(varList []string, verbose bool)

+ type GeoReqContext struct

+ GeoReq *GeoTileRequest

+ Layer *utils.Layer

+ MASAddress string

+ Service *utils.ServiceConfig

+ StyleLayer *utils.Layer

+ type GeoTileAxis struct

+ Aggregate int

+ End *float64

+ IdxSelectors []*GeoTileIdxSelector

+ InValues []float64

+ Order int

+ Start *float64

+ type GeoTileGranule struct

+ BBox []float64

+ BandIdx int

+ CRS string

+ DstGeoTransform []float64

+ GeoLocation *GeoLocInfo

+ Height int

+ NameSpace string

+ OffX int

+ OffY int

+ Path string

+ Polygon string

+ RasterType string

+ RawHeight int

+ RawPath string

+ RawWidth int

+ SrcGeoTransform []float64

+ SrcSRS string

+ TimeStamp float64

+ VarNameSpace string

+ Width int

+ type GeoTileIdxSelector struct

+ End *int

+ IsAll bool

+ IsRange bool

+ Start *int

+ Step *int

+ type GeoTileRequest struct

+ Axes map[string]*GeoTileAxis

+ BBox []float64

+ CRS string

+ Collection string

+ EndTime *time.Time

+ Height int

+ OffX int

+ OffY int

+ OrigBBox []float64

+ StartTime *time.Time

+ Width int

+ type InfoPipeline struct

+ Context context.Context

+ Error chan error

+ RPCAdds []string

+ func InitInfoPipeline(ctx context.Context, rpcAddrs []string, errChan chan error) *InfoPipeline

+ func (dp *InfoPipeline) Process(rootPath string, contains *regexp.Regexp, file io.Writer) chan struct{}

+ type Int16Raster struct

+ Data []int16

+ Height int

+ NameSpace string

+ NoData float64

+ OffX int

+ OffY int

+ Width int

+ func (s16 *Int16Raster) GetNoData() float64

+ type JPGEncoder struct

+ Error chan error

+ In chan *ByteRaster

+ Out chan []byte

+ func NewJPGEncoder(errChan chan error) *JPGEncoder

+ func (enc *JPGEncoder) Run()

+ type JSONEncoder struct

+ Error chan error

+ In chan *GeoFile

+ Out chan []byte

+ func NewJSONEncoder(errChan chan error) *JSONEncoder

+ func (jp *JSONEncoder) Run()

+ type JSONPrinter struct

+ Error chan error

+ File io.Writer

+ In chan []byte

+ Out chan struct{}

+ func NewJSONPrinter(file io.Writer, errChan chan error) *JSONPrinter

+ func (jp *JSONPrinter) Run()

+ type MetadataResponse struct

+ Error string

+ GDALDatasets []*GDALDataset

+ type Overview struct

+ XSize int32

+ YSize int32

+ type PNGEncoder struct

+ Error chan error

+ In chan *ByteRaster

+ Out chan []byte

+ func NewPNGEncoder(errChan chan error) *PNGEncoder

+ func (enc *PNGEncoder) Run()

+ type POSIXDescriptor struct

+ ATime int64

+ CTime int64

+ GID uint32

+ Group string

+ INode uint64

+ MTime int64

+ Mode string

+ Size int64

+ Type string

+ UID uint32

+ User string

+ type PosixInfo struct

+ Error chan error

+ In chan string

+ Out chan string

+ type Raster interface

+ GetNoData func() float64

+ type RasterMerger struct

+ Context context.Context

+ Error chan error

+ In chan []*FlexRaster

+ Out chan []utils.Raster

+ func NewRasterMerger(ctx context.Context, errChan chan error) *RasterMerger

+ func (enc *RasterMerger) Run(bandExpr *utils.BandExpressions, verbose bool)

+ type RasterScaler struct

+ Error chan error

+ In chan Raster

+ Out chan *ByteRaster

+ func NewRasterScaler(errChan chan error) *RasterScaler

+ func (scl *RasterScaler) Run()

+ type ScaleParams struct

+ Clip float64

+ ColourScale int

+ Offset float64

+ Scale float64

+ type TileIndexer struct

+ APIAddress string

+ Context context.Context

+ Error chan error

+ In chan *GeoTileRequest

+ Out chan *GeoTileGranule

+ QueryLimit int

+ func NewTileIndexer(ctx context.Context, apiAddr string, errChan chan error) *TileIndexer

+ func (p *TileIndexer) Run(verbose bool)

+ func (p *TileIndexer) URLIndexGet(ctx context.Context, url string, geoReq *GeoTileRequest, errChan chan error, ...)

+ type TilePipeline struct

+ Context context.Context

+ CurrentLayer *utils.Layer

+ DataSources map[string]*utils.Config

+ Error chan error

+ MASAddress string

+ MaxGrpcBufferSize int

+ MaxGrpcRecvMsgSize int

+ PolygonShardConcLimit int

+ RPCAddress []string

+ func InitTilePipeline(ctx context.Context, masAddr string, rpcAddr []string, maxGrpcRecvMsgSize int, ...) *TilePipeline

+ func (dp *TilePipeline) GetFileList(geoReq *GeoTileRequest, verbose bool) ([]*GeoTileGranule, error)

+ func (dp *TilePipeline) Process(geoReq *GeoTileRequest, verbose bool) chan []utils.Raster

+ type TiledResponse struct

+ IndexerID int

+ IndexerTime time.Duration

+ Metadata *MetadataResponse

+ NumIndexers int

+ type TimeSplitter struct

+ Error chan error

+ In chan *GeoDrillRequest

+ Out chan *GeoDrillRequest

+ YearStep int

+ func NewTimeSplitter(yearStep int, errChan chan error) *TimeSplitter

+ func (ts *TimeSplitter) Run()

+ type UInt16Raster struct

+ Data []uint16

+ Height int

+ NameSpace string

+ NoData float64

+ OffX int

+ OffY int

+ Width int

+ func (u16 *UInt16Raster) GetNoData() float64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL