Documentation
¶
Overview ¶
Package historical contains example implementation of the provider.FeedProvider.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HistoricalProvider ¶
type HistoricalProvider struct {
// contains filtered or unexported fields
}
HistoricalProvider is an example implementation of the provider.FeedProvider that streams historical data.
func NewHistoricalProvider ¶
func NewHistoricalProvider(n int, pathToData string) ( *HistoricalProvider, error)
NewHistoricalProvider returns initialized HistoricalProvider that pushes up to n times historical feed and any error encountered. If n < 0 it will loop forever.
func (*HistoricalProvider) Stream ¶
func (h *HistoricalProvider) Stream(feed chan<- *transitrealtime.FeedMessage)
Source Files
Click to show internal directories.
Click to hide internal directories.