transit

package

v0.0.0-...-bb3eb04 Latest Latest Go to latest Published: Jan 10, 2021 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rmrobinson/nerves

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Feed
- func NewFeed(logger *zap.Logger, dataset *gtfs.Dataset, realtimePath string) *Feed
- func (f *Feed) GetRealtimeFeed(ctx context.Context) (*gtfs_realtime.FeedMessage, error)
- func (f *Feed) MonitorRealtimeFeed(ctx context.Context)
type Service
- func NewService(logger *zap.Logger) *Service
- func (s *Service) AddFeed(feed *Feed)
- func (s *Service) GetStopArrivals(ctx context.Context, req *GetStopArrivalsRequest) (*GetStopArrivalsResponse, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrStopNotFound is returned if the queried stop isn't found
	ErrStopNotFound = status.New(codes.NotFound, "stop not found")
	// ErrStopCutoffInvalid is returned if the stop cutoff is invalid
	ErrStopCutoffInvalid = status.New(codes.InvalidArgument, "stop cutoff not a valid time")
)

Functions ¶

This section is empty.

Types ¶

type Feed ¶

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

Feed represents a single feed, potentially encapsulating both static and real-time elements.

func NewFeed ¶

func NewFeed(logger *zap.Logger, dataset *gtfs.Dataset, realtimePath string) *Feed

NewFeed creates a new feed from the supplied dataset and the realtime path.

func (*Feed) GetRealtimeFeed ¶

func (f *Feed) GetRealtimeFeed(ctx context.Context) (*gtfs_realtime.FeedMessage, error)

GetRealtimeFeed retrieves the GTFS realtime data.

func (*Feed) MonitorRealtimeFeed ¶

func (f *Feed) MonitorRealtimeFeed(ctx context.Context)

MonitorRealtimeFeed periodically polls the realtime feed endpoint and updates the times for the trips.

type Service ¶

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

Service is a really simple service that retrieves a transit feed

func NewService ¶

func NewService(logger *zap.Logger) *Service

NewService creates a new service

func (*Service) AddFeed ¶

func (s *Service) AddFeed(feed *Feed)

AddFeed adds a GTFS dataset to this transit instance.

func (*Service) GetStopArrivals ¶

func (s *Service) GetStopArrivals(ctx context.Context, req *GetStopArrivalsRequest) (*GetStopArrivalsResponse, error)

GetStopArrivals returns the arrival info for the specified stop.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cmd
transitd
gtfs

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