29 lines
1.1 KiB
Go
29 lines
1.1 KiB
Go
package weathersource
|
|
|
|
import "weather-data/storage"
|
|
|
|
//NewWeatherDataCallbackFunc Function-Signature for new weather data callback function
|
|
type NewWeatherDataCallbackFunc func(storage.WeatherData)
|
|
|
|
//WeatherSource is the interface for different weather-source implementations
|
|
type WeatherSource interface {
|
|
AddNewWeatherDataCallback(NewWeatherDataCallbackFunc)
|
|
Close()
|
|
}
|
|
|
|
//WeatherSourceBase is the lowlevel-implementation of the WeatherSource interface, intended to used by highlevel-implementations
|
|
type WeatherSourceBase struct {
|
|
newWeatherDataCallbackFuncs []NewWeatherDataCallbackFunc
|
|
}
|
|
|
|
//AddNewWeatherDataCallback adds a new callbackMethod for incoming weather data
|
|
func (source *WeatherSourceBase) AddNewWeatherDataCallback(callback NewWeatherDataCallbackFunc) {
|
|
source.newWeatherDataCallbackFuncs = append(source.newWeatherDataCallbackFuncs, callback)
|
|
}
|
|
|
|
//NewWeatherData executes all newWeatherDataCallbackFuncs for this datapoint
|
|
func (source *WeatherSourceBase) NewWeatherData(datapoint storage.WeatherData) {
|
|
for _, callback := range source.newWeatherDataCallbackFuncs {
|
|
callback(datapoint)
|
|
}
|
|
}
|