Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WeatherReader ¶
type WeatherReader struct {
// contains filtered or unexported fields
}
WeatherReader reads weather data from an API and implements the Reader interface.
func NewWeatherReader ¶
func NewWeatherReader(ctx context.Context, cities []config.City, client *http.Client) (*WeatherReader, error)
NewWeatherReader creates a new reader for reading weather data from a list of cities.
func (*WeatherReader) Close ¶
func (r *WeatherReader) Close() error
Close releases any resources associated with the WeatherReader.
func (*WeatherReader) Read ¶
func (r *WeatherReader) Read() (arrow.Record, error)
Read reads the next record of weather data from the API.
func (*WeatherReader) Schema ¶
func (r *WeatherReader) Schema() *arrow.Schema
Schema returns the schema of the records being read from the Weather API.
Source Files
Click to show internal directories.
Click to hide internal directories.