repository

Documentation

Index

• Variables
• type DtdRepository
• type DtdRepositorySql
  • func NewDtdRepositorySql(options *DtdSqlDBOptions) (*DtdRepositorySql, error)
  • func (dtd *DtdRepositorySql) FindAllFlowsForStation(nlc string) (flows []*models.FlowDetail, err error)
  • func (dtd *DtdRepositorySql) FindFareOverridesForNLCs(srcNlcs, dstNlcs []string) (fares []*models.FareDetailExtreme, err error)
  • func (dtd *DtdRepositorySql) FindFaresForFlows(flowIds []string) (fares []*models.FareDetail, err error)
  • func (dtd *DtdRepositorySql) FindFaresForNLCs(srcNlcs, dstNlcs []string, season bool, class string) (fares []*models.FareDetailExtreme, err error)
  • func (dtd *DtdRepositorySql) FindFlowsForNLCs(srcNlcs []string, dstNlcs []string) (flows []*models.FlowDetail, err error)
  • func (dtd *DtdRepositorySql) FindFlowsForStations(src, dst string) (flows []*models.FlowDetail, err error)
  • func (dtd *DtdRepositorySql) FindNLCsRelatedToCrs(crs string) (nlcs []string, err error)
  • func (dtd *DtdRepositorySql) FindStationsByCrs(crs string) (stations []*models.LocationData, err error)
• type DtdSqlDBOptions

Variables

var ErrNotFound = errors.New("not found")

ErrNotFound is returned when a record cannot be found

Types

type DtdRepository

type DtdRepository interface {
	FindStationsByCrs(crs string) (*models.LocationData, error)
	FindFlowsForStations(src, dst string) ([]*models.FlowData, error)
	FindAllFlowsForStation(nlc string) ([]*models.FlowData, error)
	FindFaresForFlows(flowIds []string) ([]*models.FareDetail, error)
	FindFaresForNLCs(srcNlcs, dstNlcs []string) ([]*models.FareDetailExtreme, error)
	FindFareOverridesForNLCs(srcNlcs, dstNlcs []string) ([]*models.FareDetailExtreme, error)
	FindNLCsRelatedToCrs(crs string) ([]string, error)
	FindFlowsForNLCs(srcNlcs []string, dstNlcs []string) ([]*models.FlowDetail, error)
}

DtdRepository provides an abstraction between databases

type DtdRepositorySql

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

DtdRepositorySql is a concrete MySql implementation of a DtdRepository

func NewDtdRepositorySql

func NewDtdRepositorySql(options *DtdSqlDBOptions) (*DtdRepositorySql, error)

func (*DtdRepositorySql) FindAllFlowsForStation

func (dtd *DtdRepositorySql) FindAllFlowsForStation(nlc string) (flows []*models.FlowDetail, err error)

func (*DtdRepositorySql) FindFareOverridesForNLCs

func (dtd *DtdRepositorySql) FindFareOverridesForNLCs(srcNlcs, dstNlcs []string) (fares []*models.FareDetailExtreme, err error)

func (*DtdRepositorySql) FindFaresForFlows

func (dtd *DtdRepositorySql) FindFaresForFlows(flowIds []string) (fares []*models.FareDetail, err error)

func (*DtdRepositorySql) FindFaresForNLCs

func (dtd *DtdRepositorySql) FindFaresForNLCs(srcNlcs, dstNlcs []string, season bool, class string) (fares []*models.FareDetailExtreme, err error)

func (*DtdRepositorySql) FindFlowsForNLCs

func (dtd *DtdRepositorySql) FindFlowsForNLCs(srcNlcs []string, dstNlcs []string) (flows []*models.FlowDetail, err error)

func (*DtdRepositorySql) FindFlowsForStations

func (dtd *DtdRepositorySql) FindFlowsForStations(src, dst string) (flows []*models.FlowDetail, err error)

FindFlowsForStations returns all flows between two NLC codes

func (*DtdRepositorySql) FindNLCsRelatedToCrs

func (dtd *DtdRepositorySql) FindNLCsRelatedToCrs(crs string) (nlcs []string, err error)

func (*DtdRepositorySql) FindStationsByCrs

func (dtd *DtdRepositorySql) FindStationsByCrs(crs string) (stations []*models.LocationData, err error)

FindStationsByCrs returns locations from the given CRS code

type DtdSqlDBOptions

type DtdSqlDBOptions struct {
	Host, Port, User, Password, DBName string
}

DBOptions holds the information required to construct a DB connection