dmfr

package
v0.13.0 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2023 License: GPL-3.0 Imports: 25 Imported by: 3

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 EntityCounter 

type EntityCounter map[string]int

EntityCounter .

func (*EntityCounter) Scan 

func (a *EntityCounter) Scan(value interface{}) error

Scan .

func (EntityCounter) Value 

func (a EntityCounter) Value() (driver.Value, error)

Value .

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
	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               EntityCounter
	WarningCount              EntityCounter
	GeneratedCount            EntityCounter
	SkipEntityErrorCount      EntityCounter
	SkipEntityReferenceCount  EntityCounter
	SkipEntityFilterCount     EntityCounter
	SkipEntityMarkedCount     EntityCounter
	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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.