messages

Documentation

Index

• type Example
• type ExportData
• type IngestAll
• type IngestStation
• type IngestionCompleted
• type IngestionFailed
• type IngestionReceived
• type ProcessIngestion
• type RefreshAllMaterializedViews
• type RefreshMaterializedView
• type RefreshStation
• type SensorDataBatch
• type SensorDataBatchCommitted
• type SensorDataBatchRow
• type SensorDataBatchesStarted
• type SensorDataModified
• type StationIngested
• type StationLocationUpdated
• type Wakeup
• type WalkEverything

Types

type Example

type Example struct {
	Name string `json:"name"`
}

type ExportData

type ExportData struct {
	ID     int64  `json:"id"`
	UserID int32  `json:"user_id"`
	Token  string `json:"token"`
	Format string `json:"format"`
}

type IngestAll

type IngestAll struct {
}

type IngestStation

type IngestStation struct {
	StationID int32 `json:"station_id"`
	Verbose   bool  `json:"verbose"`
	UserID    int32 `json:"user_id"`
}

type IngestionCompleted

type IngestionCompleted struct {
	QueuedID    int64     `json:"queued_id"`
	CompletedAt time.Time `json:"completed_at"`
	StationID   *int32    `json:"station_id"`
	UserID      int32     `json:"user_id"`
	Start       time.Time `json:"start"`
	End         time.Time `json:"end"`
}

type IngestionFailed

type IngestionFailed struct {
	QueuedID int64 `json:"queued_id"`
}

type IngestionReceived

type IngestionReceived struct {
	QueuedID    int64  `json:"queued_id"`
	IngestionID *int64 `json:"ingestion_id"`
	Verbose     bool   `json:"verbose"`
	UserID      int32  `json:"user_id"`
	SaveData    bool   `json:"save_data"` // TODO Remove this
}

type ProcessIngestion

type ProcessIngestion struct {
	IngestionReceived
}

type RefreshAllMaterializedViews

type RefreshAllMaterializedViews struct {
}

type RefreshMaterializedView

type RefreshMaterializedView struct {
	View  string
	Start time.Time
	End   time.Time
}

type RefreshStation

type RefreshStation struct {
	StationID   int32         `json:"station_id"`
	Completely  bool          `json:"completely"`
	SkipManual  bool          `json:"skip_manual,omitempty"`
	Verbose     bool          `json:"verbose"`
	UserID      int32         `json:"user_id"`
	HowRecently time.Duration `json:"how_recently"`
}

type SensorDataBatch

type SensorDataBatch struct {
	BatchID string               `json:"batch_id"`
	Rows    []SensorDataBatchRow `json:"rows"`
}

type SensorDataBatchCommitted

type SensorDataBatchCommitted struct {
	BatchID   string    `json:"batch_id"`
	Time      time.Time `json:"time"`
	DataStart time.Time `json:"data_start"`
	DataEnd   time.Time `json:"data_end"`
}

type SensorDataBatchRow

type SensorDataBatchRow struct {
	Time      time.Time  `json:"time"`
	StationID int32      `json:"station_id"`
	ModuleID  int64      `json:"module_id"`
	SensorID  int64      `json:"sensor_id"`
	Location  *[]float64 `json:"location"`
	Value     *float64   `json:"value"`
}

type SensorDataBatchesStarted

type SensorDataBatchesStarted struct {
	BatchIDs []string `json:"batch_ids"`
}

type SensorDataModified

type SensorDataModified struct {
	ModifiedAt  time.Time `json:"modified_at"`
	PublishedAt time.Time `json:"published_at"`
	StationID   *int32    `json:"station_id"`
	UserID      int32     `json:"user_id"`
	Start       time.Time `json:"start"`
	End         time.Time `json:"end"`
}

type StationIngested

type StationIngested struct {
	StationID int32 `json:"station_id"`
	UserID    int32 `json:"user_id"`
}

type StationLocationUpdated

type StationLocationUpdated struct {
	StationID int32     `json:"station_id"`
	Time      time.Time `json:"time"`
	Location  []float64 `json:"location"`
}

type Wakeup

type Wakeup struct {
	Counter int `json:"counter"`
}

type WalkEverything

type WalkEverything struct {
}