database

type Config struct {
	// contains filtered or unexported fields
}

type Database interface {
	Init(ctx context.Context) error
	Seed(ctx context.Context, reader io.Reader) error
	AddEntity(ctx context.Context, e Entity) error
	GetEntity(ctx context.Context, entityID, entityType string) (Entity, error)
	GetEntities(ctx context.Context, entityType string, page, size int) (int64, []Entity, error)
	GetChildEntities(ctx context.Context, root Entity, entityType string) ([]Entity, error)
	AddObservation(ctx context.Context, so SensorObservation) error
	GetObservations(ctx context.Context, sensorId string, starting, ending time.Time, page, size int) (int64, []Observation, error)
}

type Entity struct {
	Context  string    `json:"@context"`
	Id       string    `json:"@id"`
	Type     string    `json:"@type"`
	IsPartOf *Property `json:"isPartOf,omitempty"`
}

type Observation struct {
	ObservationTime time.Time `json:"observationTime"`
	Value           *float64  `json:"value,omitempty"`
	ValueString     *string   `json:"valueString,omitempty"`
	ValueBoolean    *bool     `json:"valueBoolean,omitempty"`
	QuantityKind    string    `json:"quantityKind"`
	SensorId        string    `json:"sensorId"`
}

type Property struct {
	Id   string `json:"@id"`
	Type string `json:"@type"`
}

type SensorObservation struct {
	Format       string        `json:"format"`
	DeviceID     string        `json:"deviceId"`
	Observations []Observation `json:"observations"`
}