dmfr

package
v0.16.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 23, 2024 License: GPL-3.0 Imports: 24 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFeedStatsFromReader added in v0.12.0

func NewFeedStatsFromReader(reader tl.Reader) (FeedVersionServiceWindow, []FeedVersionServiceLevel, error)

func ServiceLevelDefaultWeek added in v0.12.0

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

Types

type FeedFetch added in v0.10.1

type FeedFetch struct {
	ID            int
	FeedID        int
	URLType       string
	URL           string
	Success       bool
	FetchedAt     tl.Time
	FetchError    tl.String
	ResponseSize  tl.Int
	ResponseCode  tl.Int
	ResponseSHA1  tl.String
	FeedVersionID tl.Int
	tl.Timestamps
	tl.DatabaseEntity
}

func (*FeedFetch) TableName added in v0.10.1

func (ent *FeedFetch) TableName() string

type FeedState

type FeedState struct {
	ID                  int
	FeedID              int
	FeedVersionID       tt.Int
	FeedPriority        tt.Int
	FetchWait           tt.Int
	FeedRealtimeEnabled bool
	Public              bool
	tl.Timestamps
}

FeedState stores the pointer to the active FeedVersion.

func GetFeedState added in v0.11.0

func GetFeedState(atx tldb.Adapter, feedId int) (FeedState, error)

func (*FeedState) EntityID

func (ent *FeedState) EntityID() string

EntityID .

func (*FeedState) GetID added in v0.7.1

func (ent *FeedState) GetID() int

GetID .

func (*FeedState) SetID

func (ent *FeedState) SetID(id int)

SetID .

func (*FeedState) TableName

func (ent *FeedState) TableName() string

TableName .

type FeedVersionFileInfo

type FeedVersionFileInfo struct {
	ID            int
	FeedVersionID int
	Name          string
	Size          int64
	Rows          int64
	Columns       int
	Header        string
	CSVLike       bool
	SHA1          string
	ValuesUnique  tt.Counts
	ValuesCount   tt.Counts
	tl.Timestamps
}

FeedVersionFileInfo .

func NewFeedVersionFileInfosFromReader

func NewFeedVersionFileInfosFromReader(reader *tlcsv.Reader) ([]FeedVersionFileInfo, error)

NewFeedVersionFileInfosFromReader calculates statistics about the contents of a feed version

func (*FeedVersionFileInfo) EntityID

func (fvi *FeedVersionFileInfo) EntityID() string

EntityID .

func (FeedVersionFileInfo) TableName

func (FeedVersionFileInfo) TableName() string

TableName .

type FeedVersionImport

type FeedVersionImport struct {
	ID                        int
	FeedVersionID             int
	ImportLog                 string
	ExceptionLog              string
	ImportLevel               int  // deprecated
	Success                   bool // Finished, Success Yes/No
	InProgress                bool // In Progress
	ScheduleRemoved           bool // Stop times and trips have been uimported
	InterpolatedStopTimeCount int
	EntityCount               tt.Counts
	WarningCount              tt.Counts
	GeneratedCount            tt.Counts
	SkipEntityErrorCount      tt.Counts
	SkipEntityReferenceCount  tt.Counts
	SkipEntityFilterCount     tt.Counts
	SkipEntityMarkedCount     tt.Counts
	tl.Timestamps
}

FeedVersionImport .

func NewFeedVersionImport added in v0.8.0

func NewFeedVersionImport() *FeedVersionImport

NewFeedVersionImport returns an initialized FeedVersionImport.

func (*FeedVersionImport) EntityID

func (fvi *FeedVersionImport) EntityID() string

EntityID .

func (*FeedVersionImport) GetID added in v0.7.1

func (fvi *FeedVersionImport) GetID() int

GetID returns the ID

func (*FeedVersionImport) SetID added in v0.7.1

func (fvi *FeedVersionImport) SetID(v int)

SetID sets the ID.

func (FeedVersionImport) TableName

func (FeedVersionImport) TableName() string

TableName .

type FeedVersionServiceLevel added in v0.7.1

type FeedVersionServiceLevel struct {
	ID            int
	FeedVersionID int
	StartDate     tl.Date
	EndDate       tl.Date
	Monday        int
	Tuesday       int
	Wednesday     int
	Thursday      int
	Friday        int
	Saturday      int
	Sunday        int
}

FeedVersionServiceLevel .

func NewFeedVersionServiceLevelsFromReader added in v0.12.0

func NewFeedVersionServiceLevelsFromReader(reader tl.Reader) ([]FeedVersionServiceLevel, error)

NewFeedVersionServiceLevelsFromReader .

func (*FeedVersionServiceLevel) EntityID added in v0.7.1

func (fvi *FeedVersionServiceLevel) EntityID() string

EntityID .

func (FeedVersionServiceLevel) TableName added in v0.7.1

func (FeedVersionServiceLevel) TableName() string

TableName .

func (*FeedVersionServiceLevel) Total added in v0.12.0

func (fvsl *FeedVersionServiceLevel) Total() int

type FeedVersionServiceWindow added in v0.12.0

type FeedVersionServiceWindow struct {
	FeedVersionID        int
	FeedStartDate        tt.Date
	FeedEndDate          tt.Date
	EarliestCalendarDate tt.Date
	LatestCalendarDate   tt.Date
	FallbackWeek         tt.Date
	DefaultTimezone      tt.String
	tl.DatabaseEntity
	tl.Timestamps
}

func NewFeedVersionServiceWindowFromReader added in v0.12.0

func NewFeedVersionServiceWindowFromReader(reader tl.Reader) (FeedVersionServiceWindow, error)

func (*FeedVersionServiceWindow) EntityID added in v0.12.0

func (fvi *FeedVersionServiceWindow) EntityID() string

func (FeedVersionServiceWindow) TableName added in v0.12.0

func (FeedVersionServiceWindow) TableName() string

type RawRegistry added in v0.10.1

type RawRegistry struct {
	Schema                string            `json:"$schema,omitempty"`
	Feeds                 []RawRegistryFeed `json:"feeds,omitempty"`
	Operators             []tl.Operator     `json:"operators,omitempty"`
	Secrets               []tl.Secret       `json:"secrets,omitempty"`
	LicenseSpdxIdentifier string            `json:"license_spdx_identifier,omitempty"`
}

func ReadRawRegistry added in v0.10.1

func ReadRawRegistry(reader io.Reader) (*RawRegistry, error)

func (*RawRegistry) Write added in v0.10.1

func (r *RawRegistry) Write(w io.Writer) error

Format raw registry, before additional processing is applied

type RawRegistryFeed added in v0.10.1

type RawRegistryFeed struct {
	tl.Feed
	Operators []tl.Operator `json:"operators"`
}

feed.Operators should be loaded but not exported

type Registry

type Registry struct {
	Schema                string        `json:"$schema,omitempty"`
	Feeds                 []tl.Feed     `json:"feeds,omitempty"`
	Operators             []tl.Operator `json:"operators,omitempty"`
	Secrets               []tl.Secret   `json:"secrets,omitempty"`
	LicenseSpdxIdentifier string        `json:"license_spdx_identifier,omitempty"`
}

Registry represents a parsed Distributed Mobility Feed Registry (DMFR) file

func LoadAndParseRegistry

func LoadAndParseRegistry(path string) (*Registry, error)

LoadAndParseRegistry loads and parses a Distributed Mobility Feed Registry (DMFR) file from either a file system path or a URL

func ReadRegistry added in v0.10.1

func ReadRegistry(reader io.Reader) (*Registry, error)

ReadRegistry TODO

func (*Registry) Write added in v0.10.1

func (r *Registry) Write(w io.Writer) error

Format raw registry, before additional processing is applied

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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