Documentation ¶
Index ¶
- func GetFreePort() (port int, err error)
- func IsIpv6(ip string) bool
- func SetGridValue(gV grid.Grid_Value, val interface{}) error
- type AggregationPart
- type ConnError
- type ConnectionManager
- type DeleteMsg
- type Grid
- func (g *Grid) ClosestValueAt(c context.Context, call grid.Grid_closestValueAt) error
- func (g *Grid) Dimension(c context.Context, call grid.Grid_dimension) error
- func (g *Grid) Info(c context.Context, call common.Identifiable_info) error
- func (g *Grid) InitialSturdyRef() (*SturdyRef, error)
- func (g Grid) IsComparable(r Resolution) bool
- func (g *Grid) LatLonBounds(c context.Context, call grid.Grid_latLonBounds) error
- func (g *Grid) NoDataValue(c context.Context, call grid.Grid_noDataValue) error
- func (g *Grid) Resolution(c context.Context, call grid.Grid_resolution) error
- func (g *Grid) Save(c context.Context, call persistence.Persistent_save) error
- func (g *Grid) StreamCells(c context.Context, call grid.Grid_streamCells) error
- func (g *Grid) Unit(c context.Context, call grid.Grid_unit) error
- func (g *Grid) ValueAt(c context.Context, call grid.Grid_valueAt) error
- type Identifiable
- type LatLon
- type LatLonBoundaries
- type Persistable
- type ReleaseSturdyRefAction
- type Resolution
- type RestoreAnswer
- type RestoreMsg
- type Restorer
- type RowCol
- type SaveAnswer
- type SaveMsg
- type StreamingCallback
- type SturdyRef
- type SturdyRefToken
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetFreePort ¶
func SetGridValue ¶
func SetGridValue(gV grid.Grid_Value, val interface{}) error
Types ¶
type AggregationPart ¶
type ConnectionManager ¶
type ConnectionManager struct {
// contains filtered or unexported fields
}
func NewConnectionManager ¶
func NewConnectionManager() *ConnectionManager
func (*ConnectionManager) TryConnect ¶
type Grid ¶
type Grid struct { GridResolution Resolution GridUnit string NumRows uint64 NumCols uint64 NoDataType interface{} // valid types are int64, float64, bool, uint64 Bounds LatLonBoundaries BoundsFromCellCenter LatLonBoundaries // functions that need to be implemented to use the grid capnp interface RowColToLatLon func(row, col uint64) (LatLon, error) GetValueRowCol func(row, col uint64) (interface{}, error) GetValueLatLon func(lat, lon float64) (interface{}, RowCol, RowCol, error) GetValueRowColAggregated func(row, col uint64, resolution Resolution, agg string, includeAggParts bool) (interface{}, []*AggregationPart, error) GetValueLatLonAggregated func(lat, lon float64, resolution Resolution, agg string, includeAggParts bool) (interface{}, []*AggregationPart, error) // contains filtered or unexported fields }
Grid is a struct that implements the Grid_Server interface for immutable grids, the functions that need to be implemented are GetValueRowCol, GetValueLatLon GetValueRowColAggregated, GetValueLatLonAggregated not thread safe if the grid below is changing
func (*Grid) ClosestValueAt ¶
Grid_Server interface
func (*Grid) InitialSturdyRef ¶
func (Grid) IsComparable ¶
func (g Grid) IsComparable(r Resolution) bool
func (*Grid) LatLonBounds ¶
func (*Grid) NoDataValue ¶
func (*Grid) Resolution ¶
func (*Grid) Save ¶
func (g *Grid) Save(c context.Context, call persistence.Persistent_save) error
Persistence_Server interface
func (*Grid) StreamCells ¶
type Identifiable ¶
func (*Identifiable) Info ¶
func (i *Identifiable) Info(c context.Context, ii common.Identifiable_info) error
type LatLonBoundaries ¶
type Persistable ¶
type Persistable struct { //function to create a capability of the object Cap func() capnp.Client // contains filtered or unexported fields }
func (*Persistable) Save ¶
func (p *Persistable) Save(c context.Context, call persistence.Persistent_save) error
Persistent_Server interface
type ReleaseSturdyRefAction ¶
type ReleaseSturdyRefAction struct {
// contains filtered or unexported fields
}
ReleaseSturdyRefAction
func NewAction ¶
func NewAction(doSave chan *SaveMsg, doAction func() error) *ReleaseSturdyRefAction
func (*ReleaseSturdyRefAction) ReleaseSR ¶
func (a *ReleaseSturdyRefAction) ReleaseSR(c context.Context, call persistence.Persistent_ReleaseSturdyRef_releaseSR) error
ReleaseSturdyRef_Server interface
func (*ReleaseSturdyRefAction) Save ¶
func (a *ReleaseSturdyRefAction) Save(c context.Context, call persistence.Persistent_save) error
type Resolution ¶
type Resolution struct {
Value interface{}
}
func (Resolution) Compare ¶
func (r Resolution) Compare(other Resolution) int
Compare compares two resolutions 1 means r is bigger than other -1 means r is smaller than other 0 means r is equal to other
type RestoreAnswer ¶
type RestoreAnswer struct {
// contains filtered or unexported fields
}
type RestoreMsg ¶
type RestoreMsg struct {
// contains filtered or unexported fields
}
type Restorer ¶
type Restorer struct {
// contains filtered or unexported fields
}
func NewRestorer ¶
NewRestorer creates a new Restorer
func (*Restorer) BootstrapSturdyRef ¶
func (*Restorer) Restore ¶
func (r *Restorer) Restore(c context.Context, call persistence.Restorer_restore) error
Restorer_Server interface
type SaveAnswer ¶
type SaveAnswer struct {
// contains filtered or unexported fields
}
type StreamingCallback ¶
type StreamingCallback struct {
// contains filtered or unexported fields
}
func (*StreamingCallback) SendCells ¶
func (cs *StreamingCallback) SendCells(ctx context.Context, call grid.Grid_Callback_sendCells) error
type SturdyRef ¶
type SturdyRef struct {
// contains filtered or unexported fields
}
func NewSturdyRef ¶
func NewSturdyRefByString ¶
type SturdyRefToken ¶
type SturdyRefToken string
Click to show internal directories.
Click to hide internal directories.