Documentation ¶
Index ¶
- func CreateSQLGTFSRepository(driver *database.Driver) database.GTFSRepository
- type SQLAgenciesImportTask
- type SQLAgencyRepository
- func (s SQLAgencyRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLAgencyRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLAgencyRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLAgencyRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLCalendarDateRepository
- func (s SQLCalendarDateRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLCalendarDateRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLCalendarDateRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLCalendarDateRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLCalendarDatesImportTask
- type SQLCalendarRepository
- func (s SQLCalendarRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLCalendarRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLCalendarRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLCalendarRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLCalendarsImportTask
- type SQLConnectionProvider
- type SQLGTFSModelRepository
- type SQLGTFSRepository
- func (r SQLGTFSRepository) Agencies() database.GTFSCreatedModelRepository
- func (r SQLGTFSRepository) CalendarDates() database.GTFSCreatedModelRepository
- func (r SQLGTFSRepository) Calendars() database.GTFSCreatedModelRepository
- func (r SQLGTFSRepository) CreateSchema(agencyKey string) error
- func (r SQLGTFSRepository) GtfsAgencies() database.GTFSModelRepository
- func (r SQLGTFSRepository) Routes() database.GTFSCreatedModelRepository
- func (r SQLGTFSRepository) StopTimes() database.GTFSCreatedModelRepository
- func (r SQLGTFSRepository) Stops() database.GTFSCreatedModelRepository
- func (r SQLGTFSRepository) Transfers() database.GTFSCreatedModelRepository
- func (r SQLGTFSRepository) Trips() database.GTFSCreatedModelRepository
- type SQLGtfsAgenciesImportTask
- type SQLGtfsAgencyRepository
- type SQLImportTask
- type SQLRouteRepository
- func (s SQLRouteRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLRouteRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLRouteRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLRouteRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLRoutesImportTask
- type SQLStopRepository
- func (s SQLStopRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLStopRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLStopRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLStopRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLStopTimeRepository
- func (s SQLStopTimeRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLStopTimeRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLStopTimeRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLStopTimeRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLStopTimesImportTask
- type SQLStopsImportTask
- type SQLTransferRepository
- func (s SQLTransferRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLTransferRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLTransferRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLTransferRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLTransfersImportTask
- type SQLTripRepository
- func (s SQLTripRepository) AddIndexesByAgencyKey(agencyKey string) error
- func (r SQLTripRepository) CreateImportTask(taskName string, jobIndex int, fileName, agencyKey string, headers []string, ...) tasks.Task
- func (s SQLTripRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
- func (s SQLTripRepository) RemoveAllByAgencyKey(agencyKey string) error
- type SQLTripsImportTask
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateSQLGTFSRepository ¶
func CreateSQLGTFSRepository(driver *database.Driver) database.GTFSRepository
Types ¶
type SQLAgenciesImportTask ¶
type SQLAgenciesImportTask struct {
SQLImportTask
}
func (SQLAgenciesImportTask) ConvertModels ¶
func (m SQLAgenciesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLAgenciesImportTask) DoWork ¶
func (m SQLAgenciesImportTask) DoWork(_ int)
func (SQLAgenciesImportTask) ImportModels ¶
func (m SQLAgenciesImportTask) ImportModels(headers []string, as []interface{}) error
type SQLAgencyRepository ¶
type SQLAgencyRepository struct {
SQLGTFSModelRepository
}
func (SQLAgencyRepository) AddIndexesByAgencyKey ¶
func (s SQLAgencyRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLAgencyRepository) CreateImportTask ¶
func (SQLAgencyRepository) CreateTableByAgencyKey ¶
func (s SQLAgencyRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLAgencyRepository) RemoveAllByAgencyKey ¶
func (s SQLAgencyRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLCalendarDateRepository ¶
type SQLCalendarDateRepository struct {
SQLGTFSModelRepository
}
func (SQLCalendarDateRepository) AddIndexesByAgencyKey ¶
func (s SQLCalendarDateRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLCalendarDateRepository) CreateImportTask ¶
func (SQLCalendarDateRepository) CreateTableByAgencyKey ¶
func (s SQLCalendarDateRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLCalendarDateRepository) RemoveAllByAgencyKey ¶
func (s SQLCalendarDateRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLCalendarDatesImportTask ¶
type SQLCalendarDatesImportTask struct {
SQLImportTask
}
func (SQLCalendarDatesImportTask) ConvertModels ¶
func (m SQLCalendarDatesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLCalendarDatesImportTask) DoWork ¶
func (m SQLCalendarDatesImportTask) DoWork(_ int)
func (SQLCalendarDatesImportTask) ImportModels ¶
func (m SQLCalendarDatesImportTask) ImportModels(headers []string, as []interface{}) error
type SQLCalendarRepository ¶
type SQLCalendarRepository struct {
SQLGTFSModelRepository
}
func (SQLCalendarRepository) AddIndexesByAgencyKey ¶
func (s SQLCalendarRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLCalendarRepository) CreateImportTask ¶
func (SQLCalendarRepository) CreateTableByAgencyKey ¶
func (s SQLCalendarRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLCalendarRepository) RemoveAllByAgencyKey ¶
func (s SQLCalendarRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLCalendarsImportTask ¶
type SQLCalendarsImportTask struct {
SQLImportTask
}
func (SQLCalendarsImportTask) ConvertModels ¶
func (m SQLCalendarsImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLCalendarsImportTask) DoWork ¶
func (m SQLCalendarsImportTask) DoWork(_ int)
func (SQLCalendarsImportTask) ImportModels ¶
func (m SQLCalendarsImportTask) ImportModels(headers []string, as []interface{}) error
type SQLConnectionProvider ¶
type SQLGTFSModelRepository ¶
type SQLGTFSModelRepository struct {
// contains filtered or unexported fields
}
type SQLGTFSRepository ¶
type SQLGTFSRepository struct {
// contains filtered or unexported fields
}
func (SQLGTFSRepository) Agencies ¶
func (r SQLGTFSRepository) Agencies() database.GTFSCreatedModelRepository
func (SQLGTFSRepository) CalendarDates ¶
func (r SQLGTFSRepository) CalendarDates() database.GTFSCreatedModelRepository
func (SQLGTFSRepository) Calendars ¶
func (r SQLGTFSRepository) Calendars() database.GTFSCreatedModelRepository
func (SQLGTFSRepository) CreateSchema ¶
func (r SQLGTFSRepository) CreateSchema(agencyKey string) error
func (SQLGTFSRepository) GtfsAgencies ¶
func (r SQLGTFSRepository) GtfsAgencies() database.GTFSModelRepository
func (SQLGTFSRepository) Routes ¶
func (r SQLGTFSRepository) Routes() database.GTFSCreatedModelRepository
func (SQLGTFSRepository) StopTimes ¶
func (r SQLGTFSRepository) StopTimes() database.GTFSCreatedModelRepository
func (SQLGTFSRepository) Stops ¶
func (r SQLGTFSRepository) Stops() database.GTFSCreatedModelRepository
func (SQLGTFSRepository) Transfers ¶
func (r SQLGTFSRepository) Transfers() database.GTFSCreatedModelRepository
func (SQLGTFSRepository) Trips ¶
func (r SQLGTFSRepository) Trips() database.GTFSCreatedModelRepository
type SQLGtfsAgenciesImportTask ¶
type SQLGtfsAgenciesImportTask struct {
SQLImportTask
}
func (SQLGtfsAgenciesImportTask) ConvertModels ¶
func (m SQLGtfsAgenciesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLGtfsAgenciesImportTask) DoWork ¶
func (m SQLGtfsAgenciesImportTask) DoWork(_ int)
func (SQLGtfsAgenciesImportTask) ImportModels ¶
func (m SQLGtfsAgenciesImportTask) ImportModels(headers []string, as []interface{}) error
type SQLGtfsAgencyRepository ¶
type SQLGtfsAgencyRepository struct {
SQLGTFSModelRepository
}
func (SQLGtfsAgencyRepository) AddIndexesByAgencyKey ¶
func (s SQLGtfsAgencyRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLGtfsAgencyRepository) CreateImportTask ¶
func (SQLGtfsAgencyRepository) RemoveAllByAgencyKey ¶
func (s SQLGtfsAgencyRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLImportTask ¶
type SQLImportTask struct { tasks.ImportTask // contains filtered or unexported fields }
func (*SQLImportTask) OpenSqlConnection ¶
func (it *SQLImportTask) OpenSqlConnection() (*sql.DB, error)
type SQLRouteRepository ¶
type SQLRouteRepository struct {
SQLGTFSModelRepository
}
func (SQLRouteRepository) AddIndexesByAgencyKey ¶
func (s SQLRouteRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLRouteRepository) CreateImportTask ¶
func (SQLRouteRepository) CreateTableByAgencyKey ¶
func (s SQLRouteRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLRouteRepository) RemoveAllByAgencyKey ¶
func (s SQLRouteRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLRoutesImportTask ¶
type SQLRoutesImportTask struct {
SQLImportTask
}
func (SQLRoutesImportTask) ConvertModels ¶
func (m SQLRoutesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLRoutesImportTask) DoWork ¶
func (m SQLRoutesImportTask) DoWork(_ int)
func (SQLRoutesImportTask) ImportModels ¶
func (m SQLRoutesImportTask) ImportModels(headers []string, as []interface{}) error
type SQLStopRepository ¶
type SQLStopRepository struct {
SQLGTFSModelRepository
}
func (SQLStopRepository) AddIndexesByAgencyKey ¶
func (s SQLStopRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLStopRepository) CreateImportTask ¶
func (SQLStopRepository) CreateTableByAgencyKey ¶
func (s SQLStopRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLStopRepository) RemoveAllByAgencyKey ¶
func (s SQLStopRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLStopTimeRepository ¶
type SQLStopTimeRepository struct {
SQLGTFSModelRepository
}
func (SQLStopTimeRepository) AddIndexesByAgencyKey ¶
func (s SQLStopTimeRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLStopTimeRepository) CreateImportTask ¶
func (SQLStopTimeRepository) CreateTableByAgencyKey ¶
func (s SQLStopTimeRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLStopTimeRepository) RemoveAllByAgencyKey ¶
func (s SQLStopTimeRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLStopTimesImportTask ¶
type SQLStopTimesImportTask struct {
SQLImportTask
}
func (SQLStopTimesImportTask) ConvertModels ¶
func (m SQLStopTimesImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLStopTimesImportTask) DoWork ¶
func (m SQLStopTimesImportTask) DoWork(_ int)
func (SQLStopTimesImportTask) ImportModels ¶
func (m SQLStopTimesImportTask) ImportModels(headers []string, sts []interface{}) error
type SQLStopsImportTask ¶
type SQLStopsImportTask struct {
SQLImportTask
}
func (SQLStopsImportTask) ConvertModels ¶
func (m SQLStopsImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLStopsImportTask) DoWork ¶
func (m SQLStopsImportTask) DoWork(_ int)
func (SQLStopsImportTask) ImportModels ¶
func (m SQLStopsImportTask) ImportModels(headers []string, ss []interface{}) error
type SQLTransferRepository ¶
type SQLTransferRepository struct {
SQLGTFSModelRepository
}
func (SQLTransferRepository) AddIndexesByAgencyKey ¶
func (s SQLTransferRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLTransferRepository) CreateImportTask ¶
func (SQLTransferRepository) CreateTableByAgencyKey ¶
func (s SQLTransferRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLTransferRepository) RemoveAllByAgencyKey ¶
func (s SQLTransferRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLTransfersImportTask ¶
type SQLTransfersImportTask struct {
SQLImportTask
}
func (SQLTransfersImportTask) ConvertModels ¶
func (m SQLTransfersImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLTransfersImportTask) DoWork ¶
func (m SQLTransfersImportTask) DoWork(_ int)
func (SQLTransfersImportTask) ImportModels ¶
func (m SQLTransfersImportTask) ImportModels(headers []string, as []interface{}) error
type SQLTripRepository ¶
type SQLTripRepository struct {
SQLGTFSModelRepository
}
func (SQLTripRepository) AddIndexesByAgencyKey ¶
func (s SQLTripRepository) AddIndexesByAgencyKey(agencyKey string) error
func (SQLTripRepository) CreateImportTask ¶
func (SQLTripRepository) CreateTableByAgencyKey ¶
func (s SQLTripRepository) CreateTableByAgencyKey(agencyKey string, params map[string]interface{}) error
func (SQLTripRepository) RemoveAllByAgencyKey ¶
func (s SQLTripRepository) RemoveAllByAgencyKey(agencyKey string) error
type SQLTripsImportTask ¶
type SQLTripsImportTask struct {
SQLImportTask
}
func (SQLTripsImportTask) ConvertModels ¶
func (m SQLTripsImportTask) ConvertModels(headers []string, rs *models.Records) []interface{}
func (SQLTripsImportTask) DoWork ¶
func (m SQLTripsImportTask) DoWork(_ int)
func (SQLTripsImportTask) ImportModels ¶
func (m SQLTripsImportTask) ImportModels(headers []string, as []interface{}) error
Click to show internal directories.
Click to hide internal directories.