find

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Jul 12, 2021 License: GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const MAXBATCH = 1000

MAXBATCH is maximum batch size

View Source
const MAXLIMIT = 1000

MAXLIMIT .

View Source
const WAIT = 2 * time.Millisecond

WAIT is the time to wait

Variables

This section is empty.

Functions

func AgencyPlaceSelect

func AgencyPlaceSelect(limit *int, after *int, ids []int, where *model.AgencyPlaceFilter) sq.SelectBuilder

func AgencySelect

func AgencySelect(limit *int, after *int, ids []int, where *model.AgencyFilter) sq.SelectBuilder

func CensusGeographySelect

func CensusGeographySelect(param *model.CensusGeographyParam, eids []int) sq.SelectBuilder

func CensusValueSelect

func CensusValueSelect(param *model.CensusValueParam, eids []int) sq.SelectBuilder

func FeedSelect

func FeedSelect(limit *int, after *int, ids []int, where *model.FeedFilter) sq.SelectBuilder

func FeedVersionSelect

func FeedVersionSelect(limit *int, after *int, ids []int, where *model.FeedVersionFilter) sq.SelectBuilder

func FeedVersionServiceLevelSelect

func FeedVersionServiceLevelSelect(limit *int, after *int, ids []int, where *model.FeedVersionServiceLevelFilter) sq.SelectBuilder

func FindAgencies

func FindAgencies(atx sqlx.Ext, limit *int, after *int, ids []int, where *model.AgencyFilter) (ents []*model.Agency, err error)

func FindFeedVersions

func FindFeedVersions(atx sqlx.Ext, limit *int, after *int, ids []int, where *model.FeedVersionFilter) (ents []*model.FeedVersion, err error)

func FindFeeds

func FindFeeds(atx sqlx.Ext, limit *int, after *int, ids []int, where *model.FeedFilter) (ents []*model.Feed, err error)

func FindOperators

func FindOperators(atx sqlx.Ext, limit *int, after *int, ids []int, where *model.OperatorFilter) (ents []*model.Operator, err error)

func FindRoutes

func FindRoutes(atx sqlx.Ext, limit *int, after *int, ids []int, where *model.RouteFilter) (ents []*model.Route, err error)

func FindStops

func FindStops(atx sqlx.Ext, limit *int, after *int, ids []int, where *model.StopFilter) (ents []*model.Stop, err error)

func FindTrips

func FindTrips(atx sqlx.Ext, limit *int, after *int, ids []int, where *model.TripFilter) (ents []*model.Trip, err error)

func Middleware

func Middleware(atx sqlx.Ext, next http.Handler) http.Handler

Middleware .

func MustSelect

func MustSelect(db sqlx.Ext, q sq.SelectBuilder, dest interface{})

MustSelect runs a query or panics.

func OperatorSelect

func OperatorSelect(limit *int, after *int, ids []int, where *model.OperatorFilter) sq.SelectBuilder

func PathwaySelect

func PathwaySelect(limit *int, after *int, ids []int, where *model.PathwayFilter) sq.SelectBuilder

func RouteSelect

func RouteSelect(limit *int, after *int, ids []int, where *model.RouteFilter) sq.SelectBuilder

func RouteStopBufferSelect

func RouteStopBufferSelect(param model.RouteStopBufferParam) sq.SelectBuilder

func StopSelect

func StopSelect(limit *int, after *int, ids []int, where *model.StopFilter) sq.SelectBuilder

func TripSelect

func TripSelect(limit *int, after *int, ids []int, where *model.TripFilter) sq.SelectBuilder

Types

type Loaders

type Loaders struct {
	// ID Loaders
	AgenciesByID     dl.AgencyLoader
	CalendarsByID    dl.CalendarLoader
	FeedsByID        dl.FeedLoader
	RoutesByID       dl.RouteLoader
	ShapesByID       dl.ShapeLoader
	StopsByID        dl.StopLoader
	FeedVersionsByID dl.FeedVersionLoader
	LevelsByID       dl.LevelLoader
	TripsByID        dl.TripLoader
	// Other ID loaders
	FeedStatesByFeedID dl.FeedStateLoader
	// FeedVersionID Loaders
	FeedVersionGtfsImportsByFeedVersionID   dl.FeedVersionGtfsImportLoader
	FeedVersionServiceLevelsByFeedVersionID dl.FeedVersionServiceLevelWhereLoader
	FeedVersionFileInfosByFeedVersionID     dl.FeedVersionFileInfoWhereLoader
	AgenciesByFeedVersionID                 dl.AgencyWhereLoader
	RoutesByFeedVersionID                   dl.RouteWhereLoader
	StopsByFeedVersionID                    dl.StopWhereLoader
	TripsByFeedVersionID                    dl.TripWhereLoader
	FeedInfosByFeedVersionID                dl.FeedInfoWhereLoader
	// Where Loaders
	StopsByParentStopID      dl.StopWhereLoader
	AgencyPlacesByAgencyID   dl.AgencyPlaceWhereLoader
	RouteGeometriesByRouteID dl.RouteGeometryWhereLoader
	TripsByRouteID           dl.TripWhereLoader
	FrequenciesByTripID      dl.FrequencyWhereLoader
	StopTimesByTripID        dl.StopTimeWhereLoader
	StopTimesByStopID        dl.StopTimeWhereLoader
	RouteStopsByRouteID      dl.RouteStopWhereLoader
	RouteStopsByStopID       dl.RouteStopWhereLoader
	RouteHeadwaysByRouteID   dl.RouteHeadwayWhereLoader
	RoutesByAgencyID         dl.RouteWhereLoader
	FeedVersionsByFeedID     dl.FeedVersionWhereLoader
	OperatorsByFeedID        dl.OperatorWhereLoader
	PathwaysByFromStopID     dl.PathwayWhereLoader
	PathwaysByToStopID       dl.PathwayWhereLoader
	CalendarDatesByServiceID dl.CalendarDateWhereLoader
	// Census
	CensusTableByID             dl.CensusTableLoader
	CensusGeographiesByEntityID dl.CensusGeographyWhereLoader
	CensusValuesByGeographyID   dl.CensusValueWhereLoader
}

Loaders .

func For

func For(ctx context.Context) *Loaders

For .

Jump to

Keyboard shortcuts

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