stats

package

v1.3.1 Latest Latest Go to latest Published: Jan 6, 2026 License: GPL-3.0 Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/interline-io/transitland-lib

Links

Open Source Insights

Documentation ¶

Index ¶

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 WriteFeedVersionStats(ctx context.Context, atx tldb.Adapter, stats FeedVersionStats, fvid int) error
type FeedVersionOnestopIDBuilder
- func NewFeedVersionOnestopIDBuilder() *FeedVersionOnestopIDBuilder
- func (ext *FeedVersionOnestopIDBuilder) Copy(adapters.EntityCopier) error
type FeedVersionServiceLevelBuilder
- func NewFeedVersionServiceLevelBuilder() *FeedVersionServiceLevelBuilder
- func (pp *FeedVersionServiceLevelBuilder) AfterWrite(eid string, ent tt.Entity, emap *tt.EntityMap) error
- func (pp *FeedVersionServiceLevelBuilder) Copy(adapters.EntityCopier) error
- func (pp *FeedVersionServiceLevelBuilder) ServiceLevels() ([]dmfr.FeedVersionServiceLevel, error)
type FeedVersionServiceWindowBuilder
- func NewFeedVersionServiceWindowBuilder() *FeedVersionServiceWindowBuilder
- func (pp *FeedVersionServiceWindowBuilder) AfterWrite(eid string, ent tt.Entity, emap *tt.EntityMap) error
- func (pp *FeedVersionServiceWindowBuilder) Copy(adapters.EntityCopier) error
- func (pp *FeedVersionServiceWindowBuilder) ServiceWindow() (dmfr.FeedVersionServiceWindow, error)
type FeedVersionStats
- func NewFeedStatsFromReader(reader adapters.Reader) (FeedVersionStats, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateFeedStats ¶

func CreateFeedStats(ctx context.Context, atx tldb.Adapter, reader *tlcsv.Reader, fvid int) error

func EnsureFeedState ¶ added in v1.3.1

func EnsureFeedState(ctx context.Context, atx tldb.Adapter, feedId int) (dmfr.FeedState, error)

EnsureFeedState gets or creates a feed state. New feed states default to public=true.

func FeedVersionServiceBounds ¶

func FeedVersionServiceBounds(reader adapters.Reader) (time.Time, time.Time, error)

func FeedVersionTableDelete ¶

func FeedVersionTableDelete(ctx context.Context, atx tldb.Adapter, table string, fvid int, ifExists bool) error

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 ServiceLevelDays(fvsls []dmfr.FeedVersionServiceLevel, startDate time.Time, endDate time.Time) iter.Seq2[time.Time, int]

func ServiceLevelDaysMaxWindow ¶ added in v1.0.0

func ServiceLevelDaysMaxWindow(fvsls []dmfr.FeedVersionServiceLevel, startDate time.Time, endDate time.Time, windowSize int) (time.Time, time.Time, int)

func ServiceLevelDefaultWeek ¶

func ServiceLevelDefaultWeek(start tt.Date, end tt.Date, fvsls []dmfr.FeedVersionServiceLevel) (tt.Date, error)

func SetFeedStatePublic ¶ added in v1.3.1

func SetFeedStatePublic(ctx context.Context, atx tldb.Adapter, feedId int, public bool) error

SetFeedStatePublic sets the public flag on an existing feed state.

func WriteFeedVersionStats ¶ added in v1.0.0

func WriteFeedVersionStats(ctx context.Context, atx tldb.Adapter, stats FeedVersionStats, fvid int) 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 (pp *FeedVersionServiceLevelBuilder) AfterWrite(eid string, ent tt.Entity, emap *tt.EntityMap) error

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 (pp *FeedVersionServiceWindowBuilder) AfterWrite(eid string, ent tt.Entity, emap *tt.EntityMap) error

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
}

func NewFeedStatsFromReader ¶

func NewFeedStatsFromReader(reader adapters.Reader) (FeedVersionStats, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL