Documentation
¶
Index ¶
- Constants
- Variables
- func CreateFeedStats(ctx context.Context, atx tldb.Adapter, reader *tlcsv.Reader, fvid int, ...) error
- func EnsureFeedState(ctx context.Context, atx tldb.Adapter, feedId int) (dmfr.FeedState, error)
- func FeedVersionServiceBounds(reader adapters.Reader) (time.Time, time.Time, error)
- func FeedVersionTableDelete(ctx context.Context, atx tldb.Adapter, table string, fvid int, ifExists bool) error
- func NewFeedVersionFileInfosFromReader(reader *tlcsv.Reader) ([]dmfr.FeedVersionFileInfo, error)
- func NewFeedVersionFromReader(reader adapters.Reader) (dmfr.FeedVersion, error)
- func NewFeedVersionServiceLevelsFromReader(reader adapters.Reader) ([]dmfr.FeedVersionServiceLevel, error)
- func NewFeedVersionServiceWindowFromReader(reader adapters.Reader) (dmfr.FeedVersionServiceWindow, error)
- func ServiceLevelDays(fvsls []dmfr.FeedVersionServiceLevel, startDate time.Time, endDate time.Time) iter.Seq2[time.Time, int]
- func ServiceLevelDaysMaxWindow(fvsls []dmfr.FeedVersionServiceLevel, startDate time.Time, endDate time.Time, ...) (time.Time, time.Time, int)
- func ServiceLevelDefaultWeek(start tt.Date, end tt.Date, fvsls []dmfr.FeedVersionServiceLevel) (tt.Date, error)
- func SetFeedStatePublic(ctx context.Context, atx tldb.Adapter, feedId int, public bool) error
- func ValidateStatNames(names []string) error
- func WriteFeedVersionStats(ctx context.Context, atx tldb.Adapter, stats FeedVersionStats, fvid int, ...) error
- type FeedVersionOnestopIDBuilder
- type FeedVersionServiceLevelBuilder
- type FeedVersionServiceWindowBuilder
- type FeedVersionStats
- type WriteOptions
Constants ¶
View Source
const ( StatFileInfos = "file_infos" StatServiceLevels = "service_levels" StatServiceWindows = "service_windows" StatOnestopIDs = "onestop_ids" StatGeohash = "geohash" )
Stat names accepted by WriteOptions.Stats. Each maps to one or more FetchStatDerivedTables; only the selected stats are deleted and re-inserted.
Variables ¶
View Source
var AllStats = []string{ StatFileInfos, StatServiceLevels, StatServiceWindows, StatOnestopIDs, StatGeohash, }
AllStats lists every supported stat name in the order they are written.
Functions ¶
func CreateFeedStats ¶
func EnsureFeedState ¶ added in v1.3.1
EnsureFeedState gets or creates a feed state. New feed states default to public=true.
func FeedVersionTableDelete ¶
func NewFeedVersionFileInfosFromReader ¶
func NewFeedVersionFileInfosFromReader(reader *tlcsv.Reader) ([]dmfr.FeedVersionFileInfo, error)
NewFeedVersionFileInfosFromReader calculates statistics about the contents of a feed version
func NewFeedVersionFromReader ¶
func NewFeedVersionFromReader(reader adapters.Reader) (dmfr.FeedVersion, error)
NewFeedVersionFromReader returns a FeedVersion from a Reader.
func NewFeedVersionServiceLevelsFromReader ¶
func NewFeedVersionServiceLevelsFromReader(reader adapters.Reader) ([]dmfr.FeedVersionServiceLevel, error)
NewFeedVersionServiceLevelsFromReader .
func NewFeedVersionServiceWindowFromReader ¶
func NewFeedVersionServiceWindowFromReader(reader adapters.Reader) (dmfr.FeedVersionServiceWindow, error)
func ServiceLevelDays ¶ added in v1.0.0
func ServiceLevelDaysMaxWindow ¶ added in v1.0.0
func ServiceLevelDefaultWeek ¶
func SetFeedStatePublic ¶ added in v1.3.1
SetFeedStatePublic sets the public flag on an existing feed state.
func ValidateStatNames ¶ added in v1.3.4
ValidateStatNames returns an error if any name in names is not a recognized stat. Empty/nil is valid and means "all stats".
func WriteFeedVersionStats ¶ added in v1.0.0
func WriteFeedVersionStats(ctx context.Context, atx tldb.Adapter, stats FeedVersionStats, fvid int, opts WriteOptions) error
Types ¶
type FeedVersionOnestopIDBuilder ¶
type FeedVersionOnestopIDBuilder struct {
*builders.OnestopIDBuilder
}
func NewFeedVersionOnestopIDBuilder ¶
func NewFeedVersionOnestopIDBuilder() *FeedVersionOnestopIDBuilder
func (*FeedVersionOnestopIDBuilder) Copy ¶
func (ext *FeedVersionOnestopIDBuilder) Copy(adapters.EntityCopier) error
type FeedVersionServiceLevelBuilder ¶
type FeedVersionServiceLevelBuilder struct {
// contains filtered or unexported fields
}
func NewFeedVersionServiceLevelBuilder ¶
func NewFeedVersionServiceLevelBuilder() *FeedVersionServiceLevelBuilder
func (*FeedVersionServiceLevelBuilder) AfterWrite ¶
func (*FeedVersionServiceLevelBuilder) Copy ¶
func (pp *FeedVersionServiceLevelBuilder) Copy(adapters.EntityCopier) error
func (*FeedVersionServiceLevelBuilder) ServiceLevels ¶
func (pp *FeedVersionServiceLevelBuilder) ServiceLevels() ([]dmfr.FeedVersionServiceLevel, error)
type FeedVersionServiceWindowBuilder ¶
type FeedVersionServiceWindowBuilder struct {
// contains filtered or unexported fields
}
func NewFeedVersionServiceWindowBuilder ¶
func NewFeedVersionServiceWindowBuilder() *FeedVersionServiceWindowBuilder
func (*FeedVersionServiceWindowBuilder) AfterWrite ¶
func (*FeedVersionServiceWindowBuilder) Copy ¶
func (pp *FeedVersionServiceWindowBuilder) Copy(adapters.EntityCopier) error
func (*FeedVersionServiceWindowBuilder) ServiceWindow ¶
func (pp *FeedVersionServiceWindowBuilder) ServiceWindow() (dmfr.FeedVersionServiceWindow, error)
type FeedVersionStats ¶
type FeedVersionStats struct {
ServiceWindow dmfr.FeedVersionServiceWindow
ServiceLevels []dmfr.FeedVersionServiceLevel
AgencyOnestopIDs []dmfr.FeedVersionAgencyOnestopID
RouteOnestopIDs []dmfr.FeedVersionRouteOnestopID
StopOnestopIDs []dmfr.FeedVersionStopOnestopID
FileInfos []dmfr.FeedVersionFileInfo
GeohashCells map[string]int
}
func NewFeedStatsFromReader ¶
func NewFeedStatsFromReader(reader adapters.Reader) (FeedVersionStats, error)
type WriteOptions ¶ added in v1.3.4
type WriteOptions struct {
// Subset of stat names to write; empty means all.
Stats []string
}
WriteOptions configures which stats WriteFeedVersionStats persists. Builders always run regardless of selection; only the database delete/insert step is gated, so callers can target a single stat without churning unrelated records.
Source Files
Click to show internal directories.
Click to hide internal directories.