geocube

package

Go to main page

Versions in this module

v1

v1.0.2

May 15, 2023

v1.0.1

Mar 31, 2023

v1.0.0

Sep 28, 2022

Changes in this version

type ConsolidationContainer

+ OvrResamplingAlg Resampling

v0

v0.6.0

Aug 30, 2022

Changes in this version

type ConsolidationContainer

+ InterlacingPattern string

type Container

+ ID int

type Job

+ LogsCount int

+ NewLogs JobLogs

+ func (j *Job) ClearPersistedLogs()

+ func (j *Job) ResetTasks(states []TaskState)

type JobState

+ const JobStateCONSOLIDATIONFORCERETRYING

type Layout

+ InterlacingPattern string

+ OverviewsMinSize int

+ func (l *Layout) MucogInterlacingPattern() string

type TaskState

+ const TaskStateNEW

type TaskStatus

+ const TaskSent

v0.5.1

Jun 24, 2022

Changes in this version

+ func CompressionStrings() []string

+ func DTypeStrings() []string

+ func DatasetStatusStrings() []string

+ func JobStateStrings() []string

+ func JobStatusStrings() []string

+ func JobTypeStrings() []string

+ func ResamplingStrings() []string

+ func StorageClassStrings() []string

+ func TaskStateStrings() []string

v0.5.0

Apr 14, 2022

v0.4.1

Mar 4, 2022

v0.4.0

Mar 3, 2022

Changes in this version

+ func GDALURI(uri, subdir string) string

type Dataset

+ func (d *Dataset) GDALURI() string

type Record

+ func RecordFromProtobuf(record *pb.Record) (*Record, error)

v0.3.0

Jan 10, 2022

Changes in this version

+ const NO_OVERVIEW

+ const OVERVIEWS_DEFAULT_MIN_SIZE

type AOI

+ func NewAOIFromMultiPolygon(geomAOI geom.MultiPolygon) (*AOI, error)

+ type Cell struct

+ CRS string

+ Coordinates proj.GeographicRing

+ ID string

+ SRID int

type ConsolidationContainer

+ OverviewsMinSize int

type ConsolidationParams

+ OverviewsMinSize int

+ ResamplingAlg Resampling

type ConsolidationRecord

+ ValidShape *proj.Shape

+ type CustomGrid struct

+ Flags []string

+ Name string

+ Parameters map[string]string

+ func (cg *CustomGrid) Cell(uri string) (*gridlib.Cell, error)

+ func (cg *CustomGrid) Covers(ctx context.Context, geomAOI *geom.MultiPolygon) (<-chan gridlib.StreamedURI, error)

+ type CustomGridInitializer interface

+ FindCells func(ctx context.Context, gridName string, aoi *AOI) ([]Cell, []geom.MultiPolygon, error)

+ ReadGrid func(ctx context.Context, name string) (*Grid, error)

type DataFormat

+ func (df DataFormat) ToProtobuf() *pb.DataFormat

+ type ExecutionLevel int32

+ const ExecutionAsynchronous

+ const ExecutionSynchronous

+ const StepByStepAll

+ const StepByStepCritical

+ const StepByStepMajor

+ const StepByStepNever

+ type Grid struct

+ Cells []Cell

+ Description string

+ Name string

+ func NewGridFromProtobuf(grid *pb.Grid) (*Grid, error)

+ func (g *Grid) ToProtobuf() *pb.Grid

type Job

+ ExecutionLevel ExecutionLevel

+ Logs JobLogs

+ Waiting bool

+ func NewDeletionJob(jobName string, executionLevel ExecutionLevel) *Job

+ func (j *Job) CreateDeletionTask(containerURI string) error

+ func (j *Job) LogErr(err string)

+ func (j *Job) LogMsg(severity LogSeverity, msg string)

+ func (j *Job) LogMsgf(severity LogSeverity, msg string, args ...interface{})

+ func (j *Job) SetParams(params ConsolidationParams) error

+ type JobLog struct

+ Date time.Time

+ Msg string

+ Severity LogSeverity

+ Status string

+ type JobLogs []JobLog

+ func (jl *JobLogs) Scan(value interface{}) error

+ func (jl JobLogs) Len() int

+ func (jl JobLogs) Less(i, j int) bool

+ func (jl JobLogs) Swap(i, j int)

+ func (jl JobLogs) Value() (driver.Value, error)

type JobPayload

+ Layout string

type JobState

+ const JobStateDELETIONEFFECTIVE

+ const JobStateDELETIONFAILED

+ const JobStateDELETIONINPROGRESS

+ const JobStateROLLBACKFAILED

+ type JobStateInfo struct

+ Level ExecutionLevel

+ RetryForced bool

type JobStatus

+ const CancelledByUserForced

+ const Continue

+ const DeletionNotReady

+ const DeletionReady

+ const DeletionStarted

+ const OrdersPrepared

+ const PrepareOrdersFailed

+ const RemovalDone

+ const RemovalFailed

+ const Retried

+ const SendOrdersFailed

+ const StartDeletionFailed

+ func JobStatusString(s string) (JobStatus, error)

+ func JobStatusValues() []JobStatus

+ func (i *JobStatus) Scan(value interface{}) error

+ func (i *JobStatus) UnmarshalJSON(data []byte) error

+ func (i JobStatus) IsAJobStatus() bool

+ func (i JobStatus) MarshalJSON() ([]byte, error)

+ func (i JobStatus) Value() (driver.Value, error)

type Layout

+ func (l *Layout) InitGrid(ctx context.Context, initializer CustomGridInitializer) error

+ type LogSeverity string

+ const DEBUG

+ const ERROR

+ const INFO

+ const WARN

+ type StreamedCell struct

+ Error error

type Task

+ func (t *Task) DeletionPayload() (string, error)

v0.2.0

Jun 22, 2021

Changes in this version

+ const DetailAlreadyExistsEntity

+ const DetailAlreadyExistsID

+ const DetailAlreadyExistsKeyID

+ const DetailDependencyStillExistsEntity1

+ const DetailDependencyStillExistsEntity2

+ const DetailDependencyStillExistsID

+ const DetailDependencyStillExistsKeyID

+ const DetailNotFoundEntity

+ const DetailNotFoundID

+ const DetailNotFoundKeyID

+ func IsError(err error, code ErrorCode) bool

+ func MarshalConsolidationEvent(evt ConsolidationEvent) ([]byte, error)

+ func MarshalEvent(evt Event) ([]byte, error)

+ func NewDependencyStillExists(entity1, entity2, keyID, id, desc string, a ...interface{}) error

+ func NewEntityAlreadyExists(entity, keyID, id, desc string, a ...interface{}) error

+ func NewEntityNotFound(entity, keyID, id, desc string, a ...interface{}) error

+ func NewShouldNeverHappen(desc string, a ...interface{}) error

+ func NewUnhandledEvent(desc string, a ...interface{}) error

+ func NewValidationError(desc string, a ...interface{}) error

+ type AOI struct

+ Geometry *wkb.MultiPolygon

+ ID string

+ func NewAOIFromProtobuf(polygons []*pb.Polygon, canBeEmpty bool) (*AOI, error)

+ func (aoi *AOI) HashGeometry() (string, error)

+ func (aoi *AOI) ToProtobuf() *pb.AOI

+ type Bitmap struct

+ Bands int

+ ByteOrder binary.ByteOrder

+ Bytes []byte

+ DType DType

+ Rect image.Rectangle

+ func NewBitmapFromDataset(ds *godal.Dataset) (*Bitmap, error)

+ func NewBitmapHeader(r image.Rectangle, dtype DType, bands int) *Bitmap

+ func (i *Bitmap) SizeX() int

+ func (i *Bitmap) SizeY() int

+ type Compression int32

+ const CompressionLOSSLESS

+ const CompressionLOSSY

+ const CompressionNO

+ func CompressionString(s string) (Compression, error)

+ func CompressionValues() []Compression

+ func (i *Compression) Scan(value interface{}) error

+ func (i *Compression) UnmarshalJSON(data []byte) error

+ func (i Compression) IsACompression() bool

+ func (i Compression) MarshalJSON() ([]byte, error)

+ func (i Compression) String() string

+ func (i Compression) Value() (driver.Value, error)

+ type ConsolidationContainer struct

+ BandsCount int

+ BlockXSize int

+ BlockYSize int

+ CRS string

+ Compression Compression

+ CreateOverviews bool

+ Cutline string

+ DatasetFormat DataMapping

+ Height int

+ InterleaveBands bool

+ InterleaveRecords bool

+ ResamplingAlg Resampling

+ StorageClass StorageClass

+ Transform [6]float64

+ URI string

+ Width int

+ func NewConsolidationContainer(URI string, variable *Variable, params *ConsolidationParams, layout *Layout, ...) (*ConsolidationContainer, error)

+ type ConsolidationDataset struct

+ Bands []int64

+ DatasetFormat DataMapping

+ Overviews bool

+ Subdir string

+ URI string

+ func NewConsolidationDataset(d *Dataset) *ConsolidationDataset

+ func (d *ConsolidationDataset) InGroupOfContainers(c *ConsolidationContainer) bool

+ func (d *ConsolidationDataset) NeedsReconsolidation(c *ConsolidationContainer) bool

+ type ConsolidationEvent struct

+ Container ConsolidationContainer

+ JobID string

+ Records []ConsolidationRecord

+ TaskID string

+ func UnmarshalConsolidationEvent(r io.Reader) (*ConsolidationEvent, error)

+ type ConsolidationParams struct

+ BandsInterleave bool

+ Compression Compression

+ DFormat DataFormat

+ DownsamplingAlg Resampling

+ Exponent float64

+ Overviews bool

+ StorageClass StorageClass

+ func NewConsolidationParamsFromProtobuf(pbp *pb.ConsolidationParams) (*ConsolidationParams, error)

+ func (c *ConsolidationParams) ToProtobuf() *pb.ConsolidationParams

+ func (p *ConsolidationParams) Clean()

+ func (p *ConsolidationParams) Deleted()

+ func (p ConsolidationParams) IsActive() bool

+ func (p ConsolidationParams) IsClean() bool

+ func (p ConsolidationParams) IsDeleted() bool

+ func (p ConsolidationParams) IsDirty() bool

+ func (p ConsolidationParams) IsNew() bool

+ func (p ConsolidationParams) IsToDelete() bool

+ type ConsolidationRecord struct

+ Datasets []ConsolidationDataset

+ DateTime string

+ ID string

+ type Container struct

+ Datasets []*Dataset

+ Managed bool

+ StorageClass StorageClass

+ URI string

+ func NewContainerFromConsolidation(oc *ConsolidationContainer) (*Container, error)

+ func NewContainerFromProtobuf(pbc *pb.Container) (*Container, error)

+ func (c *Container) AddDataset(d *Dataset) error

+ func (c *Container) Clean(all bool)

+ func (c *Container) Delete() error

+ func (c *Container) RemoveDataset(datasetID string) (bool, error)

+ func (c *Container) SetStorageClass(storageClass StorageClass) error

+ func (p *Container) Deleted()

+ func (p Container) IsActive() bool

+ func (p Container) IsClean() bool

+ func (p Container) IsDeleted() bool

+ func (p Container) IsDirty() bool

+ func (p Container) IsNew() bool

+ func (p Container) IsToDelete() bool

+ type DType int

+ const DTypeCOMPLEX64

+ const DTypeFLOAT32

+ const DTypeFLOAT64

+ const DTypeINT16

+ const DTypeINT32

+ const DTypeINT8

+ const DTypeUINT16

+ const DTypeUINT32

+ const DTypeUINT8

+ const DTypeUNDEFINED

+ func DTypeFromGDal(dtype godal.DataType) DType

+ func DTypeFromString(dtype string) DType

+ func DTypeString(s string) (DType, error)

+ func DTypeValues() []DType

+ func (dtype DType) IsFloatingPointFormat() bool

+ func (dtype DType) Size() int

+ func (dtype DType) ToGDAL() godal.DataType

+ func (i *DType) Scan(value interface{}) error

+ func (i *DType) UnmarshalJSON(data []byte) error

+ func (i DType) IsADType() bool

+ func (i DType) MarshalJSON() ([]byte, error)

+ func (i DType) String() string

+ func (i DType) Value() (driver.Value, error)

+ type DataFormat struct

+ DType DType

+ NoData float64

+ Range Range

+ func NewDataFormatFromProtobuf(pbdf *pb.DataFormat) *DataFormat

+ func (df DataFormat) Equals(df2 DataFormat) bool

+ func (df DataFormat) NoDataDefined() bool

+ type DataMapping struct

+ Exponent float64

+ RangeExt Range

+ func (dm DataMapping) Equals(dm2 DataMapping) bool

+ type Dataset struct

+ Bands []int64

+ ContainerSubDir string

+ ContainerURI string

+ DataMapping DataMapping

+ GeogShape proj.GeographicShape

+ GeomShape proj.GeometricShape

+ ID string

+ InstanceID string

+ Overviews bool

+ RecordID string

+ Shape proj.Shape

+ Status DatasetStatus

+ func IncompleteDatasetFromConsolidation(c *ConsolidationContainer, instanceID string) (*Dataset, error)

+ func NewDatasetFromIncomplete(d Dataset, recordID, subdir string) (*Dataset, error)

+ func NewDatasetFromProtobuf(pbd *pb.Dataset, uri string) (*Dataset, error)

+ func (d *Dataset) GDALOpenName() string

+ func (d *Dataset) SetDataType(dtype DType) error

+ func (d *Dataset) SetOverviews(hasOverviews bool) error

+ func (d *Dataset) SetShape(shape *geom.Polygon, crsS string) error

+ func (d *Dataset) ValidateWithVariable(v *Variable) error

+ func (p *Dataset) Clean()

+ func (p *Dataset) Deleted()

+ func (p Dataset) IsActive() bool

+ func (p Dataset) IsClean() bool

+ func (p Dataset) IsDeleted() bool

+ func (p Dataset) IsDirty() bool

+ func (p Dataset) IsNew() bool

+ func (p Dataset) IsToDelete() bool

+ type DatasetStatus int

+ const DatasetStatusACTIVE

+ const DatasetStatusINACTIVE

+ const DatasetStatusTODELETE

+ func DatasetStatusString(s string) (DatasetStatus, error)

+ func DatasetStatusValues() []DatasetStatus

+ func (i *DatasetStatus) Scan(value interface{}) error

+ func (i *DatasetStatus) UnmarshalJSON(data []byte) error

+ func (i DatasetStatus) IsADatasetStatus() bool

+ func (i DatasetStatus) MarshalJSON() ([]byte, error)

+ func (i DatasetStatus) String() string

+ func (i DatasetStatus) Value() (driver.Value, error)

+ type ErrorCode int

+ const DependencyStillExists

+ const EntityAlreadyExists

+ const EntityNotFound

+ const EntityValidationError

+ const ShouldNeverHappen

+ const UnhandledEvent

+ type Event interface

+ func UnmarshalEvent(r io.Reader) (Event, error)

+ type GeocubeError struct

+ func AsError(err error, code ErrorCode) (GeocubeError, bool)

+ func (e GeocubeError) Code() ErrorCode

+ func (e GeocubeError) Desc() string

+ func (e GeocubeError) Detail(i int) string

+ func (e GeocubeError) Error() string

+ type Job struct

+ ActiveTasks int

+ CreationTime time.Time

+ FailedTasks int

+ ID string

+ LastUpdateTime time.Time

+ LockedDatasets [int32(LockFlagNB)]LockedDatasets

+ Log *log.Logger

+ Name string

+ Params JobParams

+ Payload JobPayload

+ State JobState

+ Tasks []*Task

+ Type JobType

+ func NewConsolidationJob(jobName, layoutID, instanceID string, params ConsolidationParams, ...) *Job

+ func NewJob(id string) *Job

+ func (j *Job) CancelTask(index int)

+ func (j *Job) Clean(all bool)

+ func (j *Job) CreateConsolidationTask(evt ConsolidationEvent) error

+ func (j *Job) DeleteAllTasks()

+ func (j *Job) DeleteTask(index int)

+ func (j *Job) LockDatasets(datasetsID []string, flag LockFlag)

+ func (j *Job) OCCTime() time.Time

+ func (j *Job) ReleaseDatasets(flag LockFlag)

+ func (j *Job) ResetAllTasks()

+ func (j *Job) ToDelete(all bool) bool

+ func (j *Job) ToProtobuf() (*pb.Job, error)

+ func (j *Job) Trigger(evt JobEvent) error

+ func (j *Job) UpdateTask(evt TaskEvent) error

+ func (p *Job) Deleted()

+ func (p Job) IsActive() bool

+ func (p Job) IsClean() bool

+ func (p Job) IsDeleted() bool

+ func (p Job) IsDirty() bool

+ func (p Job) IsNew() bool

+ func (p Job) IsToDelete() bool

+ type JobEvent struct

+ Error string

+ JobID string

+ Status JobStatus

+ func NewJobEvent(jobID string, status JobStatus, err string) *JobEvent

+ type JobParams interface

+ Clean func()

+ Deleted func()

+ IsDirty func() bool

+ IsNew func() bool

+ IsToDelete func() bool

+ type JobPayload struct

+ Err string

+ InstanceID string

+ LayoutID string

+ ParamsID string

+ func (jp *JobPayload) Scan(value interface{}) error

+ func (jp JobPayload) Value() (driver.Value, error)

+ type JobState int32

+ const JobStateABORTED

+ const JobStateCANCELLATIONFAILED

+ const JobStateCONSOLIDATIONCANCELLING

+ const JobStateCONSOLIDATIONDONE

+ const JobStateCONSOLIDATIONEFFECTIVE

+ const JobStateCONSOLIDATIONFAILED

+ const JobStateCONSOLIDATIONINDEXED

+ const JobStateCONSOLIDATIONINPROGRESS

+ const JobStateCONSOLIDATIONRETRYING

+ const JobStateCREATED

+ const JobStateDONE

+ const JobStateDONEBUTUNTIDY

+ const JobStateFAILED

+ const JobStateINITIALISATIONFAILED

+ const JobStateNEW

+ func JobStateString(s string) (JobState, error)

+ func JobStateValues() []JobState

+ func (i *JobState) Scan(value interface{}) error

+ func (i *JobState) UnmarshalJSON(data []byte) error

+ func (i JobState) IsAJobState() bool

+ func (i JobState) MarshalJSON() ([]byte, error)

+ func (i JobState) String() string

+ func (i JobState) Value() (driver.Value, error)

+ type JobStatus int32

+ const CancellationDone

+ const CancellationFailed

+ const CancelledByUser

+ const ConsolidationDone

+ const ConsolidationFailed

+ const ConsolidationIndexed

+ const ConsolidationIndexingFailed

+ const ConsolidationOrdersPrepared

+ const ConsolidationRetried

+ const ConsolidationRetryFailed

+ const DatasetsSwapped

+ const DeletionDone

+ const DeletionFailed

+ const DeletionOrdersSent

+ const JobCreated

+ const PrepareConsolidationOrdersFailed

+ const RetryForced

+ const RollbackDone

+ const RollbackFailed

+ const SendConsolidationOrdersFailed

+ const SendDeletionOrdersFailed

+ const SwapDatasetsFailed

+ func (s JobStatus) String() string

+ type JobType int32

+ const JobTypeCONSOLIDATION

+ const JobTypeDELETION

+ const JobTypeINGESTION

+ func JobTypeString(s string) (JobType, error)

+ func JobTypeValues() []JobType

+ func (i *JobType) Scan(value interface{}) error

+ func (i *JobType) UnmarshalJSON(data []byte) error

+ func (i JobType) IsAJobType() bool

+ func (i JobType) MarshalJSON() ([]byte, error)

+ func (i JobType) String() string

+ func (i JobType) Value() (driver.Value, error)

+ type Layout struct

+ BlockXSize int

+ BlockYSize int

+ GridFlags []string

+ GridParameters Metadata

+ ID string

+ MaxRecords int

+ Name string

+ func NewLayoutFromProtobuf(pbl *pb.Layout) (*Layout, error)

+ func (l *Layout) Covers(aoi *geom.MultiPolygon) ([]*gridlib.Cell, error)

+ func (l *Layout) ToProtobuf() *pb.Layout

+ type LockFlag int32

+ const LockFlagALL

+ const LockFlagINIT

+ const LockFlagNB

+ const LockFlagNEW

+ const LockFlagTODELETE

+ type LockedDatasets struct

+ func (l *LockedDatasets) Clean()

+ func (l LockedDatasets) NewIDs() []string

+ func (p *LockedDatasets) Deleted()

+ func (p LockedDatasets) IsActive() bool

+ func (p LockedDatasets) IsClean() bool

+ func (p LockedDatasets) IsDeleted() bool

+ func (p LockedDatasets) IsDirty() bool

+ func (p LockedDatasets) IsNew() bool

+ func (p LockedDatasets) IsToDelete() bool

+ type Metadata map[string]string

+ func (m *Metadata) Scan(src interface{}) error

+ func (m Metadata) Value() (driver.Value, error)

+ type Palette struct

+ Name string

+ Points []colorPoint

+ func NewPaletteFromPb(pbp *pb.Palette) (Palette, error)

+ func (p *Palette) Clean()

+ func (p *Palette) Deleted()

+ func (p Palette) IsActive() bool

+ func (p Palette) IsClean() bool

+ func (p Palette) IsDeleted() bool

+ func (p Palette) IsDirty() bool

+ func (p Palette) IsNew() bool

+ func (p Palette) IsToDelete() bool

+ func (p Palette) PaletteN(n int) color.Palette

+ func (p Palette) Validate() error

+ type Range struct

+ Max float64

+ Min float64

+ func (r Range) Interval() float64

+ type Record struct

+ AOI AOI

+ ID string

+ Name URN

+ Tags Metadata

+ Time time.Time

+ func NewRecordFromProtobuf(record *pb.NewRecord) (*Record, error)

+ func (p *Record) Clean()

+ func (p *Record) Deleted()

+ func (p Record) IsActive() bool

+ func (p Record) IsClean() bool

+ func (p Record) IsDeleted() bool

+ func (p Record) IsDirty() bool

+ func (p Record) IsNew() bool

+ func (p Record) IsToDelete() bool

+ func (r *Record) ToProtobuf(withAOI bool) *pb.Record

+ type Resampling int32

+ const ResamplingAVERAGE

+ const ResamplingBILINEAR

+ const ResamplingCUBIC

+ const ResamplingCUBICSPLINE

+ const ResamplingLANCZOS

+ const ResamplingMAX

+ const ResamplingMED

+ const ResamplingMIN

+ const ResamplingMODE

+ const ResamplingNEAR

+ const ResamplingQ1

+ const ResamplingQ3

+ func ResamplingString(s string) (Resampling, error)

+ func ResamplingValues() []Resampling

+ func (i *Resampling) Scan(value interface{}) error

+ func (i *Resampling) UnmarshalJSON(data []byte) error

+ func (i Resampling) IsAResampling() bool

+ func (i Resampling) MarshalJSON() ([]byte, error)

+ func (i Resampling) String() string

+ func (i Resampling) Value() (driver.Value, error)

+ func (r Resampling) CanInterpolate() bool

+ func (r Resampling) ToGDAL() godal.ResamplingAlg

+ type StorageClass int

+ const StorageClassARCHIVE

+ const StorageClassDEEPARCHIVE

+ const StorageClassINFREQUENT

+ const StorageClassSTANDARD

+ const StorageClassUNDEFINED

+ func StorageClassString(s string) (StorageClass, error)

+ func StorageClassValues() []StorageClass

+ func ToGcStorageClass(s string) (StorageClass, error)

+ func ToStorageClass(s string) (StorageClass, error)

+ func (i *StorageClass) Scan(value interface{}) error

+ func (i *StorageClass) UnmarshalJSON(data []byte) error

+ func (i StorageClass) IsAStorageClass() bool

+ func (i StorageClass) MarshalJSON() ([]byte, error)

+ func (i StorageClass) String() string

+ func (i StorageClass) Value() (driver.Value, error)

+ type Task struct

+ ID string

+ Payload []byte

+ State TaskState

+ func (p *Task) Clean()

+ func (p *Task) Deleted()

+ func (p Task) IsActive() bool

+ func (p Task) IsClean() bool

+ func (p Task) IsDeleted() bool

+ func (p Task) IsDirty() bool

+ func (p Task) IsNew() bool

+ func (p Task) IsToDelete() bool

+ func (t *Task) ConsolidationOutput() (*ConsolidationContainer, []ConsolidationRecord, error)

+ type TaskEvent struct

+ Error string

+ JobID string

+ Status TaskStatus

+ TaskID string

+ func NewTaskEvent(jobID, taskID string, eventStatus TaskStatus, err error) *TaskEvent

+ type TaskState int32

+ const TaskStateCANCELLED

+ const TaskStateDONE

+ const TaskStateFAILED

+ const TaskStatePENDING

+ func TaskStateString(s string) (TaskState, error)

+ func TaskStateValues() []TaskState

+ func (i *TaskState) Scan(value interface{}) error

+ func (i *TaskState) UnmarshalJSON(data []byte) error

+ func (i TaskState) IsATaskState() bool

+ func (i TaskState) MarshalJSON() ([]byte, error)

+ func (i TaskState) String() string

+ func (i TaskState) Value() (driver.Value, error)

+ type TaskStatus int32

+ const TaskCancelled

+ const TaskFailed

+ const TaskIgnored

+ const TaskSuccessful

+ func (ts TaskStatus) String() string

+ type URN string

+ func (urn *URN) Scan(src interface{}) error

+ func (urn URN) Value() (driver.Value, error)

+ type Variable struct

+ Bands []string

+ ConsolidationParams ConsolidationParams

+ DFormat DataFormat

+ Description string

+ ID string

+ Instances map[string]*VariableInstance

+ Name string

+ Palette string

+ Resampling Resampling

+ Unit string

+ func NewVariableFromProtobuf(pbv *pb.Variable) (*Variable, error)

+ func (p *Variable) Deleted()

+ func (p Variable) IsActive() bool

+ func (p Variable) IsClean() bool

+ func (p Variable) IsDeleted() bool

+ func (p Variable) IsDirty() bool

+ func (p Variable) IsNew() bool

+ func (p Variable) IsToDelete() bool

+ func (v *Variable) AddInstance(vi *VariableInstance) error

+ func (v *Variable) CheckInstanceExists(instanceID string) error

+ func (v *Variable) Clean(all bool)

+ func (v *Variable) SetConsolidationParams(params ConsolidationParams) error

+ func (v *Variable) ToDelete(instanceID string)

+ func (v *Variable) ToProtobuf() *pb.Variable

+ func (v *Variable) Update(name, unit, description, palette *string, resampling *Resampling) error

+ func (v *Variable) UpdateInstance(instanceID string, name *string, newMetadata map[string]string, ...) error

+ type VariableInstance struct

+ ID string

+ Metadata Metadata

+ Name string

+ func NewInstance(name string, metadata map[string]string) (*VariableInstance, error)

+ func (p *VariableInstance) Clean()

+ func (p *VariableInstance) Deleted()

+ func (p VariableInstance) IsActive() bool

+ func (p VariableInstance) IsClean() bool

+ func (p VariableInstance) IsDeleted() bool

+ func (p VariableInstance) IsDirty() bool

+ func (p VariableInstance) IsNew() bool

+ func (p VariableInstance) IsToDelete() bool

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