Documentation ¶
Index ¶
- Constants
- Variables
- func ApplyMigrations(operation, path string, database *sql.DB) error
- func CleanTestDb(t *testing.T)
- func CloseDB(database *gorp.DbMap)
- func InitDB(config config.DatabaseConfig) *gorp.DbMap
- func InitTestDb(t *testing.T)
- func LoadFromCSVFile(filePath string, referentialSlug string, force bool) error
- func NewSituationUpdateManager(model Model) func([]*SituationUpdateEvent)
- func NewUpdateManager(model Model) func(UpdateEvent)
- func NormalizedOccupancyName(occupancy string) string
- type Affect
- type AffectedDestination
- type AffectedLine
- type AffectedRoute
- type AffectedSection
- type AffectedStopArea
- type Attributes
- type Blocking
- type ByTime
- type Code
- type CodeConsumer
- func (consumer *CodeConsumer) Code(codeSpace string) (Code, bool)
- func (consumer *CodeConsumer) CodeSlice() (objs []string)
- func (consumer *CodeConsumer) CodeWithFallback(codeSpaces []string) (Code, bool)
- func (consumer *CodeConsumer) Codes() Codes
- func (consumer *CodeConsumer) CodesResponse() map[string]string
- func (consumer *CodeConsumer) Copy() CodeConsumer
- func (consumer *CodeConsumer) SetCode(code Code)
- type CodeConsumerInterface
- type CodeIndex
- type Codes
- type Collectable
- type ComplexError
- type Consequence
- type DatabaseLine
- type DatabaseOperator
- type DatabasePartner
- type DatabaseReferential
- type DatabaseStopArea
- type DatabaseStopVisit
- type DatabaseVehicleJourney
- type Date
- type DiffResult
- type EventKind
- type GeneralMessageBroadcastEvent
- type Index
- type IndexableExtractor
- type Line
- func (line *Line) Attribute(key string) (string, bool)
- func (line *Line) Id() LineId
- func (line *Line) MarshalJSON() ([]byte, error)
- func (line *Line) Origin() string
- func (line *Line) Reference(key string) (Reference, bool)
- func (line *Line) Save() bool
- func (line *Line) SetOrigin(origin string)
- func (line *Line) UnmarshalJSON(data []byte) error
- type LineId
- type LineUpdateEvent
- type Lines
- type Loader
- type MemoryLines
- func (manager *MemoryLines) Delete(line *Line) bool
- func (manager *MemoryLines) Find(id LineId) (*Line, bool)
- func (manager *MemoryLines) FindAll() (lines []*Line)
- func (manager *MemoryLines) FindByCode(code Code) (*Line, bool)
- func (manager *MemoryLines) Load(referentialSlug string) error
- func (manager *MemoryLines) New() *Line
- func (manager *MemoryLines) Save(line *Line) bool
- type MemoryModel
- func (model *MemoryModel) Date() Date
- func (model *MemoryModel) Lines() Lines
- func (model *MemoryModel) Load(referentialSlug string) error
- func (model *MemoryModel) Operators() Operators
- func (model *MemoryModel) Referential() string
- func (model *MemoryModel) Reload(referentialSlug string) *MemoryModel
- func (model *MemoryModel) ScheduledStopVisits() StopVisits
- func (model *MemoryModel) SetBroadcastGMChan(broadcastGMEventChan chan GeneralMessageBroadcastEvent)
- func (model *MemoryModel) SetBroadcastSMChan(broadcastSMEventChan chan StopMonitoringBroadcastEvent)
- func (model *MemoryModel) SetBroadcastVeChan(broadcastVeEventChan chan VehicleBroadcastEvent)
- func (model *MemoryModel) SetReferential(referential string)
- func (model *MemoryModel) Situations() Situations
- func (model *MemoryModel) StopAreas() StopAreas
- func (model *MemoryModel) StopVisits() StopVisits
- func (model *MemoryModel) VehicleJourneys() VehicleJourneys
- func (model *MemoryModel) Vehicles() Vehicles
- type MemoryOperators
- func (manager *MemoryOperators) Delete(operator *Operator) bool
- func (manager *MemoryOperators) Find(id OperatorId) (*Operator, bool)
- func (manager *MemoryOperators) FindAll() (operators []*Operator)
- func (manager *MemoryOperators) FindByCode(code Code) (*Operator, bool)
- func (manager *MemoryOperators) Load(referentialSlug string) error
- func (manager *MemoryOperators) New() *Operator
- func (manager *MemoryOperators) Save(operator *Operator) bool
- type MemorySituations
- func (manager *MemorySituations) Delete(situation *Situation) bool
- func (manager *MemorySituations) Find(id SituationId) (Situation, bool)
- func (manager *MemorySituations) FindAll() (situations []Situation)
- func (manager *MemorySituations) FindByCode(code Code) (Situation, bool)
- func (manager *MemorySituations) New() Situation
- func (manager *MemorySituations) Save(situation *Situation) bool
- type MemoryStopAreas
- func (manager *MemoryStopAreas) Delete(stopArea *StopArea) bool
- func (manager *MemoryStopAreas) Find(id StopAreaId) (*StopArea, bool)
- func (manager *MemoryStopAreas) FindAll() (stopAreas []*StopArea)
- func (manager *MemoryStopAreas) FindAscendants(stopAreaId StopAreaId) (stopAreas []*StopArea)
- func (manager *MemoryStopAreas) FindAscendantsWithCodeSpace(stopAreaId StopAreaId, kind string) (stopAreaCodes []Code)
- func (manager *MemoryStopAreas) FindByCode(code Code) (*StopArea, bool)
- func (manager *MemoryStopAreas) FindByLineId(id LineId) (stopAreas []*StopArea)
- func (manager *MemoryStopAreas) FindByOrigin(origin string) (stopAreas []StopAreaId)
- func (manager *MemoryStopAreas) FindFamily(stopAreaId StopAreaId) (stopAreaIds []StopAreaId)
- func (manager *MemoryStopAreas) Load(referentialSlug string) error
- func (manager *MemoryStopAreas) New() *StopArea
- func (manager *MemoryStopAreas) Save(stopArea *StopArea) bool
- type MemoryStopVisits
- func (manager *MemoryStopVisits) Delete(stopVisit *StopVisit) bool
- func (manager *MemoryStopVisits) DeleteMultiple(stopVisits []*StopVisit) bool
- func (manager *MemoryStopVisits) Find(id StopVisitId) (*StopVisit, bool)
- func (manager *MemoryStopVisits) FindAll() (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindAllAfter(t time.Time) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindByCode(code Code) (*StopVisit, bool)
- func (manager *MemoryStopVisits) FindByStopAreaId(id StopAreaId) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindByVehicleJourneyId(id VehicleJourneyId) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindByVehicleJourneyIdAfter(id VehicleJourneyId, t time.Time) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindByVehicleJourneyIdAndStopAreaId(vjId VehicleJourneyId, saId StopAreaId) []StopVisitId
- func (manager *MemoryStopVisits) FindByVehicleJourneyIdAndStopVisitOrder(vjId VehicleJourneyId, order int) *StopVisit
- func (manager *MemoryStopVisits) FindFollowingByStopAreaId(id StopAreaId) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindFollowingByStopAreaIds(stopAreaIds []StopAreaId) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindFollowingByVehicleJourneyId(id VehicleJourneyId) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) FindMonitoredByOriginByStopAreaId(id StopAreaId, origin string) (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) Load(referentialSlug string) error
- func (manager *MemoryStopVisits) New() *StopVisit
- func (manager *MemoryStopVisits) Save(stopVisit *StopVisit) bool
- func (manager *MemoryStopVisits) StopVisitsLenByVehicleJourney(id VehicleJourneyId) int
- func (manager *MemoryStopVisits) UnsafeDelete(stopVisit *StopVisit)
- func (manager *MemoryStopVisits) UnsafeFindAll() (stopVisits []*StopVisit)
- func (manager *MemoryStopVisits) VehicleJourneyHasStopVisits(id VehicleJourneyId) bool
- type MemoryVehicleJourneys
- func (manager *MemoryVehicleJourneys) Delete(vehicleJourney *VehicleJourney) bool
- func (manager *MemoryVehicleJourneys) DeleteById(id VehicleJourneyId) bool
- func (manager *MemoryVehicleJourneys) Find(id VehicleJourneyId) (*VehicleJourney, bool)
- func (manager *MemoryVehicleJourneys) FindAll() (vehicleJourneys []*VehicleJourney)
- func (manager *MemoryVehicleJourneys) FindByCode(code Code) (*VehicleJourney, bool)
- func (manager *MemoryVehicleJourneys) FindByLineId(id LineId) (vehicleJourneys []*VehicleJourney)
- func (manager *MemoryVehicleJourneys) FullVehicleJourneyExistBySubscriptionId(id string, vehicleJourneyId VehicleJourneyId) bool
- func (manager *MemoryVehicleJourneys) Load(referentialSlug string) error
- func (manager *MemoryVehicleJourneys) New() *VehicleJourney
- func (manager *MemoryVehicleJourneys) Save(vehicleJourney *VehicleJourney) bool
- func (manager *MemoryVehicleJourneys) SetFullVehicleJourneyBySubscriptionId(id string, vehicleJourneyId VehicleJourneyId)
- func (manager *MemoryVehicleJourneys) TestLenFullVehicleJourneyBySubscriptionId() int
- type MemoryVehicles
- func (manager *MemoryVehicles) Delete(vehicle *Vehicle) bool
- func (manager *MemoryVehicles) Find(id VehicleId) (*Vehicle, bool)
- func (manager *MemoryVehicles) FindAll() (vehicles []*Vehicle)
- func (manager *MemoryVehicles) FindByCode(code Code) (*Vehicle, bool)
- func (manager *MemoryVehicles) FindByLineId(id LineId) (vehicles []*Vehicle)
- func (manager *MemoryVehicles) FindByNextStopVisitId(stopVisitId StopVisitId) (*Vehicle, bool)
- func (manager *MemoryVehicles) New() *Vehicle
- func (manager *MemoryVehicles) Save(vehicle *Vehicle) bool
- type Message
- type Model
- type ModelId
- type ModelInstance
- type NotCollectedUpdateEvent
- type ObjectId
- type Operator
- type OperatorId
- type Operators
- type Purifier
- type Reference
- type References
- func (references *References) Copy() References
- func (references *References) Get(key string) (Reference, bool)
- func (references *References) GetReferences() map[string]Reference
- func (references *References) GetSiriReferences() map[string]string
- func (references *References) IsEmpty() bool
- func (references *References) Set(key string, value Reference)
- func (references *References) SetCode(key string, obj Code)
- func (references *References) SetReference(key string, r Reference)
- func (references *References) SetReferences(r map[string]Reference)
- type ReportType
- type Result
- type SelectLine
- type SelectOperator
- type SelectPartner
- type SelectReferential
- type SelectStopArea
- type SelectStopVisit
- type SelectVehicleJourney
- type Situation
- func (situation *Situation) GMValidUntil() time.Time
- func (situation *Situation) GetGMChannel() (string, bool)
- func (situation *Situation) Id() SituationId
- func (situation *Situation) MarshalJSON() ([]byte, error)
- func (situation *Situation) Save() (ok bool)
- func (situation *Situation) UnmarshalJSON(data []byte) error
- type SituationAlertCause
- type SituationId
- type SituationProgress
- type SituationSeverity
- type SituationTranslatedString
- type SituationType
- type SituationUpdateEvent
- func (event *SituationUpdateEvent) Id() SituationUpdateRequestId
- func (event *SituationUpdateEvent) SetId(id SituationUpdateRequestId)
- func (event *SituationUpdateEvent) TestFindAffectByLineId(lineId LineId) (bool, *AffectedLine)
- func (event *SituationUpdateEvent) TestFindAffectByStopAreaId(stopAreaId StopAreaId) (bool, *AffectedStopArea)
- type SituationUpdateManager
- type SituationUpdateRequestId
- type Situations
- type StatusUpdateEvent
- type StopArea
- func (stopArea *StopArea) Attribute(key string) (value string, present bool)
- func (stopArea *StopArea) Id() StopAreaId
- func (stopArea *StopArea) Lines() (lines []*Line)
- func (stopArea *StopArea) MarshalJSON() ([]byte, error)
- func (stopArea *StopArea) Parent() (*StopArea, bool)
- func (stopArea *StopArea) Reference(key string) (Reference, bool)
- func (stopArea *StopArea) Referent() (*StopArea, bool)
- func (stopArea *StopArea) ReferentOrSelfCode(codeSpace string) (Code, bool)
- func (stopArea *StopArea) SPDCode(codeSpace string) (Code, bool)
- func (stopArea *StopArea) Save() bool
- func (stopArea *StopArea) SetPartnerStatus(partner string, status bool)
- func (stopArea *StopArea) UnmarshalJSON(data []byte) error
- type StopAreaId
- type StopAreaLineIds
- type StopAreaOrigins
- func (origins *StopAreaOrigins) AllOrigin() map[string]bool
- func (origins *StopAreaOrigins) Copy() *StopAreaOrigins
- func (origins *StopAreaOrigins) MarshalJSON() ([]byte, error)
- func (origins *StopAreaOrigins) Monitored() (monitored bool)
- func (origins *StopAreaOrigins) NewOrigin(partner string)
- func (origins *StopAreaOrigins) Origin(partner string) (status bool, present bool)
- func (origins *StopAreaOrigins) PartnersKO() (partnersSlice []string)
- func (origins *StopAreaOrigins) PartnersLost(comparedOrigins *StopAreaOrigins) (partnersLost []string, r bool)
- func (origins *StopAreaOrigins) SetOriginsFromMap(originMap map[string]bool)
- func (origins *StopAreaOrigins) SetPartnerStatus(partner string, status bool)
- type StopAreaUpdateEvent
- type StopAreas
- type StopMonitoringBroadcastEvent
- type StopVisit
- func (stopVisit *StopVisit) Attribute(key string) (string, bool)
- func (stopVisit *StopVisit) Collected(t time.Time)
- func (stopVisit *StopVisit) CollectedAt() time.Time
- func (stopVisit *StopVisit) Id() StopVisitId
- func (stopVisit *StopVisit) IsArchivable() bool
- func (stopVisit *StopVisit) IsCollected() bool
- func (stopVisit *StopVisit) IsRecordable() bool
- func (stopVisit *StopVisit) MarshalJSON() ([]byte, error)
- func (stopVisit *StopVisit) NotCollected(notCollectedAt time.Time)
- func (stopVisit *StopVisit) Reference(key string) (Reference, bool)
- func (stopVisit *StopVisit) ReferenceArrivalTime() time.Time
- func (stopVisit *StopVisit) ReferenceDepartureTime() time.Time
- func (stopVisit *StopVisit) ReferenceTime() time.Time
- func (stopVisit *StopVisit) Save() bool
- func (stopVisit *StopVisit) StopArea() *StopArea
- func (stopVisit *StopVisit) UnmarshalJSON(data []byte) error
- func (stopVisit *StopVisit) VehicleJourney() *VehicleJourney
- type StopVisitArchiver
- type StopVisitArrivalStatus
- type StopVisitDepartureStatus
- type StopVisitId
- type StopVisitSchedule
- func (schedule *StopVisitSchedule) ArrivalTime() time.Time
- func (schedule *StopVisitSchedule) DepartureTime() time.Time
- func (schedule *StopVisitSchedule) Kind() StopVisitScheduleType
- func (schedule *StopVisitSchedule) MarshalJSON() ([]byte, error)
- func (schedule *StopVisitSchedule) SetArrivalTime(t time.Time) time.Time
- func (schedule *StopVisitSchedule) SetDepartureTime(t time.Time) time.Time
- func (schedule *StopVisitSchedule) UnmarshalJSON(data []byte) error
- type StopVisitScheduleType
- type StopVisitSchedules
- func (schedules *StopVisitSchedules) ArrivalTimeFromKind(kinds []StopVisitScheduleType) time.Time
- func (schedules *StopVisitSchedules) Copy() *StopVisitSchedules
- func (schedules *StopVisitSchedules) DepartureTimeFromKind(kinds []StopVisitScheduleType) time.Time
- func (schedules *StopVisitSchedules) Eq(scs *StopVisitSchedules) bool
- func (schedules *StopVisitSchedules) Include(scs *StopVisitSchedules) bool
- func (schedules *StopVisitSchedules) Merge(newSchedules *StopVisitSchedules)
- func (schedules *StopVisitSchedules) ReferenceArrivalTime() time.Time
- func (schedules *StopVisitSchedules) ReferenceDepartureTime() time.Time
- func (schedules *StopVisitSchedules) ReferenceTime() time.Time
- func (schedules *StopVisitSchedules) Schedule(kind StopVisitScheduleType) *StopVisitSchedule
- func (schedules *StopVisitSchedules) SetArrivalTime(kind StopVisitScheduleType, arrivalTime time.Time)
- func (schedules *StopVisitSchedules) SetArrivalTimeIfNotDefined(kind StopVisitScheduleType, arrivalTime time.Time)
- func (schedules *StopVisitSchedules) SetDepartureTime(kind StopVisitScheduleType, departureTime time.Time)
- func (schedules *StopVisitSchedules) SetDepartureTimeIfNotDefined(kind StopVisitScheduleType, departureTime time.Time)
- func (schedules *StopVisitSchedules) SetSchedule(kind StopVisitScheduleType, departureTime time.Time, arrivalTime time.Time)
- func (schedules *StopVisitSchedules) ToSlice() (scheduleSlice []StopVisitSchedule)
- type StopVisitSelector
- func CompositeStopVisitSelector(selectors []StopVisitSelector) StopVisitSelector
- func StopVisitSelectByStopAreaId(stopAreaId StopAreaId) StopVisitSelector
- func StopVisitSelectorAfterTime(startTime time.Time) StopVisitSelector
- func StopVisitSelectorBeforeTime(endTime time.Time) StopVisitSelector
- func StopVisitSelectorByLine(code Code) StopVisitSelector
- func StopVisitSelectorByTime(startTime, endTime time.Time) StopVisitSelector
- type StopVisitUpdateEvent
- type StopVisits
- type TimeRange
- type UpdateEvent
- type UpdateManager
- type Vehicle
- type VehicleBroadcastEvent
- type VehicleId
- type VehicleJourney
- func (vehicleJourney *VehicleJourney) Attribute(key string) (string, bool)
- func (vehicleJourney *VehicleJourney) Id() VehicleJourneyId
- func (vehicleJourney *VehicleJourney) Line() *Line
- func (vehicleJourney *VehicleJourney) MarshalJSON() ([]byte, error)
- func (vehicleJourney *VehicleJourney) Reference(key string) (Reference, bool)
- func (vehicleJourney *VehicleJourney) Save() bool
- func (vehicleJourney *VehicleJourney) ToFormat() []string
- func (vehicleJourney *VehicleJourney) UnmarshalJSON(data []byte) error
- type VehicleJourneyId
- type VehicleJourneyUpdateEvent
- type VehicleJourneys
- type VehicleUpdateEvent
- type Vehicles
Constants ¶
const ( STOP_AREA = "stop_area" LINE = "line" VEHICLE_JOURNEY = "vehicle_journey" STOP_VISIT = "stop_visit" OPERATOR = "operator" TOTAL_INSERTS = "Total" ERRORS = "Errors" )
CSV Structure
operator,Id,ModelName,Name,Codes stop_area,Id,ParentId,ReferentId,ModelName,Name,Codes,LineIds,Attributes,References,CollectedAlways,CollectChildren,CollectSituations line,Id,ModelName,Name,Codes,Attributes,References,CollectSituations vehicle_journey,Id,ModelName,Name,Codes,LineId,OriginName,DestinationName,Attributes,References,DirectionType, Number stop_visit,Id,ModelName,Codes,StopAreaId,VehicleJourneyId,PassageOrder,Schedules,Attributes,References
Comments are '#' Separators are ',' leading spaces are trimed
Escape quotes with another quote ex: "[""1234"",""5678""]"
const ( Undefined = "" Unknown = "unknown" Empty = "empty" ManySeatsAvailable = "manySeatsAvailable" FewSeatsAvailable = "fewSeatsAvailable" StandingRoomOnly = "standingRoomOnly" CrushedStandingRoomOnly = "crushedStandingRoomOnly" Full = "full" NotAcceptingPassengers = "notAcceptingPassengers" StandingAvailable = "standingAvailable" SeatsAvailable = "seatsAvailable" )
const ( SituationReportTypeGeneral ReportType = "general" SituationReportTypeIncident ReportType = "incident" SituationTypeLine SituationType = "Line" SituationTypeStopArea SituationType = "StopArea" )
const ( VEHICLE_DIRECTION_INBOUND = "inbound" VEHICLE_DIRECTION_OUTBOUND = "outbound" )
Variables ¶
var Database *gorp.DbMap
var SCHEDULE_ORDER_ARRAY = [3]StopVisitScheduleType{ STOP_VISIT_SCHEDULE_ACTUAL, STOP_VISIT_SCHEDULE_EXPECTED, STOP_VISIT_SCHEDULE_AIMED, }
Functions ¶
func CleanTestDb ¶
func InitDB ¶
func InitDB(config config.DatabaseConfig) *gorp.DbMap
func InitTestDb ¶
func LoadFromCSVFile ¶
func NewSituationUpdateManager ¶
func NewSituationUpdateManager(model Model) func([]*SituationUpdateEvent)
func NewUpdateManager ¶
func NewUpdateManager(model Model) func(UpdateEvent)
func NormalizedOccupancyName ¶
Types ¶
type AffectedDestination ¶
type AffectedDestination struct {
StopAreaId StopAreaId
}
type AffectedLine ¶
type AffectedLine struct { LineId LineId `json:",omitempty"` AffectedDestinations []*AffectedDestination `json:",omitempty"` AffectedSections []*AffectedSection `json:",omitempty"` AffectedRoutes []*AffectedRoute `json:",omitempty"` }
func NewAffectedLine ¶
func NewAffectedLine() *AffectedLine
func (AffectedLine) GetId ¶
func (a AffectedLine) GetId() ModelId
func (AffectedLine) GetType ¶
func (a AffectedLine) GetType() SituationType
func (AffectedLine) MarshalJSON ¶
func (affect AffectedLine) MarshalJSON() ([]byte, error)
type AffectedRoute ¶
type AffectedRoute struct { RouteRef string `json:",omitempty"` StopAreaIds []StopAreaId `json:",omitempty"` }
type AffectedSection ¶
type AffectedSection struct { FirstStop StopAreaId LastStop StopAreaId }
type AffectedStopArea ¶
type AffectedStopArea struct { StopAreaId StopAreaId `json:",omitempty"` LineIds []LineId `json:",omitempty"` }
func NewAffectedStopArea ¶
func NewAffectedStopArea() *AffectedStopArea
func (AffectedStopArea) GetId ¶
func (a AffectedStopArea) GetId() ModelId
func (AffectedStopArea) GetType ¶
func (a AffectedStopArea) GetType() SituationType
func (AffectedStopArea) MarshalJSON ¶
func (affect AffectedStopArea) MarshalJSON() ([]byte, error)
type Attributes ¶
func NewAttributes ¶
func NewAttributes() Attributes
func (Attributes) Copy ¶
func (attributes Attributes) Copy() (c Attributes)
func (Attributes) IsEmpty ¶
func (attributes Attributes) IsEmpty() bool
func (Attributes) Set ¶
func (attributes Attributes) Set(key string, value string)
type Code ¶
type Code struct {
// contains filtered or unexported fields
}
func (*Code) MarshalJSON ¶
func (*Code) UnmarshalJSON ¶
type CodeConsumer ¶
type CodeConsumer struct {
// contains filtered or unexported fields
}
func (*CodeConsumer) CodeSlice ¶
func (consumer *CodeConsumer) CodeSlice() (objs []string)
func (*CodeConsumer) CodeWithFallback ¶
func (consumer *CodeConsumer) CodeWithFallback(codeSpaces []string) (Code, bool)
func (*CodeConsumer) Codes ¶
func (consumer *CodeConsumer) Codes() Codes
func (*CodeConsumer) CodesResponse ¶
func (consumer *CodeConsumer) CodesResponse() map[string]string
func (*CodeConsumer) Copy ¶
func (consumer *CodeConsumer) Copy() CodeConsumer
func (*CodeConsumer) SetCode ¶
func (consumer *CodeConsumer) SetCode(code Code)
type CodeConsumerInterface ¶
type CodeIndex ¶
type CodeIndex struct {
// contains filtered or unexported fields
}
func NewCodeIndex ¶
func NewCodeIndex() *CodeIndex
func (*CodeIndex) Index ¶
func (index *CodeIndex) Index(model ModelInstance)
type Collectable ¶
type Collectable struct {
// contains filtered or unexported fields
}
func (*Collectable) CollectedAt ¶
func (c *Collectable) CollectedAt() time.Time
func (*Collectable) NextCollect ¶
func (c *Collectable) NextCollect(collectTime time.Time)
func (*Collectable) NextCollectAt ¶
func (c *Collectable) NextCollectAt() time.Time
func (*Collectable) Updated ¶
func (c *Collectable) Updated(updateTime time.Time)
type ComplexError ¶
type ComplexError struct {
Errors []string
}
func (*ComplexError) Add ¶
func (c *ComplexError) Add(field string, err error)
func (ComplexError) Error ¶
func (c ComplexError) Error() string
func (ComplexError) ErrorCount ¶
func (c ComplexError) ErrorCount() int
type Consequence ¶
type Consequence struct { Periods []*TimeRange `json:",omitempty"` Severity SituationSeverity `json:",omitempty"` Affects []Affect `json:",omitempty"` Blocking *Blocking `json:",omitempty"` }
func (*Consequence) UnmarshalJSON ¶
func (c *Consequence) UnmarshalJSON(data []byte) error
type DatabaseLine ¶
type DatabaseLine struct { Id string `db:"id"` ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Name string `db:"name"` Codes string `db:"codes"` Attributes string `db:"attributes"` References string `db:"siri_references"` CollectSituations bool `db:"collect_situations"` }
type DatabaseOperator ¶
type DatabasePartner ¶
type DatabaseReferential ¶
type DatabaseStopArea ¶
type DatabaseStopArea struct { LineIds string `db:"line_ids"` ReferentialSlug string `db:"referential_slug"` References string `db:"siri_references"` Attributes string `db:"attributes"` ModelName string `db:"model_name"` Name string `db:"name"` Codes string `db:"codes"` Id string `db:"id"` ReferentId sql.NullString `db:"referent_id"` ParentId sql.NullString `db:"parent_id"` CollectedAlways bool `db:"collected_always"` CollectChildren bool `db:"collect_children"` CollectSituations bool `db:"collect_situations"` }
type DatabaseStopVisit ¶
type DatabaseStopVisit struct { Id string ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Codes string `db:"codes"` StopAreaId string `db:"stop_area_id"` VehicleJourneyId string `db:"vehicle_journey_id"` Schedules string `db:"schedules"` Attributes string `db:"attributes"` References string `db:"siri_references"` PassageOrder int `db:"passage_order"` }
type DatabaseVehicleJourney ¶
type DatabaseVehicleJourney struct { Id string `db:"id"` ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Name string `db:"name"` Codes string `db:"codes"` LineId string `db:"line_id"` OriginName string `db:"origin_name"` DestinationName string `db:"destination_name"` DirectionType string `db:"direction_type"` Attributes string `db:"attributes"` References string `db:"siri_references"` }
type DiffResult ¶
func Equal ¶
func Equal(x, y interface{}) (*DiffResult, error)
type GeneralMessageBroadcastEvent ¶
type GeneralMessageBroadcastEvent struct {
SituationId SituationId
}
type Index ¶
type Index struct {
// contains filtered or unexported fields
}
func NewIndex ¶
func NewIndex(extractor IndexableExtractor) *Index
func (*Index) Index ¶
func (index *Index) Index(model ModelInstance)
func (*Index) IndexableLength ¶
type IndexableExtractor ¶
type IndexableExtractor func(ModelInstance) ModelId
type Line ¶
type Line struct { Collectable References References CodeConsumer Attributes Attributes Name string `json:",omitempty"` Number string `json:",omitempty"` CollectSituations bool // contains filtered or unexported fields }
func (*Line) MarshalJSON ¶
func (*Line) UnmarshalJSON ¶
type LineUpdateEvent ¶
func NewLineUpdateEvent ¶
func NewLineUpdateEvent() *LineUpdateEvent
func (*LineUpdateEvent) EventKind ¶
func (ue *LineUpdateEvent) EventKind() EventKind
type MemoryLines ¶
type MemoryLines struct { uuid.UUIDConsumer // contains filtered or unexported fields }
func NewMemoryLines ¶
func NewMemoryLines() *MemoryLines
func (*MemoryLines) Delete ¶
func (manager *MemoryLines) Delete(line *Line) bool
func (*MemoryLines) FindAll ¶
func (manager *MemoryLines) FindAll() (lines []*Line)
func (*MemoryLines) FindByCode ¶
func (manager *MemoryLines) FindByCode(code Code) (*Line, bool)
func (*MemoryLines) Load ¶
func (manager *MemoryLines) Load(referentialSlug string) error
func (*MemoryLines) New ¶
func (manager *MemoryLines) New() *Line
func (*MemoryLines) Save ¶
func (manager *MemoryLines) Save(line *Line) bool
type MemoryModel ¶
type MemoryModel struct { SMEventsChan chan StopMonitoringBroadcastEvent GMEventsChan chan GeneralMessageBroadcastEvent VeEventChan chan VehicleBroadcastEvent // contains filtered or unexported fields }
func NewMemoryModel ¶
func NewMemoryModel(referential ...string) *MemoryModel
Optionnal argument for tests
func (*MemoryModel) Date ¶
func (model *MemoryModel) Date() Date
func (*MemoryModel) Lines ¶
func (model *MemoryModel) Lines() Lines
func (*MemoryModel) Load ¶
func (model *MemoryModel) Load(referentialSlug string) error
func (*MemoryModel) Operators ¶
func (model *MemoryModel) Operators() Operators
func (*MemoryModel) Referential ¶
func (model *MemoryModel) Referential() string
func (*MemoryModel) Reload ¶
func (model *MemoryModel) Reload(referentialSlug string) *MemoryModel
func (*MemoryModel) ScheduledStopVisits ¶
func (model *MemoryModel) ScheduledStopVisits() StopVisits
func (*MemoryModel) SetBroadcastGMChan ¶
func (model *MemoryModel) SetBroadcastGMChan(broadcastGMEventChan chan GeneralMessageBroadcastEvent)
func (*MemoryModel) SetBroadcastSMChan ¶
func (model *MemoryModel) SetBroadcastSMChan(broadcastSMEventChan chan StopMonitoringBroadcastEvent)
func (*MemoryModel) SetBroadcastVeChan ¶
func (model *MemoryModel) SetBroadcastVeChan(broadcastVeEventChan chan VehicleBroadcastEvent)
func (*MemoryModel) SetReferential ¶
func (model *MemoryModel) SetReferential(referential string)
func (*MemoryModel) Situations ¶
func (model *MemoryModel) Situations() Situations
func (*MemoryModel) StopAreas ¶
func (model *MemoryModel) StopAreas() StopAreas
func (*MemoryModel) StopVisits ¶
func (model *MemoryModel) StopVisits() StopVisits
func (*MemoryModel) VehicleJourneys ¶
func (model *MemoryModel) VehicleJourneys() VehicleJourneys
func (*MemoryModel) Vehicles ¶
func (model *MemoryModel) Vehicles() Vehicles
type MemoryOperators ¶
type MemoryOperators struct { uuid.UUIDConsumer // contains filtered or unexported fields }
func NewMemoryOperators ¶
func NewMemoryOperators() *MemoryOperators
func (*MemoryOperators) Delete ¶
func (manager *MemoryOperators) Delete(operator *Operator) bool
func (*MemoryOperators) Find ¶
func (manager *MemoryOperators) Find(id OperatorId) (*Operator, bool)
func (*MemoryOperators) FindAll ¶
func (manager *MemoryOperators) FindAll() (operators []*Operator)
func (*MemoryOperators) FindByCode ¶
func (manager *MemoryOperators) FindByCode(code Code) (*Operator, bool)
func (*MemoryOperators) Load ¶
func (manager *MemoryOperators) Load(referentialSlug string) error
func (*MemoryOperators) New ¶
func (manager *MemoryOperators) New() *Operator
func (*MemoryOperators) Save ¶
func (manager *MemoryOperators) Save(operator *Operator) bool
type MemorySituations ¶
type MemorySituations struct { uuid.UUIDConsumer // contains filtered or unexported fields }
func NewMemorySituations ¶
func NewMemorySituations() *MemorySituations
func (*MemorySituations) Delete ¶
func (manager *MemorySituations) Delete(situation *Situation) bool
func (*MemorySituations) Find ¶
func (manager *MemorySituations) Find(id SituationId) (Situation, bool)
func (*MemorySituations) FindAll ¶
func (manager *MemorySituations) FindAll() (situations []Situation)
func (*MemorySituations) FindByCode ¶
func (manager *MemorySituations) FindByCode(code Code) (Situation, bool)
func (*MemorySituations) New ¶
func (manager *MemorySituations) New() Situation
func (*MemorySituations) Save ¶
func (manager *MemorySituations) Save(situation *Situation) bool
type MemoryStopAreas ¶
type MemoryStopAreas struct { uuid.UUIDConsumer // contains filtered or unexported fields }
func NewMemoryStopAreas ¶
func NewMemoryStopAreas() *MemoryStopAreas
func (*MemoryStopAreas) Delete ¶
func (manager *MemoryStopAreas) Delete(stopArea *StopArea) bool
func (*MemoryStopAreas) Find ¶
func (manager *MemoryStopAreas) Find(id StopAreaId) (*StopArea, bool)
func (*MemoryStopAreas) FindAll ¶
func (manager *MemoryStopAreas) FindAll() (stopAreas []*StopArea)
func (*MemoryStopAreas) FindAscendants ¶
func (manager *MemoryStopAreas) FindAscendants(stopAreaId StopAreaId) (stopAreas []*StopArea)
func (*MemoryStopAreas) FindAscendantsWithCodeSpace ¶
func (manager *MemoryStopAreas) FindAscendantsWithCodeSpace(stopAreaId StopAreaId, kind string) (stopAreaCodes []Code)
func (*MemoryStopAreas) FindByCode ¶
func (manager *MemoryStopAreas) FindByCode(code Code) (*StopArea, bool)
func (*MemoryStopAreas) FindByLineId ¶
func (manager *MemoryStopAreas) FindByLineId(id LineId) (stopAreas []*StopArea)
func (*MemoryStopAreas) FindByOrigin ¶
func (manager *MemoryStopAreas) FindByOrigin(origin string) (stopAreas []StopAreaId)
func (*MemoryStopAreas) FindFamily ¶
func (manager *MemoryStopAreas) FindFamily(stopAreaId StopAreaId) (stopAreaIds []StopAreaId)
func (*MemoryStopAreas) Load ¶
func (manager *MemoryStopAreas) Load(referentialSlug string) error
func (*MemoryStopAreas) New ¶
func (manager *MemoryStopAreas) New() *StopArea
func (*MemoryStopAreas) Save ¶
func (manager *MemoryStopAreas) Save(stopArea *StopArea) bool
type MemoryStopVisits ¶
type MemoryStopVisits struct { uuid.UUIDConsumer clock.ClockConsumer // contains filtered or unexported fields }
func NewMemoryStopVisits ¶
func NewMemoryStopVisits() *MemoryStopVisits
func (*MemoryStopVisits) Delete ¶
func (manager *MemoryStopVisits) Delete(stopVisit *StopVisit) bool
func (*MemoryStopVisits) DeleteMultiple ¶
func (manager *MemoryStopVisits) DeleteMultiple(stopVisits []*StopVisit) bool
func (*MemoryStopVisits) Find ¶
func (manager *MemoryStopVisits) Find(id StopVisitId) (*StopVisit, bool)
func (*MemoryStopVisits) FindAll ¶
func (manager *MemoryStopVisits) FindAll() (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindAllAfter ¶
func (manager *MemoryStopVisits) FindAllAfter(t time.Time) (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindByCode ¶
func (manager *MemoryStopVisits) FindByCode(code Code) (*StopVisit, bool)
func (*MemoryStopVisits) FindByStopAreaId ¶
func (manager *MemoryStopVisits) FindByStopAreaId(id StopAreaId) (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindByVehicleJourneyId ¶
func (manager *MemoryStopVisits) FindByVehicleJourneyId(id VehicleJourneyId) (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindByVehicleJourneyIdAfter ¶
func (manager *MemoryStopVisits) FindByVehicleJourneyIdAfter(id VehicleJourneyId, t time.Time) (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindByVehicleJourneyIdAndStopAreaId ¶
func (manager *MemoryStopVisits) FindByVehicleJourneyIdAndStopAreaId(vjId VehicleJourneyId, saId StopAreaId) []StopVisitId
func (*MemoryStopVisits) FindByVehicleJourneyIdAndStopVisitOrder ¶
func (manager *MemoryStopVisits) FindByVehicleJourneyIdAndStopVisitOrder(vjId VehicleJourneyId, order int) *StopVisit
func (*MemoryStopVisits) FindFollowingByStopAreaId ¶
func (manager *MemoryStopVisits) FindFollowingByStopAreaId(id StopAreaId) (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindFollowingByStopAreaIds ¶
func (manager *MemoryStopVisits) FindFollowingByStopAreaIds(stopAreaIds []StopAreaId) (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindFollowingByVehicleJourneyId ¶
func (manager *MemoryStopVisits) FindFollowingByVehicleJourneyId(id VehicleJourneyId) (stopVisits []*StopVisit)
func (*MemoryStopVisits) FindMonitoredByOriginByStopAreaId ¶
func (manager *MemoryStopVisits) FindMonitoredByOriginByStopAreaId(id StopAreaId, origin string) (stopVisits []*StopVisit)
func (*MemoryStopVisits) Load ¶
func (manager *MemoryStopVisits) Load(referentialSlug string) error
func (*MemoryStopVisits) New ¶
func (manager *MemoryStopVisits) New() *StopVisit
func (*MemoryStopVisits) Save ¶
func (manager *MemoryStopVisits) Save(stopVisit *StopVisit) bool
func (*MemoryStopVisits) StopVisitsLenByVehicleJourney ¶
func (manager *MemoryStopVisits) StopVisitsLenByVehicleJourney(id VehicleJourneyId) int
func (*MemoryStopVisits) UnsafeDelete ¶
func (manager *MemoryStopVisits) UnsafeDelete(stopVisit *StopVisit)
func (*MemoryStopVisits) UnsafeFindAll ¶
func (manager *MemoryStopVisits) UnsafeFindAll() (stopVisits []*StopVisit)
Warning, this method doesn't copy the StopVisits so we shouldn't access its maps
func (*MemoryStopVisits) VehicleJourneyHasStopVisits ¶
func (manager *MemoryStopVisits) VehicleJourneyHasStopVisits(id VehicleJourneyId) bool
type MemoryVehicleJourneys ¶
type MemoryVehicleJourneys struct { uuid.UUIDConsumer // contains filtered or unexported fields }
func NewMemoryVehicleJourneys ¶
func NewMemoryVehicleJourneys() *MemoryVehicleJourneys
func (*MemoryVehicleJourneys) Delete ¶
func (manager *MemoryVehicleJourneys) Delete(vehicleJourney *VehicleJourney) bool
func (*MemoryVehicleJourneys) DeleteById ¶
func (manager *MemoryVehicleJourneys) DeleteById(id VehicleJourneyId) bool
func (*MemoryVehicleJourneys) Find ¶
func (manager *MemoryVehicleJourneys) Find(id VehicleJourneyId) (*VehicleJourney, bool)
func (*MemoryVehicleJourneys) FindAll ¶
func (manager *MemoryVehicleJourneys) FindAll() (vehicleJourneys []*VehicleJourney)
func (*MemoryVehicleJourneys) FindByCode ¶
func (manager *MemoryVehicleJourneys) FindByCode(code Code) (*VehicleJourney, bool)
func (*MemoryVehicleJourneys) FindByLineId ¶
func (manager *MemoryVehicleJourneys) FindByLineId(id LineId) (vehicleJourneys []*VehicleJourney)
func (*MemoryVehicleJourneys) FullVehicleJourneyExistBySubscriptionId ¶
func (manager *MemoryVehicleJourneys) FullVehicleJourneyExistBySubscriptionId(id string, vehicleJourneyId VehicleJourneyId) bool
func (*MemoryVehicleJourneys) Load ¶
func (manager *MemoryVehicleJourneys) Load(referentialSlug string) error
func (*MemoryVehicleJourneys) New ¶
func (manager *MemoryVehicleJourneys) New() *VehicleJourney
func (*MemoryVehicleJourneys) Save ¶
func (manager *MemoryVehicleJourneys) Save(vehicleJourney *VehicleJourney) bool
func (*MemoryVehicleJourneys) SetFullVehicleJourneyBySubscriptionId ¶
func (manager *MemoryVehicleJourneys) SetFullVehicleJourneyBySubscriptionId(id string, vehicleJourneyId VehicleJourneyId)
func (*MemoryVehicleJourneys) TestLenFullVehicleJourneyBySubscriptionId ¶
func (manager *MemoryVehicleJourneys) TestLenFullVehicleJourneyBySubscriptionId() int
type MemoryVehicles ¶
type MemoryVehicles struct { uuid.UUIDConsumer clock.ClockConsumer // contains filtered or unexported fields }
func NewMemoryVehicles ¶
func NewMemoryVehicles() *MemoryVehicles
func (*MemoryVehicles) Delete ¶
func (manager *MemoryVehicles) Delete(vehicle *Vehicle) bool
func (*MemoryVehicles) FindAll ¶
func (manager *MemoryVehicles) FindAll() (vehicles []*Vehicle)
func (*MemoryVehicles) FindByCode ¶
func (manager *MemoryVehicles) FindByCode(code Code) (*Vehicle, bool)
func (*MemoryVehicles) FindByLineId ¶
func (manager *MemoryVehicles) FindByLineId(id LineId) (vehicles []*Vehicle)
func (*MemoryVehicles) FindByNextStopVisitId ¶
func (manager *MemoryVehicles) FindByNextStopVisitId(stopVisitId StopVisitId) (*Vehicle, bool)
func (*MemoryVehicles) New ¶
func (manager *MemoryVehicles) New() *Vehicle
func (*MemoryVehicles) Save ¶
func (manager *MemoryVehicles) Save(vehicle *Vehicle) bool
type Model ¶
type Model interface { Date() Date Referential() string Lines() Lines Situations() Situations StopAreas() StopAreas StopVisits() StopVisits ScheduledStopVisits() StopVisits VehicleJourneys() VehicleJourneys Operators() Operators Vehicles() Vehicles }
type ModelInstance ¶
type ModelInstance interface { CodeConsumerInterface // contains filtered or unexported methods }
type NotCollectedUpdateEvent ¶
func NewNotCollectedUpdateEvent ¶
func NewNotCollectedUpdateEvent(obj Code, t time.Time) *NotCollectedUpdateEvent
func (*NotCollectedUpdateEvent) EventKind ¶
func (ue *NotCollectedUpdateEvent) EventKind() EventKind
type Operator ¶
type Operator struct { CodeConsumer Name string `json:",omitempty"` // contains filtered or unexported fields }
func NewOperator ¶
func (*Operator) Id ¶
func (operator *Operator) Id() OperatorId
func (*Operator) MarshalJSON ¶
func (*Operator) UnmarshalJSON ¶
type OperatorId ¶
type OperatorId string
type Purifier ¶
type Purifier struct {
// contains filtered or unexported fields
}
func NewPurifier ¶
type References ¶
type References struct {
// contains filtered or unexported fields
}
func NewReferences ¶
func NewReferences() References
func (*References) Copy ¶
func (references *References) Copy() References
func (*References) GetReferences ¶
func (references *References) GetReferences() map[string]Reference
func (*References) GetSiriReferences ¶
func (references *References) GetSiriReferences() map[string]string
func (*References) IsEmpty ¶
func (references *References) IsEmpty() bool
func (*References) Set ¶
func (references *References) Set(key string, value Reference)
func (*References) SetCode ¶
func (references *References) SetCode(key string, obj Code)
func (*References) SetReference ¶
func (references *References) SetReference(key string, r Reference)
func (*References) SetReferences ¶
func (references *References) SetReferences(r map[string]Reference)
type ReportType ¶
type ReportType string
type SelectLine ¶
type SelectLine struct { Id string ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Name sql.NullString Number sql.NullString `db:"number"` Codes sql.NullString `db:"codes"` Attributes sql.NullString References sql.NullString `db:"siri_references"` CollectSituations sql.NullBool `db:"collect_situations"` }
type SelectOperator ¶
type SelectOperator struct { Id string ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Name sql.NullString Codes sql.NullString `db:"codes"` }
type SelectPartner ¶
type SelectPartner struct { Id string ReferentialId string `db:"referential_id"` Slug string Name sql.NullString Settings sql.NullString ConnectorTypes sql.NullString `db:"connector_types"` }
type SelectReferential ¶
type SelectReferential struct { ReferentialId string `db:"referential_id"` OrganisationId sql.NullString `db:"organisation_id"` Slug string Name sql.NullString Settings sql.NullString Tokens sql.NullString ImportTokens sql.NullString `db:"import_tokens"` }
type SelectStopArea ¶
type SelectStopArea struct { Id string ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Name sql.NullString Codes sql.NullString `db:"codes"` ParentId sql.NullString `db:"parent_id"` ReferentId sql.NullString `db:"referent_id"` Attributes sql.NullString References sql.NullString `db:"siri_references"` LineIds sql.NullString `db:"line_ids"` CollectedAlways sql.NullBool `db:"collected_always"` CollectChildren sql.NullBool `db:"collect_children"` CollectSituations sql.NullBool `db:"collect_situations"` }
type SelectStopVisit ¶
type SelectStopVisit struct { Id string ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Codes sql.NullString `db:"codes"` StopAreaId sql.NullString `db:"stop_area_id"` VehicleJourneyId sql.NullString `db:"vehicle_journey_id"` Schedules sql.NullString `db:"schedules"` Attributes sql.NullString `db:"attributes"` References sql.NullString `db:"siri_references"` PassageOrder sql.NullInt64 `db:"passage_order"` }
type SelectVehicleJourney ¶
type SelectVehicleJourney struct { Id string ReferentialSlug string `db:"referential_slug"` ModelName string `db:"model_name"` Name sql.NullString Codes sql.NullString `db:"codes"` LineId sql.NullString `db:"line_id"` OriginName sql.NullString `db:"origin_name"` DestinationName sql.NullString `db:"destination_name"` DirectionType sql.NullString `db:"direction_type"` Attributes sql.NullString References sql.NullString `db:"siri_references"` }
type Situation ¶
type Situation struct { CodeConsumer Origin string RecordedAt time.Time Version int `json:",omitempty"` VersionedAt time.Time ValidityPeriods []*TimeRange PublicationWindows []*TimeRange Progress SituationProgress `json:",omitempty"` Severity SituationSeverity `json:",omitempty"` Keywords []string `json:",omitempty"` ReportType ReportType `json:",omitempty"` AlertCause SituationAlertCause `json:",omitempty"` ProducerRef string `json:",omitempty"` Format string `json:",omitempty"` InternalTags []string `json:",omitempty"` ParticipantRef string `json:",omitempty"` Summary *SituationTranslatedString `json:",omitempty"` Description *SituationTranslatedString `json:",omitempty"` Affects []Affect `json:",omitempty"` Consequences []*Consequence `json:",omitempty"` // contains filtered or unexported fields }
func NewSituation ¶
func (*Situation) GMValidUntil ¶
func (*Situation) GetGMChannel ¶
func (*Situation) Id ¶
func (situation *Situation) Id() SituationId
func (*Situation) MarshalJSON ¶
func (*Situation) UnmarshalJSON ¶
type SituationAlertCause ¶
type SituationAlertCause string
const ( SituationAlertCauseAccident SituationAlertCause = "accident" SituationAlertCauseAirraid SituationAlertCause = "airRaid" SituationAlertCauseAltercation SituationAlertCause = "altercation" SituationAlertCauseAnimalontheline SituationAlertCause = "animalOnTheLine" SituationAlertCauseAsphalting SituationAlertCause = "asphalting" SituationAlertCauseAssault SituationAlertCause = "assault" SituationAlertCauseAttack SituationAlertCause = "attack" SituationAlertCauseAvalanches SituationAlertCause = "avalanches" SituationAlertCauseAwaitingapproach SituationAlertCause = "awaitingApproach" SituationAlertCauseAwaitingoncomingvehicle SituationAlertCause = "awaitingOncomingVehicle" SituationAlertCauseAwaitingshuttle SituationAlertCause = "awaitingShuttle" SituationAlertCauseBlizzardconditions SituationAlertCause = "blizzardConditions" SituationAlertCauseBoardingdelay SituationAlertCause = "boardingDelay" SituationAlertCauseBombalert SituationAlertCause = "bombAlert" SituationAlertCauseBombdisposal SituationAlertCause = "bombDisposal" SituationAlertCauseBombexplosion SituationAlertCause = "bombExplosion" SituationAlertCauseBordercontrol SituationAlertCause = "borderControl" SituationAlertCauseBreakdown SituationAlertCause = "breakDown" SituationAlertCauseBridgedamage SituationAlertCause = "bridgeDamage" SituationAlertCauseBridgestrike SituationAlertCause = "bridgeStrike" SituationAlertCauseBrokenrail SituationAlertCause = "brokenRail" SituationAlertCauseCablefire SituationAlertCause = "cableFire" SituationAlertCauseCabletheft SituationAlertCause = "cableTheft" SituationAlertCauseChangeincarriages SituationAlertCause = "changeInCarriages" SituationAlertCauseCivilemergency SituationAlertCause = "civilEmergency" SituationAlertCauseClosedformaintenance SituationAlertCause = "closedForMaintenance" SituationAlertCauseCollision SituationAlertCause = "collision" SituationAlertCauseCongestion SituationAlertCause = "congestion" SituationAlertCauseConstructionwork SituationAlertCause = "constructionWork" SituationAlertCauseContractorstaffinjury SituationAlertCause = "contractorStaffInjury" SituationAlertCauseDefectivecctv SituationAlertCause = "defectiveCctv" SituationAlertCauseDefectivefirealarmequipment SituationAlertCause = "defectiveFireAlarmEquipment" SituationAlertCauseDefectiveplatformedgedoors SituationAlertCause = "defectivePlatformEdgeDoors" SituationAlertCauseDefectivepublicannouncementsystem SituationAlertCause = "defectivePublicAnnouncementSystem" SituationAlertCauseDefectivesecuritysystem SituationAlertCause = "defectiveSecuritySystem" SituationAlertCauseDefectivetrain SituationAlertCause = "defectiveTrain" SituationAlertCauseDefectivevehicle SituationAlertCause = "defectiveVehicle" SituationAlertCauseDeicingwork SituationAlertCause = "deicingWork" SituationAlertCauseDemonstration SituationAlertCause = "demonstration" SituationAlertCauseDerailment SituationAlertCause = "derailment" SituationAlertCauseDoorfailure SituationAlertCause = "doorFailure" SituationAlertCauseDriftingsnow SituationAlertCause = "driftingSnow" SituationAlertCauseEarthquakedamage SituationAlertCause = "earthquakeDamage" SituationAlertCauseEmergencybrake SituationAlertCause = "emergencyBrake" SituationAlertCauseEmergencyengineeringwork SituationAlertCause = "emergencyEngineeringWork" SituationAlertCauseEmergencymedicalservices SituationAlertCause = "emergencyMedicalServices" SituationAlertCauseEmergencyservices SituationAlertCause = "emergencyServices" SituationAlertCauseEmergencyservicescall SituationAlertCause = "emergencyServicesCall" SituationAlertCauseEnginefailure SituationAlertCause = "engineFailure" SituationAlertCauseEscalatorfailure SituationAlertCause = "escalatorFailure" SituationAlertCauseEvacuation SituationAlertCause = "evacuation" SituationAlertCauseExplosion SituationAlertCause = "explosion" SituationAlertCauseExplosionhazard SituationAlertCause = "explosionHazard" SituationAlertCauseFallenleaves SituationAlertCause = "fallenLeaves" SituationAlertCauseFallentree SituationAlertCause = "fallenTree" SituationAlertCauseFallentreeontheline SituationAlertCause = "fallenTreeOnTheLine" SituationAlertCauseFatality SituationAlertCause = "fatality" SituationAlertCauseFilterblockade SituationAlertCause = "filterBlockade" SituationAlertCauseFire SituationAlertCause = "fire" SituationAlertCauseFireatstation SituationAlertCause = "fireAtStation" SituationAlertCauseFireatthestation SituationAlertCause = "fireAtTheStation" SituationAlertCauseFirebrigadeorder SituationAlertCause = "fireBrigadeOrder" SituationAlertCauseFirebrigadesafetychecks SituationAlertCause = "fireBrigadeSafetyChecks" SituationAlertCauseFirerun SituationAlertCause = "fireRun" SituationAlertCauseFlashfloods SituationAlertCause = "flashFloods" SituationAlertCauseFlooding SituationAlertCause = "flooding" SituationAlertCauseFog SituationAlertCause = "fog" SituationAlertCauseForeigndisturbances SituationAlertCause = "foreignDisturbances" SituationAlertCauseFrozen SituationAlertCause = "frozen" SituationAlertCauseFuelproblem SituationAlertCause = "fuelProblem" SituationAlertCauseFuelshortage SituationAlertCause = "fuelShortage" SituationAlertCauseGangwayproblem SituationAlertCause = "gangwayProblem" SituationAlertCauseGlazedfrost SituationAlertCause = "glazedFrost" SituationAlertCauseGrassfire SituationAlertCause = "grassFire" SituationAlertCauseGunfireonroadway SituationAlertCause = "gunfireOnRoadway" SituationAlertCauseHail SituationAlertCause = "hail" SituationAlertCauseHeavyrain SituationAlertCause = "heavyRain" SituationAlertCauseHeavysnowfall SituationAlertCause = "heavySnowfall" SituationAlertCauseHeavytraffic SituationAlertCause = "heavyTraffic" SituationAlertCauseHightemperatures SituationAlertCause = "highTemperatures" SituationAlertCauseHightide SituationAlertCause = "highTide" SituationAlertCauseHighwaterlevel SituationAlertCause = "highWaterLevel" SituationAlertCauseHoliday SituationAlertCause = "holiday" SituationAlertCauseIce SituationAlertCause = "ice" SituationAlertCauseIcedrift SituationAlertCause = "iceDrift" SituationAlertCauseIceoncarriages SituationAlertCause = "iceOnCarriages" SituationAlertCauseIceonrailway SituationAlertCause = "iceOnRailway" SituationAlertCauseIllvehicleoccupants SituationAlertCause = "illVehicleOccupants" SituationAlertCauseIncident SituationAlertCause = "incident" SituationAlertCauseIndustrialaction SituationAlertCause = "industrialAction" SituationAlertCauseInsufficientdemand SituationAlertCause = "insufficientDemand" SituationAlertCauseLackofoperationalstock SituationAlertCause = "lackOfOperationalStock" SituationAlertCauseLandslide SituationAlertCause = "landslide" SituationAlertCauseLatefinishtoengineeringwork SituationAlertCause = "lateFinishToEngineeringWork" SituationAlertCauseLeaderboardfailure SituationAlertCause = "leaderBoardFailure" SituationAlertCauseLevelcrossingaccident SituationAlertCause = "levelCrossingAccident" SituationAlertCauseLevelcrossingblocked SituationAlertCause = "levelCrossingBlocked" SituationAlertCauseLevelcrossingfailure SituationAlertCause = "levelCrossingFailure" SituationAlertCauseLevelcrossingincident SituationAlertCause = "levelCrossingIncident" SituationAlertCauseLiftfailure SituationAlertCause = "liftFailure" SituationAlertCauseLightingfailure SituationAlertCause = "lightingFailure" SituationAlertCauseLightningstrike SituationAlertCause = "lightningStrike" SituationAlertCauseLinesidefire SituationAlertCause = "linesideFire" SituationAlertCauseLogisticproblems SituationAlertCause = "logisticProblems" SituationAlertCauseLowtide SituationAlertCause = "lowTide" SituationAlertCauseLowwaterlevel SituationAlertCause = "lowWaterLevel" SituationAlertCauseLuggagecarouselproblem SituationAlertCause = "luggageCarouselProblem" SituationAlertCauseMaintenancework SituationAlertCause = "maintenanceWork" SituationAlertCauseMarch SituationAlertCause = "march" SituationAlertCauseMiscellaneous SituationAlertCause = "miscellaneous" SituationAlertCauseMudslide SituationAlertCause = "mudslide" SituationAlertCauseNearmiss SituationAlertCause = "nearMiss" SituationAlertCauseObjectontheline SituationAlertCause = "objectOnTheLine" SituationAlertCauseOperatorceasedtrading SituationAlertCause = "operatorCeasedTrading" SituationAlertCauseOperatorsuspended SituationAlertCause = "operatorSuspended" SituationAlertCauseOvercrowded SituationAlertCause = "overcrowded" SituationAlertCauseOverheadobstruction SituationAlertCause = "overheadObstruction" SituationAlertCauseOverheadwirefailure SituationAlertCause = "overheadWireFailure" SituationAlertCauseOvertaking SituationAlertCause = "overtaking" SituationAlertCausePassengeraction SituationAlertCause = "passengerAction" SituationAlertCausePassengersblockingdoors SituationAlertCause = "passengersBlockingDoors" SituationAlertCausePaving SituationAlertCause = "paving" SituationAlertCausePersonhitbytrain SituationAlertCause = "personHitByTrain" SituationAlertCausePersonhitbyvehicle SituationAlertCause = "personHitByVehicle" SituationAlertCausePersonillonvehicle SituationAlertCause = "personIllOnVehicle" SituationAlertCausePersonontheline SituationAlertCause = "personOnTheLine" SituationAlertCausePersonundertrain SituationAlertCause = "personUnderTrain" SituationAlertCausePointsfailure SituationAlertCause = "pointsFailure" SituationAlertCausePointsproblem SituationAlertCause = "pointsProblem" SituationAlertCausePoliceactivity SituationAlertCause = "policeActivity" SituationAlertCausePoliceorder SituationAlertCause = "policeOrder" SituationAlertCausePoorrailconditions SituationAlertCause = "poorRailConditions" SituationAlertCausePoorweather SituationAlertCause = "poorWeather" SituationAlertCausePowerproblem SituationAlertCause = "powerProblem" SituationAlertCausePrecedingvehicle SituationAlertCause = "precedingVehicle" SituationAlertCausePreviousdisturbances SituationAlertCause = "previousDisturbances" SituationAlertCauseProblemsatborderpost SituationAlertCause = "problemsAtBorderPost" SituationAlertCauseProblemsatcustomspost SituationAlertCause = "problemsAtCustomsPost" SituationAlertCauseProblemsonlocalroad SituationAlertCause = "problemsOnLocalRoad" SituationAlertCauseProcession SituationAlertCause = "procession" SituationAlertCauseProvisiondelay SituationAlertCause = "provisionDelay" SituationAlertCausePublicdisturbance SituationAlertCause = "publicDisturbance" SituationAlertCauseRailwaycrime SituationAlertCause = "railwayCrime" SituationAlertCauseRepairwork SituationAlertCause = "repairWork" SituationAlertCauseRiskofavalanches SituationAlertCause = "riskOfAvalanches" SituationAlertCauseRiskofflooding SituationAlertCause = "riskOfFlooding" SituationAlertCauseRiskoflandslide SituationAlertCause = "riskOfLandslide" SituationAlertCauseRoadclosed SituationAlertCause = "roadClosed" SituationAlertCauseRoadmaintenance SituationAlertCause = "roadMaintenance" SituationAlertCauseRoadwaydamage SituationAlertCause = "roadwayDamage" SituationAlertCauseRoadworks SituationAlertCause = "roadworks" SituationAlertCauseRockfalls SituationAlertCause = "rockfalls" SituationAlertCauseRoughsea SituationAlertCause = "roughSea" SituationAlertCauseRouteblockage SituationAlertCause = "routeBlockage" SituationAlertCauseRoutediversion SituationAlertCause = "routeDiversion" SituationAlertCauseSabotage SituationAlertCause = "sabotage" SituationAlertCauseSafetyviolation SituationAlertCause = "safetyViolation" SituationAlertCauseSecurityalert SituationAlertCause = "securityAlert" SituationAlertCauseSecurityincident SituationAlertCause = "securityIncident" SituationAlertCauseServicedisruption SituationAlertCause = "serviceDisruption" SituationAlertCauseServicefailure SituationAlertCause = "serviceFailure" SituationAlertCauseServiceindicatorfailure SituationAlertCause = "serviceIndicatorFailure" SituationAlertCauseSeweragemaintenance SituationAlertCause = "sewerageMaintenance" SituationAlertCauseSeweroverflow SituationAlertCause = "sewerOverflow" SituationAlertCauseSightseersobstructingaccess SituationAlertCause = "sightseersObstructingAccess" SituationAlertCauseSignalandswitchfailure SituationAlertCause = "signalAndSwitchFailure" SituationAlertCauseSignalfailure SituationAlertCause = "signalFailure" SituationAlertCauseSignalpassedatdanger SituationAlertCause = "signalPassedAtDanger" SituationAlertCauseSignalproblem SituationAlertCause = "signalProblem" SituationAlertCauseSleet SituationAlertCause = "sleet" SituationAlertCauseSlipperiness SituationAlertCause = "slipperiness" SituationAlertCauseSlipperytrack SituationAlertCause = "slipperyTrack" SituationAlertCauseSmokedetectedonvehicle SituationAlertCause = "smokeDetectedOnVehicle" SituationAlertCauseSpecialevent SituationAlertCause = "specialEvent" SituationAlertCauseSpeedrestrictions SituationAlertCause = "speedRestrictions" SituationAlertCauseStaffabsence SituationAlertCause = "staffAbsence" SituationAlertCauseStaffassault SituationAlertCause = "staffAssault" SituationAlertCauseStaffinjury SituationAlertCause = "staffInjury" SituationAlertCauseStaffinwrongplace SituationAlertCause = "staffInWrongPlace" SituationAlertCauseStaffshortage SituationAlertCause = "staffShortage" SituationAlertCauseStaffsickness SituationAlertCause = "staffSickness" SituationAlertCauseStationoverrun SituationAlertCause = "stationOverrun" SituationAlertCauseStormconditions SituationAlertCause = "stormConditions" SituationAlertCauseStormdamage SituationAlertCause = "stormDamage" SituationAlertCauseStrongwinds SituationAlertCause = "strongWinds" SituationAlertCauseSubsidence SituationAlertCause = "subsidence" SituationAlertCauseSuspectvehicle SituationAlertCause = "suspectVehicle" SituationAlertCauseSwingbridgefailure SituationAlertCause = "swingBridgeFailure" SituationAlertCauseTechnicalproblem SituationAlertCause = "technicalProblem" SituationAlertCauseTelephonedthreat SituationAlertCause = "telephonedThreat" SituationAlertCauseTerroristincident SituationAlertCause = "terroristIncident" SituationAlertCauseTheft SituationAlertCause = "theft" SituationAlertCauseTicketingsystemnotavailable SituationAlertCause = "ticketingSystemNotAvailable" SituationAlertCauseTidalrestrictions SituationAlertCause = "tidalRestrictions" SituationAlertCauseTrackcircuitproblem SituationAlertCause = "trackCircuitProblem" SituationAlertCauseTractionfailure SituationAlertCause = "tractionFailure" SituationAlertCauseTrafficmanagementsystemfailure SituationAlertCause = "trafficManagementSystemFailure" SituationAlertCauseTraincoupling SituationAlertCause = "trainCoupling" SituationAlertCauseTraindoor SituationAlertCause = "trainDoor" SituationAlertCauseTrainstruckanimal SituationAlertCause = "trainStruckAnimal" SituationAlertCauseTrainstruckobject SituationAlertCause = "trainStruckObject" SituationAlertCauseTrainwarningsystemproblem SituationAlertCause = "trainWarningSystemProblem" SituationAlertCauseUnattendedbag SituationAlertCause = "unattendedBag" SituationAlertCauseUndefinedalertcause SituationAlertCause = "undefinedAlertCause" SituationAlertCauseUndefinedenvironmentalproblem SituationAlertCause = "undefinedEnvironmentalProblem" SituationAlertCauseUndefinedequipmentproblem SituationAlertCause = "undefinedEquipmentProblem" SituationAlertCauseUndefinedpersonnelproblem SituationAlertCause = "undefinedPersonnelProblem" SituationAlertCauseUndefinedproblem SituationAlertCause = "undefinedProblem" SituationAlertCauseUnknown SituationAlertCause = "unknown" SituationAlertCauseUnofficialindustrialaction SituationAlertCause = "unofficialIndustrialAction" SituationAlertCauseUnscheduledconstructionwork SituationAlertCause = "unscheduledConstructionWork" SituationAlertCauseVandalism SituationAlertCause = "vandalism" SituationAlertCauseVegetation SituationAlertCause = "vegetation" SituationAlertCauseVehicleblockingtrack SituationAlertCause = "vehicleBlockingTrack" SituationAlertCauseVehiclefailure SituationAlertCause = "vehicleFailure" SituationAlertCauseVehicleontheline SituationAlertCause = "vehicleOnTheLine" SituationAlertCauseVehiclestruckanimal SituationAlertCause = "vehicleStruckAnimal" SituationAlertCauseVehiclestruckobject SituationAlertCause = "vehicleStruckObject" SituationAlertCauseViaductfailure SituationAlertCause = "viaductFailure" SituationAlertCauseWaitingfortransferpassengers SituationAlertCause = "waitingForTransferPassengers" SituationAlertCauseWaterlogged SituationAlertCause = "waterlogged" SituationAlertCauseWheelimpactload SituationAlertCause = "wheelImpactLoad" SituationAlertCauseWheelproblem SituationAlertCause = "wheelProblem" SituationAlertCauseWildlandfire SituationAlertCause = "wildlandFire" SituationAlertCauseWorktorule SituationAlertCause = "workToRule" )
func (*SituationAlertCause) FromString ¶
func (alertCause *SituationAlertCause) FromString(s string) error
type SituationId ¶
type SituationId string
type SituationProgress ¶
type SituationProgress string
const ( SituationProgressDraft SituationProgress = "draft" SituationProgressPendingApproval SituationProgress = "pendingApproval" SituationProgressApprovedDraft SituationProgress = "approvedDraft" SituationProgressOpend SituationProgress = "open" SituationProgressPublished SituationProgress = "published" SituationProgressClosing SituationProgress = "closing" SituationProgressClosed SituationProgress = "closed" )
func (*SituationProgress) FromString ¶
func (progress *SituationProgress) FromString(s string) error
type SituationSeverity ¶
type SituationSeverity string
const ( SituationSeverityNoImpact SituationSeverity = "noImpact" SituationSeverityVerySlight SituationSeverity = "verySlight" SituationSeveritySlight SituationSeverity = "slight" SituationSeverityNormal SituationSeverity = "normal" SituationSeveritySevere SituationSeverity = "severe" SituationSeverityVerySevere SituationSeverity = "verySevere" )
func (*SituationSeverity) FromString ¶
func (severity *SituationSeverity) FromString(s string) error
type SituationType ¶
type SituationType string
type SituationUpdateEvent ¶
type SituationUpdateEvent struct { CreatedAt time.Time RecordedAt time.Time SituationCode Code Origin string Format string ProducerRef string ParticipantRef string VersionedAt time.Time ValidityPeriods []*TimeRange PublicationWindows []*TimeRange Keywords []string InternalTags []string AlertCause SituationAlertCause Progress SituationProgress Severity SituationSeverity ReportType ReportType Version int Summary *SituationTranslatedString Description *SituationTranslatedString Affects []Affect Consequences []*Consequence // contains filtered or unexported fields }
func (*SituationUpdateEvent) Id ¶
func (event *SituationUpdateEvent) Id() SituationUpdateRequestId
func (*SituationUpdateEvent) SetId ¶
func (event *SituationUpdateEvent) SetId(id SituationUpdateRequestId)
func (*SituationUpdateEvent) TestFindAffectByLineId ¶
func (event *SituationUpdateEvent) TestFindAffectByLineId(lineId LineId) (bool, *AffectedLine)
func (*SituationUpdateEvent) TestFindAffectByStopAreaId ¶
func (event *SituationUpdateEvent) TestFindAffectByStopAreaId(stopAreaId StopAreaId) (bool, *AffectedStopArea)
type SituationUpdateManager ¶
type SituationUpdateManager struct { clock.ClockConsumer // contains filtered or unexported fields }
func (*SituationUpdateManager) Update ¶
func (manager *SituationUpdateManager) Update(events []*SituationUpdateEvent)
type SituationUpdateRequestId ¶
type SituationUpdateRequestId string
type Situations ¶
type StatusUpdateEvent ¶
type StatusUpdateEvent struct { StopAreaId StopAreaId Partner string Status bool }
func NewStatusUpdateEvent ¶
func NewStatusUpdateEvent(stopAreaId StopAreaId, partner string, status bool) *StatusUpdateEvent
func (*StatusUpdateEvent) EventKind ¶
func (ue *StatusUpdateEvent) EventKind() EventKind
type StopArea ¶
type StopArea struct { Collectable CollectedUntil time.Time References References CodeConsumer Origins *StopAreaOrigins Attributes Attributes ReferentId StopAreaId `json:",omitempty"` ParentId StopAreaId `json:",omitempty"` Name string LineIds StopAreaLineIds `json:"Lines,omitempty"` Latitude float64 `json:",omitempty"` Longitude float64 `json:",omitempty"` CollectChildren bool CollectSituations bool CollectedAlways bool Monitored bool // contains filtered or unexported fields }
func NewStopArea ¶
func (*StopArea) Id ¶
func (stopArea *StopArea) Id() StopAreaId
func (*StopArea) MarshalJSON ¶
func (*StopArea) ReferentOrSelfCode ¶
func (*StopArea) SPDCode ¶
Returns true if we need to send the StopArea in a SPD
We only send the StopArea if it has no referent with a correct codeSpace. If that's the case, we'll send the Referent instead
func (*StopArea) SetPartnerStatus ¶
func (*StopArea) UnmarshalJSON ¶
type StopAreaId ¶
type StopAreaId ModelId
type StopAreaLineIds ¶
type StopAreaLineIds []LineId
func (*StopAreaLineIds) Add ¶
func (ids *StopAreaLineIds) Add(id LineId)
func (StopAreaLineIds) Contains ¶
func (ids StopAreaLineIds) Contains(id LineId) bool
func (StopAreaLineIds) Copy ¶
func (ids StopAreaLineIds) Copy() (t StopAreaLineIds)
type StopAreaOrigins ¶
func NewStopAreaOrigins ¶
func NewStopAreaOrigins() *StopAreaOrigins
func (*StopAreaOrigins) AllOrigin ¶
func (origins *StopAreaOrigins) AllOrigin() map[string]bool
func (*StopAreaOrigins) Copy ¶
func (origins *StopAreaOrigins) Copy() *StopAreaOrigins
func (*StopAreaOrigins) MarshalJSON ¶
func (origins *StopAreaOrigins) MarshalJSON() ([]byte, error)
func (*StopAreaOrigins) Monitored ¶
func (origins *StopAreaOrigins) Monitored() (monitored bool)
func (*StopAreaOrigins) NewOrigin ¶
func (origins *StopAreaOrigins) NewOrigin(partner string)
func (*StopAreaOrigins) Origin ¶
func (origins *StopAreaOrigins) Origin(partner string) (status bool, present bool)
func (*StopAreaOrigins) PartnersKO ¶
func (origins *StopAreaOrigins) PartnersKO() (partnersSlice []string)
func (*StopAreaOrigins) PartnersLost ¶
func (origins *StopAreaOrigins) PartnersLost(comparedOrigins *StopAreaOrigins) (partnersLost []string, r bool)
func (*StopAreaOrigins) SetOriginsFromMap ¶
func (origins *StopAreaOrigins) SetOriginsFromMap(originMap map[string]bool)
func (*StopAreaOrigins) SetPartnerStatus ¶
func (origins *StopAreaOrigins) SetPartnerStatus(partner string, status bool)
type StopAreaUpdateEvent ¶
type StopAreaUpdateEvent struct { Origin string Code Code ParentCode Code Name string CollectedAlways bool Longitude float64 Latitude float64 }
func NewStopAreaUpdateEvent ¶
func NewStopAreaUpdateEvent() *StopAreaUpdateEvent
func (*StopAreaUpdateEvent) EventKind ¶
func (ue *StopAreaUpdateEvent) EventKind() EventKind
type StopAreas ¶
type StopAreas interface { uuid.UUIDInterface New() *StopArea Find(StopAreaId) (*StopArea, bool) FindByCode(Code) (*StopArea, bool) FindByLineId(LineId) []*StopArea FindByOrigin(string) []StopAreaId FindAll() []*StopArea FindFamily(StopAreaId) []StopAreaId FindAscendants(StopAreaId) []*StopArea FindAscendantsWithCodeSpace(StopAreaId, string) []Code Save(*StopArea) bool Delete(*StopArea) bool }
type StopVisit ¶
type StopVisit struct { RecordedAt time.Time References References Attributes Attributes Schedules *StopVisitSchedules CodeConsumer VehicleJourneyId VehicleJourneyId `json:",omitempty"` StopAreaId StopAreaId `json:",omitempty"` ArrivalStatus StopVisitArrivalStatus `json:",omitempty"` DepartureStatus StopVisitDepartureStatus `json:",omitempty"` DataFrameRef string `json:",omitempty"` Origin string PassageOrder int `json:",omitempty"` VehicleAtStop bool // contains filtered or unexported fields }
func NewStopVisit ¶
func (*StopVisit) CollectedAt ¶
func (*StopVisit) Id ¶
func (stopVisit *StopVisit) Id() StopVisitId
func (*StopVisit) IsArchivable ¶
func (*StopVisit) IsCollected ¶
func (*StopVisit) IsRecordable ¶
func (*StopVisit) MarshalJSON ¶
func (*StopVisit) NotCollected ¶
func (*StopVisit) ReferenceArrivalTime ¶
func (*StopVisit) ReferenceDepartureTime ¶
func (*StopVisit) ReferenceTime ¶
func (*StopVisit) UnmarshalJSON ¶
func (*StopVisit) VehicleJourney ¶
func (stopVisit *StopVisit) VehicleJourney() *VehicleJourney
type StopVisitArchiver ¶
func (*StopVisitArchiver) Archive ¶
func (sva *StopVisitArchiver) Archive()
func (*StopVisitArchiver) StopArea ¶
func (sva *StopVisitArchiver) StopArea() *StopArea
func (*StopVisitArchiver) VehicleJourney ¶
func (sva *StopVisitArchiver) VehicleJourney() *VehicleJourney
type StopVisitArrivalStatus ¶
type StopVisitArrivalStatus string
const ( STOP_VISIT_ARRIVAL_ARRIVED StopVisitArrivalStatus = "arrived" STOP_VISIT_ARRIVAL_ONTIME StopVisitArrivalStatus = "onTime" STOP_VISIT_ARRIVAL_EARLY StopVisitArrivalStatus = "early" STOP_VISIT_ARRIVAL_DELAYED StopVisitArrivalStatus = "delayed" STOP_VISIT_ARRIVAL_CANCELLED StopVisitArrivalStatus = "cancelled" STOP_VISIT_ARRIVAL_NOREPORT StopVisitArrivalStatus = "noreport" STOP_VISIT_ARRIVAL_MISSED StopVisitArrivalStatus = "missed" STOP_VISIT_ARRIVAL_NOT_EXPECTED StopVisitArrivalStatus = "notExpected" )
func SetStopVisitArrivalStatus ¶
func SetStopVisitArrivalStatus(arrivalStatus string) StopVisitArrivalStatus
func (StopVisitArrivalStatus) Arrived ¶
func (svas StopVisitArrivalStatus) Arrived() bool
type StopVisitDepartureStatus ¶
type StopVisitDepartureStatus string
const ( STOP_VISIT_DEPARTURE_ONTIME StopVisitDepartureStatus = "onTime" STOP_VISIT_DEPARTURE_EARLY StopVisitDepartureStatus = "early" STOP_VISIT_DEPARTURE_DELAYED StopVisitDepartureStatus = "delayed" STOP_VISIT_DEPARTURE_CANCELLED StopVisitDepartureStatus = "cancelled" STOP_VISIT_DEPARTURE_NOREPORT StopVisitDepartureStatus = "noreport" STOP_VISIT_DEPARTURE_DEPARTED StopVisitDepartureStatus = "departed" )
func SetStopVisitDepartureStatus ¶
func SetStopVisitDepartureStatus(departureStatus string) StopVisitDepartureStatus
func (StopVisitDepartureStatus) Departed ¶
func (svds StopVisitDepartureStatus) Departed() bool
type StopVisitId ¶
type StopVisitId ModelId
type StopVisitSchedule ¶
type StopVisitSchedule struct {
// contains filtered or unexported fields
}
func (*StopVisitSchedule) ArrivalTime ¶
func (schedule *StopVisitSchedule) ArrivalTime() time.Time
func (*StopVisitSchedule) DepartureTime ¶
func (schedule *StopVisitSchedule) DepartureTime() time.Time
func (*StopVisitSchedule) Kind ¶
func (schedule *StopVisitSchedule) Kind() StopVisitScheduleType
func (*StopVisitSchedule) MarshalJSON ¶
func (schedule *StopVisitSchedule) MarshalJSON() ([]byte, error)
func (*StopVisitSchedule) SetArrivalTime ¶
func (schedule *StopVisitSchedule) SetArrivalTime(t time.Time) time.Time
func (*StopVisitSchedule) SetDepartureTime ¶
func (schedule *StopVisitSchedule) SetDepartureTime(t time.Time) time.Time
func (*StopVisitSchedule) UnmarshalJSON ¶
func (schedule *StopVisitSchedule) UnmarshalJSON(data []byte) error
type StopVisitScheduleType ¶
type StopVisitScheduleType string
const ( STOP_VISIT_SCHEDULE_AIMED StopVisitScheduleType = "aimed" STOP_VISIT_SCHEDULE_EXPECTED StopVisitScheduleType = "expected" STOP_VISIT_SCHEDULE_ACTUAL StopVisitScheduleType = "actual" )
type StopVisitSchedules ¶
func NewStopVisitSchedules ¶
func NewStopVisitSchedules() *StopVisitSchedules
func (*StopVisitSchedules) ArrivalTimeFromKind ¶
func (schedules *StopVisitSchedules) ArrivalTimeFromKind(kinds []StopVisitScheduleType) time.Time
func (*StopVisitSchedules) Copy ¶
func (schedules *StopVisitSchedules) Copy() *StopVisitSchedules
func (*StopVisitSchedules) DepartureTimeFromKind ¶
func (schedules *StopVisitSchedules) DepartureTimeFromKind(kinds []StopVisitScheduleType) time.Time
func (*StopVisitSchedules) Eq ¶
func (schedules *StopVisitSchedules) Eq(scs *StopVisitSchedules) bool
func (*StopVisitSchedules) Include ¶
func (schedules *StopVisitSchedules) Include(scs *StopVisitSchedules) bool
func (*StopVisitSchedules) Merge ¶
func (schedules *StopVisitSchedules) Merge(newSchedules *StopVisitSchedules)
func (*StopVisitSchedules) ReferenceArrivalTime ¶
func (schedules *StopVisitSchedules) ReferenceArrivalTime() time.Time
func (*StopVisitSchedules) ReferenceDepartureTime ¶
func (schedules *StopVisitSchedules) ReferenceDepartureTime() time.Time
func (*StopVisitSchedules) ReferenceTime ¶
func (schedules *StopVisitSchedules) ReferenceTime() time.Time
func (*StopVisitSchedules) Schedule ¶
func (schedules *StopVisitSchedules) Schedule(kind StopVisitScheduleType) *StopVisitSchedule
func (*StopVisitSchedules) SetArrivalTime ¶
func (schedules *StopVisitSchedules) SetArrivalTime(kind StopVisitScheduleType, arrivalTime time.Time)
func (*StopVisitSchedules) SetArrivalTimeIfNotDefined ¶
func (schedules *StopVisitSchedules) SetArrivalTimeIfNotDefined(kind StopVisitScheduleType, arrivalTime time.Time)
func (*StopVisitSchedules) SetDepartureTime ¶
func (schedules *StopVisitSchedules) SetDepartureTime(kind StopVisitScheduleType, departureTime time.Time)
func (*StopVisitSchedules) SetDepartureTimeIfNotDefined ¶
func (schedules *StopVisitSchedules) SetDepartureTimeIfNotDefined(kind StopVisitScheduleType, departureTime time.Time)
func (*StopVisitSchedules) SetSchedule ¶
func (schedules *StopVisitSchedules) SetSchedule(kind StopVisitScheduleType, departureTime time.Time, arrivalTime time.Time)
func (*StopVisitSchedules) ToSlice ¶
func (schedules *StopVisitSchedules) ToSlice() (scheduleSlice []StopVisitSchedule)
type StopVisitSelector ¶
func CompositeStopVisitSelector ¶
func CompositeStopVisitSelector(selectors []StopVisitSelector) StopVisitSelector
func StopVisitSelectByStopAreaId ¶
func StopVisitSelectByStopAreaId(stopAreaId StopAreaId) StopVisitSelector
func StopVisitSelectorAfterTime ¶
func StopVisitSelectorAfterTime(startTime time.Time) StopVisitSelector
func StopVisitSelectorBeforeTime ¶
func StopVisitSelectorBeforeTime(endTime time.Time) StopVisitSelector
func StopVisitSelectorByLine ¶
func StopVisitSelectorByLine(code Code) StopVisitSelector
func StopVisitSelectorByTime ¶
func StopVisitSelectorByTime(startTime, endTime time.Time) StopVisitSelector
type StopVisitUpdateEvent ¶
type StopVisitUpdateEvent struct { RecordedAt time.Time Schedules *StopVisitSchedules SiriXML *sxml.XMLMonitoredStopVisit VehicleJourneyCode Code StopAreaCode Code Code Code CodeSpace string DepartureStatus StopVisitDepartureStatus ArrivalStatus StopVisitArrivalStatus DataFrameRef string Origin string PassageOrder int Monitored bool VehicleAtStop bool // contains filtered or unexported fields }
func NewStopVisitUpdateEvent ¶
func NewStopVisitUpdateEvent() *StopVisitUpdateEvent
func (*StopVisitUpdateEvent) Attributes ¶
func (ue *StopVisitUpdateEvent) Attributes() Attributes
func (*StopVisitUpdateEvent) EventKind ¶
func (ue *StopVisitUpdateEvent) EventKind() EventKind
func (*StopVisitUpdateEvent) References ¶
func (ue *StopVisitUpdateEvent) References() References
type StopVisits ¶
type StopVisits interface { uuid.UUIDInterface New() *StopVisit Find(StopVisitId) (*StopVisit, bool) FindByCode(Code) (*StopVisit, bool) FindByVehicleJourneyId(VehicleJourneyId) []*StopVisit FindByVehicleJourneyIdAndStopVisitOrder(VehicleJourneyId, int) *StopVisit VehicleJourneyHasStopVisits(VehicleJourneyId) bool FindByVehicleJourneyIdAfter(VehicleJourneyId, time.Time) []*StopVisit FindFollowingByVehicleJourneyId(VehicleJourneyId) []*StopVisit StopVisitsLenByVehicleJourney(VehicleJourneyId) int FindByStopAreaId(StopAreaId) []*StopVisit FindMonitoredByOriginByStopAreaId(StopAreaId, string) []*StopVisit FindFollowingByStopAreaId(StopAreaId) []*StopVisit FindFollowingByStopAreaIds([]StopAreaId) []*StopVisit FindAll() []*StopVisit UnsafeFindAll() []*StopVisit FindByVehicleJourneyIdAndStopAreaId(VehicleJourneyId, StopAreaId) []StopVisitId FindAllAfter(time.Time) []*StopVisit Save(*StopVisit) bool Delete(*StopVisit) bool DeleteMultiple([]*StopVisit) bool }
type UpdateEvent ¶
type UpdateEvent interface {
EventKind() EventKind
}
type UpdateManager ¶
type UpdateManager struct { clock.ClockConsumer uuid.UUIDConsumer // contains filtered or unexported fields }
func (*UpdateManager) Update ¶
func (manager *UpdateManager) Update(event UpdateEvent)
type Vehicle ¶
type Vehicle struct { RecordedAtTime time.Time ValidUntilTime time.Time `json:",omitempty"` CodeConsumer Attributes Attributes StopAreaId StopAreaId `json:",omitempty"` Occupancy string `json:",omitempty"` LineId LineId `json:",omitempty"` VehicleJourneyId VehicleJourneyId `json:",omitempty"` DriverRef string `json:",omitempty"` NextStopVisitId StopVisitId `json:",omitempty"` LinkDistance float64 `json:",omitempty"` Percentage float64 `json:",omitempty"` Longitude float64 `json:",omitempty"` Latitude float64 `json:",omitempty"` Bearing float64 `json:",omitempty"` // contains filtered or unexported fields }
func NewVehicle ¶
func (*Vehicle) MarshalJSON ¶
func (*Vehicle) UnmarshalJSON ¶
func (*Vehicle) VehicleJourney ¶
func (vehicle *Vehicle) VehicleJourney() *VehicleJourney
type VehicleBroadcastEvent ¶
type VehicleJourney ¶
type VehicleJourney struct { References References Attributes Attributes CodeConsumer LineId LineId `json:",omitempty"` Name string `json:",omitempty"` DestinationName string `json:",omitempty"` Occupancy string `json:",omitempty"` DirectionType string `json:",omitempty"` Origin string `json:",omitempty"` OriginName string `json:",omitempty"` Monitored bool HasCompleteStopSequence bool // contains filtered or unexported fields }
func NewVehicleJourney ¶
func NewVehicleJourney(model Model) *VehicleJourney
func (*VehicleJourney) Attribute ¶
func (vehicleJourney *VehicleJourney) Attribute(key string) (string, bool)
func (*VehicleJourney) Id ¶
func (vehicleJourney *VehicleJourney) Id() VehicleJourneyId
func (*VehicleJourney) Line ¶
func (vehicleJourney *VehicleJourney) Line() *Line
func (*VehicleJourney) MarshalJSON ¶
func (vehicleJourney *VehicleJourney) MarshalJSON() ([]byte, error)
func (*VehicleJourney) Reference ¶
func (vehicleJourney *VehicleJourney) Reference(key string) (Reference, bool)
func (*VehicleJourney) Save ¶
func (vehicleJourney *VehicleJourney) Save() bool
func (*VehicleJourney) ToFormat ¶
func (vehicleJourney *VehicleJourney) ToFormat() []string
func (*VehicleJourney) UnmarshalJSON ¶
func (vehicleJourney *VehicleJourney) UnmarshalJSON(data []byte) error
type VehicleJourneyId ¶
type VehicleJourneyId ModelId
type VehicleJourneyUpdateEvent ¶
type VehicleJourneyUpdateEvent struct { SiriXML *sxml.XMLMonitoredVehicleJourney Code Code LineCode Code Direction string DestinationName string DestinationRef string DirectionType string Occupancy string OriginName string CodeSpace string OriginRef string Origin string Monitored bool // contains filtered or unexported fields }
func NewVehicleJourneyUpdateEvent ¶
func NewVehicleJourneyUpdateEvent() *VehicleJourneyUpdateEvent
func (*VehicleJourneyUpdateEvent) Attributes ¶
func (ue *VehicleJourneyUpdateEvent) Attributes() Attributes
func (*VehicleJourneyUpdateEvent) EventKind ¶
func (ue *VehicleJourneyUpdateEvent) EventKind() EventKind
func (*VehicleJourneyUpdateEvent) References ¶
func (ue *VehicleJourneyUpdateEvent) References() References
type VehicleJourneys ¶
type VehicleJourneys interface { uuid.UUIDInterface New() *VehicleJourney Find(VehicleJourneyId) (*VehicleJourney, bool) FindByCode(code Code) (*VehicleJourney, bool) FindByLineId(LineId) []*VehicleJourney FullVehicleJourneyExistBySubscriptionId(string, VehicleJourneyId) bool FindAll() []*VehicleJourney Save(*VehicleJourney) bool SetFullVehicleJourneyBySubscriptionId(string, VehicleJourneyId) Delete(*VehicleJourney) bool DeleteById(VehicleJourneyId) bool }
type VehicleUpdateEvent ¶
type VehicleUpdateEvent struct { ValidUntilTime time.Time RecordedAt time.Time Code Code StopAreaCode Code VehicleJourneyCode Code Occupancy string DriverRef string Origin string Longitude float64 Latitude float64 Bearing float64 Percentage float64 LinkDistance float64 NextStopPointOrder int }
func NewVehicleUpdateEvent ¶
func NewVehicleUpdateEvent() *VehicleUpdateEvent
func (*VehicleUpdateEvent) EventKind ¶
func (ue *VehicleUpdateEvent) EventKind() EventKind
Source Files ¶
- attributes.go
- code.go
- code_index.go
- collectable.go
- database.go
- database_structures.go
- date.go
- diff.go
- general_message_broadcast_event.go
- general_message_update_event.go
- index.go
- line_update_event.go
- lines.go
- load_from_csv.go
- model_interface.go
- not_collected_update_event.go
- occupancy_status.go
- operator.go
- purge.go
- reference.go
- references.go
- situation.go
- situation_attributes.go
- situation_update_manager.go
- status_update_event.go
- stop_area.go
- stop_area_line_ids.go
- stop_area_origin.go
- stop_area_update_event.go
- stop_visit.go
- stop_visit_archiver.go
- stop_visit_arrival_status.go
- stop_visit_broadcast_event.go
- stop_visit_departure_status.go
- stop_visit_schedule.go
- stop_visit_selector.go
- stop_visit_update_event.go
- update_event.go
- update_manager.go
- vehicle_journey.go
- vehicle_journey_update_event.go
- vehicle_montoring_brodcast_event.go
- vehicle_update_event.go
- vehicles.go