core

Documentation

Index

• Constants
• func CancelSubscription(subId, kind string, connector Connector)
• func GetModelReferenceSlice(refs map[string]struct{}) []string
• type APIPartner
  • func (partner *APIPartner) IsSettingDefined(setting string) (ok bool)
  • func (partner *APIPartner) UnmarshalJSON(data []byte) error
  • func (partner *APIPartner) Validate() bool
  • func (partner *APIPartner) ValidatePresenceOfConnector(connector string) bool
  • func (partner *APIPartner) ValidatePresenceOfLightRemoteCredentials() bool
  • func (partner *APIPartner) ValidatePresenceOfLocalCredentials() bool
  • func (partner *APIPartner) ValidatePresenceOfRemoteCodeSpace() bool
  • func (partner *APIPartner) ValidatePresenceOfRemoteCredentials() bool
  • func (partner *APIPartner) ValidatePresenceOfSetting(setting string) bool
• type APIReferential
  • func (referential *APIReferential) Id() ReferentialId
  • func (apiReferential *APIReferential) UnmarshalJSON(data []byte) error
  • func (referential *APIReferential) Validate() bool
• type APISubscription
• type ActualAttributesSimulator
  • func NewActualAttributesSimulator(stopVisit *model.StopVisit) *ActualAttributesSimulator
  • func (simulator *ActualAttributesSimulator) AfterArrivalTime() bool
  • func (simulator *ActualAttributesSimulator) AfterDepartureTime() bool
  • func (simulator *ActualAttributesSimulator) ArrivalTime() time.Time
  • func (simulator *ActualAttributesSimulator) CanArrive() bool
  • func (simulator *ActualAttributesSimulator) CanDepart() bool
  • func (simulator *ActualAttributesSimulator) DepartureTime() time.Time
  • func (simulator *ActualAttributesSimulator) Now() time.Time
  • func (simulator *ActualAttributesSimulator) Simulate() bool
• type BroadcastGeneralMessageBuilder
  • func NewBroadcastGeneralMessageBuilder(partner *Partner, connector string) *BroadcastGeneralMessageBuilder
  • func (builder *BroadcastGeneralMessageBuilder) BuildGeneralMessage(situation model.Situation) *siri.SIRIGeneralMessage
  • func (builder *BroadcastGeneralMessageBuilder) BuildGeneralMessageCancellation(situation model.Situation) *siri.SIRIGeneralMessageCancellation
  • func (builder *BroadcastGeneralMessageBuilder) SetLineRef(lineRef []string)
  • func (builder *BroadcastGeneralMessageBuilder) SetStopPointRef(stopPointRef []string)
• type BroadcastManager
  • func NewBroadcastManager(referential *Referential) *BroadcastManager
  • func (manager *BroadcastManager) GetGeneralMessageBroadcastEventChan() chan model.SituationBroadcastEvent
  • func (manager *BroadcastManager) GetSituationExchangeBroadcastEventChan() chan model.SituationBroadcastEvent
  • func (manager *BroadcastManager) GetStopMonitoringBroadcastEventChan() chan model.StopMonitoringBroadcastEvent
  • func (manager *BroadcastManager) GetVehicleBroadcastEventChan() chan model.VehicleBroadcastEvent
  • func (manager *BroadcastManager) Start()
  • func (manager *BroadcastManager) Stop()
• type BroadcastManagerInterface
• type BroadcastSituationExchangeBuilder
  • func NewBroadcastSituationExchangeBuilder(partner *Partner, connector string) *BroadcastSituationExchangeBuilder
  • func (builder *BroadcastSituationExchangeBuilder) BuildSituationExchange(situation model.Situation, delivery *siri.SIRISituationExchangeDelivery)
• type BroadcastStopMonitoringBuilder
  • func NewBroadcastStopMonitoringBuilder(partner *Partner, connectorName string) *BroadcastStopMonitoringBuilder
  • func (builder *BroadcastStopMonitoringBuilder) BuildCancelledStopVisit(stopVisit *model.StopVisit) *siri.SIRICancelledStopVisit
  • func (builder *BroadcastStopMonitoringBuilder) BuildMonitoredStopVisit(stopVisit *model.StopVisit) *siri.SIRIMonitoredStopVisit
• type ByPriority
  • func (a ByPriority) Len() int
  • func (a ByPriority) Less(i, j int) bool
  • func (a ByPriority) Swap(i, j int)
• type CheckStatusClient
• type CheckStatusServer
• type CollectManager
  • func (manager *CollectManager) BroadcastUpdateEvent(event model.UpdateEvent)
  • func (manager *CollectManager) HandlePartnerStatusChange(partner string, status bool)
  • func (manager *CollectManager) HandleUpdateEvent(UpdateSubscriber UpdateSubscriber)
  • func (manager *CollectManager) UpdateLine(ctx context.Context, request *LineUpdateRequest)
  • func (manager *CollectManager) UpdateSituation(request *SituationUpdateRequest)
  • func (manager *CollectManager) UpdateStopArea(request *StopAreaUpdateRequest)
  • func (manager *CollectManager) UpdateVehicle(ctx context.Context, request *VehicleUpdateRequest)
• type CollectManagerInterface
  • func NewCollectManager(referential *Referential) CollectManagerInterface
  • func NewTestCollectManager() CollectManagerInterface
• type CollectSubscriber
  • func NewCollectSubcriber(c Connector, name string) *CollectSubscriber
  • func (cs *CollectSubscriber) GetSubscriptionRequest() map[SubscriptionId]*subscriptionRequest
  • func (cs *CollectSubscriber) HandleResponse(subscriptionRequests map[SubscriptionId]*subscriptionRequest, ...)
  • func (cs *CollectSubscriber) IncrementRetryCountFromMap(subscriptionRequests map[SubscriptionId]*subscriptionRequest)
• type CollectUpdateEvents
  • func NewCollectUpdateEvents() *CollectUpdateEvents
• type CollectedRefs
  • func NewCollectedRefs() *CollectedRefs
  • func (events *CollectedRefs) GetLines() []string
  • func (events *CollectedRefs) GetStopAreas() []string
  • func (events *CollectedRefs) GetVehicleJourneys() []string
  • func (events *CollectedRefs) GetVehicles() []string
• type Connector
• type ConnectorFactory
  • func NewConnectorFactory(connectorType string) ConnectorFactory
• type DeletedSubscriptions
  • func NewDeletedSubscriptions() *DeletedSubscriptions
  • func (ds *DeletedSubscriptions) AlreadySend(subID string) bool
• type ETTBroadcaster
• type ETTSubscriber
• type EstimatedTimetableBroadcaster
  • func NewFakeSIRIEstimatedTimetableBroadcaster(connector *SIRIEstimatedTimetableSubscriptionBroadcaster) EstimatedTimetableBroadcaster
  • func NewSIRIEstimatedTimetableBroadcaster(connector *SIRIEstimatedTimetableSubscriptionBroadcaster) EstimatedTimetableBroadcaster
• type EstimatedTimetableRequestBroadcaster
• type EstimatedTimetableSubscriber
  • func (subscriber *EstimatedTimetableSubscriber) Start()
  • func (subscriber *EstimatedTimetableSubscriber) Stop()
• type EstimatedTimetableSubscriptionCollector
• type EstimatedTimetableUpdateEventBuilder
  • func NewEstimatedTimetableUpdateEventBuilder(partner *Partner) EstimatedTimetableUpdateEventBuilder
  • func (builder *EstimatedTimetableUpdateEventBuilder) SetUpdateEvents(estimatedJourneyVersionFrames []*sxml.XMLEstimatedJourneyVersionFrame)
  • func (builder *EstimatedTimetableUpdateEventBuilder) UpdateEvents() CollectUpdateEvents
• type FakeGeneralMessageBroadcaster
  • func (broadcaster *FakeGeneralMessageBroadcaster) Start()
  • func (broadcaster *FakeGeneralMessageBroadcaster) Stop()
• type FakeGeneralMessageSubscriber
  • func (subscriber *FakeGeneralMessageSubscriber) Start()
  • func (subscriber *FakeGeneralMessageSubscriber) Stop()
• type FakeProductionTimetableBroadcaster
  • func (broadcaster *FakeProductionTimetableBroadcaster) Start()
  • func (broadcaster *FakeProductionTimetableBroadcaster) Stop()
• type FakeSIRIEstimatedTimetableBroadcaster
  • func (broadcaster *FakeSIRIEstimatedTimetableBroadcaster) Start()
  • func (broadcaster *FakeSIRIEstimatedTimetableBroadcaster) Stop()
• type FakeSIRIVehicleMonitoringBroadcaster
  • func (broadcaster *FakeSIRIVehicleMonitoringBroadcaster) Start()
  • func (broadcaster *FakeSIRIVehicleMonitoringBroadcaster) Stop()
• type FakeSituationExchangeBroadcaster
  • func (broadcaster *FakeSituationExchangeBroadcaster) Start()
  • func (broadcaster *FakeSituationExchangeBroadcaster) Stop()
• type FakeSituationExchangeSubscriber
  • func (subscriber *FakeSituationExchangeSubscriber) Start()
  • func (subscriber *FakeSituationExchangeSubscriber) Stop()
• type FakeStopMonitoringBroadcaster
  • func (broadcaster *FakeStopMonitoringBroadcaster) Start()
  • func (broadcaster *FakeStopMonitoringBroadcaster) Stop()
• type FakeStopMonitoringSubscriber
  • func (subscriber *FakeStopMonitoringSubscriber) Start()
  • func (subscriber *FakeStopMonitoringSubscriber) Stop()
• type FakeVehicleMonitoringSubscriber
  • func (subscriber *FakeVehicleMonitoringSubscriber) Start()
  • func (subscriber *FakeVehicleMonitoringSubscriber) Stop()
• type GMBroadcaster
• type GMSubscriber
• type GeneralMessageBroadcaster
  • func (gmb *GeneralMessageBroadcaster) Start()
  • func (gmb *GeneralMessageBroadcaster) Stop()
• type GeneralMessageRequestBroadcaster
• type GeneralMessageSubscriber
  • func (subscriber *GeneralMessageSubscriber) Start()
  • func (subscriber *GeneralMessageSubscriber) Stop()
• type GeneralMessageSubscriptionCollector
• type GeneralMessageUpdateEventBuilder
  • func NewGeneralMessageUpdateEventBuilder(partner *Partner) GeneralMessageUpdateEventBuilder
  • func (builder *GeneralMessageUpdateEventBuilder) SetGeneralMessageDeliveryUpdateEvents(event *CollectUpdateEvents, xmlResponse *sxml.XMLGeneralMessageDelivery, ...)
  • func (builder *GeneralMessageUpdateEventBuilder) SetGeneralMessageResponseUpdateEvents(event *CollectUpdateEvents, xmlResponse *sxml.XMLGeneralMessageResponse)
• type GraphqlServer
  • func NewGraphqlServer(partner *Partner) *GraphqlServer
  • func (c *GraphqlServer) Partner() *Partner
  • func (c *GraphqlServer) RemoteCodeSpace() string
• type GraphqlServerFactory
  • func (factory *GraphqlServerFactory) CreateConnector(partner *Partner) Connector
  • func (factory *GraphqlServerFactory) Validate(apiPartner *APIPartner)
• type GtfsConnector
• type GtfsRequestCollector
  • func NewGtfsRequestCollector(partner *Partner) *GtfsRequestCollector
  • func (c *GtfsRequestCollector) Partner() *Partner
  • func (c *GtfsRequestCollector) RemoteCodeSpace() string
  • func (connector *GtfsRequestCollector) SetSubscriber(s UpdateSubscriber)
  • func (connector *GtfsRequestCollector) Start()
  • func (connector *GtfsRequestCollector) Stop()
• type GtfsRequestCollectorFactory
  • func (factory *GtfsRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *GtfsRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type LineDirection
• type LineSection
• type LineUpdateRequest
  • func NewLineUpdateRequest(lineId model.LineId) *LineUpdateRequest
  • func (vehicleUpdateRequest *LineUpdateRequest) CreatedAt() time.Time
  • func (vehicleUpdateRequest *LineUpdateRequest) LineId() model.LineId
• type LinesDiscoveryRequestBroadcaster
• type LinesDiscoveryRequestCollector
• type LiteStopMonitoringRequestCollector
• type LiteStopMonitoringUpdateEventBuilder
  • func NewLiteStopMonitoringUpdateEventBuilder(partner *Partner, originStopAreaCode model.Code) LiteStopMonitoringUpdateEventBuilder
  • func (builder *LiteStopMonitoringUpdateEventBuilder) SetUpdateEvents(stopVisits []slite.MonitoredStopVisit)
  • func (builder *LiteStopMonitoringUpdateEventBuilder) UpdateEvents() CollectUpdateEvents
• type LocalCredentialsIndex
  • func NewLocalCredentialsIndex() *LocalCredentialsIndex
  • func (index *LocalCredentialsIndex) Delete(modelId PartnerId)
  • func (index *LocalCredentialsIndex) Find(c string) (modelId PartnerId, ok bool)
  • func (index *LocalCredentialsIndex) Index(modelId PartnerId, localCredentials string)
  • func (index *LocalCredentialsIndex) UniqCredentials(modelId PartnerId, localCredentials string) bool
• type MemoryReferentials
  • func NewMemoryReferentials() *MemoryReferentials
  • func (manager *MemoryReferentials) Delete(referential *Referential) bool
  • func (manager *MemoryReferentials) Find(id ReferentialId) *Referential
  • func (manager *MemoryReferentials) FindAll() (referentials []*Referential)
  • func (manager *MemoryReferentials) FindBySlug(slug ReferentialSlug) *Referential
  • func (manager *MemoryReferentials) Load() error
  • func (manager *MemoryReferentials) New(slug ReferentialSlug) *Referential
  • func (manager *MemoryReferentials) Save(referential *Referential) bool
  • func (manager *MemoryReferentials) SaveToDatabase() (int, error)
  • func (manager *MemoryReferentials) Start()
• type MemorySubscriptions
  • func NewMemorySubscriptions(partner *Partner) *MemorySubscriptions
  • func (manager *MemorySubscriptions) CancelBroadcastSubscriptions()
  • func (manager *MemorySubscriptions) CancelCollectSubscriptions()
  • func (manager *MemorySubscriptions) CancelSubscriptions()
  • func (manager *MemorySubscriptions) CancelSubscriptionsResourcesBefore(time time.Time)
  • func (manager *MemorySubscriptions) Delete(subscription *Subscription) bool
  • func (manager *MemorySubscriptions) DeleteById(id SubscriptionId)
  • func (manager *MemorySubscriptions) Find(id SubscriptionId) (*Subscription, bool)
  • func (manager *MemorySubscriptions) FindAll() (subscriptions []*Subscription)
  • func (manager *MemorySubscriptions) FindBroadcastSubscriptions() (subscriptions []*Subscription)
  • func (manager *MemorySubscriptions) FindByExternalId(externalId string) (*Subscription, bool)
  • func (manager *MemorySubscriptions) FindByKind(kind string) (*Subscription, bool)
  • func (manager *MemorySubscriptions) FindByResourceId(id, kind string) []*Subscription
  • func (manager *MemorySubscriptions) FindOrCreateByKind(kind string) *Subscription
  • func (manager *MemorySubscriptions) FindSubscriptionsByKind(kind string) (subscriptions []*Subscription)
  • func (manager *MemorySubscriptions) Index(subscription *Subscription)
  • func (manager *MemorySubscriptions) MarshalJSON() ([]byte, error)
  • func (manager *MemorySubscriptions) New(kind string) *Subscription
  • func (manager *MemorySubscriptions) Save(subscription *Subscription) bool
• type ModelGuardian
  • func NewModelGuardian(referential *Referential) *ModelGuardian
  • func (guardian *ModelGuardian) Run()
  • func (guardian *ModelGuardian) Start()
  • func (guardian *ModelGuardian) Stop()
• type OperationnalStatus
• type PTTBroadcaster
• type Partner
  • func NewPartner() *Partner
  • func (partner *Partner) Allow(ip string) bool
  • func (partner *Partner) CanCollect(stopId string, lineIds map[string]struct{}) bool
  • func (partner *Partner) CanCollectLine(lineId string) bool
  • func (partner *Partner) CanCollectLines(lineIds map[string]struct{}) s.CollectStatus
  • func (partner *Partner) CanCollectStop(stopId string) s.CollectStatus
  • func (partner *Partner) CancelBroadcastSubscriptions()
  • func (partner *Partner) CancelSubscriptions()
  • func (partner *Partner) CheckStatus() (PartnerStatus, error)
  • func (partner *Partner) CheckStatusClient() (csc CheckStatusClient)
  • func (partner *Partner) Connector(connectorType string) (Connector, bool)
  • func (partner *Partner) CreateSubscriptionRequestDispatcher()
  • func (partner *Partner) Definition() *APIPartner
  • func (partner *Partner) Discover()
  • func (partner *Partner) EstimatedTimetableSubscriptionCollector() EstimatedTimetableSubscriptionCollector
  • func (partner *Partner) GeneralMessageSubscriptionCollector() GeneralMessageSubscriptionCollector
  • func (partner *Partner) GtfsCache() *cache.CacheTable
  • func (partner *Partner) GtfsConnectors() (connectors []GtfsConnector, ok bool)
  • func (partner *Partner) GtfsStatus(s OperationnalStatus)
  • func (partner *Partner) HTTPClient() *remote.HTTPClient
  • func (partner *Partner) HaveAtLeastOneConnector(connectorTypes []string) bool
  • func (partner *Partner) Id() PartnerId
  • func (partner *Partner) LastDiscovery() time.Time
  • func (partner *Partner) LiteStopMonitoringRequestCollector() (lsmrc LiteStopMonitoringRequestCollector)
  • func (partner *Partner) MarshalJSON() ([]byte, error)
  • func (partner *Partner) Model() model.Model
  • func (partner *Partner) OperationnalStatus() OperationnalStatus
  • func (partner *Partner) Pushed()
  • func (partner *Partner) Referential() *Referential
  • func (partner *Partner) RefreshConnectors()
  • func (partner *Partner) RegisterDiscoveredLines(lines []string)
  • func (partner *Partner) RegisterDiscoveredStopAreas(stops []string)
  • func (partner *Partner) SIRIClient() *remote.SIRIClient
  • func (partner *Partner) SIRILiteClient() *remote.SIRILiteClient
  • func (partner *Partner) Save() (ok bool)
  • func (partner *Partner) SetDefinition(apiPartner *APIPartner)
  • func (partner *Partner) SetSlug(s PartnerSlug)
  • func (partner *Partner) SituationExchangeRequestCollector() SituationExchangeRequestCollector
  • func (partner *Partner) SituationExchangeSubscriptionCollector() SituationExchangeSubscriptionCollector
  • func (partner *Partner) Slug() PartnerSlug
  • func (partner *Partner) Start()
  • func (partner *Partner) StartedAt() time.Time
  • func (partner *Partner) Stop()
  • func (partner *Partner) StopMonitoringRequestCollector() (smrc StopMonitoringRequestCollector)
  • func (partner *Partner) StopMonitoringSubscriptionCollector() StopMonitoringSubscriptionCollector
  • func (partner *Partner) Subscriptions() Subscriptions
  • func (partner *Partner) VehicleMonitoringRequestCollector() VehicleMonitoringRequestCollector
  • func (partner *Partner) VehicleMonitoringSubscriptionCollector() VehicleMonitoringSubscriptionCollector
• type PartnerId
• type PartnerManager
  • func NewPartnerManager(referential *Referential) *PartnerManager
  • func (manager *PartnerManager) CancelSubscriptions()
  • func (manager *PartnerManager) Delete(partner *Partner) bool
  • func (manager *PartnerManager) Find(id PartnerId) *Partner
  • func (manager *PartnerManager) FindAll() (partners []*Partner)
  • func (manager *PartnerManager) FindAllByCollectPriority() []*Partner
  • func (manager *PartnerManager) FindAllWithConnector(connectorTypes []string) (partners []*Partner)
  • func (manager *PartnerManager) FindByCredential(c string) (*Partner, bool)
  • func (manager *PartnerManager) FindBySlug(slug PartnerSlug) (*Partner, bool)
  • func (manager *PartnerManager) Guardian() *PartnersGuardian
  • func (manager *PartnerManager) IsEmpty() bool
  • func (manager *PartnerManager) Load() error
  • func (manager *PartnerManager) MarshalJSON() ([]byte, error)
  • func (manager *PartnerManager) Model() model.Model
  • func (manager *PartnerManager) New(slug PartnerSlug) *Partner
  • func (manager *PartnerManager) Referential() *Referential
  • func (manager *PartnerManager) Save(partner *Partner) bool
  • func (manager *PartnerManager) SaveToDatabase() (int, error)
  • func (manager *PartnerManager) Start()
  • func (manager *PartnerManager) Stop()
  • func (manager *PartnerManager) UniqCredentials(modelId PartnerId, localCredentials string) bool
• type PartnerSlug
• type PartnerStatus
• type PartnerStatusCheck
• type Partners
• type PartnersGuardian
  • func NewPartnersGuardian(referential *Referential) *PartnersGuardian
  • func (guardian *PartnersGuardian) Run()
  • func (guardian *PartnersGuardian) Start()
  • func (guardian *PartnersGuardian) Stop()
• type ProductionTimetableBroadcaster
  • func (ptt *ProductionTimetableBroadcaster) Start()
  • func (ptt *ProductionTimetableBroadcaster) Stop()
• type PushCollector
  • func NewPushCollector(partner *Partner) *PushCollector
  • func (pc *PushCollector) HandlePushNotification(model *em.ExternalCompleteModel, message *audit.BigQueryMessage)
  • func (c *PushCollector) Partner() *Partner
  • func (c *PushCollector) RemoteCodeSpace() string
  • func (pc *PushCollector) SetSubscriber(subscriber UpdateSubscriber)
• type PushCollectorFactory
  • func (factory *PushCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *PushCollectorFactory) Validate(apiPartner *APIPartner)
• type Referential
  • func (referential *Referential) CollectManager() CollectManagerInterface
  • func (referential *Referential) DatabaseOrganisationId() sql.NullString
  • func (referential *Referential) Definition() *APIReferential
  • func (referential *Referential) Id() ReferentialId
  • func (referential *Referential) Load()
  • func (referential *Referential) MarshalJSON() ([]byte, error)
  • func (referential *Referential) Model() model.Model
  • func (referential *Referential) ModelGuardian() *ModelGuardian
  • func (referential *Referential) NextReloadAt() time.Time
  • func (referential *Referential) Partners() Partners
  • func (referential *Referential) ReloadModel()
  • func (referential *Referential) Save() (ok bool)
  • func (referential *Referential) SetDefinition(apiReferential *APIReferential)
  • func (referential *Referential) Slug() ReferentialSlug
  • func (referential *Referential) Start()
  • func (referential *Referential) StartedAt() time.Time
  • func (referential *Referential) Stop()
• type ReferentialId
• type ReferentialSlug
• type Referentials
  • func CurrentReferentials() Referentials
• type ReferentialsConsumer
  • func (consumer *ReferentialsConsumer) CurrentReferentials() Referentials
  • func (consumer *ReferentialsConsumer) SetReferentials(referentials Referentials)
• type SIRICheckStatusClient
  • func NewSIRICheckStatusClient(partner *Partner) *SIRICheckStatusClient
  • func (c *SIRICheckStatusClient) Partner() *Partner
  • func (c *SIRICheckStatusClient) RemoteCodeSpace() string
  • func (connector *SIRICheckStatusClient) Status() (PartnerStatus, error)
• type SIRICheckStatusClientFactory
  • func (factory *SIRICheckStatusClientFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRICheckStatusClientFactory) Validate(apiPartner *APIPartner)
• type SIRICheckStatusServer
  • func NewSIRICheckStatusServer(partner *Partner) *SIRICheckStatusServer
  • func (connector *SIRICheckStatusServer) CheckStatus(request *sxml.XMLCheckStatusRequest, message *audit.BigQueryMessage) (*siri.SIRICheckStatusResponse, error)
  • func (c *SIRICheckStatusServer) Partner() *Partner
  • func (c *SIRICheckStatusServer) RemoteCodeSpace() string
• type SIRICheckStatusServerFactory
  • func (factory *SIRICheckStatusServerFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRICheckStatusServerFactory) Validate(apiPartner *APIPartner)
• type SIRIEstimatedTimetableBroadcaster
  • func (ett *SIRIEstimatedTimetableBroadcaster) Start()
  • func (ett *SIRIEstimatedTimetableBroadcaster) Stop()
• type SIRIEstimatedTimetableRequestBroadcaster
  • func NewSIRIEstimatedTimetableRequestBroadcaster(partner *Partner) *SIRIEstimatedTimetableRequestBroadcaster
  • func (c *SIRIEstimatedTimetableRequestBroadcaster) Partner() *Partner
  • func (c *SIRIEstimatedTimetableRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIEstimatedTimetableRequestBroadcaster) RequestLine(request *sxml.XMLGetEstimatedTimetable, message *audit.BigQueryMessage) *siri.SIRIEstimatedTimetableResponse
  • func (connector *SIRIEstimatedTimetableRequestBroadcaster) Start()
• type SIRIEstimatedTimetableRequestBroadcasterFactory
  • func (factory *SIRIEstimatedTimetableRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIEstimatedTimetableRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIEstimatedTimetableSubscriber
  • func NewSIRIEstimatedTimetableSubscriber(connector *SIRIEstimatedTimetableSubscriptionCollector) SIRIEstimatedTimetableSubscriber
• type SIRIEstimatedTimetableSubscriptionBroadcaster
  • func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) HandleBroadcastEvent(event *model.StopMonitoringBroadcastEvent)
  • func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)
  • func (c *SIRIEstimatedTimetableSubscriptionBroadcaster) Partner() *Partner
  • func (c *SIRIEstimatedTimetableSubscriptionBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) Start()
  • func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) Stop()
  • func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) UseVisitNumber() bool
• type SIRIEstimatedTimetableSubscriptionBroadcasterFactory
  • func (factory *SIRIEstimatedTimetableSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIEstimatedTimetableSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIEstimatedTimetableSubscriptionCollector
  • func NewSIRIEstimatedTimetableSubscriptionCollector(partner *Partner) *SIRIEstimatedTimetableSubscriptionCollector
  • func (connector *SIRIEstimatedTimetableSubscriptionCollector) HandleNotifyEstimatedTimetable(notify *sxml.XMLNotifyEstimatedTimetable) (collectedRefs *CollectedRefs)
  • func (c *SIRIEstimatedTimetableSubscriptionCollector) Partner() *Partner
  • func (c *SIRIEstimatedTimetableSubscriptionCollector) RemoteCodeSpace() string
  • func (connector *SIRIEstimatedTimetableSubscriptionCollector) RequestLineUpdate(request *LineUpdateRequest)
  • func (connector *SIRIEstimatedTimetableSubscriptionCollector) SetEstimatedTimetableSubscriber(estimatedTimetableSubscriber SIRIEstimatedTimetableSubscriber)
  • func (connector *SIRIEstimatedTimetableSubscriptionCollector) Start()
  • func (connector *SIRIEstimatedTimetableSubscriptionCollector) Stop()
• type SIRIEstimatedTimetableSubscriptionCollectorFactory
  • func (factory *SIRIEstimatedTimetableSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIEstimatedTimetableSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRIGeneralMessageBroadcaster
  • func NewFakeGeneralMessageBroadcaster(connector *SIRIGeneralMessageSubscriptionBroadcaster) SIRIGeneralMessageBroadcaster
  • func NewSIRIGeneralMessageBroadcaster(connector *SIRIGeneralMessageSubscriptionBroadcaster) SIRIGeneralMessageBroadcaster
• type SIRIGeneralMessageRequestBroadcaster
  • func NewSIRIGeneralMessageRequestBroadcaster(partner *Partner) *SIRIGeneralMessageRequestBroadcaster
  • func (c *SIRIGeneralMessageRequestBroadcaster) Partner() *Partner
  • func (c *SIRIGeneralMessageRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIGeneralMessageRequestBroadcaster) Situations(request *sxml.XMLGetGeneralMessage, message *audit.BigQueryMessage) (*siri.SIRIGeneralMessageResponse, error)
• type SIRIGeneralMessageRequestBroadcasterFactory
  • func (factory *SIRIGeneralMessageRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIGeneralMessageRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIGeneralMessageRequestCollector
  • func NewSIRIGeneralMessageRequestCollector(partner *Partner) *SIRIGeneralMessageRequestCollector
  • func (c *SIRIGeneralMessageRequestCollector) Partner() *Partner
  • func (c *SIRIGeneralMessageRequestCollector) RemoteCodeSpace() string
  • func (connector *SIRIGeneralMessageRequestCollector) RequestAllSituationsUpdate()
  • func (connector *SIRIGeneralMessageRequestCollector) RequestSituationUpdate(kind, requestedId string)
  • func (connector *SIRIGeneralMessageRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)
• type SIRIGeneralMessageRequestCollectorFactory
  • func (factory *SIRIGeneralMessageRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIGeneralMessageRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRIGeneralMessageSubscriber
  • func NewFakeGeneralMessageSubscriber(connector *SIRIGeneralMessageSubscriptionCollector) SIRIGeneralMessageSubscriber
  • func NewSIRIGeneralMessageSubscriber(connector *SIRIGeneralMessageSubscriptionCollector) SIRIGeneralMessageSubscriber
• type SIRIGeneralMessageSubscriptionBroadcaster
  • func (connector *SIRIGeneralMessageSubscriptionBroadcaster) HandleGeneralMessageBroadcastEvent(event *model.SituationBroadcastEvent)
  • func (connector *SIRIGeneralMessageSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) []siri.SIRIResponseStatus
  • func (c *SIRIGeneralMessageSubscriptionBroadcaster) Partner() *Partner
  • func (c *SIRIGeneralMessageSubscriptionBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIGeneralMessageSubscriptionBroadcaster) Start()
  • func (connector *SIRIGeneralMessageSubscriptionBroadcaster) Stop()
• type SIRIGeneralMessageSubscriptionBroadcasterFactory
  • func (factory *SIRIGeneralMessageSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIGeneralMessageSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIGeneralMessageSubscriptionCollector
  • func NewSIRIGeneralMessageSubscriptionCollector(partner *Partner) *SIRIGeneralMessageSubscriptionCollector
  • func (connector *SIRIGeneralMessageSubscriptionCollector) HandleNotifyGeneralMessage(notify *sxml.XMLNotifyGeneralMessage) (collectedRefs *CollectedRefs)
  • func (c *SIRIGeneralMessageSubscriptionCollector) Partner() *Partner
  • func (c *SIRIGeneralMessageSubscriptionCollector) RemoteCodeSpace() string
  • func (connector *SIRIGeneralMessageSubscriptionCollector) RequestAllSituationsUpdate()
  • func (connector *SIRIGeneralMessageSubscriptionCollector) RequestSituationUpdate(kind string, requestedCode model.Code)
  • func (connector *SIRIGeneralMessageSubscriptionCollector) SetGeneralMessageSubscriber(generalMessageSubscriber SIRIGeneralMessageSubscriber)
  • func (connector *SIRIGeneralMessageSubscriptionCollector) SetSituationUpdateSubscriber(updateSubscriber UpdateSubscriber)
  • func (connector *SIRIGeneralMessageSubscriptionCollector) Start()
  • func (connector *SIRIGeneralMessageSubscriptionCollector) Stop()
• type SIRIGeneralMessageSubscriptionCollectorFactory
  • func (factory *SIRIGeneralMessageSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIGeneralMessageSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRILinesDiscoveryRequestBroadcaster
  • func NewSIRILinesDiscoveryRequestBroadcaster(partner *Partner) *SIRILinesDiscoveryRequestBroadcaster
  • func (connector *SIRILinesDiscoveryRequestBroadcaster) Lines(request *sxml.XMLLinesDiscoveryRequest, message *audit.BigQueryMessage) (*siri.SIRILinesDiscoveryResponse, error)
  • func (c *SIRILinesDiscoveryRequestBroadcaster) Partner() *Partner
  • func (c *SIRILinesDiscoveryRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRILinesDiscoveryRequestBroadcaster) Start()
• type SIRILinesDiscoveryRequestBroadcasterFactory
  • func (factory *SIRILinesDiscoveryRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRILinesDiscoveryRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRILinesDiscoveryRequestCollector
  • func NewSIRILinesDiscoveryRequestCollector(partner *Partner) *SIRILinesDiscoveryRequestCollector
  • func (c *SIRILinesDiscoveryRequestCollector) Partner() *Partner
  • func (c *SIRILinesDiscoveryRequestCollector) RemoteCodeSpace() string
  • func (connector *SIRILinesDiscoveryRequestCollector) RequestLines()
  • func (connector *SIRILinesDiscoveryRequestCollector) SetSubscriber(subscriber UpdateSubscriber)
  • func (connector *SIRILinesDiscoveryRequestCollector) Start()
• type SIRILinesDiscoveryRequestCollectorFactory
  • func (factory *SIRILinesDiscoveryRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRILinesDiscoveryRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRILiteStopMonitoringRequestCollector
  • func NewSIRILiteStopMonitoringRequestCollector(partner *Partner) *SIRILiteStopMonitoringRequestCollector
  • func (c *SIRILiteStopMonitoringRequestCollector) Partner() *Partner
  • func (c *SIRILiteStopMonitoringRequestCollector) RemoteCodeSpace() string
  • func (connector *SIRILiteStopMonitoringRequestCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)
  • func (connector *SIRILiteStopMonitoringRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)
• type SIRILiteStopMonitoringRequestCollectorFactory
  • func (factory *SIRILiteStopMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRILiteStopMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRILiteVehicleMonitoringRequestBroadcaster
  • func NewSIRILiteVehicleMonitoringRequestBroadcaster(partner *Partner) *SIRILiteVehicleMonitoringRequestBroadcaster
  • func (c *SIRILiteVehicleMonitoringRequestBroadcaster) Partner() *Partner
  • func (c *SIRILiteVehicleMonitoringRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRILiteVehicleMonitoringRequestBroadcaster) RequestVehicles(url string, filters url.Values, message *audit.BigQueryMessage) (siriLiteResponse *siri.SiriLiteResponse)
• type SIRILiteVehicleMonitoringRequestBroadcasterFactory
  • func (factory *SIRILiteVehicleMonitoringRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRILiteVehicleMonitoringRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIProductionTimetableBroadcaster
  • func NewFakeProductionTimetableBroadcaster(connector *SIRIProductionTimetableSubscriptionBroadcaster) SIRIProductionTimetableBroadcaster
  • func NewSIRIProductionTimetableBroadcaster(connector *SIRIProductionTimetableSubscriptionBroadcaster) SIRIProductionTimetableBroadcaster
• type SIRIProductionTimetableSubscriptionBroadcaster
  • func (connector *SIRIProductionTimetableSubscriptionBroadcaster) HandleBroadcastEvent(event *model.StopMonitoringBroadcastEvent)
  • func (connector *SIRIProductionTimetableSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)
  • func (c *SIRIProductionTimetableSubscriptionBroadcaster) Partner() *Partner
  • func (c *SIRIProductionTimetableSubscriptionBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIProductionTimetableSubscriptionBroadcaster) Start()
  • func (connector *SIRIProductionTimetableSubscriptionBroadcaster) Stop()
• type SIRIProductionTimetableSubscriptionBroadcasterFactory
  • func (factory *SIRIProductionTimetableSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIProductionTimetableSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIServiceRequestBroadcaster
  • func NewSIRIServiceRequestBroadcaster(partner *Partner) *SIRIServiceRequestBroadcaster
  • func (connector *SIRIServiceRequestBroadcaster) HandleRequests(request *sxml.XMLSiriServiceRequest, message *audit.BigQueryMessage) *siri.SIRIServiceResponse
  • func (c *SIRIServiceRequestBroadcaster) Partner() *Partner
  • func (c *SIRIServiceRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIServiceRequestBroadcaster) Start()
• type SIRIServiceRequestBroadcasterFactory
  • func (factory *SIRIServiceRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIServiceRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRISituationExchangeBroadcaster
  • func NewFakeSituationExchangeBroadcaster(connector *SIRISituationExchangeSubscriptionBroadcaster) SIRISituationExchangeBroadcaster
  • func NewSIRISituationExchangeBroadcaster(connector *SIRISituationExchangeSubscriptionBroadcaster) SIRISituationExchangeBroadcaster
• type SIRISituationExchangeRequestBroadcaster
  • func NewSIRISituationExchangeRequestBroadcaster(partner *Partner) *SIRISituationExchangeRequestBroadcaster
  • func (c *SIRISituationExchangeRequestBroadcaster) Partner() *Partner
  • func (c *SIRISituationExchangeRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRISituationExchangeRequestBroadcaster) Situations(request *sxml.XMLGetSituationExchange, message *audit.BigQueryMessage) *siri.SIRISituationExchangeResponse
  • func (connector *SIRISituationExchangeRequestBroadcaster) Start()
• type SIRISituationExchangeRequestBroadcasterFactory
  • func (factory *SIRISituationExchangeRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRISituationExchangeRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRISituationExchangeRequestCollector
  • func NewSIRISituationExchangeRequestCollector(partner *Partner) *SIRISituationExchangeRequestCollector
  • func (c *SIRISituationExchangeRequestCollector) Partner() *Partner
  • func (c *SIRISituationExchangeRequestCollector) RemoteCodeSpace() string
  • func (connector *SIRISituationExchangeRequestCollector) RequestAllSituationsUpdate()
  • func (connector *SIRISituationExchangeRequestCollector) RequestSituationUpdate(kind, requestedId string)
  • func (connector *SIRISituationExchangeRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)
• type SIRISituationExchangeRequestCollectorFactory
  • func (factory *SIRISituationExchangeRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRISituationExchangeRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRISituationExchangeSubscriber
  • func NewFakeSituationExchangeSubscriber(connector *SIRISituationExchangeSubscriptionCollector) SIRISituationExchangeSubscriber
  • func NewSIRISituationExchangeSubscriber(connector *SIRISituationExchangeSubscriptionCollector) SIRISituationExchangeSubscriber
• type SIRISituationExchangeSubscriptionBroadcaster
  • func (connector *SIRISituationExchangeSubscriptionBroadcaster) HandleSituationExchangeBroadcastEvent(event *model.SituationBroadcastEvent)
  • func (connector *SIRISituationExchangeSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) []siri.SIRIResponseStatus
  • func (c *SIRISituationExchangeSubscriptionBroadcaster) Partner() *Partner
  • func (c *SIRISituationExchangeSubscriptionBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRISituationExchangeSubscriptionBroadcaster) Start()
  • func (connector *SIRISituationExchangeSubscriptionBroadcaster) Stop()
• type SIRISituationExchangeSubscriptionBroadcasterFactory
  • func (factory *SIRISituationExchangeSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRISituationExchangeSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRISituationExchangeSubscriptionCollector
  • func NewSIRISituationExchangeSubscriptionCollector(partner *Partner) *SIRISituationExchangeSubscriptionCollector
  • func (connector *SIRISituationExchangeSubscriptionCollector) HandleNotifySituationExchange(notify *sxml.XMLNotifySituationExchange) (collectedRefs *CollectedRefs)
  • func (c *SIRISituationExchangeSubscriptionCollector) Partner() *Partner
  • func (c *SIRISituationExchangeSubscriptionCollector) RemoteCodeSpace() string
  • func (connector *SIRISituationExchangeSubscriptionCollector) RequestAllSituationsUpdate()
  • func (connector *SIRISituationExchangeSubscriptionCollector) RequestSituationUpdate(kind string, requestedCode model.Code)
  • func (connector *SIRISituationExchangeSubscriptionCollector) SetSituationExchangeSubscriber(situationExchangeSubscriber SIRISituationExchangeSubscriber)
  • func (connector *SIRISituationExchangeSubscriptionCollector) SetSituationUpdateSubscriber(updateSubscriber UpdateSubscriber)
  • func (connector *SIRISituationExchangeSubscriptionCollector) Start()
  • func (connector *SIRISituationExchangeSubscriptionCollector) Stop()
• type SIRISituationExchangeSubscriptionCollectorFactory
  • func (factory *SIRISituationExchangeSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRISituationExchangeSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRIStopMonitoringBroadcaster
  • func NewFakeStopMonitoringBroadcaster(connector *SIRIStopMonitoringSubscriptionBroadcaster) SIRIStopMonitoringBroadcaster
  • func NewSIRIStopMonitoringBroadcaster(connector *SIRIStopMonitoringSubscriptionBroadcaster) SIRIStopMonitoringBroadcaster
• type SIRIStopMonitoringRequestBroadcaster
  • func NewSIRIStopMonitoringRequestBroadcaster(partner *Partner) *SIRIStopMonitoringRequestBroadcaster
  • func (c *SIRIStopMonitoringRequestBroadcaster) Partner() *Partner
  • func (c *SIRIStopMonitoringRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIStopMonitoringRequestBroadcaster) RequestStopArea(request *sxml.XMLGetStopMonitoring, message *audit.BigQueryMessage) *siri.SIRIStopMonitoringResponse
  • func (connector *SIRIStopMonitoringRequestBroadcaster) Start()
• type SIRIStopMonitoringRequestBroadcasterFactory
  • func (factory *SIRIStopMonitoringRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIStopMonitoringRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIStopMonitoringRequestCollector
  • func NewSIRIStopMonitoringRequestCollector(partner *Partner) *SIRIStopMonitoringRequestCollector
  • func (c *SIRIStopMonitoringRequestCollector) Partner() *Partner
  • func (c *SIRIStopMonitoringRequestCollector) RemoteCodeSpace() string
  • func (connector *SIRIStopMonitoringRequestCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)
  • func (connector *SIRIStopMonitoringRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)
  • func (connector *SIRIStopMonitoringRequestCollector) Start()
• type SIRIStopMonitoringRequestCollectorFactory
  • func (factory *SIRIStopMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIStopMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRIStopMonitoringSubscriber
  • func NewFakeStopMonitoringSubscriber(connector *SIRIStopMonitoringSubscriptionCollector) SIRIStopMonitoringSubscriber
  • func NewSIRIStopMonitoringSubscriber(connector *SIRIStopMonitoringSubscriptionCollector) SIRIStopMonitoringSubscriber
• type SIRIStopMonitoringSubscriptionBroadcaster
  • func (connector *SIRIStopMonitoringSubscriptionBroadcaster) HandleStopMonitoringBroadcastEvent(event *model.StopMonitoringBroadcastEvent)
  • func (connector *SIRIStopMonitoringSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)
  • func (c *SIRIStopMonitoringSubscriptionBroadcaster) Partner() *Partner
  • func (c *SIRIStopMonitoringSubscriptionBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIStopMonitoringSubscriptionBroadcaster) Start()
  • func (connector *SIRIStopMonitoringSubscriptionBroadcaster) Stop()
• type SIRIStopMonitoringSubscriptionBroadcasterFactory
  • func (factory *SIRIStopMonitoringSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIStopMonitoringSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIStopMonitoringSubscriptionCollector
  • func NewSIRIStopMonitoringSubscriptionCollector(partner *Partner) *SIRIStopMonitoringSubscriptionCollector
  • func (connector *SIRIStopMonitoringSubscriptionCollector) HandleNotifyStopMonitoring(notify *sxml.XMLNotifyStopMonitoring) (collectedRefs *CollectedRefs)
  • func (c *SIRIStopMonitoringSubscriptionCollector) Partner() *Partner
  • func (c *SIRIStopMonitoringSubscriptionCollector) RemoteCodeSpace() string
  • func (connector *SIRIStopMonitoringSubscriptionCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)
  • func (connector *SIRIStopMonitoringSubscriptionCollector) SetStopMonitoringSubscriber(stopMonitoringSubscriber SIRIStopMonitoringSubscriber)
  • func (connector *SIRIStopMonitoringSubscriptionCollector) Start()
  • func (connector *SIRIStopMonitoringSubscriptionCollector) Stop()
• type SIRIStopMonitoringSubscriptionCollectorFactory
  • func (factory *SIRIStopMonitoringSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIStopMonitoringSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRIStopPointsDiscoveryRequestBroadcaster
  • func NewSIRIStopDiscoveryRequestBroadcaster(partner *Partner) *SIRIStopPointsDiscoveryRequestBroadcaster
  • func (c *SIRIStopPointsDiscoveryRequestBroadcaster) Partner() *Partner
  • func (c *SIRIStopPointsDiscoveryRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIStopPointsDiscoveryRequestBroadcaster) Start()
  • func (connector *SIRIStopPointsDiscoveryRequestBroadcaster) StopAreas(request *sxml.XMLStopPointsDiscoveryRequest, message *audit.BigQueryMessage) (*siri.SIRIStopPointsDiscoveryResponse, error)
• type SIRIStopPointsDiscoveryRequestBroadcasterFactory
  • func (factory *SIRIStopPointsDiscoveryRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIStopPointsDiscoveryRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIStopPointsDiscoveryRequestCollector
  • func NewSIRIStopPointsDiscoveryRequestCollector(partner *Partner) *SIRIStopPointsDiscoveryRequestCollector
  • func (c *SIRIStopPointsDiscoveryRequestCollector) Partner() *Partner
  • func (c *SIRIStopPointsDiscoveryRequestCollector) RemoteCodeSpace() string
  • func (connector *SIRIStopPointsDiscoveryRequestCollector) RequestStopPoints()
  • func (connector *SIRIStopPointsDiscoveryRequestCollector) SetSubscriber(subscriber UpdateSubscriber)
  • func (connector *SIRIStopPointsDiscoveryRequestCollector) Start()
• type SIRIStopPointsDiscoveryRequestCollectorFactory
  • func (factory *SIRIStopPointsDiscoveryRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIStopPointsDiscoveryRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRISubscriptionRequestDispatcher
  • func NewSIRISubscriptionRequestDispatcher(partner *Partner) *SIRISubscriptionRequestDispatcher
  • func (connector *SIRISubscriptionRequestDispatcher) CancelSubscription(r *sxml.XMLDeleteSubscriptionRequest, message *audit.BigQueryMessage) *siri.SIRIDeleteSubscriptionResponse
  • func (connector *SIRISubscriptionRequestDispatcher) Dispatch(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (*siri.SIRISubscriptionResponse, error)
  • func (connector *SIRISubscriptionRequestDispatcher) HandleNotifySubscriptionTerminated(r *sxml.XMLNotifySubscriptionTerminated)
  • func (connector *SIRISubscriptionRequestDispatcher) HandleSubscriptionTerminatedNotification(r *sxml.XMLSubscriptionTerminatedNotification)
  • func (c *SIRISubscriptionRequestDispatcher) Partner() *Partner
  • func (c *SIRISubscriptionRequestDispatcher) RemoteCodeSpace() string
• type SIRISubscriptionRequestDispatcherFactory
  • func (factory *SIRISubscriptionRequestDispatcherFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRISubscriptionRequestDispatcherFactory) Validate(apiPartner *APIPartner)
• type SIRIVehicleMonitoringBroadcaster
  • func (vm *SIRIVehicleMonitoringBroadcaster) Start()
  • func (vm *SIRIVehicleMonitoringBroadcaster) Stop()
• type SIRIVehicleMonitoringRequestBroadcaster
  • func NewSIRIVehicleMonitoringRequestBroadcaster(partner *Partner) *SIRIVehicleMonitoringRequestBroadcaster
  • func (c *SIRIVehicleMonitoringRequestBroadcaster) Partner() *Partner
  • func (c *SIRIVehicleMonitoringRequestBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIVehicleMonitoringRequestBroadcaster) RequestVehicles(request *sxml.XMLGetVehicleMonitoring, message *audit.BigQueryMessage) (siriResponse *siri.SIRIVehicleMonitoringResponse)
  • func (connector *SIRIVehicleMonitoringRequestBroadcaster) Start()
• type SIRIVehicleMonitoringRequestBroadcasterFactory
  • func (factory *SIRIVehicleMonitoringRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIVehicleMonitoringRequestBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIVehicleMonitoringRequestCollector
  • func NewSIRIVehicleMonitoringRequestCollector(partner *Partner) *SIRIVehicleMonitoringRequestCollector
  • func (c *SIRIVehicleMonitoringRequestCollector) Partner() *Partner
  • func (c *SIRIVehicleMonitoringRequestCollector) RemoteCodeSpace() string
  • func (connector *SIRIVehicleMonitoringRequestCollector) RequestVehicleUpdate(request *VehicleUpdateRequest)
  • func (connector *SIRIVehicleMonitoringRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)
  • func (connector *SIRIVehicleMonitoringRequestCollector) Start()
• type SIRIVehicleMonitoringRequestCollectorFactory
  • func (factory *SIRIVehicleMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIVehicleMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type SIRIVehicleMonitoringSubscriber
  • func NewFakeVehicleMonitoringSubscriber(connector *SIRIVehicleMonitoringSubscriptionCollector) SIRIVehicleMonitoringSubscriber
  • func NewSIRIVehicleMonitoringSubscriber(connector *SIRIVehicleMonitoringSubscriptionCollector) SIRIVehicleMonitoringSubscriber
• type SIRIVehicleMonitoringSubscriptionBroadcaster
  • func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) HandleBroadcastEvent(event *model.VehicleBroadcastEvent)
  • func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)
  • func (c *SIRIVehicleMonitoringSubscriptionBroadcaster) Partner() *Partner
  • func (c *SIRIVehicleMonitoringSubscriptionBroadcaster) RemoteCodeSpace() string
  • func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) Start()
  • func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) Stop()
• type SIRIVehicleMonitoringSubscriptionBroadcasterFactory
  • func (factory *SIRIVehicleMonitoringSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIVehicleMonitoringSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type SIRIVehicleMonitoringSubscriptionCollector
  • func NewSIRIVehicleMonitoringSubscriptionCollector(partner *Partner) *SIRIVehicleMonitoringSubscriptionCollector
  • func (connector *SIRIVehicleMonitoringSubscriptionCollector) HandleNotifyVehicleMonitoring(notify *sxml.XMLNotifyVehicleMonitoring) (collectedRefs *CollectedRefs)
  • func (c *SIRIVehicleMonitoringSubscriptionCollector) Partner() *Partner
  • func (c *SIRIVehicleMonitoringSubscriptionCollector) RemoteCodeSpace() string
  • func (connector *SIRIVehicleMonitoringSubscriptionCollector) RequestVehicleUpdate(request *VehicleUpdateRequest)
  • func (connector *SIRIVehicleMonitoringSubscriptionCollector) SetVehicleMonitoringSubscriber(vehicleMonitoringSubscriber SIRIVehicleMonitoringSubscriber)
  • func (connector *SIRIVehicleMonitoringSubscriptionCollector) Start()
  • func (connector *SIRIVehicleMonitoringSubscriptionCollector) Stop()
• type SIRIVehicleMonitoringSubscriptionCollectorFactory
  • func (factory *SIRIVehicleMonitoringSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *SIRIVehicleMonitoringSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)
• type SMBroadcaster
• type SMSubscriber
• type SXBroadcaster
• type SXSubscriber
• type ServiceAlertsBroadcaster
  • func NewServiceAlertsBroadcaster(partner *Partner) *ServiceAlertsBroadcaster
  • func (connector *ServiceAlertsBroadcaster) HandleGtfs(feed *gtfs.FeedMessage)
  • func (c *ServiceAlertsBroadcaster) Partner() *Partner
  • func (c *ServiceAlertsBroadcaster) RemoteCodeSpace() string
  • func (connector *ServiceAlertsBroadcaster) Start()
• type ServiceAlertsBroadcasterFactory
  • func (factory *ServiceAlertsBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *ServiceAlertsBroadcasterFactory) Validate(apiPartner *APIPartner)
• type ServiceRequestBroadcaster
• type SituationExchangeBroadcaster
  • func (sxb *SituationExchangeBroadcaster) Start()
  • func (sxb *SituationExchangeBroadcaster) Stop()
• type SituationExchangeRequestBroadcaster
• type SituationExchangeRequestCollector
• type SituationExchangeSubscriber
  • func (subscriber *SituationExchangeSubscriber) Start()
  • func (subscriber *SituationExchangeSubscriber) Stop()
• type SituationExchangeSubscriptionCollector
• type SituationExchangeUpdateEventBuilder
  • func NewSituationExchangeUpdateEventBuilder(partner *Partner) SituationExchangeUpdateEventBuilder
  • func (builder *SituationExchangeUpdateEventBuilder) SetSituationExchangeDeliveryUpdateEvents(events *CollectUpdateEvents, ...)
  • func (builder *SituationExchangeUpdateEventBuilder) SetSituationExchangeUpdateEvents(event *CollectUpdateEvents, xmlResponse *sxml.XMLSituationExchangeResponse)
• type SituationUpdateRequest
  • func NewSituationUpdateRequest(kind, requestedId string) *SituationUpdateRequest
  • func (situationUpdateRequest *SituationUpdateRequest) CreatedAt() time.Time
  • func (situationUpdateRequest *SituationUpdateRequest) Kind() string
  • func (situationUpdateRequest *SituationUpdateRequest) RequestedId() string
• type SituationUpdateRequestId
• type StopAreaLogger
  • func NewStopAreaLogger(referential *Referential, stopArea *model.StopArea) *StopAreaLogger
  • func (stopAreaLogger *StopAreaLogger) IsVerbose() bool
  • func (stopAreaLogger *StopAreaLogger) Printf(format string, values ...interface{})
• type StopAreaUpdateRequest
  • func NewStopAreaUpdateRequest(stopAreaId model.StopAreaId) *StopAreaUpdateRequest
  • func (stopAreaUpdateRequest *StopAreaUpdateRequest) CreatedAt() time.Time
  • func (stopAreaUpdateRequest *StopAreaUpdateRequest) StopAreaId() model.StopAreaId
• type StopMonitoringBroadcaster
  • func (smb *StopMonitoringBroadcaster) Start()
  • func (smb *StopMonitoringBroadcaster) Stop()
• type StopMonitoringRequestBroadcaster
• type StopMonitoringRequestCollector
• type StopMonitoringSubscriber
  • func (subscriber *StopMonitoringSubscriber) Start()
  • func (subscriber *StopMonitoringSubscriber) Stop()
• type StopMonitoringSubscriptionCollector
• type StopMonitoringUpdateEventBuilder
  • func NewStopMonitoringUpdateEventBuilder(partner *Partner, originStopAreaCode model.Code) StopMonitoringUpdateEventBuilder
  • func (builder *StopMonitoringUpdateEventBuilder) SetStopVisitCancellationEvents(delivery *sxml.XMLNotifyStopMonitoringDelivery)
  • func (builder *StopMonitoringUpdateEventBuilder) SetUpdateEvents(stopVisits []*sxml.XMLMonitoredStopVisit)
  • func (builder *StopMonitoringUpdateEventBuilder) UpdateEvents() CollectUpdateEvents
• type StopPointsDiscoveryRequestCollector
• type SubscribedResource
  • func NewResource(ref model.Reference) *SubscribedResource
  • func (sr *SubscribedResource) LastState(state string) (l ls.LastState, ok bool)
  • func (sr *SubscribedResource) MarshalJSON() ([]byte, error)
  • func (sr *SubscribedResource) ResourcesOptions() map[string]string
  • func (sr *SubscribedResource) SetLastState(s string, l ls.LastState)
  • func (sr *SubscribedResource) Subscribed(t time.Time)
  • func (sr *SubscribedResource) SubscribedAt() time.Time
• type Subscription
  • func (subscription *Subscription) AddNewResource(resource *SubscribedResource)
  • func (subscription *Subscription) CreateAndAddNewResource(reference model.Reference) *SubscribedResource
  • func (subscription *Subscription) Delete() (ok bool)
  • func (subscription *Subscription) DeleteResource(key string)
  • func (subscription *Subscription) ExternalId() string
  • func (subscription *Subscription) Id() SubscriptionId
  • func (subscription *Subscription) Kind() string
  • func (subscription *Subscription) MarshalJSON() ([]byte, error)
  • func (subscription *Subscription) Resource(obj model.Code) *SubscribedResource
  • func (subscription *Subscription) Resources(now time.Time) (ressources []*SubscribedResource)
  • func (subscription *Subscription) ResourcesByCodeCopy() map[string]*SubscribedResource
  • func (subscription *Subscription) ResourcesLen() (i int)
  • func (subscription *Subscription) Save() (ok bool)
  • func (subscription *Subscription) SetDefinition(apisub *APISubscription)
  • func (subscription *Subscription) SetExternalId(externalId string)
  • func (subscription *Subscription) SetKind(kind string)
  • func (subscription *Subscription) SetSubscriptionOption(key, value string)
  • func (subscription *Subscription) SubscriptionOption(key string) (o string)
  • func (subscription *Subscription) UniqueResource() (r *SubscribedResource)
• type SubscriptionId
• type SubscriptionRequestDispatcher
• type Subscriptions
• type TestCheckStatusClient
  • func NewTestCheckStatusClient() *TestCheckStatusClient
  • func (c *TestCheckStatusClient) Partner() *Partner
  • func (c *TestCheckStatusClient) RemoteCodeSpace() string
  • func (connector *TestCheckStatusClient) SetStatus(status OperationnalStatus)
  • func (connector *TestCheckStatusClient) Status() (PartnerStatus, error)
• type TestCheckStatusClientFactory
  • func (factory *TestCheckStatusClientFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestCheckStatusClientFactory) Validate(apiPartner *APIPartner)
• type TestCollectManager
  • func (manager *TestCollectManager) BroadcastUpdateEvent(event model.UpdateEvent)
  • func (manager *TestCollectManager) HandlePartnerStatusChange(partner string, status bool)
  • func (manager *TestCollectManager) HandleUpdateEvent(UpdateSubscriber)
  • func (manager *TestCollectManager) TestUpdateSubscriber(event model.UpdateEvent)
  • func (manager *TestCollectManager) UpdateLine(context.Context, *LineUpdateRequest)
  • func (manager *TestCollectManager) UpdateSituation(*SituationUpdateRequest)
  • func (manager *TestCollectManager) UpdateStopArea(request *StopAreaUpdateRequest)
  • func (manager *TestCollectManager) UpdateVehicle(context.Context, *VehicleUpdateRequest)
• type TestETTSubscriptionBroadcaster
  • func NewTestETTSubscriptionBroadcaster() *TestETTSubscriptionBroadcaster
  • func (connector *TestETTSubscriptionBroadcaster) HandleBroadcastEvent(event *model.StopMonitoringBroadcastEvent)
  • func (c *TestETTSubscriptionBroadcaster) Partner() *Partner
  • func (c *TestETTSubscriptionBroadcaster) RemoteCodeSpace() string
• type TestGeneralMessageSubscriptionBroadcaster
  • func NewTestGeneralMessageSubscriptionBroadcaster() *TestGeneralMessageSubscriptionBroadcaster
  • func (connector *TestGeneralMessageSubscriptionBroadcaster) HandleGeneralMessageBroadcastEvent(event *model.SituationBroadcastEvent)
  • func (c *TestGeneralMessageSubscriptionBroadcaster) Partner() *Partner
  • func (c *TestGeneralMessageSubscriptionBroadcaster) RemoteCodeSpace() string
• type TestSIRIETTSubscriptionBroadcasterFactory
  • func (factory *TestSIRIETTSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestSIRIETTSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type TestSIRIGeneralMessageSubscriptionBroadcasterFactory
  • func (factory *TestSIRIGeneralMessageSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestSIRIGeneralMessageSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type TestSIRIStopMonitoringSubscriptionBroadcasterFactory
  • func (factory *TestSIRIStopMonitoringSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestSIRIStopMonitoringSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type TestSIRIVMSubscriptionBroadcasterFactory
  • func (factory *TestSIRIVMSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestSIRIVMSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type TestStartableConnector
  • func (c *TestStartableConnector) Partner() *Partner
  • func (c *TestStartableConnector) RemoteCodeSpace() string
  • func (connector *TestStartableConnector) Start()
  • func (connector *TestStartableConnector) Stop()
• type TestStartableFactory
  • func (factory *TestStartableFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestStartableFactory) Validate(apiPartner *APIPartner)
• type TestStopMonitoringRequestCollector
  • func NewTestStopMonitoringRequestCollector() *TestStopMonitoringRequestCollector
  • func (c *TestStopMonitoringRequestCollector) Partner() *Partner
  • func (c *TestStopMonitoringRequestCollector) RemoteCodeSpace() string
  • func (connector *TestStopMonitoringRequestCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)
• type TestStopMonitoringRequestCollectorFactory
  • func (factory *TestStopMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestStopMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)
• type TestStopMonitoringSubscriptionBroadcaster
  • func NewTestStopMonitoringSubscriptionBroadcaster() *TestStopMonitoringSubscriptionBroadcaster
  • func (connector *TestStopMonitoringSubscriptionBroadcaster) HandleStopMonitoringBroadcastEvent(event *model.StopMonitoringBroadcastEvent)
  • func (c *TestStopMonitoringSubscriptionBroadcaster) Partner() *Partner
  • func (c *TestStopMonitoringSubscriptionBroadcaster) RemoteCodeSpace() string
• type TestVMSubscriptionBroadcaster
  • func NewTestVMSubscriptionBroadcaster() *TestVMSubscriptionBroadcaster
  • func (connector *TestVMSubscriptionBroadcaster) HandleBroadcastEvent(event *model.VehicleBroadcastEvent)
  • func (c *TestVMSubscriptionBroadcaster) Partner() *Partner
  • func (c *TestVMSubscriptionBroadcaster) RemoteCodeSpace() string
• type TestValidationConnector
  • func (c *TestValidationConnector) Partner() *Partner
  • func (c *TestValidationConnector) RemoteCodeSpace() string
• type TestValidationFactory
  • func (factory *TestValidationFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TestValidationFactory) Validate(apiPartner *APIPartner)
• type TripUpdatesBroadcaster
  • func NewTripUpdatesBroadcaster(partner *Partner) *TripUpdatesBroadcaster
  • func (connector *TripUpdatesBroadcaster) HandleGtfs(feed *gtfs.FeedMessage)
  • func (c *TripUpdatesBroadcaster) Partner() *Partner
  • func (c *TripUpdatesBroadcaster) RemoteCodeSpace() string
  • func (connector *TripUpdatesBroadcaster) Start()
• type TripUpdatesBroadcasterFactory
  • func (factory *TripUpdatesBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *TripUpdatesBroadcasterFactory) Validate(apiPartner *APIPartner)
• type UpdateSubscriber
• type VMBroadcaster
• type VMSubscriber
• type VehicleMonitoringBroadcaster
  • func NewFakeSIRIVehicleMonitoringBroadcaster(connector *SIRIVehicleMonitoringSubscriptionBroadcaster) VehicleMonitoringBroadcaster
  • func NewSIRIVehicleMonitoringBroadcaster(connector *SIRIVehicleMonitoringSubscriptionBroadcaster) VehicleMonitoringBroadcaster
• type VehicleMonitoringLiteRequestBroadcaster
• type VehicleMonitoringRequestBroadcaster
• type VehicleMonitoringRequestCollector
• type VehicleMonitoringSubscriber
  • func (subscriber *VehicleMonitoringSubscriber) Start()
  • func (subscriber *VehicleMonitoringSubscriber) Stop()
• type VehicleMonitoringSubscriptionCollector
• type VehicleMonitoringUpdateEventBuilder
  • func NewVehicleMonitoringUpdateEventBuilder(partner *Partner) VehicleMonitoringUpdateEventBuilder
  • func (builder *VehicleMonitoringUpdateEventBuilder) SetUpdateEvents(activities []*sxml.XMLVehicleActivity)
  • func (builder *VehicleMonitoringUpdateEventBuilder) UpdateEvents() VehicleMonitoringUpdateEvents
• type VehicleMonitoringUpdateEvents
  • func (events VehicleMonitoringUpdateEvents) GetLines() []string
  • func (events VehicleMonitoringUpdateEvents) GetStopAreas() []string
  • func (events VehicleMonitoringUpdateEvents) GetVehicleJourneys() []string
  • func (events VehicleMonitoringUpdateEvents) GetVehicles() []string
• type VehiclePositionBroadcaster
  • func NewVehiclePositionBroadcaster(partner *Partner) *VehiclePositionBroadcaster
  • func (connector *VehiclePositionBroadcaster) HandleGtfs(feed *gtfs.FeedMessage)
  • func (c *VehiclePositionBroadcaster) Partner() *Partner
  • func (c *VehiclePositionBroadcaster) RemoteCodeSpace() string
  • func (connector *VehiclePositionBroadcaster) Start()
• type VehiclePositionBroadcasterFactory
  • func (factory *VehiclePositionBroadcasterFactory) CreateConnector(partner *Partner) Connector
  • func (factory *VehiclePositionBroadcasterFactory) Validate(apiPartner *APIPartner)
• type VehicleUpdateRequest
  • func NewVehicleUpdateRequest(lineId model.LineId) *VehicleUpdateRequest
  • func (vehicleUpdateRequest *VehicleUpdateRequest) CreatedAt() time.Time
  • func (vehicleUpdateRequest *VehicleUpdateRequest) LineId() model.LineId

Constants

const (
	SIRI_PARTNER = "siri-partner"

	// Connectors
	PUSH_COLLECTOR                                 = "push-collector"
	SIRI_STOP_POINTS_DISCOVERY_REQUEST_COLLECTOR   = "siri-stop-points-discovery-request-collector"
	SIRI_STOP_POINTS_DISCOVERY_REQUEST_BROADCASTER = "siri-stop-points-discovery-request-broadcaster"
	SIRI_LINES_DISCOVERY_REQUEST_COLLECTOR         = "siri-lines-discovery-request-collector"
	SIRI_LINES_DISCOVERY_REQUEST_BROADCASTER       = "siri-lines-discovery-request-broadcaster"
	SIRI_SERVICE_REQUEST_BROADCASTER               = "siri-service-request-broadcaster"
	SIRI_STOP_MONITORING_REQUEST_COLLECTOR         = "siri-stop-monitoring-request-collector"
	SIRI_LITE_STOP_MONITORING_REQUEST_COLLECTOR    = "siri-lite-stop-monitoring-request-collector"
	TEST_STOP_MONITORING_REQUEST_COLLECTOR         = "test-stop-monitoring-request-collector"
	SIRI_STOP_MONITORING_REQUEST_BROADCASTER       = "siri-stop-monitoring-request-broadcaster"
	SIRI_STOP_MONITORING_SUBSCRIPTION_COLLECTOR    = "siri-stop-monitoring-subscription-collector"
	SIRI_STOP_MONITORING_SUBSCRIPTION_BROADCASTER  = "siri-stop-monitoring-subscription-broadcaster"
	TEST_STOP_MONITORING_SUBSCRIPTION_BROADCASTER  = "siri-stop-monitoring-subscription-broadcaster-test"
	SIRI_GENERAL_MESSAGE_REQUEST_COLLECTOR         = "siri-general-message-request-collector"
	SIRI_GENERAL_MESSAGE_REQUEST_BROADCASTER       = "siri-general-message-request-broadcaster"
	SIRI_GENERAL_MESSAGE_SUBSCRIPTION_COLLECTOR    = "siri-general-message-subscription-collector"
	SIRI_GENERAL_MESSAGE_SUBSCRIPTION_BROADCASTER  = "siri-general-message-subscription-broadcaster"
	TEST_GENERAL_MESSAGE_SUBSCRIPTION_BROADCASTER  = "siri-general-message-subscription-broadcaster-test"
	// SIRI_ESTIMATED_TIMETABLE_REQUEST_COLLECTOR        = "siri-estimated-timetable-request-collector"
	SIRI_ESTIMATED_TIMETABLE_REQUEST_BROADCASTER      = "siri-estimated-timetable-request-broadcaster"
	SIRI_ESTIMATED_TIMETABLE_SUBSCRIPTION_COLLECTOR   = "siri-estimated-timetable-subscription-collector"
	SIRI_ESTIMATED_TIMETABLE_SUBSCRIPTION_BROADCASTER = "siri-estimated-timetable-subscription-broadcaster"
	TEST_ESTIMATED_TIMETABLE_SUBSCRIPTION_BROADCASTER = "siri-estimated-timetable-subscription-broadcaster-test"
	// SIRI_PRODUCTION_TIMETABLE_REQUEST_BROADCASTER      = "siri-production-timetable-request-broadcaster"
	SIRI_PRODUCTION_TIMETABLE_SUBSCRIPTION_BROADCASTER = "siri-production-timetable-subscription-broadcaster"
	SIRI_SITUATION_EXCHANGE_REQUEST_BROADCASTER        = "siri-situation-exchange-request-broadcaster"
	SIRI_SITUATION_EXCHANGE_REQUEST_COLLECTOR          = "siri-situation-exchange-request-collector"
	SIRI_SITUATION_EXCHANGE_SUBSCRIPTION_COLLECTOR     = "siri-situation-exchange-subscription-collector"
	SIRI_SITUATION_EXCHANGE_SUBSCRIPTION_BROADCASTER   = "siri-situation-exchange-subscription-broadcaster"
	SIRI_VEHICLE_MONITORING_REQUEST_COLLECTOR          = "siri-vehicle-monitoring-request-collector"
	SIRI_VEHICLE_MONITORING_SUBSCRIPTION_COLLECTOR     = "siri-vehicle-monitoring-subscription-collector"
	SIRI_SUBSCRIPTION_REQUEST_DISPATCHER               = "siri-subscription-request-dispatcher"
	SIRI_CHECK_STATUS_CLIENT_TYPE                      = "siri-check-status-client"
	TEST_CHECK_STATUS_CLIENT_TYPE                      = "test-check-status-client"
	SIRI_CHECK_STATUS_SERVER_TYPE                      = "siri-check-status-server"
	SIRI_LITE_VEHICLE_MONITORING_REQUEST_BROADCASTER   = "siri-lite-vehicle-monitoring-request-broadcaster"
	SIRI_VEHICLE_MONITORING_REQUEST_BROADCASTER        = "siri-vehicle-monitoring-request-broadcaster"
	SIRI_VEHICLE_MONITORING_SUBSCRIPTION_BROADCASTER   = "siri-vehicle-monitoring-subscription-broadcaster"
	TEST_VEHICLE_MONITORING_SUBSCRIPTION_BROADCASTER   = "siri-vehicle-monitoring-subscription-broadcaster-test"
	TEST_VALIDATION_CONNECTOR                          = "test-validation-connector"
	TEST_STARTABLE_CONNECTOR                           = "test-startable-connector-connector"
	GTFS_RT_REQUEST_COLLECTOR                          = "gtfs-rt-request-collector"
	GTFS_RT_SERVICE_ALERTS_BROADCASTER                 = "gtfs-rt-service-alerts-broadcaster"
	GTFS_RT_TRIP_UPDATES_BROADCASTER                   = "gtfs-rt-trip-updates-broadcaster"
	GTFS_RT_VEHICLE_POSITIONS_BROADCASTER              = "gtfs-rt-vehicle-positions-broadcaster"
	GRAPHQL_SERVER                                     = "graphql-server"
)

const (
	SITUATION_UPDATE_REQUEST_ALL       = "requestAll"
	SITUATION_UPDATE_REQUEST_LINE      = "requestLine"
	SITUATION_UPDATE_REQUEST_STOP_AREA = "requestStopArea"
)

const (
	EstimatedTimetableBroadcast  = "EstimatedTimetableBroadcast"
	GeneralMessageBroadcast      = "GeneralMessageBroadcast"
	ProductionTimetableBroadcast = "ProductionTimetableBroadcast"
	SituationExchangeBroadcast   = "SituationExchangeBroadcast"
	StopMonitoringBroadcast      = "StopMonitoringBroadcast"
	VehicleMonitoringBroadcast   = "VehicleMonitoringBroadcast"

	EstimatedTimetableCollect = "EstimatedTimetableCollect"
	GeneralMessageCollect     = "GeneralMessageCollect"
	SituationExchangeCollect  = "SituationExchangeCollect"
	StopMonitoringCollect     = "StopMonitoringCollect"
	VehicleMonitoringCollect  = "VehicleMonitoringCollect"
)

const (
	DELETED_SUBSCRIPTION_TIMER = 5 * time.Minute
)

const (
	PAST_STOP_VISITS_MAX_TIME = -2 * time.Minute
)

Functions

func CancelSubscription

func CancelSubscription(subId, kind string, connector Connector)

func GetModelReferenceSlice

func GetModelReferenceSlice(refs map[string]struct{}) []string

Types

type APIPartner

type APIPartner struct {
	Id             PartnerId `json:"Id,omitempty"`
	Slug           PartnerSlug
	Name           string            `json:"Name,omitempty"`
	Settings       map[string]string `json:"Settings,omitempty"`
	ConnectorTypes []string          `json:"ConnectorTypes,omitempty"`
	Errors         e.Errors          `json:"Errors,omitempty"`
	// contains filtered or unexported fields
}

func (*APIPartner) IsSettingDefined

func (partner *APIPartner) IsSettingDefined(setting string) (ok bool)

func (*APIPartner) UnmarshalJSON

func (partner *APIPartner) UnmarshalJSON(data []byte) error

func (*APIPartner) Validate

func (partner *APIPartner) Validate() bool

func (*APIPartner) ValidatePresenceOfConnector

func (partner *APIPartner) ValidatePresenceOfConnector(connector string) bool

func (*APIPartner) ValidatePresenceOfLightRemoteCredentials

func (partner *APIPartner) ValidatePresenceOfLightRemoteCredentials() bool

func (*APIPartner) ValidatePresenceOfLocalCredentials

func (partner *APIPartner) ValidatePresenceOfLocalCredentials() bool

func (*APIPartner) ValidatePresenceOfRemoteCodeSpace

func (partner *APIPartner) ValidatePresenceOfRemoteCodeSpace() bool

func (*APIPartner) ValidatePresenceOfRemoteCredentials

func (partner *APIPartner) ValidatePresenceOfRemoteCredentials() bool

func (*APIPartner) ValidatePresenceOfSetting

func (partner *APIPartner) ValidatePresenceOfSetting(setting string) bool

type APIReferential

type APIReferential struct {
	OrganisationId string            `json:",omitempty"`
	Slug           ReferentialSlug   `json:"Slug,omitempty"`
	Name           string            `json:",omitempty"`
	Errors         e.Errors          `json:"Errors,omitempty"`
	Settings       map[string]string `json:"Settings,omitempty"`
	Tokens         []string          `json:"Tokens,omitempty"`
	ImportTokens   []string          `json:"ImportTokens,omitempty"`
	// contains filtered or unexported fields
}

func (*APIReferential) Id

func (referential *APIReferential) Id() ReferentialId

func (*APIReferential) UnmarshalJSON

func (apiReferential *APIReferential) UnmarshalJSON(data []byte) error

func (*APIReferential) Validate

func (referential *APIReferential) Validate() bool

type APISubscription

type APISubscription struct {
	ExternalId            string
	Kind                  string
	SubscriberRef         string
	SubscribeResourcesNow bool

	References []model.Reference
}

type ActualAttributesSimulator

type ActualAttributesSimulator struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

func NewActualAttributesSimulator

func NewActualAttributesSimulator(stopVisit *model.StopVisit) *ActualAttributesSimulator

func (*ActualAttributesSimulator) AfterArrivalTime

func (simulator *ActualAttributesSimulator) AfterArrivalTime() bool

func (*ActualAttributesSimulator) AfterDepartureTime

func (simulator *ActualAttributesSimulator) AfterDepartureTime() bool

func (*ActualAttributesSimulator) ArrivalTime

func (simulator *ActualAttributesSimulator) ArrivalTime() time.Time

func (*ActualAttributesSimulator) CanArrive

func (simulator *ActualAttributesSimulator) CanArrive() bool

func (*ActualAttributesSimulator) CanDepart

func (simulator *ActualAttributesSimulator) CanDepart() bool

func (*ActualAttributesSimulator) DepartureTime

func (simulator *ActualAttributesSimulator) DepartureTime() time.Time

func (*ActualAttributesSimulator) Now

func (simulator *ActualAttributesSimulator) Now() time.Time

func (*ActualAttributesSimulator) Simulate

func (simulator *ActualAttributesSimulator) Simulate() bool

type BroadcastGeneralMessageBuilder

type BroadcastGeneralMessageBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer

	InfoChannelRef []string
	// contains filtered or unexported fields
}

func NewBroadcastGeneralMessageBuilder

func NewBroadcastGeneralMessageBuilder(partner *Partner, connector string) *BroadcastGeneralMessageBuilder

func (*BroadcastGeneralMessageBuilder) BuildGeneralMessage

func (builder *BroadcastGeneralMessageBuilder) BuildGeneralMessage(situation model.Situation) *siri.SIRIGeneralMessage

func (*BroadcastGeneralMessageBuilder) BuildGeneralMessageCancellation

func (builder *BroadcastGeneralMessageBuilder) BuildGeneralMessageCancellation(situation model.Situation) *siri.SIRIGeneralMessageCancellation

func (*BroadcastGeneralMessageBuilder) SetLineRef

func (builder *BroadcastGeneralMessageBuilder) SetLineRef(lineRef []string)

func (*BroadcastGeneralMessageBuilder) SetStopPointRef

func (builder *BroadcastGeneralMessageBuilder) SetStopPointRef(stopPointRef []string)

type BroadcastManager

type BroadcastManager struct {
	Referential *Referential
	// contains filtered or unexported fields
}

func NewBroadcastManager

func NewBroadcastManager(referential *Referential) *BroadcastManager

func (*BroadcastManager) GetGeneralMessageBroadcastEventChan

func (manager *BroadcastManager) GetGeneralMessageBroadcastEventChan() chan model.SituationBroadcastEvent

func (*BroadcastManager) GetSituationExchangeBroadcastEventChan

func (manager *BroadcastManager) GetSituationExchangeBroadcastEventChan() chan model.SituationBroadcastEvent

func (*BroadcastManager) GetStopMonitoringBroadcastEventChan

func (manager *BroadcastManager) GetStopMonitoringBroadcastEventChan() chan model.StopMonitoringBroadcastEvent

func (*BroadcastManager) GetVehicleBroadcastEventChan

func (manager *BroadcastManager) GetVehicleBroadcastEventChan() chan model.VehicleBroadcastEvent

func (*BroadcastManager) Start

func (manager *BroadcastManager) Start()

func (*BroadcastManager) Stop

func (manager *BroadcastManager) Stop()

type BroadcastManagerInterface

type BroadcastManagerInterface interface {
	state.Startable
	state.Stopable

	GetStopMonitoringBroadcastEventChan() chan model.StopMonitoringBroadcastEvent
	GetGeneralMessageBroadcastEventChan() chan model.SituationBroadcastEvent
	GetSituationExchangeBroadcastEventChan() chan model.SituationBroadcastEvent
	GetVehicleBroadcastEventChan() chan model.VehicleBroadcastEvent
}

type BroadcastSituationExchangeBuilder

type BroadcastSituationExchangeBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewBroadcastSituationExchangeBuilder

func NewBroadcastSituationExchangeBuilder(partner *Partner, connector string) *BroadcastSituationExchangeBuilder

func (*BroadcastSituationExchangeBuilder) BuildSituationExchange

func (builder *BroadcastSituationExchangeBuilder) BuildSituationExchange(situation model.Situation, delivery *siri.SIRISituationExchangeDelivery)

type BroadcastStopMonitoringBuilder

type BroadcastStopMonitoringBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer

	StopVisitTypes string
	MonitoringRef  string
	// contains filtered or unexported fields
}

func NewBroadcastStopMonitoringBuilder

func NewBroadcastStopMonitoringBuilder(partner *Partner, connectorName string) *BroadcastStopMonitoringBuilder

func (*BroadcastStopMonitoringBuilder) BuildCancelledStopVisit

func (builder *BroadcastStopMonitoringBuilder) BuildCancelledStopVisit(stopVisit *model.StopVisit) *siri.SIRICancelledStopVisit

func (*BroadcastStopMonitoringBuilder) BuildMonitoredStopVisit

func (builder *BroadcastStopMonitoringBuilder) BuildMonitoredStopVisit(stopVisit *model.StopVisit) *siri.SIRIMonitoredStopVisit

type ByPriority

type ByPriority []*Partner

func (ByPriority) Len

func (a ByPriority) Len() int

func (ByPriority) Less

func (a ByPriority) Less(i, j int) bool

func (ByPriority) Swap

func (a ByPriority) Swap(i, j int)

type CheckStatusClient

type CheckStatusClient interface {
	Status() (PartnerStatus, error)
}

type CheckStatusServer

type CheckStatusServer interface {
	CheckStatus(*sxml.XMLCheckStatusRequest, *audit.BigQueryMessage) (*siri.SIRICheckStatusResponse, error)
}

type CollectManager

type CollectManager struct {
	uuid.UUIDConsumer

	UpdateSubscribers []UpdateSubscriber
	// contains filtered or unexported fields
}

func (*CollectManager) BroadcastUpdateEvent

func (manager *CollectManager) BroadcastUpdateEvent(event model.UpdateEvent)

func (*CollectManager) HandlePartnerStatusChange

func (manager *CollectManager) HandlePartnerStatusChange(partner string, status bool)

func (*CollectManager) HandleUpdateEvent

func (manager *CollectManager) HandleUpdateEvent(UpdateSubscriber UpdateSubscriber)

func (*CollectManager) UpdateLine

func (manager *CollectManager) UpdateLine(ctx context.Context, request *LineUpdateRequest)

func (*CollectManager) UpdateSituation

func (manager *CollectManager) UpdateSituation(request *SituationUpdateRequest)

func (*CollectManager) UpdateStopArea

func (manager *CollectManager) UpdateStopArea(request *StopAreaUpdateRequest)

func (*CollectManager) UpdateVehicle

func (manager *CollectManager) UpdateVehicle(ctx context.Context, request *VehicleUpdateRequest)

type CollectManagerInterface

type CollectManagerInterface interface {
	HandlePartnerStatusChange(partner string, status bool)

	UpdateStopArea(request *StopAreaUpdateRequest)
	UpdateLine(ctx context.Context, request *LineUpdateRequest)
	UpdateVehicle(ctx context.Context, request *VehicleUpdateRequest)
	UpdateSituation(request *SituationUpdateRequest)

	HandleUpdateEvent(UpdateSubscriber UpdateSubscriber)
	BroadcastUpdateEvent(event model.UpdateEvent)
}

func NewCollectManager

func NewCollectManager(referential *Referential) CollectManagerInterface

func NewTestCollectManager

func NewTestCollectManager() CollectManagerInterface

type CollectSubscriber

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

func NewCollectSubcriber

func NewCollectSubcriber(c Connector, name string) *CollectSubscriber

func (*CollectSubscriber) GetSubscriptionRequest

func (cs *CollectSubscriber) GetSubscriptionRequest() map[SubscriptionId]*subscriptionRequest

func (*CollectSubscriber) HandleResponse

func (cs *CollectSubscriber) HandleResponse(subscriptionRequests map[SubscriptionId]*subscriptionRequest, message *audit.BigQueryMessage, response *sxml.XMLSubscriptionResponse)

func (*CollectSubscriber) IncrementRetryCountFromMap

func (cs *CollectSubscriber) IncrementRetryCountFromMap(subscriptionRequests map[SubscriptionId]*subscriptionRequest)

type CollectUpdateEvents

type CollectUpdateEvents struct {
	StopAreas       map[string]*model.StopAreaUpdateEvent
	Lines           map[string]*model.LineUpdateEvent
	VehicleJourneys map[string]*model.VehicleJourneyUpdateEvent
	StopVisits      map[string]map[string]*model.StopVisitUpdateEvent
	Vehicles        map[string]*model.VehicleUpdateEvent
	Situations      []*model.SituationUpdateEvent
	Cancellations   []*model.NotCollectedUpdateEvent
	*CollectedRefs
}

func NewCollectUpdateEvents

func NewCollectUpdateEvents() *CollectUpdateEvents

type CollectedRefs

type CollectedRefs struct {
	MonitoringRefs     map[string]struct{}
	LineRefs           map[string]struct{}
	VehicleJourneyRefs map[string]struct{}
	VehicleRefs        map[string]struct{}
}

func NewCollectedRefs

func NewCollectedRefs() *CollectedRefs

func (*CollectedRefs) GetLines

func (events *CollectedRefs) GetLines() []string

func (*CollectedRefs) GetStopAreas

func (events *CollectedRefs) GetStopAreas() []string

func (*CollectedRefs) GetVehicleJourneys

func (events *CollectedRefs) GetVehicleJourneys() []string

func (*CollectedRefs) GetVehicles

func (events *CollectedRefs) GetVehicles() []string

type Connector

type Connector interface {
	clock.ClockInterface
	uuid.UUIDInterface

	Partner() *Partner
	RemoteCodeSpace() string
}

type ConnectorFactory

type ConnectorFactory interface {
	Validate(*APIPartner) // Validate() fill the Errors of the APIPartner
	CreateConnector(*Partner) Connector
}

func NewConnectorFactory

func NewConnectorFactory(connectorType string) ConnectorFactory

type DeletedSubscriptions

type DeletedSubscriptions struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDeletedSubscriptions

func NewDeletedSubscriptions() *DeletedSubscriptions

func (*DeletedSubscriptions) AlreadySend

func (ds *DeletedSubscriptions) AlreadySend(subID string) bool

Returns true if we send a DeleteSubscription request in the last 5 minutes Otherwise register it

type ETTBroadcaster

type ETTBroadcaster struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type ETTSubscriber

type ETTSubscriber struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type EstimatedTimetableBroadcaster

type EstimatedTimetableBroadcaster interface {
	state.Stopable
	state.Startable
}

func NewFakeSIRIEstimatedTimetableBroadcaster

func NewFakeSIRIEstimatedTimetableBroadcaster(connector *SIRIEstimatedTimetableSubscriptionBroadcaster) EstimatedTimetableBroadcaster

func NewSIRIEstimatedTimetableBroadcaster

func NewSIRIEstimatedTimetableBroadcaster(connector *SIRIEstimatedTimetableSubscriptionBroadcaster) EstimatedTimetableBroadcaster

type EstimatedTimetableRequestBroadcaster

type EstimatedTimetableRequestBroadcaster interface {
	RequestLine(*sxml.XMLGetEstimatedTimetable, *audit.BigQueryMessage) *siri.SIRIEstimatedTimetableResponse
}

type EstimatedTimetableSubscriber

type EstimatedTimetableSubscriber struct {
	ETTSubscriber
	// contains filtered or unexported fields
}

func (*EstimatedTimetableSubscriber) Start

func (subscriber *EstimatedTimetableSubscriber) Start()

func (*EstimatedTimetableSubscriber) Stop

func (subscriber *EstimatedTimetableSubscriber) Stop()

type EstimatedTimetableSubscriptionCollector

type EstimatedTimetableSubscriptionCollector interface {
	state.Stopable
	state.Startable

	RequestLineUpdate(request *LineUpdateRequest)
	HandleNotifyEstimatedTimetable(delivery *sxml.XMLNotifyEstimatedTimetable) *CollectedRefs
}

type EstimatedTimetableUpdateEventBuilder

type EstimatedTimetableUpdateEventBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewEstimatedTimetableUpdateEventBuilder

func NewEstimatedTimetableUpdateEventBuilder(partner *Partner) EstimatedTimetableUpdateEventBuilder

func (*EstimatedTimetableUpdateEventBuilder) SetUpdateEvents

func (builder *EstimatedTimetableUpdateEventBuilder) SetUpdateEvents(estimatedJourneyVersionFrames []*sxml.XMLEstimatedJourneyVersionFrame)

func (*EstimatedTimetableUpdateEventBuilder) UpdateEvents

func (builder *EstimatedTimetableUpdateEventBuilder) UpdateEvents() CollectUpdateEvents

type FakeGeneralMessageBroadcaster

type FakeGeneralMessageBroadcaster struct {
	GMBroadcaster

	clock.ClockConsumer
}

func (*FakeGeneralMessageBroadcaster) Start

func (broadcaster *FakeGeneralMessageBroadcaster) Start()

func (*FakeGeneralMessageBroadcaster) Stop

func (broadcaster *FakeGeneralMessageBroadcaster) Stop()

type FakeGeneralMessageSubscriber

type FakeGeneralMessageSubscriber struct {
	GMSubscriber
}

func (*FakeGeneralMessageSubscriber) Start

func (subscriber *FakeGeneralMessageSubscriber) Start()

func (*FakeGeneralMessageSubscriber) Stop

func (subscriber *FakeGeneralMessageSubscriber) Stop()

type FakeProductionTimetableBroadcaster

type FakeProductionTimetableBroadcaster struct {
	PTTBroadcaster
}

func (*FakeProductionTimetableBroadcaster) Start

func (broadcaster *FakeProductionTimetableBroadcaster) Start()

func (*FakeProductionTimetableBroadcaster) Stop

func (broadcaster *FakeProductionTimetableBroadcaster) Stop()

type FakeSIRIEstimatedTimetableBroadcaster

type FakeSIRIEstimatedTimetableBroadcaster struct {
	ETTBroadcaster
}

func (*FakeSIRIEstimatedTimetableBroadcaster) Start

func (broadcaster *FakeSIRIEstimatedTimetableBroadcaster) Start()

func (*FakeSIRIEstimatedTimetableBroadcaster) Stop

func (broadcaster *FakeSIRIEstimatedTimetableBroadcaster) Stop()

type FakeSIRIVehicleMonitoringBroadcaster

type FakeSIRIVehicleMonitoringBroadcaster struct {
	VMBroadcaster
}

func (*FakeSIRIVehicleMonitoringBroadcaster) Start

func (broadcaster *FakeSIRIVehicleMonitoringBroadcaster) Start()

func (*FakeSIRIVehicleMonitoringBroadcaster) Stop

func (broadcaster *FakeSIRIVehicleMonitoringBroadcaster) Stop()

type FakeSituationExchangeBroadcaster

type FakeSituationExchangeBroadcaster struct {
	SXBroadcaster

	clock.ClockConsumer
}

func (*FakeSituationExchangeBroadcaster) Start

func (broadcaster *FakeSituationExchangeBroadcaster) Start()

func (*FakeSituationExchangeBroadcaster) Stop

func (broadcaster *FakeSituationExchangeBroadcaster) Stop()

type FakeSituationExchangeSubscriber

type FakeSituationExchangeSubscriber struct {
	SXSubscriber
}

func (*FakeSituationExchangeSubscriber) Start

func (subscriber *FakeSituationExchangeSubscriber) Start()

func (*FakeSituationExchangeSubscriber) Stop

func (subscriber *FakeSituationExchangeSubscriber) Stop()

type FakeStopMonitoringBroadcaster

type FakeStopMonitoringBroadcaster struct {
	SMBroadcaster

	clock.ClockConsumer
}

func (*FakeStopMonitoringBroadcaster) Start

func (broadcaster *FakeStopMonitoringBroadcaster) Start()

func (*FakeStopMonitoringBroadcaster) Stop

func (broadcaster *FakeStopMonitoringBroadcaster) Stop()

type FakeStopMonitoringSubscriber

type FakeStopMonitoringSubscriber struct {
	SMSubscriber
}

func (*FakeStopMonitoringSubscriber) Start

func (subscriber *FakeStopMonitoringSubscriber) Start()

func (*FakeStopMonitoringSubscriber) Stop

func (subscriber *FakeStopMonitoringSubscriber) Stop()

type FakeVehicleMonitoringSubscriber

type FakeVehicleMonitoringSubscriber struct {
	VMSubscriber
}

func (*FakeVehicleMonitoringSubscriber) Start

func (subscriber *FakeVehicleMonitoringSubscriber) Start()

func (*FakeVehicleMonitoringSubscriber) Stop

func (subscriber *FakeVehicleMonitoringSubscriber) Stop()

type GMBroadcaster

type GMBroadcaster struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type GMSubscriber

type GMSubscriber struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type GeneralMessageBroadcaster

type GeneralMessageBroadcaster struct {
	GMBroadcaster
	// contains filtered or unexported fields
}

func (*GeneralMessageBroadcaster) Start

func (gmb *GeneralMessageBroadcaster) Start()

func (*GeneralMessageBroadcaster) Stop

func (gmb *GeneralMessageBroadcaster) Stop()

type GeneralMessageRequestBroadcaster

type GeneralMessageRequestBroadcaster interface {
	Situations(*sxml.XMLGetGeneralMessage, *audit.BigQueryMessage) (*siri.SIRIGeneralMessageResponse, error)
}

type GeneralMessageSubscriber

type GeneralMessageSubscriber struct {
	GMSubscriber
	// contains filtered or unexported fields
}

func (*GeneralMessageSubscriber) Start

func (subscriber *GeneralMessageSubscriber) Start()

func (*GeneralMessageSubscriber) Stop

func (subscriber *GeneralMessageSubscriber) Stop()

type GeneralMessageSubscriptionCollector

type GeneralMessageSubscriptionCollector interface {
	state.Stopable
	state.Startable

	RequestAllSituationsUpdate()
	RequestSituationUpdate(kind string, requestedId model.Code)
	HandleNotifyGeneralMessage(notify *sxml.XMLNotifyGeneralMessage) *CollectedRefs
}

type GeneralMessageUpdateEventBuilder

type GeneralMessageUpdateEventBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer

	MonitoringRefs map[string]struct{}
	LineRefs       map[string]struct{}
	// contains filtered or unexported fields
}

func NewGeneralMessageUpdateEventBuilder

func NewGeneralMessageUpdateEventBuilder(partner *Partner) GeneralMessageUpdateEventBuilder

func (*GeneralMessageUpdateEventBuilder) SetGeneralMessageDeliveryUpdateEvents

func (builder *GeneralMessageUpdateEventBuilder) SetGeneralMessageDeliveryUpdateEvents(event *CollectUpdateEvents, xmlResponse *sxml.XMLGeneralMessageDelivery, producerRef string)

func (*GeneralMessageUpdateEventBuilder) SetGeneralMessageResponseUpdateEvents

func (builder *GeneralMessageUpdateEventBuilder) SetGeneralMessageResponseUpdateEvents(event *CollectUpdateEvents, xmlResponse *sxml.XMLGeneralMessageResponse)

type GraphqlServer

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

Empty shell for now

func NewGraphqlServer

func NewGraphqlServer(partner *Partner) *GraphqlServer

func (*GraphqlServer) Partner

func (c *GraphqlServer) Partner() *Partner

func (*GraphqlServer) RemoteCodeSpace

func (c *GraphqlServer) RemoteCodeSpace() string

type GraphqlServerFactory

type GraphqlServerFactory struct{}

func (*GraphqlServerFactory) CreateConnector

func (factory *GraphqlServerFactory) CreateConnector(partner *Partner) Connector

func (*GraphqlServerFactory) Validate

func (factory *GraphqlServerFactory) Validate(apiPartner *APIPartner)

type GtfsConnector

type GtfsConnector interface {
	HandleGtfs(*gtfs.FeedMessage)
}

type GtfsRequestCollector

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

func NewGtfsRequestCollector

func NewGtfsRequestCollector(partner *Partner) *GtfsRequestCollector

func (*GtfsRequestCollector) Partner

func (c *GtfsRequestCollector) Partner() *Partner

func (*GtfsRequestCollector) RemoteCodeSpace

func (c *GtfsRequestCollector) RemoteCodeSpace() string

func (*GtfsRequestCollector) SetSubscriber

func (connector *GtfsRequestCollector) SetSubscriber(s UpdateSubscriber)

func (*GtfsRequestCollector) Start

func (connector *GtfsRequestCollector) Start()

func (*GtfsRequestCollector) Stop

func (connector *GtfsRequestCollector) Stop()

type GtfsRequestCollectorFactory

type GtfsRequestCollectorFactory struct{}

func (*GtfsRequestCollectorFactory) CreateConnector

func (factory *GtfsRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*GtfsRequestCollectorFactory) Validate

func (factory *GtfsRequestCollectorFactory) Validate(apiPartner *APIPartner)

type LineDirection

type LineDirection struct {
	Id        model.LineId
	Direction string
}

type LineSection

type LineSection struct {
	LineRef   string
	FirstStop string
	LastStop  string
}

type LineUpdateRequest

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

func NewLineUpdateRequest

func NewLineUpdateRequest(lineId model.LineId) *LineUpdateRequest

func (*LineUpdateRequest) CreatedAt

func (vehicleUpdateRequest *LineUpdateRequest) CreatedAt() time.Time

func (*LineUpdateRequest) LineId

func (vehicleUpdateRequest *LineUpdateRequest) LineId() model.LineId

type LinesDiscoveryRequestBroadcaster

type LinesDiscoveryRequestBroadcaster interface {
	Lines(*sxml.XMLLinesDiscoveryRequest, *audit.BigQueryMessage) (*siri.SIRILinesDiscoveryResponse, error)
}

type LinesDiscoveryRequestCollector

type LinesDiscoveryRequestCollector interface {
	state.Startable

	RequestLines()
}

type LiteStopMonitoringRequestCollector

type LiteStopMonitoringRequestCollector interface {
	RequestStopAreaUpdate(request *StopAreaUpdateRequest)
}

type LiteStopMonitoringUpdateEventBuilder

type LiteStopMonitoringUpdateEventBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewLiteStopMonitoringUpdateEventBuilder

func NewLiteStopMonitoringUpdateEventBuilder(partner *Partner, originStopAreaCode model.Code) LiteStopMonitoringUpdateEventBuilder

func (*LiteStopMonitoringUpdateEventBuilder) SetUpdateEvents

func (builder *LiteStopMonitoringUpdateEventBuilder) SetUpdateEvents(stopVisits []slite.MonitoredStopVisit)

func (*LiteStopMonitoringUpdateEventBuilder) UpdateEvents

func (builder *LiteStopMonitoringUpdateEventBuilder) UpdateEvents() CollectUpdateEvents

type LocalCredentialsIndex

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

func NewLocalCredentialsIndex

func NewLocalCredentialsIndex() *LocalCredentialsIndex

func (*LocalCredentialsIndex) Delete

func (index *LocalCredentialsIndex) Delete(modelId PartnerId)

func (*LocalCredentialsIndex) Find

func (index *LocalCredentialsIndex) Find(c string) (modelId PartnerId, ok bool)

func (*LocalCredentialsIndex) Index

func (index *LocalCredentialsIndex) Index(modelId PartnerId, localCredentials string)

func (*LocalCredentialsIndex) UniqCredentials

func (index *LocalCredentialsIndex) UniqCredentials(modelId PartnerId, localCredentials string) bool

type MemoryReferentials

type MemoryReferentials struct {
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewMemoryReferentials

func NewMemoryReferentials() *MemoryReferentials

func (*MemoryReferentials) Delete

func (manager *MemoryReferentials) Delete(referential *Referential) bool

func (*MemoryReferentials) Find

func (manager *MemoryReferentials) Find(id ReferentialId) *Referential

func (*MemoryReferentials) FindAll

func (manager *MemoryReferentials) FindAll() (referentials []*Referential)

func (*MemoryReferentials) FindBySlug

func (manager *MemoryReferentials) FindBySlug(slug ReferentialSlug) *Referential

func (*MemoryReferentials) Load

func (manager *MemoryReferentials) Load() error

func (*MemoryReferentials) New

func (manager *MemoryReferentials) New(slug ReferentialSlug) *Referential

func (*MemoryReferentials) Save

func (manager *MemoryReferentials) Save(referential *Referential) bool

func (*MemoryReferentials) SaveToDatabase

func (manager *MemoryReferentials) SaveToDatabase() (int, error)

func (*MemoryReferentials) Start

func (manager *MemoryReferentials) Start()

type MemorySubscriptions

type MemorySubscriptions struct {
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewMemorySubscriptions

func NewMemorySubscriptions(partner *Partner) *MemorySubscriptions

func (*MemorySubscriptions) CancelBroadcastSubscriptions

func (manager *MemorySubscriptions) CancelBroadcastSubscriptions()

func (*MemorySubscriptions) CancelCollectSubscriptions

func (manager *MemorySubscriptions) CancelCollectSubscriptions()

func (*MemorySubscriptions) CancelSubscriptions

func (manager *MemorySubscriptions) CancelSubscriptions()

func (*MemorySubscriptions) CancelSubscriptionsResourcesBefore

func (manager *MemorySubscriptions) CancelSubscriptionsResourcesBefore(time time.Time)

func (*MemorySubscriptions) Delete

func (manager *MemorySubscriptions) Delete(subscription *Subscription) bool

func (*MemorySubscriptions) DeleteById

func (manager *MemorySubscriptions) DeleteById(id SubscriptionId)

func (*MemorySubscriptions) Find

func (manager *MemorySubscriptions) Find(id SubscriptionId) (*Subscription, bool)

func (*MemorySubscriptions) FindAll

func (manager *MemorySubscriptions) FindAll() (subscriptions []*Subscription)

func (*MemorySubscriptions) FindBroadcastSubscriptions

func (manager *MemorySubscriptions) FindBroadcastSubscriptions() (subscriptions []*Subscription)

func (*MemorySubscriptions) FindByExternalId

func (manager *MemorySubscriptions) FindByExternalId(externalId string) (*Subscription, bool)

func (*MemorySubscriptions) FindByKind

func (manager *MemorySubscriptions) FindByKind(kind string) (*Subscription, bool)

func (*MemorySubscriptions) FindByResourceId

func (manager *MemorySubscriptions) FindByResourceId(id, kind string) []*Subscription

func (*MemorySubscriptions) FindOrCreateByKind

func (manager *MemorySubscriptions) FindOrCreateByKind(kind string) *Subscription

func (*MemorySubscriptions) FindSubscriptionsByKind

func (manager *MemorySubscriptions) FindSubscriptionsByKind(kind string) (subscriptions []*Subscription)

func (*MemorySubscriptions) Index

func (manager *MemorySubscriptions) Index(subscription *Subscription)

Index the subscription with all associated resources

func (*MemorySubscriptions) MarshalJSON

func (manager *MemorySubscriptions) MarshalJSON() ([]byte, error)

func (*MemorySubscriptions) New

func (manager *MemorySubscriptions) New(kind string) *Subscription

func (*MemorySubscriptions) Save

func (manager *MemorySubscriptions) Save(subscription *Subscription) bool

type ModelGuardian

type ModelGuardian struct {
	clock.ClockConsumer
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewModelGuardian

func NewModelGuardian(referential *Referential) *ModelGuardian

func (*ModelGuardian) Run

func (guardian *ModelGuardian) Run()

func (*ModelGuardian) Start

func (guardian *ModelGuardian) Start()

func (*ModelGuardian) Stop

func (guardian *ModelGuardian) Stop()

type OperationnalStatus

type OperationnalStatus string

const (
	OPERATIONNAL_STATUS_UNKNOWN OperationnalStatus = "unknown"
	OPERATIONNAL_STATUS_UP      OperationnalStatus = "up"
	OPERATIONNAL_STATUS_DOWN    OperationnalStatus = "down"
)

type PTTBroadcaster

type PTTBroadcaster struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type Partner

type Partner struct {
	uuid.UUIDConsumer
	*s.PartnerSettings

	Name          string `json:",omitempty"`
	PartnerStatus PartnerStatus

	ConnectorTypes []string
	// contains filtered or unexported fields
}

func NewPartner

func NewPartner() *Partner

Test Method

func (*Partner) Allow

func (partner *Partner) Allow(ip string) bool

func (*Partner) CanCollect

func (partner *Partner) CanCollect(stopId string, lineIds map[string]struct{}) bool

func (*Partner) CanCollectLine

func (partner *Partner) CanCollectLine(lineId string) bool

func (*Partner) CanCollectLines

func (partner *Partner) CanCollectLines(lineIds map[string]struct{}) s.CollectStatus

func (*Partner) CanCollectStop

func (partner *Partner) CanCollectStop(stopId string) s.CollectStatus

func (*Partner) CancelBroadcastSubscriptions

func (partner *Partner) CancelBroadcastSubscriptions()

func (*Partner) CancelSubscriptions

func (partner *Partner) CancelSubscriptions()

func (*Partner) CheckStatus

func (partner *Partner) CheckStatus() (PartnerStatus, error)

func (*Partner) CheckStatusClient

func (partner *Partner) CheckStatusClient() (csc CheckStatusClient)

func (*Partner) Connector

func (partner *Partner) Connector(connectorType string) (Connector, bool)

func (*Partner) CreateSubscriptionRequestDispatcher

func (partner *Partner) CreateSubscriptionRequestDispatcher()

func (*Partner) Definition

func (partner *Partner) Definition() *APIPartner

func (*Partner) Discover

func (partner *Partner) Discover()

func (*Partner) EstimatedTimetableSubscriptionCollector

func (partner *Partner) EstimatedTimetableSubscriptionCollector() EstimatedTimetableSubscriptionCollector

func (*Partner) GeneralMessageSubscriptionCollector

func (partner *Partner) GeneralMessageSubscriptionCollector() GeneralMessageSubscriptionCollector

func (*Partner) GtfsCache

func (partner *Partner) GtfsCache() *cache.CacheTable

func (*Partner) GtfsConnectors

func (partner *Partner) GtfsConnectors() (connectors []GtfsConnector, ok bool)

func (*Partner) GtfsStatus

func (partner *Partner) GtfsStatus(s OperationnalStatus)

func (*Partner) HTTPClient

func (partner *Partner) HTTPClient() *remote.HTTPClient

func (*Partner) HaveAtLeastOneConnector

func (partner *Partner) HaveAtLeastOneConnector(connectorTypes []string) bool

func (*Partner) Id

func (partner *Partner) Id() PartnerId

func (*Partner) LastDiscovery

func (partner *Partner) LastDiscovery() time.Time

func (*Partner) LiteStopMonitoringRequestCollector

func (partner *Partner) LiteStopMonitoringRequestCollector() (lsmrc LiteStopMonitoringRequestCollector)

func (*Partner) MarshalJSON

func (partner *Partner) MarshalJSON() ([]byte, error)

func (*Partner) Model

func (partner *Partner) Model() model.Model

func (*Partner) OperationnalStatus

func (partner *Partner) OperationnalStatus() OperationnalStatus

func (*Partner) Pushed

func (partner *Partner) Pushed()

func (*Partner) Referential

func (partner *Partner) Referential() *Referential

func (*Partner) RefreshConnectors

func (partner *Partner) RefreshConnectors()

Test method, refresh Connector instances according to connector type list without validation

func (*Partner) RegisterDiscoveredLines

func (partner *Partner) RegisterDiscoveredLines(lines []string)

func (*Partner) RegisterDiscoveredStopAreas

func (partner *Partner) RegisterDiscoveredStopAreas(stops []string)

func (*Partner) SIRIClient

func (partner *Partner) SIRIClient() *remote.SIRIClient

func (*Partner) SIRILiteClient

func (partner *Partner) SIRILiteClient() *remote.SIRILiteClient

func (*Partner) Save

func (partner *Partner) Save() (ok bool)

func (*Partner) SetDefinition

func (partner *Partner) SetDefinition(apiPartner *APIPartner)

APIPartner.Validate should be called for APIPartner factories to be set

func (*Partner) SetSlug

func (partner *Partner) SetSlug(s PartnerSlug)

func (*Partner) SituationExchangeRequestCollector

func (partner *Partner) SituationExchangeRequestCollector() SituationExchangeRequestCollector

func (*Partner) SituationExchangeSubscriptionCollector

func (partner *Partner) SituationExchangeSubscriptionCollector() SituationExchangeSubscriptionCollector

func (*Partner) Slug

func (partner *Partner) Slug() PartnerSlug

func (*Partner) Start

func (partner *Partner) Start()

func (*Partner) StartedAt

func (partner *Partner) StartedAt() time.Time

func (*Partner) Stop

func (partner *Partner) Stop()

func (*Partner) StopMonitoringRequestCollector

func (partner *Partner) StopMonitoringRequestCollector() (smrc StopMonitoringRequestCollector)

func (*Partner) StopMonitoringSubscriptionCollector

func (partner *Partner) StopMonitoringSubscriptionCollector() StopMonitoringSubscriptionCollector

func (*Partner) Subscriptions

func (partner *Partner) Subscriptions() Subscriptions

func (*Partner) VehicleMonitoringRequestCollector

func (partner *Partner) VehicleMonitoringRequestCollector() VehicleMonitoringRequestCollector

func (*Partner) VehicleMonitoringSubscriptionCollector

func (partner *Partner) VehicleMonitoringSubscriptionCollector() VehicleMonitoringSubscriptionCollector

type PartnerId

type PartnerId string

type PartnerManager

type PartnerManager struct {
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewPartnerManager

func NewPartnerManager(referential *Referential) *PartnerManager

func (*PartnerManager) CancelSubscriptions

func (manager *PartnerManager) CancelSubscriptions()

func (*PartnerManager) Delete

func (manager *PartnerManager) Delete(partner *Partner) bool

func (*PartnerManager) Find

func (manager *PartnerManager) Find(id PartnerId) *Partner

func (*PartnerManager) FindAll

func (manager *PartnerManager) FindAll() (partners []*Partner)

func (*PartnerManager) FindAllByCollectPriority

func (manager *PartnerManager) FindAllByCollectPriority() []*Partner

func (*PartnerManager) FindAllWithConnector

func (manager *PartnerManager) FindAllWithConnector(connectorTypes []string) (partners []*Partner)

func (*PartnerManager) FindByCredential

func (manager *PartnerManager) FindByCredential(c string) (*Partner, bool)

func (*PartnerManager) FindBySlug

func (manager *PartnerManager) FindBySlug(slug PartnerSlug) (*Partner, bool)

func (*PartnerManager) Guardian

func (manager *PartnerManager) Guardian() *PartnersGuardian

func (*PartnerManager) IsEmpty

func (manager *PartnerManager) IsEmpty() bool

func (*PartnerManager) Load

func (manager *PartnerManager) Load() error

func (*PartnerManager) MarshalJSON

func (manager *PartnerManager) MarshalJSON() ([]byte, error)

func (*PartnerManager) Model

func (manager *PartnerManager) Model() model.Model

func (*PartnerManager) New

func (manager *PartnerManager) New(slug PartnerSlug) *Partner

func (*PartnerManager) Referential

func (manager *PartnerManager) Referential() *Referential

func (*PartnerManager) Save

func (manager *PartnerManager) Save(partner *Partner) bool

func (*PartnerManager) SaveToDatabase

func (manager *PartnerManager) SaveToDatabase() (int, error)

func (*PartnerManager) Start

func (manager *PartnerManager) Start()

func (*PartnerManager) Stop

func (manager *PartnerManager) Stop()

func (*PartnerManager) UniqCredentials

func (manager *PartnerManager) UniqCredentials(modelId PartnerId, localCredentials string) bool

type PartnerSlug

type PartnerSlug string

type PartnerStatus

type PartnerStatus struct {
	OperationnalStatus OperationnalStatus
	RetryCount         int
	ServiceStartedAt   time.Time
}

type PartnerStatusCheck

type PartnerStatusCheck struct {
	LastCheck time.Time
	Status    OperationnalStatus
}

type Partners

type Partners interface {
	uuid.UUIDInterface
	state.Startable
	state.Stopable

	New(PartnerSlug) *Partner
	Find(PartnerId) *Partner
	FindBySlug(PartnerSlug) (*Partner, bool)
	FindByCredential(string) (*Partner, bool)
	FindAllByCollectPriority() []*Partner
	FindAllWithConnector([]string) []*Partner
	FindAll() []*Partner
	Save(partner *Partner) bool
	Delete(partner *Partner) bool
	Model() model.Model
	Referential() *Referential
	UniqCredentials(PartnerId, string) bool
	IsEmpty() bool
	CancelSubscriptions()
	Load() error
	SaveToDatabase() (int, error)
}

type PartnersGuardian

type PartnersGuardian struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

func NewPartnersGuardian

func NewPartnersGuardian(referential *Referential) *PartnersGuardian

func (*PartnersGuardian) Run

func (guardian *PartnersGuardian) Run()

func (*PartnersGuardian) Start

func (guardian *PartnersGuardian) Start()

func (*PartnersGuardian) Stop

func (guardian *PartnersGuardian) Stop()

type ProductionTimetableBroadcaster

type ProductionTimetableBroadcaster struct {
	PTTBroadcaster
	// contains filtered or unexported fields
}

func (*ProductionTimetableBroadcaster) Start

func (ptt *ProductionTimetableBroadcaster) Start()

func (*ProductionTimetableBroadcaster) Stop

func (ptt *ProductionTimetableBroadcaster) Stop()

type PushCollector

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

func NewPushCollector

func NewPushCollector(partner *Partner) *PushCollector

func (*PushCollector) HandlePushNotification

func (pc *PushCollector) HandlePushNotification(model *em.ExternalCompleteModel, message *audit.BigQueryMessage)

func (*PushCollector) Partner

func (c *PushCollector) Partner() *Partner

func (*PushCollector) RemoteCodeSpace

func (c *PushCollector) RemoteCodeSpace() string

func (*PushCollector) SetSubscriber

func (pc *PushCollector) SetSubscriber(subscriber UpdateSubscriber)

type PushCollectorFactory

type PushCollectorFactory struct{}

func (*PushCollectorFactory) CreateConnector

func (factory *PushCollectorFactory) CreateConnector(partner *Partner) Connector

func (*PushCollectorFactory) Validate

func (factory *PushCollectorFactory) Validate(apiPartner *APIPartner)

type Referential

type Referential struct {
	clock.ClockConsumer
	s.ReferentialSettings

	Name string `json:",omitempty"`

	OrganisationId string `json:",omitempty"`

	Tokens       []string `json:",omitempty"`
	ImportTokens []string `json:",omitempty"`
	// contains filtered or unexported fields
}

func (*Referential) CollectManager

func (referential *Referential) CollectManager() CollectManagerInterface

WIP: Interface ?

func (*Referential) DatabaseOrganisationId

func (referential *Referential) DatabaseOrganisationId() sql.NullString

func (*Referential) Definition

func (referential *Referential) Definition() *APIReferential

func (*Referential) Id

func (referential *Referential) Id() ReferentialId

func (*Referential) Load

func (referential *Referential) Load()

func (*Referential) MarshalJSON

func (referential *Referential) MarshalJSON() ([]byte, error)

func (*Referential) Model

func (referential *Referential) Model() model.Model

func (*Referential) ModelGuardian

func (referential *Referential) ModelGuardian() *ModelGuardian

func (*Referential) NextReloadAt

func (referential *Referential) NextReloadAt() time.Time

func (*Referential) Partners

func (referential *Referential) Partners() Partners

func (*Referential) ReloadModel

func (referential *Referential) ReloadModel()

func (*Referential) Save

func (referential *Referential) Save() (ok bool)

func (*Referential) SetDefinition

func (referential *Referential) SetDefinition(apiReferential *APIReferential)

func (*Referential) Slug

func (referential *Referential) Slug() ReferentialSlug

func (*Referential) Start

func (referential *Referential) Start()

func (*Referential) StartedAt

func (referential *Referential) StartedAt() time.Time

func (*Referential) Stop

func (referential *Referential) Stop()

type ReferentialId

type ReferentialId string

type ReferentialSlug

type ReferentialSlug string

type Referentials

type Referentials interface {
	state.Startable

	New(ReferentialSlug) *Referential
	Find(ReferentialId) *Referential
	FindBySlug(ReferentialSlug) *Referential
	FindAll() []*Referential
	Save(*Referential) bool
	Delete(*Referential) bool
	Load() error
	SaveToDatabase() (int, error)
}

func CurrentReferentials

func CurrentReferentials() Referentials

type ReferentialsConsumer

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

func (*ReferentialsConsumer) CurrentReferentials

func (consumer *ReferentialsConsumer) CurrentReferentials() Referentials

func (*ReferentialsConsumer) SetReferentials

func (consumer *ReferentialsConsumer) SetReferentials(referentials Referentials)

type SIRICheckStatusClient

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

func NewSIRICheckStatusClient

func NewSIRICheckStatusClient(partner *Partner) *SIRICheckStatusClient

func (*SIRICheckStatusClient) Partner

func (c *SIRICheckStatusClient) Partner() *Partner

func (*SIRICheckStatusClient) RemoteCodeSpace

func (c *SIRICheckStatusClient) RemoteCodeSpace() string

func (*SIRICheckStatusClient) Status

func (connector *SIRICheckStatusClient) Status() (PartnerStatus, error)

type SIRICheckStatusClientFactory

type SIRICheckStatusClientFactory struct{}

func (*SIRICheckStatusClientFactory) CreateConnector

func (factory *SIRICheckStatusClientFactory) CreateConnector(partner *Partner) Connector

func (*SIRICheckStatusClientFactory) Validate

func (factory *SIRICheckStatusClientFactory) Validate(apiPartner *APIPartner)

type SIRICheckStatusServer

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

func NewSIRICheckStatusServer

func NewSIRICheckStatusServer(partner *Partner) *SIRICheckStatusServer

func (*SIRICheckStatusServer) CheckStatus

func (connector *SIRICheckStatusServer) CheckStatus(request *sxml.XMLCheckStatusRequest, message *audit.BigQueryMessage) (*siri.SIRICheckStatusResponse, error)

func (*SIRICheckStatusServer) Partner

func (c *SIRICheckStatusServer) Partner() *Partner

func (*SIRICheckStatusServer) RemoteCodeSpace

func (c *SIRICheckStatusServer) RemoteCodeSpace() string

type SIRICheckStatusServerFactory

type SIRICheckStatusServerFactory struct{}

func (*SIRICheckStatusServerFactory) CreateConnector

func (factory *SIRICheckStatusServerFactory) CreateConnector(partner *Partner) Connector

func (*SIRICheckStatusServerFactory) Validate

func (factory *SIRICheckStatusServerFactory) Validate(apiPartner *APIPartner)

type SIRIEstimatedTimetableBroadcaster

type SIRIEstimatedTimetableBroadcaster struct {
	ETTBroadcaster
	// contains filtered or unexported fields
}

func (*SIRIEstimatedTimetableBroadcaster) Start

func (ett *SIRIEstimatedTimetableBroadcaster) Start()

func (*SIRIEstimatedTimetableBroadcaster) Stop

func (ett *SIRIEstimatedTimetableBroadcaster) Stop()

type SIRIEstimatedTimetableRequestBroadcaster

type SIRIEstimatedTimetableRequestBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewSIRIEstimatedTimetableRequestBroadcaster

func NewSIRIEstimatedTimetableRequestBroadcaster(partner *Partner) *SIRIEstimatedTimetableRequestBroadcaster

func (*SIRIEstimatedTimetableRequestBroadcaster) Partner

func (c *SIRIEstimatedTimetableRequestBroadcaster) Partner() *Partner

func (*SIRIEstimatedTimetableRequestBroadcaster) RemoteCodeSpace

func (c *SIRIEstimatedTimetableRequestBroadcaster) RemoteCodeSpace() string

func (*SIRIEstimatedTimetableRequestBroadcaster) RequestLine

func (connector *SIRIEstimatedTimetableRequestBroadcaster) RequestLine(request *sxml.XMLGetEstimatedTimetable, message *audit.BigQueryMessage) *siri.SIRIEstimatedTimetableResponse

func (*SIRIEstimatedTimetableRequestBroadcaster) Start

func (connector *SIRIEstimatedTimetableRequestBroadcaster) Start()

type SIRIEstimatedTimetableRequestBroadcasterFactory

type SIRIEstimatedTimetableRequestBroadcasterFactory struct{}

func (*SIRIEstimatedTimetableRequestBroadcasterFactory) CreateConnector

func (factory *SIRIEstimatedTimetableRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIEstimatedTimetableRequestBroadcasterFactory) Validate

func (factory *SIRIEstimatedTimetableRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIEstimatedTimetableSubscriber

type SIRIEstimatedTimetableSubscriber interface {
	state.Stopable
	state.Startable
}

func NewSIRIEstimatedTimetableSubscriber

func NewSIRIEstimatedTimetableSubscriber(connector *SIRIEstimatedTimetableSubscriptionCollector) SIRIEstimatedTimetableSubscriber

type SIRIEstimatedTimetableSubscriptionBroadcaster

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

func (*SIRIEstimatedTimetableSubscriptionBroadcaster) HandleBroadcastEvent

func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) HandleBroadcastEvent(event *model.StopMonitoringBroadcastEvent)

func (*SIRIEstimatedTimetableSubscriptionBroadcaster) HandleSubscriptionRequest

func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)

func (*SIRIEstimatedTimetableSubscriptionBroadcaster) Partner

func (c *SIRIEstimatedTimetableSubscriptionBroadcaster) Partner() *Partner

func (*SIRIEstimatedTimetableSubscriptionBroadcaster) RemoteCodeSpace

func (c *SIRIEstimatedTimetableSubscriptionBroadcaster) RemoteCodeSpace() string

func (*SIRIEstimatedTimetableSubscriptionBroadcaster) Start

func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) Start()

func (*SIRIEstimatedTimetableSubscriptionBroadcaster) Stop

func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) Stop()

func (*SIRIEstimatedTimetableSubscriptionBroadcaster) UseVisitNumber

func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) UseVisitNumber() bool

type SIRIEstimatedTimetableSubscriptionBroadcasterFactory

type SIRIEstimatedTimetableSubscriptionBroadcasterFactory struct{}

func (*SIRIEstimatedTimetableSubscriptionBroadcasterFactory) CreateConnector

func (factory *SIRIEstimatedTimetableSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIEstimatedTimetableSubscriptionBroadcasterFactory) Validate

func (factory *SIRIEstimatedTimetableSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIEstimatedTimetableSubscriptionCollector

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

func NewSIRIEstimatedTimetableSubscriptionCollector

func NewSIRIEstimatedTimetableSubscriptionCollector(partner *Partner) *SIRIEstimatedTimetableSubscriptionCollector

func (*SIRIEstimatedTimetableSubscriptionCollector) HandleNotifyEstimatedTimetable

func (connector *SIRIEstimatedTimetableSubscriptionCollector) HandleNotifyEstimatedTimetable(notify *sxml.XMLNotifyEstimatedTimetable) (collectedRefs *CollectedRefs)

func (*SIRIEstimatedTimetableSubscriptionCollector) Partner

func (c *SIRIEstimatedTimetableSubscriptionCollector) Partner() *Partner

func (*SIRIEstimatedTimetableSubscriptionCollector) RemoteCodeSpace

func (c *SIRIEstimatedTimetableSubscriptionCollector) RemoteCodeSpace() string

func (*SIRIEstimatedTimetableSubscriptionCollector) RequestLineUpdate

func (connector *SIRIEstimatedTimetableSubscriptionCollector) RequestLineUpdate(request *LineUpdateRequest)

func (*SIRIEstimatedTimetableSubscriptionCollector) SetEstimatedTimetableSubscriber

func (connector *SIRIEstimatedTimetableSubscriptionCollector) SetEstimatedTimetableSubscriber(estimatedTimetableSubscriber SIRIEstimatedTimetableSubscriber)

func (*SIRIEstimatedTimetableSubscriptionCollector) Start

func (connector *SIRIEstimatedTimetableSubscriptionCollector) Start()

func (*SIRIEstimatedTimetableSubscriptionCollector) Stop

func (connector *SIRIEstimatedTimetableSubscriptionCollector) Stop()

type SIRIEstimatedTimetableSubscriptionCollectorFactory

type SIRIEstimatedTimetableSubscriptionCollectorFactory struct{}

func (*SIRIEstimatedTimetableSubscriptionCollectorFactory) CreateConnector

func (factory *SIRIEstimatedTimetableSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIEstimatedTimetableSubscriptionCollectorFactory) Validate

func (factory *SIRIEstimatedTimetableSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)

type SIRIGeneralMessageBroadcaster

type SIRIGeneralMessageBroadcaster interface {
	state.Stopable
	state.Startable
}

func NewFakeGeneralMessageBroadcaster

func NewFakeGeneralMessageBroadcaster(connector *SIRIGeneralMessageSubscriptionBroadcaster) SIRIGeneralMessageBroadcaster

func NewSIRIGeneralMessageBroadcaster

func NewSIRIGeneralMessageBroadcaster(connector *SIRIGeneralMessageSubscriptionBroadcaster) SIRIGeneralMessageBroadcaster

type SIRIGeneralMessageRequestBroadcaster

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

func NewSIRIGeneralMessageRequestBroadcaster

func NewSIRIGeneralMessageRequestBroadcaster(partner *Partner) *SIRIGeneralMessageRequestBroadcaster

func (*SIRIGeneralMessageRequestBroadcaster) Partner

func (c *SIRIGeneralMessageRequestBroadcaster) Partner() *Partner

func (*SIRIGeneralMessageRequestBroadcaster) RemoteCodeSpace

func (c *SIRIGeneralMessageRequestBroadcaster) RemoteCodeSpace() string

func (*SIRIGeneralMessageRequestBroadcaster) Situations

func (connector *SIRIGeneralMessageRequestBroadcaster) Situations(request *sxml.XMLGetGeneralMessage, message *audit.BigQueryMessage) (*siri.SIRIGeneralMessageResponse, error)

type SIRIGeneralMessageRequestBroadcasterFactory

type SIRIGeneralMessageRequestBroadcasterFactory struct{}

func (*SIRIGeneralMessageRequestBroadcasterFactory) CreateConnector

func (factory *SIRIGeneralMessageRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIGeneralMessageRequestBroadcasterFactory) Validate

func (factory *SIRIGeneralMessageRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIGeneralMessageRequestCollector

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

func NewSIRIGeneralMessageRequestCollector

func NewSIRIGeneralMessageRequestCollector(partner *Partner) *SIRIGeneralMessageRequestCollector

func (*SIRIGeneralMessageRequestCollector) Partner

func (c *SIRIGeneralMessageRequestCollector) Partner() *Partner

func (*SIRIGeneralMessageRequestCollector) RemoteCodeSpace

func (c *SIRIGeneralMessageRequestCollector) RemoteCodeSpace() string

func (*SIRIGeneralMessageRequestCollector) RequestAllSituationsUpdate

func (connector *SIRIGeneralMessageRequestCollector) RequestAllSituationsUpdate()

func (*SIRIGeneralMessageRequestCollector) RequestSituationUpdate

func (connector *SIRIGeneralMessageRequestCollector) RequestSituationUpdate(kind, requestedId string)

func (*SIRIGeneralMessageRequestCollector) SetUpdateSubscriber

func (connector *SIRIGeneralMessageRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)

type SIRIGeneralMessageRequestCollectorFactory

type SIRIGeneralMessageRequestCollectorFactory struct{}

func (*SIRIGeneralMessageRequestCollectorFactory) CreateConnector

func (factory *SIRIGeneralMessageRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIGeneralMessageRequestCollectorFactory) Validate

func (factory *SIRIGeneralMessageRequestCollectorFactory) Validate(apiPartner *APIPartner)

type SIRIGeneralMessageSubscriber

type SIRIGeneralMessageSubscriber interface {
	state.Stopable
	state.Startable
}

func NewFakeGeneralMessageSubscriber

func NewFakeGeneralMessageSubscriber(connector *SIRIGeneralMessageSubscriptionCollector) SIRIGeneralMessageSubscriber

func NewSIRIGeneralMessageSubscriber

func NewSIRIGeneralMessageSubscriber(connector *SIRIGeneralMessageSubscriptionCollector) SIRIGeneralMessageSubscriber

type SIRIGeneralMessageSubscriptionBroadcaster

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

func (*SIRIGeneralMessageSubscriptionBroadcaster) HandleGeneralMessageBroadcastEvent

func (connector *SIRIGeneralMessageSubscriptionBroadcaster) HandleGeneralMessageBroadcastEvent(event *model.SituationBroadcastEvent)

func (*SIRIGeneralMessageSubscriptionBroadcaster) HandleSubscriptionRequest

func (connector *SIRIGeneralMessageSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) []siri.SIRIResponseStatus

func (*SIRIGeneralMessageSubscriptionBroadcaster) Partner

func (c *SIRIGeneralMessageSubscriptionBroadcaster) Partner() *Partner

func (*SIRIGeneralMessageSubscriptionBroadcaster) RemoteCodeSpace

func (c *SIRIGeneralMessageSubscriptionBroadcaster) RemoteCodeSpace() string

func (*SIRIGeneralMessageSubscriptionBroadcaster) Start

func (connector *SIRIGeneralMessageSubscriptionBroadcaster) Start()

func (*SIRIGeneralMessageSubscriptionBroadcaster) Stop

func (connector *SIRIGeneralMessageSubscriptionBroadcaster) Stop()

type SIRIGeneralMessageSubscriptionBroadcasterFactory

type SIRIGeneralMessageSubscriptionBroadcasterFactory struct{}

func (*SIRIGeneralMessageSubscriptionBroadcasterFactory) CreateConnector

func (factory *SIRIGeneralMessageSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIGeneralMessageSubscriptionBroadcasterFactory) Validate

func (factory *SIRIGeneralMessageSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIGeneralMessageSubscriptionCollector

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

func NewSIRIGeneralMessageSubscriptionCollector

func NewSIRIGeneralMessageSubscriptionCollector(partner *Partner) *SIRIGeneralMessageSubscriptionCollector

func (*SIRIGeneralMessageSubscriptionCollector) HandleNotifyGeneralMessage

func (connector *SIRIGeneralMessageSubscriptionCollector) HandleNotifyGeneralMessage(notify *sxml.XMLNotifyGeneralMessage) (collectedRefs *CollectedRefs)

func (*SIRIGeneralMessageSubscriptionCollector) Partner

func (c *SIRIGeneralMessageSubscriptionCollector) Partner() *Partner

func (*SIRIGeneralMessageSubscriptionCollector) RemoteCodeSpace

func (c *SIRIGeneralMessageSubscriptionCollector) RemoteCodeSpace() string

func (*SIRIGeneralMessageSubscriptionCollector) RequestAllSituationsUpdate

func (connector *SIRIGeneralMessageSubscriptionCollector) RequestAllSituationsUpdate()

func (*SIRIGeneralMessageSubscriptionCollector) RequestSituationUpdate

func (connector *SIRIGeneralMessageSubscriptionCollector) RequestSituationUpdate(kind string, requestedCode model.Code)

func (*SIRIGeneralMessageSubscriptionCollector) SetGeneralMessageSubscriber

func (connector *SIRIGeneralMessageSubscriptionCollector) SetGeneralMessageSubscriber(generalMessageSubscriber SIRIGeneralMessageSubscriber)

func (*SIRIGeneralMessageSubscriptionCollector) SetSituationUpdateSubscriber

func (connector *SIRIGeneralMessageSubscriptionCollector) SetSituationUpdateSubscriber(updateSubscriber UpdateSubscriber)

func (*SIRIGeneralMessageSubscriptionCollector) Start

func (connector *SIRIGeneralMessageSubscriptionCollector) Start()

func (*SIRIGeneralMessageSubscriptionCollector) Stop

func (connector *SIRIGeneralMessageSubscriptionCollector) Stop()

type SIRIGeneralMessageSubscriptionCollectorFactory

type SIRIGeneralMessageSubscriptionCollectorFactory struct{}

func (*SIRIGeneralMessageSubscriptionCollectorFactory) CreateConnector

func (factory *SIRIGeneralMessageSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIGeneralMessageSubscriptionCollectorFactory) Validate

func (factory *SIRIGeneralMessageSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)

type SIRILinesDiscoveryRequestBroadcaster

type SIRILinesDiscoveryRequestBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewSIRILinesDiscoveryRequestBroadcaster

func NewSIRILinesDiscoveryRequestBroadcaster(partner *Partner) *SIRILinesDiscoveryRequestBroadcaster

func (*SIRILinesDiscoveryRequestBroadcaster) Lines

func (connector *SIRILinesDiscoveryRequestBroadcaster) Lines(request *sxml.XMLLinesDiscoveryRequest, message *audit.BigQueryMessage) (*siri.SIRILinesDiscoveryResponse, error)

func (*SIRILinesDiscoveryRequestBroadcaster) Partner

func (c *SIRILinesDiscoveryRequestBroadcaster) Partner() *Partner

func (*SIRILinesDiscoveryRequestBroadcaster) RemoteCodeSpace

func (c *SIRILinesDiscoveryRequestBroadcaster) RemoteCodeSpace() string

func (*SIRILinesDiscoveryRequestBroadcaster) Start

func (connector *SIRILinesDiscoveryRequestBroadcaster) Start()

type SIRILinesDiscoveryRequestBroadcasterFactory

type SIRILinesDiscoveryRequestBroadcasterFactory struct{}

func (*SIRILinesDiscoveryRequestBroadcasterFactory) CreateConnector

func (factory *SIRILinesDiscoveryRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRILinesDiscoveryRequestBroadcasterFactory) Validate

func (factory *SIRILinesDiscoveryRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRILinesDiscoveryRequestCollector

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

func NewSIRILinesDiscoveryRequestCollector

func NewSIRILinesDiscoveryRequestCollector(partner *Partner) *SIRILinesDiscoveryRequestCollector

func (*SIRILinesDiscoveryRequestCollector) Partner

func (c *SIRILinesDiscoveryRequestCollector) Partner() *Partner

func (*SIRILinesDiscoveryRequestCollector) RemoteCodeSpace

func (c *SIRILinesDiscoveryRequestCollector) RemoteCodeSpace() string

func (*SIRILinesDiscoveryRequestCollector) RequestLines

func (connector *SIRILinesDiscoveryRequestCollector) RequestLines()

func (*SIRILinesDiscoveryRequestCollector) SetSubscriber

func (connector *SIRILinesDiscoveryRequestCollector) SetSubscriber(subscriber UpdateSubscriber)

func (*SIRILinesDiscoveryRequestCollector) Start

func (connector *SIRILinesDiscoveryRequestCollector) Start()

type SIRILinesDiscoveryRequestCollectorFactory

type SIRILinesDiscoveryRequestCollectorFactory struct{}

func (*SIRILinesDiscoveryRequestCollectorFactory) CreateConnector

func (factory *SIRILinesDiscoveryRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRILinesDiscoveryRequestCollectorFactory) Validate

func (factory *SIRILinesDiscoveryRequestCollectorFactory) Validate(apiPartner *APIPartner)

type SIRILiteStopMonitoringRequestCollector

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

func NewSIRILiteStopMonitoringRequestCollector

func NewSIRILiteStopMonitoringRequestCollector(partner *Partner) *SIRILiteStopMonitoringRequestCollector

func (*SIRILiteStopMonitoringRequestCollector) Partner

func (c *SIRILiteStopMonitoringRequestCollector) Partner() *Partner

func (*SIRILiteStopMonitoringRequestCollector) RemoteCodeSpace

func (c *SIRILiteStopMonitoringRequestCollector) RemoteCodeSpace() string

func (*SIRILiteStopMonitoringRequestCollector) RequestStopAreaUpdate

func (connector *SIRILiteStopMonitoringRequestCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)

func (*SIRILiteStopMonitoringRequestCollector) SetUpdateSubscriber

func (connector *SIRILiteStopMonitoringRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)

type SIRILiteStopMonitoringRequestCollectorFactory

type SIRILiteStopMonitoringRequestCollectorFactory struct{}

func (*SIRILiteStopMonitoringRequestCollectorFactory) CreateConnector

func (factory *SIRILiteStopMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRILiteStopMonitoringRequestCollectorFactory) Validate

func (factory *SIRILiteStopMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)

type SIRILiteVehicleMonitoringRequestBroadcaster

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

func NewSIRILiteVehicleMonitoringRequestBroadcaster

func NewSIRILiteVehicleMonitoringRequestBroadcaster(partner *Partner) *SIRILiteVehicleMonitoringRequestBroadcaster

func (*SIRILiteVehicleMonitoringRequestBroadcaster) Partner

func (c *SIRILiteVehicleMonitoringRequestBroadcaster) Partner() *Partner

func (*SIRILiteVehicleMonitoringRequestBroadcaster) RemoteCodeSpace

func (c *SIRILiteVehicleMonitoringRequestBroadcaster) RemoteCodeSpace() string

func (*SIRILiteVehicleMonitoringRequestBroadcaster) RequestVehicles

func (connector *SIRILiteVehicleMonitoringRequestBroadcaster) RequestVehicles(url string, filters url.Values, message *audit.BigQueryMessage) (siriLiteResponse *siri.SiriLiteResponse)

type SIRILiteVehicleMonitoringRequestBroadcasterFactory

type SIRILiteVehicleMonitoringRequestBroadcasterFactory struct{}

func (*SIRILiteVehicleMonitoringRequestBroadcasterFactory) CreateConnector

func (factory *SIRILiteVehicleMonitoringRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRILiteVehicleMonitoringRequestBroadcasterFactory) Validate

func (factory *SIRILiteVehicleMonitoringRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIProductionTimetableBroadcaster

type SIRIProductionTimetableBroadcaster interface {
	state.Stopable
	state.Startable
}

func NewFakeProductionTimetableBroadcaster

func NewFakeProductionTimetableBroadcaster(connector *SIRIProductionTimetableSubscriptionBroadcaster) SIRIProductionTimetableBroadcaster

func NewSIRIProductionTimetableBroadcaster

func NewSIRIProductionTimetableBroadcaster(connector *SIRIProductionTimetableSubscriptionBroadcaster) SIRIProductionTimetableBroadcaster

type SIRIProductionTimetableSubscriptionBroadcaster

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

func (*SIRIProductionTimetableSubscriptionBroadcaster) HandleBroadcastEvent

func (connector *SIRIProductionTimetableSubscriptionBroadcaster) HandleBroadcastEvent(event *model.StopMonitoringBroadcastEvent)

func (*SIRIProductionTimetableSubscriptionBroadcaster) HandleSubscriptionRequest

func (connector *SIRIProductionTimetableSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)

func (*SIRIProductionTimetableSubscriptionBroadcaster) Partner

func (c *SIRIProductionTimetableSubscriptionBroadcaster) Partner() *Partner

func (*SIRIProductionTimetableSubscriptionBroadcaster) RemoteCodeSpace

func (c *SIRIProductionTimetableSubscriptionBroadcaster) RemoteCodeSpace() string

func (*SIRIProductionTimetableSubscriptionBroadcaster) Start

func (connector *SIRIProductionTimetableSubscriptionBroadcaster) Start()

func (*SIRIProductionTimetableSubscriptionBroadcaster) Stop

func (connector *SIRIProductionTimetableSubscriptionBroadcaster) Stop()

type SIRIProductionTimetableSubscriptionBroadcasterFactory

type SIRIProductionTimetableSubscriptionBroadcasterFactory struct{}

func (*SIRIProductionTimetableSubscriptionBroadcasterFactory) CreateConnector

func (factory *SIRIProductionTimetableSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIProductionTimetableSubscriptionBroadcasterFactory) Validate

func (factory *SIRIProductionTimetableSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIServiceRequestBroadcaster

type SIRIServiceRequestBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewSIRIServiceRequestBroadcaster

func NewSIRIServiceRequestBroadcaster(partner *Partner) *SIRIServiceRequestBroadcaster

func (*SIRIServiceRequestBroadcaster) HandleRequests

func (connector *SIRIServiceRequestBroadcaster) HandleRequests(request *sxml.XMLSiriServiceRequest, message *audit.BigQueryMessage) *siri.SIRIServiceResponse

func (*SIRIServiceRequestBroadcaster) Partner

func (c *SIRIServiceRequestBroadcaster) Partner() *Partner

func (*SIRIServiceRequestBroadcaster) RemoteCodeSpace

func (c *SIRIServiceRequestBroadcaster) RemoteCodeSpace() string

func (*SIRIServiceRequestBroadcaster) Start

func (connector *SIRIServiceRequestBroadcaster) Start()

type SIRIServiceRequestBroadcasterFactory

type SIRIServiceRequestBroadcasterFactory struct{}

func (*SIRIServiceRequestBroadcasterFactory) CreateConnector

func (factory *SIRIServiceRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIServiceRequestBroadcasterFactory) Validate

func (factory *SIRIServiceRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRISituationExchangeBroadcaster

type SIRISituationExchangeBroadcaster interface {
	state.Stopable
	state.Startable
}

func NewFakeSituationExchangeBroadcaster

func NewFakeSituationExchangeBroadcaster(connector *SIRISituationExchangeSubscriptionBroadcaster) SIRISituationExchangeBroadcaster

func NewSIRISituationExchangeBroadcaster

func NewSIRISituationExchangeBroadcaster(connector *SIRISituationExchangeSubscriptionBroadcaster) SIRISituationExchangeBroadcaster

type SIRISituationExchangeRequestBroadcaster

type SIRISituationExchangeRequestBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewSIRISituationExchangeRequestBroadcaster

func NewSIRISituationExchangeRequestBroadcaster(partner *Partner) *SIRISituationExchangeRequestBroadcaster

func (*SIRISituationExchangeRequestBroadcaster) Partner

func (c *SIRISituationExchangeRequestBroadcaster) Partner() *Partner

func (*SIRISituationExchangeRequestBroadcaster) RemoteCodeSpace

func (c *SIRISituationExchangeRequestBroadcaster) RemoteCodeSpace() string

func (*SIRISituationExchangeRequestBroadcaster) Situations

func (connector *SIRISituationExchangeRequestBroadcaster) Situations(request *sxml.XMLGetSituationExchange, message *audit.BigQueryMessage) *siri.SIRISituationExchangeResponse

func (*SIRISituationExchangeRequestBroadcaster) Start

func (connector *SIRISituationExchangeRequestBroadcaster) Start()

type SIRISituationExchangeRequestBroadcasterFactory

type SIRISituationExchangeRequestBroadcasterFactory struct{}

func (*SIRISituationExchangeRequestBroadcasterFactory) CreateConnector

func (factory *SIRISituationExchangeRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRISituationExchangeRequestBroadcasterFactory) Validate

func (factory *SIRISituationExchangeRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRISituationExchangeRequestCollector

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

func NewSIRISituationExchangeRequestCollector

func NewSIRISituationExchangeRequestCollector(partner *Partner) *SIRISituationExchangeRequestCollector

func (*SIRISituationExchangeRequestCollector) Partner

func (c *SIRISituationExchangeRequestCollector) Partner() *Partner

func (*SIRISituationExchangeRequestCollector) RemoteCodeSpace

func (c *SIRISituationExchangeRequestCollector) RemoteCodeSpace() string

func (*SIRISituationExchangeRequestCollector) RequestAllSituationsUpdate

func (connector *SIRISituationExchangeRequestCollector) RequestAllSituationsUpdate()

func (*SIRISituationExchangeRequestCollector) RequestSituationUpdate

func (connector *SIRISituationExchangeRequestCollector) RequestSituationUpdate(kind, requestedId string)

func (*SIRISituationExchangeRequestCollector) SetUpdateSubscriber

func (connector *SIRISituationExchangeRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)

type SIRISituationExchangeRequestCollectorFactory

type SIRISituationExchangeRequestCollectorFactory struct{}

func (*SIRISituationExchangeRequestCollectorFactory) CreateConnector

func (factory *SIRISituationExchangeRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRISituationExchangeRequestCollectorFactory) Validate

func (factory *SIRISituationExchangeRequestCollectorFactory) Validate(apiPartner *APIPartner)

type SIRISituationExchangeSubscriber

type SIRISituationExchangeSubscriber interface {
	state.Stopable
	state.Startable
}

func NewFakeSituationExchangeSubscriber

func NewFakeSituationExchangeSubscriber(connector *SIRISituationExchangeSubscriptionCollector) SIRISituationExchangeSubscriber

func NewSIRISituationExchangeSubscriber

func NewSIRISituationExchangeSubscriber(connector *SIRISituationExchangeSubscriptionCollector) SIRISituationExchangeSubscriber

type SIRISituationExchangeSubscriptionBroadcaster

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

func (*SIRISituationExchangeSubscriptionBroadcaster) HandleSituationExchangeBroadcastEvent

func (connector *SIRISituationExchangeSubscriptionBroadcaster) HandleSituationExchangeBroadcastEvent(event *model.SituationBroadcastEvent)

func (*SIRISituationExchangeSubscriptionBroadcaster) HandleSubscriptionRequest

func (connector *SIRISituationExchangeSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) []siri.SIRIResponseStatus

func (*SIRISituationExchangeSubscriptionBroadcaster) Partner

func (c *SIRISituationExchangeSubscriptionBroadcaster) Partner() *Partner

func (*SIRISituationExchangeSubscriptionBroadcaster) RemoteCodeSpace

func (c *SIRISituationExchangeSubscriptionBroadcaster) RemoteCodeSpace() string

func (*SIRISituationExchangeSubscriptionBroadcaster) Start

func (connector *SIRISituationExchangeSubscriptionBroadcaster) Start()

func (*SIRISituationExchangeSubscriptionBroadcaster) Stop

func (connector *SIRISituationExchangeSubscriptionBroadcaster) Stop()

type SIRISituationExchangeSubscriptionBroadcasterFactory

type SIRISituationExchangeSubscriptionBroadcasterFactory struct{}

func (*SIRISituationExchangeSubscriptionBroadcasterFactory) CreateConnector

func (factory *SIRISituationExchangeSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRISituationExchangeSubscriptionBroadcasterFactory) Validate

func (factory *SIRISituationExchangeSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRISituationExchangeSubscriptionCollector

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

func NewSIRISituationExchangeSubscriptionCollector

func NewSIRISituationExchangeSubscriptionCollector(partner *Partner) *SIRISituationExchangeSubscriptionCollector

func (*SIRISituationExchangeSubscriptionCollector) HandleNotifySituationExchange

func (connector *SIRISituationExchangeSubscriptionCollector) HandleNotifySituationExchange(notify *sxml.XMLNotifySituationExchange) (collectedRefs *CollectedRefs)

func (*SIRISituationExchangeSubscriptionCollector) Partner

func (c *SIRISituationExchangeSubscriptionCollector) Partner() *Partner

func (*SIRISituationExchangeSubscriptionCollector) RemoteCodeSpace

func (c *SIRISituationExchangeSubscriptionCollector) RemoteCodeSpace() string

func (*SIRISituationExchangeSubscriptionCollector) RequestAllSituationsUpdate

func (connector *SIRISituationExchangeSubscriptionCollector) RequestAllSituationsUpdate()

func (*SIRISituationExchangeSubscriptionCollector) RequestSituationUpdate

func (connector *SIRISituationExchangeSubscriptionCollector) RequestSituationUpdate(kind string, requestedCode model.Code)

func (*SIRISituationExchangeSubscriptionCollector) SetSituationExchangeSubscriber

func (connector *SIRISituationExchangeSubscriptionCollector) SetSituationExchangeSubscriber(situationExchangeSubscriber SIRISituationExchangeSubscriber)

func (*SIRISituationExchangeSubscriptionCollector) SetSituationUpdateSubscriber

func (connector *SIRISituationExchangeSubscriptionCollector) SetSituationUpdateSubscriber(updateSubscriber UpdateSubscriber)

func (*SIRISituationExchangeSubscriptionCollector) Start

func (connector *SIRISituationExchangeSubscriptionCollector) Start()

func (*SIRISituationExchangeSubscriptionCollector) Stop

func (connector *SIRISituationExchangeSubscriptionCollector) Stop()

type SIRISituationExchangeSubscriptionCollectorFactory

type SIRISituationExchangeSubscriptionCollectorFactory struct{}

func (*SIRISituationExchangeSubscriptionCollectorFactory) CreateConnector

func (factory *SIRISituationExchangeSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRISituationExchangeSubscriptionCollectorFactory) Validate

func (factory *SIRISituationExchangeSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)

type SIRIStopMonitoringBroadcaster

type SIRIStopMonitoringBroadcaster interface {
	state.Stopable
	state.Startable
}

func NewFakeStopMonitoringBroadcaster

func NewFakeStopMonitoringBroadcaster(connector *SIRIStopMonitoringSubscriptionBroadcaster) SIRIStopMonitoringBroadcaster

func NewSIRIStopMonitoringBroadcaster

func NewSIRIStopMonitoringBroadcaster(connector *SIRIStopMonitoringSubscriptionBroadcaster) SIRIStopMonitoringBroadcaster

type SIRIStopMonitoringRequestBroadcaster

type SIRIStopMonitoringRequestBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewSIRIStopMonitoringRequestBroadcaster

func NewSIRIStopMonitoringRequestBroadcaster(partner *Partner) *SIRIStopMonitoringRequestBroadcaster

func (*SIRIStopMonitoringRequestBroadcaster) Partner

func (c *SIRIStopMonitoringRequestBroadcaster) Partner() *Partner

func (*SIRIStopMonitoringRequestBroadcaster) RemoteCodeSpace

func (c *SIRIStopMonitoringRequestBroadcaster) RemoteCodeSpace() string

func (*SIRIStopMonitoringRequestBroadcaster) RequestStopArea

func (connector *SIRIStopMonitoringRequestBroadcaster) RequestStopArea(request *sxml.XMLGetStopMonitoring, message *audit.BigQueryMessage) *siri.SIRIStopMonitoringResponse

func (*SIRIStopMonitoringRequestBroadcaster) Start

func (connector *SIRIStopMonitoringRequestBroadcaster) Start()

type SIRIStopMonitoringRequestBroadcasterFactory

type SIRIStopMonitoringRequestBroadcasterFactory struct{}

func (*SIRIStopMonitoringRequestBroadcasterFactory) CreateConnector

func (factory *SIRIStopMonitoringRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIStopMonitoringRequestBroadcasterFactory) Validate

func (factory *SIRIStopMonitoringRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIStopMonitoringRequestCollector

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

func NewSIRIStopMonitoringRequestCollector

func NewSIRIStopMonitoringRequestCollector(partner *Partner) *SIRIStopMonitoringRequestCollector

func (*SIRIStopMonitoringRequestCollector) Partner

func (c *SIRIStopMonitoringRequestCollector) Partner() *Partner

func (*SIRIStopMonitoringRequestCollector) RemoteCodeSpace

func (c *SIRIStopMonitoringRequestCollector) RemoteCodeSpace() string

func (*SIRIStopMonitoringRequestCollector) RequestStopAreaUpdate

func (connector *SIRIStopMonitoringRequestCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)

func (*SIRIStopMonitoringRequestCollector) SetUpdateSubscriber

func (connector *SIRIStopMonitoringRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)

func (*SIRIStopMonitoringRequestCollector) Start

func (connector *SIRIStopMonitoringRequestCollector) Start()

type SIRIStopMonitoringRequestCollectorFactory

type SIRIStopMonitoringRequestCollectorFactory struct{}

func (*SIRIStopMonitoringRequestCollectorFactory) CreateConnector

func (factory *SIRIStopMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIStopMonitoringRequestCollectorFactory) Validate

func (factory *SIRIStopMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)

type SIRIStopMonitoringSubscriber

type SIRIStopMonitoringSubscriber interface {
	state.Stopable
	state.Startable
}

func NewFakeStopMonitoringSubscriber

func NewFakeStopMonitoringSubscriber(connector *SIRIStopMonitoringSubscriptionCollector) SIRIStopMonitoringSubscriber

func NewSIRIStopMonitoringSubscriber

func NewSIRIStopMonitoringSubscriber(connector *SIRIStopMonitoringSubscriptionCollector) SIRIStopMonitoringSubscriber

type SIRIStopMonitoringSubscriptionBroadcaster

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

func (*SIRIStopMonitoringSubscriptionBroadcaster) HandleStopMonitoringBroadcastEvent

func (connector *SIRIStopMonitoringSubscriptionBroadcaster) HandleStopMonitoringBroadcastEvent(event *model.StopMonitoringBroadcastEvent)

func (*SIRIStopMonitoringSubscriptionBroadcaster) HandleSubscriptionRequest

func (connector *SIRIStopMonitoringSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)

func (*SIRIStopMonitoringSubscriptionBroadcaster) Partner

func (c *SIRIStopMonitoringSubscriptionBroadcaster) Partner() *Partner

func (*SIRIStopMonitoringSubscriptionBroadcaster) RemoteCodeSpace

func (c *SIRIStopMonitoringSubscriptionBroadcaster) RemoteCodeSpace() string

func (*SIRIStopMonitoringSubscriptionBroadcaster) Start

func (connector *SIRIStopMonitoringSubscriptionBroadcaster) Start()

func (*SIRIStopMonitoringSubscriptionBroadcaster) Stop

func (connector *SIRIStopMonitoringSubscriptionBroadcaster) Stop()

type SIRIStopMonitoringSubscriptionBroadcasterFactory

type SIRIStopMonitoringSubscriptionBroadcasterFactory struct{}

func (*SIRIStopMonitoringSubscriptionBroadcasterFactory) CreateConnector

func (factory *SIRIStopMonitoringSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIStopMonitoringSubscriptionBroadcasterFactory) Validate

func (factory *SIRIStopMonitoringSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIStopMonitoringSubscriptionCollector

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

func NewSIRIStopMonitoringSubscriptionCollector

func NewSIRIStopMonitoringSubscriptionCollector(partner *Partner) *SIRIStopMonitoringSubscriptionCollector

func (*SIRIStopMonitoringSubscriptionCollector) HandleNotifyStopMonitoring

func (connector *SIRIStopMonitoringSubscriptionCollector) HandleNotifyStopMonitoring(notify *sxml.XMLNotifyStopMonitoring) (collectedRefs *CollectedRefs)

func (*SIRIStopMonitoringSubscriptionCollector) Partner

func (c *SIRIStopMonitoringSubscriptionCollector) Partner() *Partner

func (*SIRIStopMonitoringSubscriptionCollector) RemoteCodeSpace

func (c *SIRIStopMonitoringSubscriptionCollector) RemoteCodeSpace() string

func (*SIRIStopMonitoringSubscriptionCollector) RequestStopAreaUpdate

func (connector *SIRIStopMonitoringSubscriptionCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)

func (*SIRIStopMonitoringSubscriptionCollector) SetStopMonitoringSubscriber

func (connector *SIRIStopMonitoringSubscriptionCollector) SetStopMonitoringSubscriber(stopMonitoringSubscriber SIRIStopMonitoringSubscriber)

func (*SIRIStopMonitoringSubscriptionCollector) Start

func (connector *SIRIStopMonitoringSubscriptionCollector) Start()

func (*SIRIStopMonitoringSubscriptionCollector) Stop

func (connector *SIRIStopMonitoringSubscriptionCollector) Stop()

type SIRIStopMonitoringSubscriptionCollectorFactory

type SIRIStopMonitoringSubscriptionCollectorFactory struct{}

func (*SIRIStopMonitoringSubscriptionCollectorFactory) CreateConnector

func (factory *SIRIStopMonitoringSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIStopMonitoringSubscriptionCollectorFactory) Validate

func (factory *SIRIStopMonitoringSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)

type SIRIStopPointsDiscoveryRequestBroadcaster

type SIRIStopPointsDiscoveryRequestBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewSIRIStopDiscoveryRequestBroadcaster

func NewSIRIStopDiscoveryRequestBroadcaster(partner *Partner) *SIRIStopPointsDiscoveryRequestBroadcaster

func (*SIRIStopPointsDiscoveryRequestBroadcaster) Partner

func (c *SIRIStopPointsDiscoveryRequestBroadcaster) Partner() *Partner

func (*SIRIStopPointsDiscoveryRequestBroadcaster) RemoteCodeSpace

func (c *SIRIStopPointsDiscoveryRequestBroadcaster) RemoteCodeSpace() string

func (*SIRIStopPointsDiscoveryRequestBroadcaster) Start

func (connector *SIRIStopPointsDiscoveryRequestBroadcaster) Start()

func (*SIRIStopPointsDiscoveryRequestBroadcaster) StopAreas

func (connector *SIRIStopPointsDiscoveryRequestBroadcaster) StopAreas(request *sxml.XMLStopPointsDiscoveryRequest, message *audit.BigQueryMessage) (*siri.SIRIStopPointsDiscoveryResponse, error)

type SIRIStopPointsDiscoveryRequestBroadcasterFactory

type SIRIStopPointsDiscoveryRequestBroadcasterFactory struct{}

func (*SIRIStopPointsDiscoveryRequestBroadcasterFactory) CreateConnector

func (factory *SIRIStopPointsDiscoveryRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIStopPointsDiscoveryRequestBroadcasterFactory) Validate

func (factory *SIRIStopPointsDiscoveryRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIStopPointsDiscoveryRequestCollector

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

func NewSIRIStopPointsDiscoveryRequestCollector

func NewSIRIStopPointsDiscoveryRequestCollector(partner *Partner) *SIRIStopPointsDiscoveryRequestCollector

func (*SIRIStopPointsDiscoveryRequestCollector) Partner

func (c *SIRIStopPointsDiscoveryRequestCollector) Partner() *Partner

func (*SIRIStopPointsDiscoveryRequestCollector) RemoteCodeSpace

func (c *SIRIStopPointsDiscoveryRequestCollector) RemoteCodeSpace() string

func (*SIRIStopPointsDiscoveryRequestCollector) RequestStopPoints

func (connector *SIRIStopPointsDiscoveryRequestCollector) RequestStopPoints()

func (*SIRIStopPointsDiscoveryRequestCollector) SetSubscriber

func (connector *SIRIStopPointsDiscoveryRequestCollector) SetSubscriber(subscriber UpdateSubscriber)

func (*SIRIStopPointsDiscoveryRequestCollector) Start

func (connector *SIRIStopPointsDiscoveryRequestCollector) Start()

type SIRIStopPointsDiscoveryRequestCollectorFactory

type SIRIStopPointsDiscoveryRequestCollectorFactory struct{}

func (*SIRIStopPointsDiscoveryRequestCollectorFactory) CreateConnector

func (factory *SIRIStopPointsDiscoveryRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIStopPointsDiscoveryRequestCollectorFactory) Validate

func (factory *SIRIStopPointsDiscoveryRequestCollectorFactory) Validate(apiPartner *APIPartner)

type SIRISubscriptionRequestDispatcher

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

func NewSIRISubscriptionRequestDispatcher

func NewSIRISubscriptionRequestDispatcher(partner *Partner) *SIRISubscriptionRequestDispatcher

func (*SIRISubscriptionRequestDispatcher) CancelSubscription

func (connector *SIRISubscriptionRequestDispatcher) CancelSubscription(r *sxml.XMLDeleteSubscriptionRequest, message *audit.BigQueryMessage) *siri.SIRIDeleteSubscriptionResponse

func (*SIRISubscriptionRequestDispatcher) Dispatch

func (connector *SIRISubscriptionRequestDispatcher) Dispatch(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (*siri.SIRISubscriptionResponse, error)

func (*SIRISubscriptionRequestDispatcher) HandleNotifySubscriptionTerminated

func (connector *SIRISubscriptionRequestDispatcher) HandleNotifySubscriptionTerminated(r *sxml.XMLNotifySubscriptionTerminated)

func (*SIRISubscriptionRequestDispatcher) HandleSubscriptionTerminatedNotification

func (connector *SIRISubscriptionRequestDispatcher) HandleSubscriptionTerminatedNotification(r *sxml.XMLSubscriptionTerminatedNotification)

func (*SIRISubscriptionRequestDispatcher) Partner

func (c *SIRISubscriptionRequestDispatcher) Partner() *Partner

func (*SIRISubscriptionRequestDispatcher) RemoteCodeSpace

func (c *SIRISubscriptionRequestDispatcher) RemoteCodeSpace() string

type SIRISubscriptionRequestDispatcherFactory

type SIRISubscriptionRequestDispatcherFactory struct{}

func (*SIRISubscriptionRequestDispatcherFactory) CreateConnector

func (factory *SIRISubscriptionRequestDispatcherFactory) CreateConnector(partner *Partner) Connector

func (*SIRISubscriptionRequestDispatcherFactory) Validate

func (factory *SIRISubscriptionRequestDispatcherFactory) Validate(apiPartner *APIPartner)

type SIRIVehicleMonitoringBroadcaster

type SIRIVehicleMonitoringBroadcaster struct {
	VMBroadcaster
	// contains filtered or unexported fields
}

func (*SIRIVehicleMonitoringBroadcaster) Start

func (vm *SIRIVehicleMonitoringBroadcaster) Start()

func (*SIRIVehicleMonitoringBroadcaster) Stop

func (vm *SIRIVehicleMonitoringBroadcaster) Stop()

type SIRIVehicleMonitoringRequestBroadcaster

type SIRIVehicleMonitoringRequestBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewSIRIVehicleMonitoringRequestBroadcaster

func NewSIRIVehicleMonitoringRequestBroadcaster(partner *Partner) *SIRIVehicleMonitoringRequestBroadcaster

func (*SIRIVehicleMonitoringRequestBroadcaster) Partner

func (c *SIRIVehicleMonitoringRequestBroadcaster) Partner() *Partner

func (*SIRIVehicleMonitoringRequestBroadcaster) RemoteCodeSpace

func (c *SIRIVehicleMonitoringRequestBroadcaster) RemoteCodeSpace() string

func (*SIRIVehicleMonitoringRequestBroadcaster) RequestVehicles

func (connector *SIRIVehicleMonitoringRequestBroadcaster) RequestVehicles(request *sxml.XMLGetVehicleMonitoring, message *audit.BigQueryMessage) (siriResponse *siri.SIRIVehicleMonitoringResponse)

func (*SIRIVehicleMonitoringRequestBroadcaster) Start

func (connector *SIRIVehicleMonitoringRequestBroadcaster) Start()

type SIRIVehicleMonitoringRequestBroadcasterFactory

type SIRIVehicleMonitoringRequestBroadcasterFactory struct{}

func (*SIRIVehicleMonitoringRequestBroadcasterFactory) CreateConnector

func (factory *SIRIVehicleMonitoringRequestBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIVehicleMonitoringRequestBroadcasterFactory) Validate

func (factory *SIRIVehicleMonitoringRequestBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIVehicleMonitoringRequestCollector

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

func NewSIRIVehicleMonitoringRequestCollector

func NewSIRIVehicleMonitoringRequestCollector(partner *Partner) *SIRIVehicleMonitoringRequestCollector

func (*SIRIVehicleMonitoringRequestCollector) Partner

func (c *SIRIVehicleMonitoringRequestCollector) Partner() *Partner

func (*SIRIVehicleMonitoringRequestCollector) RemoteCodeSpace

func (c *SIRIVehicleMonitoringRequestCollector) RemoteCodeSpace() string

func (*SIRIVehicleMonitoringRequestCollector) RequestVehicleUpdate

func (connector *SIRIVehicleMonitoringRequestCollector) RequestVehicleUpdate(request *VehicleUpdateRequest)

func (*SIRIVehicleMonitoringRequestCollector) SetUpdateSubscriber

func (connector *SIRIVehicleMonitoringRequestCollector) SetUpdateSubscriber(updateSubscriber UpdateSubscriber)

func (*SIRIVehicleMonitoringRequestCollector) Start

func (connector *SIRIVehicleMonitoringRequestCollector) Start()

type SIRIVehicleMonitoringRequestCollectorFactory

type SIRIVehicleMonitoringRequestCollectorFactory struct{}

func (*SIRIVehicleMonitoringRequestCollectorFactory) CreateConnector

func (factory *SIRIVehicleMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIVehicleMonitoringRequestCollectorFactory) Validate

func (factory *SIRIVehicleMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)

type SIRIVehicleMonitoringSubscriber

type SIRIVehicleMonitoringSubscriber interface {
	state.Stopable
	state.Startable
}

func NewFakeVehicleMonitoringSubscriber

func NewFakeVehicleMonitoringSubscriber(connector *SIRIVehicleMonitoringSubscriptionCollector) SIRIVehicleMonitoringSubscriber

func NewSIRIVehicleMonitoringSubscriber

func NewSIRIVehicleMonitoringSubscriber(connector *SIRIVehicleMonitoringSubscriptionCollector) SIRIVehicleMonitoringSubscriber

type SIRIVehicleMonitoringSubscriptionBroadcaster

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

func (*SIRIVehicleMonitoringSubscriptionBroadcaster) HandleBroadcastEvent

func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) HandleBroadcastEvent(event *model.VehicleBroadcastEvent)

func (*SIRIVehicleMonitoringSubscriptionBroadcaster) HandleSubscriptionRequest

func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) HandleSubscriptionRequest(request *sxml.XMLSubscriptionRequest, message *audit.BigQueryMessage) (resps []siri.SIRIResponseStatus)

func (*SIRIVehicleMonitoringSubscriptionBroadcaster) Partner

func (c *SIRIVehicleMonitoringSubscriptionBroadcaster) Partner() *Partner

func (*SIRIVehicleMonitoringSubscriptionBroadcaster) RemoteCodeSpace

func (c *SIRIVehicleMonitoringSubscriptionBroadcaster) RemoteCodeSpace() string

func (*SIRIVehicleMonitoringSubscriptionBroadcaster) Start

func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) Start()

func (*SIRIVehicleMonitoringSubscriptionBroadcaster) Stop

func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) Stop()

type SIRIVehicleMonitoringSubscriptionBroadcasterFactory

type SIRIVehicleMonitoringSubscriptionBroadcasterFactory struct{}

func (*SIRIVehicleMonitoringSubscriptionBroadcasterFactory) CreateConnector

func (factory *SIRIVehicleMonitoringSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*SIRIVehicleMonitoringSubscriptionBroadcasterFactory) Validate

func (factory *SIRIVehicleMonitoringSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type SIRIVehicleMonitoringSubscriptionCollector

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

func NewSIRIVehicleMonitoringSubscriptionCollector

func NewSIRIVehicleMonitoringSubscriptionCollector(partner *Partner) *SIRIVehicleMonitoringSubscriptionCollector

func (*SIRIVehicleMonitoringSubscriptionCollector) HandleNotifyVehicleMonitoring

func (connector *SIRIVehicleMonitoringSubscriptionCollector) HandleNotifyVehicleMonitoring(notify *sxml.XMLNotifyVehicleMonitoring) (collectedRefs *CollectedRefs)

func (*SIRIVehicleMonitoringSubscriptionCollector) Partner

func (c *SIRIVehicleMonitoringSubscriptionCollector) Partner() *Partner

func (*SIRIVehicleMonitoringSubscriptionCollector) RemoteCodeSpace

func (c *SIRIVehicleMonitoringSubscriptionCollector) RemoteCodeSpace() string

func (*SIRIVehicleMonitoringSubscriptionCollector) RequestVehicleUpdate

func (connector *SIRIVehicleMonitoringSubscriptionCollector) RequestVehicleUpdate(request *VehicleUpdateRequest)

func (*SIRIVehicleMonitoringSubscriptionCollector) SetVehicleMonitoringSubscriber

func (connector *SIRIVehicleMonitoringSubscriptionCollector) SetVehicleMonitoringSubscriber(vehicleMonitoringSubscriber SIRIVehicleMonitoringSubscriber)

func (*SIRIVehicleMonitoringSubscriptionCollector) Start

func (connector *SIRIVehicleMonitoringSubscriptionCollector) Start()

func (*SIRIVehicleMonitoringSubscriptionCollector) Stop

func (connector *SIRIVehicleMonitoringSubscriptionCollector) Stop()

type SIRIVehicleMonitoringSubscriptionCollectorFactory

type SIRIVehicleMonitoringSubscriptionCollectorFactory struct{}

func (*SIRIVehicleMonitoringSubscriptionCollectorFactory) CreateConnector

func (factory *SIRIVehicleMonitoringSubscriptionCollectorFactory) CreateConnector(partner *Partner) Connector

func (*SIRIVehicleMonitoringSubscriptionCollectorFactory) Validate

func (factory *SIRIVehicleMonitoringSubscriptionCollectorFactory) Validate(apiPartner *APIPartner)

type SMBroadcaster

type SMBroadcaster struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type SMSubscriber

type SMSubscriber struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type SXBroadcaster

type SXBroadcaster struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type SXSubscriber

type SXSubscriber struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type ServiceAlertsBroadcaster

type ServiceAlertsBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewServiceAlertsBroadcaster

func NewServiceAlertsBroadcaster(partner *Partner) *ServiceAlertsBroadcaster

func (*ServiceAlertsBroadcaster) HandleGtfs

func (connector *ServiceAlertsBroadcaster) HandleGtfs(feed *gtfs.FeedMessage)

func (*ServiceAlertsBroadcaster) Partner

func (c *ServiceAlertsBroadcaster) Partner() *Partner

func (*ServiceAlertsBroadcaster) RemoteCodeSpace

func (c *ServiceAlertsBroadcaster) RemoteCodeSpace() string

func (*ServiceAlertsBroadcaster) Start

func (connector *ServiceAlertsBroadcaster) Start()

type ServiceAlertsBroadcasterFactory

type ServiceAlertsBroadcasterFactory struct{}

func (*ServiceAlertsBroadcasterFactory) CreateConnector

func (factory *ServiceAlertsBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*ServiceAlertsBroadcasterFactory) Validate

func (factory *ServiceAlertsBroadcasterFactory) Validate(apiPartner *APIPartner)

type ServiceRequestBroadcaster

type ServiceRequestBroadcaster interface {
	HandleRequests(*sxml.XMLSiriServiceRequest, *audit.BigQueryMessage) *siri.SIRIServiceResponse
}

type SituationExchangeBroadcaster

type SituationExchangeBroadcaster struct {
	SXBroadcaster
	// contains filtered or unexported fields
}

func (*SituationExchangeBroadcaster) Start

func (sxb *SituationExchangeBroadcaster) Start()

func (*SituationExchangeBroadcaster) Stop

func (sxb *SituationExchangeBroadcaster) Stop()

type SituationExchangeRequestBroadcaster

type SituationExchangeRequestBroadcaster interface {
	Situations(*sxml.XMLGetSituationExchange, *audit.BigQueryMessage) *siri.SIRISituationExchangeResponse
}

type SituationExchangeRequestCollector

type SituationExchangeRequestCollector interface {
	RequestSituationUpdate(kind, requestedId string)
}

type SituationExchangeSubscriber

type SituationExchangeSubscriber struct {
	SXSubscriber
	// contains filtered or unexported fields
}

func (*SituationExchangeSubscriber) Start

func (subscriber *SituationExchangeSubscriber) Start()

func (*SituationExchangeSubscriber) Stop

func (subscriber *SituationExchangeSubscriber) Stop()

type SituationExchangeSubscriptionCollector

type SituationExchangeSubscriptionCollector interface {
	state.Stopable
	state.Startable

	RequestAllSituationsUpdate()
	RequestSituationUpdate(kind string, requestedId model.Code)
	HandleNotifySituationExchange(notify *sxml.XMLNotifySituationExchange) *CollectedRefs
}

type SituationExchangeUpdateEventBuilder

type SituationExchangeUpdateEventBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer

	MonitoringRefs map[string]struct{}
	LineRefs       map[string]struct{}
	// contains filtered or unexported fields
}

func NewSituationExchangeUpdateEventBuilder

func NewSituationExchangeUpdateEventBuilder(partner *Partner) SituationExchangeUpdateEventBuilder

func (*SituationExchangeUpdateEventBuilder) SetSituationExchangeDeliveryUpdateEvents

func (builder *SituationExchangeUpdateEventBuilder) SetSituationExchangeDeliveryUpdateEvents(events *CollectUpdateEvents, xmlSituationExchangeDelivery *sxml.XMLSituationExchangeDelivery, producerRef string)

func (*SituationExchangeUpdateEventBuilder) SetSituationExchangeUpdateEvents

func (builder *SituationExchangeUpdateEventBuilder) SetSituationExchangeUpdateEvents(event *CollectUpdateEvents, xmlResponse *sxml.XMLSituationExchangeResponse)

type SituationUpdateRequest

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

func NewSituationUpdateRequest

func NewSituationUpdateRequest(kind, requestedId string) *SituationUpdateRequest

func (*SituationUpdateRequest) CreatedAt

func (situationUpdateRequest *SituationUpdateRequest) CreatedAt() time.Time

func (*SituationUpdateRequest) Kind

func (situationUpdateRequest *SituationUpdateRequest) Kind() string

func (*SituationUpdateRequest) RequestedId

func (situationUpdateRequest *SituationUpdateRequest) RequestedId() string

type SituationUpdateRequestId

type SituationUpdateRequestId string

type StopAreaLogger

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

func NewStopAreaLogger

func NewStopAreaLogger(referential *Referential, stopArea *model.StopArea) *StopAreaLogger

func (*StopAreaLogger) IsVerbose

func (stopAreaLogger *StopAreaLogger) IsVerbose() bool

func (*StopAreaLogger) Printf

func (stopAreaLogger *StopAreaLogger) Printf(format string, values ...interface{})

type StopAreaUpdateRequest

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

func NewStopAreaUpdateRequest

func NewStopAreaUpdateRequest(stopAreaId model.StopAreaId) *StopAreaUpdateRequest

func (*StopAreaUpdateRequest) CreatedAt

func (stopAreaUpdateRequest *StopAreaUpdateRequest) CreatedAt() time.Time

func (*StopAreaUpdateRequest) StopAreaId

func (stopAreaUpdateRequest *StopAreaUpdateRequest) StopAreaId() model.StopAreaId

type StopMonitoringBroadcaster

type StopMonitoringBroadcaster struct {
	SMBroadcaster
	// contains filtered or unexported fields
}

func (*StopMonitoringBroadcaster) Start

func (smb *StopMonitoringBroadcaster) Start()

func (*StopMonitoringBroadcaster) Stop

func (smb *StopMonitoringBroadcaster) Stop()

type StopMonitoringRequestBroadcaster

type StopMonitoringRequestBroadcaster interface {
	RequestStopArea(*sxml.XMLGetStopMonitoring, *audit.BigQueryMessage) *siri.SIRIStopMonitoringResponse
}

type StopMonitoringRequestCollector

type StopMonitoringRequestCollector interface {
	state.Startable

	RequestStopAreaUpdate(request *StopAreaUpdateRequest)
}

type StopMonitoringSubscriber

type StopMonitoringSubscriber struct {
	SMSubscriber
	// contains filtered or unexported fields
}

func (*StopMonitoringSubscriber) Start

func (subscriber *StopMonitoringSubscriber) Start()

func (*StopMonitoringSubscriber) Stop

func (subscriber *StopMonitoringSubscriber) Stop()

type StopMonitoringSubscriptionCollector

type StopMonitoringSubscriptionCollector interface {
	state.Stopable
	state.Startable

	RequestStopAreaUpdate(request *StopAreaUpdateRequest)
	HandleNotifyStopMonitoring(delivery *sxml.XMLNotifyStopMonitoring) *CollectedRefs
}

type StopMonitoringUpdateEventBuilder

type StopMonitoringUpdateEventBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewStopMonitoringUpdateEventBuilder

func NewStopMonitoringUpdateEventBuilder(partner *Partner, originStopAreaCode model.Code) StopMonitoringUpdateEventBuilder

func (*StopMonitoringUpdateEventBuilder) SetStopVisitCancellationEvents

func (builder *StopMonitoringUpdateEventBuilder) SetStopVisitCancellationEvents(delivery *sxml.XMLNotifyStopMonitoringDelivery)

Used only in StopMonitoringSubscriptionCollector

func (*StopMonitoringUpdateEventBuilder) SetUpdateEvents

func (builder *StopMonitoringUpdateEventBuilder) SetUpdateEvents(stopVisits []*sxml.XMLMonitoredStopVisit)

func (*StopMonitoringUpdateEventBuilder) UpdateEvents

func (builder *StopMonitoringUpdateEventBuilder) UpdateEvents() CollectUpdateEvents

type StopPointsDiscoveryRequestCollector

type StopPointsDiscoveryRequestCollector interface {
	state.Startable

	RequestStopPoints()
}

type SubscribedResource

type SubscribedResource struct {
	sync.RWMutex

	Reference       model.Reference
	RetryCount      int
	SubscribedUntil time.Time
	// contains filtered or unexported fields
}

func NewResource

func NewResource(ref model.Reference) *SubscribedResource

func (*SubscribedResource) LastState

func (sr *SubscribedResource) LastState(state string) (l ls.LastState, ok bool)

func (*SubscribedResource) MarshalJSON

func (sr *SubscribedResource) MarshalJSON() ([]byte, error)

func (*SubscribedResource) ResourcesOptions

func (sr *SubscribedResource) ResourcesOptions() map[string]string

func (*SubscribedResource) SetLastState

func (sr *SubscribedResource) SetLastState(s string, l ls.LastState)

func (*SubscribedResource) Subscribed

func (sr *SubscribedResource) Subscribed(t time.Time)

func (*SubscribedResource) SubscribedAt

func (sr *SubscribedResource) SubscribedAt() time.Time

type Subscription

type Subscription struct {
	sync.RWMutex
	clock.ClockConsumer

	SubscriberRef string
	// contains filtered or unexported fields
}

func (*Subscription) AddNewResource

func (subscription *Subscription) AddNewResource(resource *SubscribedResource)

func (*Subscription) CreateAndAddNewResource

func (subscription *Subscription) CreateAndAddNewResource(reference model.Reference) *SubscribedResource

func (*Subscription) Delete

func (subscription *Subscription) Delete() (ok bool)

func (*Subscription) DeleteResource

func (subscription *Subscription) DeleteResource(key string)

func (*Subscription) ExternalId

func (subscription *Subscription) ExternalId() string

func (*Subscription) Id

func (subscription *Subscription) Id() SubscriptionId

func (*Subscription) Kind

func (subscription *Subscription) Kind() string

func (*Subscription) MarshalJSON

func (subscription *Subscription) MarshalJSON() ([]byte, error)

func (*Subscription) Resource

func (subscription *Subscription) Resource(obj model.Code) *SubscribedResource

func (*Subscription) Resources

func (subscription *Subscription) Resources(now time.Time) (ressources []*SubscribedResource)

func (*Subscription) ResourcesByCodeCopy

func (subscription *Subscription) ResourcesByCodeCopy() map[string]*SubscribedResource

func (*Subscription) ResourcesLen

func (subscription *Subscription) ResourcesLen() (i int)

func (*Subscription) Save

func (subscription *Subscription) Save() (ok bool)

func (*Subscription) SetDefinition

func (subscription *Subscription) SetDefinition(apisub *APISubscription)

func (*Subscription) SetExternalId

func (subscription *Subscription) SetExternalId(externalId string)

func (*Subscription) SetKind

func (subscription *Subscription) SetKind(kind string)

func (*Subscription) SetSubscriptionOption

func (subscription *Subscription) SetSubscriptionOption(key, value string)

func (*Subscription) SubscriptionOption

func (subscription *Subscription) SubscriptionOption(key string) (o string)

func (*Subscription) UniqueResource

func (subscription *Subscription) UniqueResource() (r *SubscribedResource)

type SubscriptionId

type SubscriptionId string

type SubscriptionRequestDispatcher

type SubscriptionRequestDispatcher interface {
	Dispatch(*sxml.XMLSubscriptionRequest, *audit.BigQueryMessage) (*siri.SIRISubscriptionResponse, error)
	CancelSubscription(*sxml.XMLDeleteSubscriptionRequest, *audit.BigQueryMessage) *siri.SIRIDeleteSubscriptionResponse
	HandleSubscriptionTerminatedNotification(*sxml.XMLSubscriptionTerminatedNotification)
	HandleNotifySubscriptionTerminated(*sxml.XMLNotifySubscriptionTerminated)
}

type Subscriptions

type Subscriptions interface {
	uuid.UUIDInterface

	New(string) *Subscription
	Find(SubscriptionId) (*Subscription, bool)
	FindAll() []*Subscription
	FindOrCreateByKind(string) *Subscription
	FindByKind(string) (*Subscription, bool)
	FindSubscriptionsByKind(string) []*Subscription
	FindBroadcastSubscriptions() []*Subscription
	Index(*Subscription)
	Save(*Subscription) bool
	Delete(*Subscription) bool
	DeleteById(SubscriptionId)
	CancelSubscriptions()
	CancelSubscriptionsResourcesBefore(time.Time)
	CancelBroadcastSubscriptions()
	CancelCollectSubscriptions()
	FindByResourceId(id, kind string) []*Subscription
	FindByExternalId(string) (*Subscription, bool)
}

type TestCheckStatusClient

type TestCheckStatusClient struct {
	Done chan bool
	// contains filtered or unexported fields
}

func NewTestCheckStatusClient

func NewTestCheckStatusClient() *TestCheckStatusClient

func (*TestCheckStatusClient) Partner

func (c *TestCheckStatusClient) Partner() *Partner

func (*TestCheckStatusClient) RemoteCodeSpace

func (c *TestCheckStatusClient) RemoteCodeSpace() string

func (*TestCheckStatusClient) SetStatus

func (connector *TestCheckStatusClient) SetStatus(status OperationnalStatus)

func (*TestCheckStatusClient) Status

func (connector *TestCheckStatusClient) Status() (PartnerStatus, error)

type TestCheckStatusClientFactory

type TestCheckStatusClientFactory struct{}

func (*TestCheckStatusClientFactory) CreateConnector

func (factory *TestCheckStatusClientFactory) CreateConnector(partner *Partner) Connector

func (*TestCheckStatusClientFactory) Validate

func (factory *TestCheckStatusClientFactory) Validate(apiPartner *APIPartner)

type TestCollectManager

type TestCollectManager struct {
	Done         chan bool
	UpdateEvents []model.UpdateEvent
}

TestCollectManager has a test StopAreaUpdateSubscriber method

func (*TestCollectManager) BroadcastUpdateEvent

func (manager *TestCollectManager) BroadcastUpdateEvent(event model.UpdateEvent)

func (*TestCollectManager) HandlePartnerStatusChange

func (manager *TestCollectManager) HandlePartnerStatusChange(partner string, status bool)

func (*TestCollectManager) HandleUpdateEvent

func (manager *TestCollectManager) HandleUpdateEvent(UpdateSubscriber)

New structure

func (*TestCollectManager) TestUpdateSubscriber

func (manager *TestCollectManager) TestUpdateSubscriber(event model.UpdateEvent)

func (*TestCollectManager) UpdateLine

func (manager *TestCollectManager) UpdateLine(context.Context, *LineUpdateRequest)

func (*TestCollectManager) UpdateSituation

func (manager *TestCollectManager) UpdateSituation(*SituationUpdateRequest)

func (*TestCollectManager) UpdateStopArea

func (manager *TestCollectManager) UpdateStopArea(request *StopAreaUpdateRequest)

func (*TestCollectManager) UpdateVehicle

func (manager *TestCollectManager) UpdateVehicle(context.Context, *VehicleUpdateRequest)

type TestETTSubscriptionBroadcaster

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

func NewTestETTSubscriptionBroadcaster

func NewTestETTSubscriptionBroadcaster() *TestETTSubscriptionBroadcaster

func (*TestETTSubscriptionBroadcaster) HandleBroadcastEvent

func (connector *TestETTSubscriptionBroadcaster) HandleBroadcastEvent(event *model.StopMonitoringBroadcastEvent)

func (*TestETTSubscriptionBroadcaster) Partner

func (c *TestETTSubscriptionBroadcaster) Partner() *Partner

func (*TestETTSubscriptionBroadcaster) RemoteCodeSpace

func (c *TestETTSubscriptionBroadcaster) RemoteCodeSpace() string

type TestGeneralMessageSubscriptionBroadcaster

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

func NewTestGeneralMessageSubscriptionBroadcaster

func NewTestGeneralMessageSubscriptionBroadcaster() *TestGeneralMessageSubscriptionBroadcaster

func (*TestGeneralMessageSubscriptionBroadcaster) HandleGeneralMessageBroadcastEvent

func (connector *TestGeneralMessageSubscriptionBroadcaster) HandleGeneralMessageBroadcastEvent(event *model.SituationBroadcastEvent)

func (*TestGeneralMessageSubscriptionBroadcaster) Partner

func (c *TestGeneralMessageSubscriptionBroadcaster) Partner() *Partner

func (*TestGeneralMessageSubscriptionBroadcaster) RemoteCodeSpace

func (c *TestGeneralMessageSubscriptionBroadcaster) RemoteCodeSpace() string

type TestSIRIETTSubscriptionBroadcasterFactory

type TestSIRIETTSubscriptionBroadcasterFactory struct{}

func (*TestSIRIETTSubscriptionBroadcasterFactory) CreateConnector

func (factory *TestSIRIETTSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*TestSIRIETTSubscriptionBroadcasterFactory) Validate

func (factory *TestSIRIETTSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type TestSIRIGeneralMessageSubscriptionBroadcasterFactory

type TestSIRIGeneralMessageSubscriptionBroadcasterFactory struct{}

func (*TestSIRIGeneralMessageSubscriptionBroadcasterFactory) CreateConnector

func (factory *TestSIRIGeneralMessageSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*TestSIRIGeneralMessageSubscriptionBroadcasterFactory) Validate

func (factory *TestSIRIGeneralMessageSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type TestSIRIStopMonitoringSubscriptionBroadcasterFactory

type TestSIRIStopMonitoringSubscriptionBroadcasterFactory struct{}

func (*TestSIRIStopMonitoringSubscriptionBroadcasterFactory) CreateConnector

func (factory *TestSIRIStopMonitoringSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*TestSIRIStopMonitoringSubscriptionBroadcasterFactory) Validate

func (factory *TestSIRIStopMonitoringSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type TestSIRIVMSubscriptionBroadcasterFactory

type TestSIRIVMSubscriptionBroadcasterFactory struct{}

func (*TestSIRIVMSubscriptionBroadcasterFactory) CreateConnector

func (factory *TestSIRIVMSubscriptionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*TestSIRIVMSubscriptionBroadcasterFactory) Validate

func (factory *TestSIRIVMSubscriptionBroadcasterFactory) Validate(apiPartner *APIPartner)

type TestStartableConnector

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

func (*TestStartableConnector) Partner

func (c *TestStartableConnector) Partner() *Partner

func (*TestStartableConnector) RemoteCodeSpace

func (c *TestStartableConnector) RemoteCodeSpace() string

func (*TestStartableConnector) Start

func (connector *TestStartableConnector) Start()

func (*TestStartableConnector) Stop

func (connector *TestStartableConnector) Stop()

type TestStartableFactory

type TestStartableFactory struct{}

func (*TestStartableFactory) CreateConnector

func (factory *TestStartableFactory) CreateConnector(partner *Partner) Connector

func (*TestStartableFactory) Validate

func (factory *TestStartableFactory) Validate(apiPartner *APIPartner)

type TestStopMonitoringRequestCollector

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

func NewTestStopMonitoringRequestCollector

func NewTestStopMonitoringRequestCollector() *TestStopMonitoringRequestCollector

func (*TestStopMonitoringRequestCollector) Partner

func (c *TestStopMonitoringRequestCollector) Partner() *Partner

func (*TestStopMonitoringRequestCollector) RemoteCodeSpace

func (c *TestStopMonitoringRequestCollector) RemoteCodeSpace() string

func (*TestStopMonitoringRequestCollector) RequestStopAreaUpdate

func (connector *TestStopMonitoringRequestCollector) RequestStopAreaUpdate(request *StopAreaUpdateRequest)

type TestStopMonitoringRequestCollectorFactory

type TestStopMonitoringRequestCollectorFactory struct{}

func (*TestStopMonitoringRequestCollectorFactory) CreateConnector

func (factory *TestStopMonitoringRequestCollectorFactory) CreateConnector(partner *Partner) Connector

func (*TestStopMonitoringRequestCollectorFactory) Validate

func (factory *TestStopMonitoringRequestCollectorFactory) Validate(apiPartner *APIPartner)

type TestStopMonitoringSubscriptionBroadcaster

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

func NewTestStopMonitoringSubscriptionBroadcaster

func NewTestStopMonitoringSubscriptionBroadcaster() *TestStopMonitoringSubscriptionBroadcaster

func (*TestStopMonitoringSubscriptionBroadcaster) HandleStopMonitoringBroadcastEvent

func (connector *TestStopMonitoringSubscriptionBroadcaster) HandleStopMonitoringBroadcastEvent(event *model.StopMonitoringBroadcastEvent)

func (*TestStopMonitoringSubscriptionBroadcaster) Partner

func (c *TestStopMonitoringSubscriptionBroadcaster) Partner() *Partner

func (*TestStopMonitoringSubscriptionBroadcaster) RemoteCodeSpace

func (c *TestStopMonitoringSubscriptionBroadcaster) RemoteCodeSpace() string

type TestVMSubscriptionBroadcaster

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

func NewTestVMSubscriptionBroadcaster

func NewTestVMSubscriptionBroadcaster() *TestVMSubscriptionBroadcaster

func (*TestVMSubscriptionBroadcaster) HandleBroadcastEvent

func (connector *TestVMSubscriptionBroadcaster) HandleBroadcastEvent(event *model.VehicleBroadcastEvent)

func (*TestVMSubscriptionBroadcaster) Partner

func (c *TestVMSubscriptionBroadcaster) Partner() *Partner

func (*TestVMSubscriptionBroadcaster) RemoteCodeSpace

func (c *TestVMSubscriptionBroadcaster) RemoteCodeSpace() string

type TestValidationConnector

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

func (*TestValidationConnector) Partner

func (c *TestValidationConnector) Partner() *Partner

func (*TestValidationConnector) RemoteCodeSpace

func (c *TestValidationConnector) RemoteCodeSpace() string

type TestValidationFactory

type TestValidationFactory struct{}

func (*TestValidationFactory) CreateConnector

func (factory *TestValidationFactory) CreateConnector(partner *Partner) Connector

func (*TestValidationFactory) Validate

func (factory *TestValidationFactory) Validate(apiPartner *APIPartner)

type TripUpdatesBroadcaster

type TripUpdatesBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewTripUpdatesBroadcaster

func NewTripUpdatesBroadcaster(partner *Partner) *TripUpdatesBroadcaster

func (*TripUpdatesBroadcaster) HandleGtfs

func (connector *TripUpdatesBroadcaster) HandleGtfs(feed *gtfs.FeedMessage)

func (*TripUpdatesBroadcaster) Partner

func (c *TripUpdatesBroadcaster) Partner() *Partner

func (*TripUpdatesBroadcaster) RemoteCodeSpace

func (c *TripUpdatesBroadcaster) RemoteCodeSpace() string

func (*TripUpdatesBroadcaster) Start

func (connector *TripUpdatesBroadcaster) Start()

type TripUpdatesBroadcasterFactory

type TripUpdatesBroadcasterFactory struct{}

func (*TripUpdatesBroadcasterFactory) CreateConnector

func (factory *TripUpdatesBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*TripUpdatesBroadcasterFactory) Validate

func (factory *TripUpdatesBroadcasterFactory) Validate(apiPartner *APIPartner)

type UpdateSubscriber

type UpdateSubscriber func(model.UpdateEvent)

type VMBroadcaster

type VMBroadcaster struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type VMSubscriber

type VMSubscriber struct {
	clock.ClockConsumer
	// contains filtered or unexported fields
}

type VehicleMonitoringBroadcaster

type VehicleMonitoringBroadcaster interface {
	state.Stopable
	state.Startable
}

func NewFakeSIRIVehicleMonitoringBroadcaster

func NewFakeSIRIVehicleMonitoringBroadcaster(connector *SIRIVehicleMonitoringSubscriptionBroadcaster) VehicleMonitoringBroadcaster

func NewSIRIVehicleMonitoringBroadcaster

func NewSIRIVehicleMonitoringBroadcaster(connector *SIRIVehicleMonitoringSubscriptionBroadcaster) VehicleMonitoringBroadcaster

type VehicleMonitoringLiteRequestBroadcaster

type VehicleMonitoringLiteRequestBroadcaster interface {
	RequestVehicles(string, url.Values, *audit.BigQueryMessage) *siri.SiriLiteResponse
}

type VehicleMonitoringRequestBroadcaster

type VehicleMonitoringRequestBroadcaster interface {
	RequestVehicles(*sxml.XMLGetVehicleMonitoring, *audit.BigQueryMessage) *siri.SIRIVehicleMonitoringResponse
}

type VehicleMonitoringRequestCollector

type VehicleMonitoringRequestCollector interface {
	state.Startable

	RequestVehicleUpdate(request *VehicleUpdateRequest)
}

type VehicleMonitoringSubscriber

type VehicleMonitoringSubscriber struct {
	VMSubscriber
	// contains filtered or unexported fields
}

func (*VehicleMonitoringSubscriber) Start

func (subscriber *VehicleMonitoringSubscriber) Start()

func (*VehicleMonitoringSubscriber) Stop

func (subscriber *VehicleMonitoringSubscriber) Stop()

type VehicleMonitoringSubscriptionCollector

type VehicleMonitoringSubscriptionCollector interface {
	state.Stopable
	state.Startable

	RequestVehicleUpdate(request *VehicleUpdateRequest)
	HandleNotifyVehicleMonitoring(delivery *sxml.XMLNotifyVehicleMonitoring) *CollectedRefs
}

type VehicleMonitoringUpdateEventBuilder

type VehicleMonitoringUpdateEventBuilder struct {
	clock.ClockConsumer
	uuid.UUIDConsumer
	// contains filtered or unexported fields
}

func NewVehicleMonitoringUpdateEventBuilder

func NewVehicleMonitoringUpdateEventBuilder(partner *Partner) VehicleMonitoringUpdateEventBuilder

func (*VehicleMonitoringUpdateEventBuilder) SetUpdateEvents

func (builder *VehicleMonitoringUpdateEventBuilder) SetUpdateEvents(activities []*sxml.XMLVehicleActivity)

func (*VehicleMonitoringUpdateEventBuilder) UpdateEvents

func (builder *VehicleMonitoringUpdateEventBuilder) UpdateEvents() VehicleMonitoringUpdateEvents

type VehicleMonitoringUpdateEvents

type VehicleMonitoringUpdateEvents struct {
	StopAreas          map[string]*model.StopAreaUpdateEvent
	Lines              map[string]*model.LineUpdateEvent
	VehicleJourneys    map[string]*model.VehicleJourneyUpdateEvent
	Vehicles           map[string]*model.VehicleUpdateEvent
	VehicleRefs        map[string]struct{}
	LineRefs           map[string]struct{}
	VehicleJourneyRefs map[string]struct{}
	MonitoringRefs     map[string]struct{}
}

func (VehicleMonitoringUpdateEvents) GetLines

func (events VehicleMonitoringUpdateEvents) GetLines() []string

func (VehicleMonitoringUpdateEvents) GetStopAreas

func (events VehicleMonitoringUpdateEvents) GetStopAreas() []string

func (VehicleMonitoringUpdateEvents) GetVehicleJourneys

func (events VehicleMonitoringUpdateEvents) GetVehicleJourneys() []string

func (VehicleMonitoringUpdateEvents) GetVehicles

func (events VehicleMonitoringUpdateEvents) GetVehicles() []string

type VehiclePositionBroadcaster

type VehiclePositionBroadcaster struct {
	state.Startable
	// contains filtered or unexported fields
}

func NewVehiclePositionBroadcaster

func NewVehiclePositionBroadcaster(partner *Partner) *VehiclePositionBroadcaster

func (*VehiclePositionBroadcaster) HandleGtfs

func (connector *VehiclePositionBroadcaster) HandleGtfs(feed *gtfs.FeedMessage)

func (*VehiclePositionBroadcaster) Partner

func (c *VehiclePositionBroadcaster) Partner() *Partner

func (*VehiclePositionBroadcaster) RemoteCodeSpace

func (c *VehiclePositionBroadcaster) RemoteCodeSpace() string

func (*VehiclePositionBroadcaster) Start

func (connector *VehiclePositionBroadcaster) Start()

type VehiclePositionBroadcasterFactory

type VehiclePositionBroadcasterFactory struct{}

func (*VehiclePositionBroadcasterFactory) CreateConnector

func (factory *VehiclePositionBroadcasterFactory) CreateConnector(partner *Partner) Connector

func (*VehiclePositionBroadcasterFactory) Validate

func (factory *VehiclePositionBroadcasterFactory) Validate(apiPartner *APIPartner)

type VehicleUpdateRequest

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

func NewVehicleUpdateRequest

func NewVehicleUpdateRequest(lineId model.LineId) *VehicleUpdateRequest

func (*VehicleUpdateRequest) CreatedAt

func (vehicleUpdateRequest *VehicleUpdateRequest) CreatedAt() time.Time

func (*VehicleUpdateRequest) LineId

func (vehicleUpdateRequest *VehicleUpdateRequest) LineId() model.LineId