realtime

Documentation

Overview

Package realtime contains the code for updating the database from a GTFS realtime feed.

Index

• func Parse(content []byte, opts *api.GtfsRealtimeOptions) (*gtfs.Realtime, error)
• func Update(ctx context.Context, updateCtx common.UpdateContext, data *gtfs.Realtime) error
• type StopHeadsignMatcher
  • func NewStopHeadsignMatcher(ctx context.Context, querier db.Querier, stopIDToPk map[string]int64, ...) (*StopHeadsignMatcher, error)
  • func (m *StopHeadsignMatcher) Match(stopPk int64, track *string) *string

Functions

func Parse

func Parse(content []byte, opts *api.GtfsRealtimeOptions) (*gtfs.Realtime, error)

func Update

func Update(ctx context.Context, updateCtx common.UpdateContext, data *gtfs.Realtime) error

Types

type StopHeadsignMatcher

type StopHeadsignMatcher struct {
	// contains filtered or unexported fields
}

func NewStopHeadsignMatcher

func NewStopHeadsignMatcher(ctx context.Context, querier db.Querier, stopIDToPk map[string]int64, trips []gtfs.Trip) (*StopHeadsignMatcher, error)

func (*StopHeadsignMatcher) Match

func (m *StopHeadsignMatcher) Match(stopPk int64, track *string) *string