gdalservice

package
v0.0.0-...-1152cda Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 9, 2018 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package gdalservice is a generated protocol buffer package.

It is generated from these files:

gdalservice.proto

It has these top-level messages:
GeoRPCGranule
Raster
TimeSeries
Overview
GeoMetaData
GeoFile
Result

Index

Constants

This section is empty.

Variables

View Source
var LibexecDir = "/usr/local/libexec"

Functions

func RegisterGDALServer

func RegisterGDALServer(s *grpc.Server, srv GDALServer)

Types

type ErrorMsg

type ErrorMsg struct {
	Address string
	Replace bool
	Error   error
}

type GDALClient

type GDALClient interface {
	Process(ctx context.Context, in *GeoRPCGranule, opts ...grpc.CallOption) (*Result, error)
}

func NewGDALClient

func NewGDALClient(cc *grpc.ClientConn) GDALClient

type GDALServer

type GDALServer interface {
	Process(context.Context, *GeoRPCGranule) (*Result, error)
}

type GeoFile

type GeoFile struct {
	FileName string         `protobuf:"bytes,1,opt,name=fileName" json:"fileName,omitempty"`
	Driver   string         `protobuf:"bytes,2,opt,name=driver" json:"driver,omitempty"`
	DataSets []*GeoMetaData `protobuf:"bytes,3,rep,name=dataSets" json:"dataSets,omitempty"`
}

func (*GeoFile) Descriptor

func (*GeoFile) Descriptor() ([]byte, []int)

func (*GeoFile) GetDataSets

func (m *GeoFile) GetDataSets() []*GeoMetaData

func (*GeoFile) GetDriver

func (m *GeoFile) GetDriver() string

func (*GeoFile) GetFileName

func (m *GeoFile) GetFileName() string

func (*GeoFile) ProtoMessage

func (*GeoFile) ProtoMessage()

func (*GeoFile) Reset

func (m *GeoFile) Reset()

func (*GeoFile) String

func (m *GeoFile) String() string

type GeoMetaData

type GeoMetaData struct {
	DatasetName  string                       `protobuf:"bytes,1,opt,name=datasetName" json:"datasetName,omitempty"`
	NameSpace    string                       `protobuf:"bytes,2,opt,name=nameSpace" json:"nameSpace,omitempty"`
	Type         string                       `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
	RasterCount  int32                        `protobuf:"varint,4,opt,name=rasterCount" json:"rasterCount,omitempty"`
	TimeStamps   []*google_protobuf.Timestamp `protobuf:"bytes,5,rep,name=timeStamps" json:"timeStamps,omitempty"`
	Height       []float64                    `protobuf:"fixed64,6,rep,packed,name=height" json:"height,omitempty"`
	Overviews    []*Overview                  `protobuf:"bytes,7,rep,name=overviews" json:"overviews,omitempty"`
	XSize        int32                        `protobuf:"varint,8,opt,name=xSize" json:"xSize,omitempty"`
	YSize        int32                        `protobuf:"varint,9,opt,name=ySize" json:"ySize,omitempty"`
	GeoTransform []float64                    `protobuf:"fixed64,10,rep,packed,name=geoTransform" json:"geoTransform,omitempty"`
	Polygon      string                       `protobuf:"bytes,11,opt,name=polygon" json:"polygon,omitempty"`
	ProjWKT      string                       `protobuf:"bytes,12,opt,name=projWKT" json:"projWKT,omitempty"`
	Proj4        string                       `protobuf:"bytes,13,opt,name=proj4" json:"proj4,omitempty"`
}

func (*GeoMetaData) Descriptor

func (*GeoMetaData) Descriptor() ([]byte, []int)

func (*GeoMetaData) GetDatasetName

func (m *GeoMetaData) GetDatasetName() string

func (*GeoMetaData) GetGeoTransform

func (m *GeoMetaData) GetGeoTransform() []float64

func (*GeoMetaData) GetHeight

func (m *GeoMetaData) GetHeight() []float64

func (*GeoMetaData) GetNameSpace

func (m *GeoMetaData) GetNameSpace() string

func (*GeoMetaData) GetOverviews

func (m *GeoMetaData) GetOverviews() []*Overview

func (*GeoMetaData) GetPolygon

func (m *GeoMetaData) GetPolygon() string

func (*GeoMetaData) GetProj4

func (m *GeoMetaData) GetProj4() string

func (*GeoMetaData) GetProjWKT

func (m *GeoMetaData) GetProjWKT() string

func (*GeoMetaData) GetRasterCount

func (m *GeoMetaData) GetRasterCount() int32

func (*GeoMetaData) GetTimeStamps

func (m *GeoMetaData) GetTimeStamps() []*google_protobuf.Timestamp

func (*GeoMetaData) GetType

func (m *GeoMetaData) GetType() string

func (*GeoMetaData) GetXSize

func (m *GeoMetaData) GetXSize() int32

func (*GeoMetaData) GetYSize

func (m *GeoMetaData) GetYSize() int32

func (*GeoMetaData) ProtoMessage

func (*GeoMetaData) ProtoMessage()

func (*GeoMetaData) Reset

func (m *GeoMetaData) Reset()

func (*GeoMetaData) String

func (m *GeoMetaData) String() string

type GeoRPCGranule

type GeoRPCGranule struct {
	Path     string    `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
	Geometry string    `protobuf:"bytes,2,opt,name=geometry" json:"geometry,omitempty"`
	Bands    []int32   `protobuf:"varint,3,rep,packed,name=bands" json:"bands,omitempty"`
	Height   int32     `protobuf:"varint,4,opt,name=height" json:"height,omitempty"`
	Width    int32     `protobuf:"varint,5,opt,name=width" json:"width,omitempty"`
	EPSG     int32     `protobuf:"varint,6,opt,name=ePSG" json:"ePSG,omitempty"`
	Geot     []float64 `protobuf:"fixed64,7,rep,packed,name=geot" json:"geot,omitempty"`
}

func (*GeoRPCGranule) Descriptor

func (*GeoRPCGranule) Descriptor() ([]byte, []int)

func (*GeoRPCGranule) GetBands

func (m *GeoRPCGranule) GetBands() []int32

func (*GeoRPCGranule) GetEPSG

func (m *GeoRPCGranule) GetEPSG() int32

func (*GeoRPCGranule) GetGeometry

func (m *GeoRPCGranule) GetGeometry() string

func (*GeoRPCGranule) GetGeot

func (m *GeoRPCGranule) GetGeot() []float64

func (*GeoRPCGranule) GetHeight

func (m *GeoRPCGranule) GetHeight() int32

func (*GeoRPCGranule) GetPath

func (m *GeoRPCGranule) GetPath() string

func (*GeoRPCGranule) GetWidth

func (m *GeoRPCGranule) GetWidth() int32

func (*GeoRPCGranule) ProtoMessage

func (*GeoRPCGranule) ProtoMessage()

func (*GeoRPCGranule) Reset

func (m *GeoRPCGranule) Reset()

func (*GeoRPCGranule) String

func (m *GeoRPCGranule) String() string

type Overview

type Overview struct {
	XSize int32 `protobuf:"varint,1,opt,name=xSize" json:"xSize,omitempty"`
	YSize int32 `protobuf:"varint,2,opt,name=ySize" json:"ySize,omitempty"`
}

func (*Overview) Descriptor

func (*Overview) Descriptor() ([]byte, []int)

func (*Overview) GetXSize

func (m *Overview) GetXSize() int32

func (*Overview) GetYSize

func (m *Overview) GetYSize() int32

func (*Overview) ProtoMessage

func (*Overview) ProtoMessage()

func (*Overview) Reset

func (m *Overview) Reset()

func (*Overview) String

func (m *Overview) String() string

type Process

type Process struct {
	Context        context.Context
	CancelFunc     context.CancelFunc
	TaskQueue      chan *Task
	Address        string
	Cmd            *exec.Cmd
	CombinedOutput io.ReadCloser
	ErrorMsg       chan *ErrorMsg
}

func NewProcess

func NewProcess(ctx context.Context, tQueue chan *Task, binary string, errChan chan *ErrorMsg, debug bool) *Process

func (*Process) Cancel

func (p *Process) Cancel()

func (*Process) Start

func (p *Process) Start()

type ProcessPool

type ProcessPool struct {
	Pool      []*Process
	TaskQueue chan *Task
	ErrorMsg  chan *ErrorMsg
}

func CreateProcessPool

func CreateProcessPool(n int, debug bool) *ProcessPool

func (*ProcessPool) AddProcess

func (p *ProcessPool) AddProcess(debug bool)

func (p *ProcessPool) AddProcess(errChan chan error, healthChan chan *HealthMsg) {

func (*ProcessPool) AddQueue

func (p *ProcessPool) AddQueue(task *Task)

func (*ProcessPool) DeleteProcessPool

func (p *ProcessPool) DeleteProcessPool()

type Raster

type Raster struct {
	Data       []byte  `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	NoData     float64 `protobuf:"fixed64,2,opt,name=noData" json:"noData,omitempty"`
	RasterType string  `protobuf:"bytes,3,opt,name=rasterType" json:"rasterType,omitempty"`
}

func (*Raster) Descriptor

func (*Raster) Descriptor() ([]byte, []int)

func (*Raster) GetData

func (m *Raster) GetData() []byte

func (*Raster) GetNoData

func (m *Raster) GetNoData() float64

func (*Raster) GetRasterType

func (m *Raster) GetRasterType() string

func (*Raster) ProtoMessage

func (*Raster) ProtoMessage()

func (*Raster) Reset

func (m *Raster) Reset()

func (*Raster) String

func (m *Raster) String() string

type Result

type Result struct {
	TimeSeries []*TimeSeries `protobuf:"bytes,1,rep,name=timeSeries" json:"timeSeries,omitempty"`
	Raster     *Raster       `protobuf:"bytes,2,opt,name=raster" json:"raster,omitempty"`
	Info       *GeoFile      `protobuf:"bytes,3,opt,name=info" json:"info,omitempty"`
	Error      string        `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"`
}

func (*Result) Descriptor

func (*Result) Descriptor() ([]byte, []int)

func (*Result) GetError

func (m *Result) GetError() string

func (*Result) GetInfo

func (m *Result) GetInfo() *GeoFile

func (*Result) GetRaster

func (m *Result) GetRaster() *Raster

func (*Result) GetTimeSeries

func (m *Result) GetTimeSeries() []*TimeSeries

func (*Result) ProtoMessage

func (*Result) ProtoMessage()

func (*Result) Reset

func (m *Result) Reset()

func (*Result) String

func (m *Result) String() string

type Task

type Task struct {
	Payload *GeoRPCGranule
	Resp    chan *Result
	Error   chan error
}

type TimeSeries

type TimeSeries struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value" json:"value,omitempty"`
	Count int32   `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*TimeSeries) Descriptor

func (*TimeSeries) Descriptor() ([]byte, []int)

func (*TimeSeries) GetCount

func (m *TimeSeries) GetCount() int32

func (*TimeSeries) GetValue

func (m *TimeSeries) GetValue() float64

func (*TimeSeries) ProtoMessage

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset

func (m *TimeSeries) Reset()

func (*TimeSeries) String

func (m *TimeSeries) String() string

Jump to

Keyboard shortcuts

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