core

package
v0.0.0-...-f9f6af2 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2024 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
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_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_TRIP_UPDATES_BROADCASTER                   = "gtfs-rt-trip-updates-broadcaster"
	GTFS_RT_VEHICLE_POSITIONS_BROADCASTER              = "gtfs-rt-vehicle-positions-broadcaster"
	GRAPHQL_SERVER                                     = "graphql-server"
)
View Source 
const (
	SITUATION_UPDATE_REQUEST_ALL       = "requestAll"
	SITUATION_UPDATE_REQUEST_LINE      = "requestLine"
	SITUATION_UPDATE_REQUEST_STOP_AREA = "requestStopArea"
)
View Source 
const (
	EstimatedTimetableBroadcast  = "EstimatedTimetableBroadcast"
	GeneralMessageBroadcast      = "GeneralMessageBroadcast"
	ProductionTimetableBroadcast = "ProductionTimetableBroadcast"
	StopMonitoringBroadcast      = "StopMonitoringBroadcast"
	VehicleMonitoringBroadcast   = "VehicleMonitoringBroadcast"

	EstimatedTimetableCollect = "EstimatedTimetableCollect"
	GeneralMessageCollect     = "GeneralMessageCollect"
	SituationExchangeCollect  = "SituationExchangeCollect"
	StopMonitoringCollect     = "StopMonitoringCollect"
	VehicleMonitoringCollect  = "VehicleMonitoringCollect"
)
View Source 
const (
	DELETED_SUBSCRIPTION_TIMER = 5 * time.Minute
)
View Source 
const (
	PAST_STOP_VISITS_MAX_TIME = -2 * time.Minute
)

Variables

This section is empty.

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) 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.GeneralMessageBroadcastEvent

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.GeneralMessageBroadcastEvent
	GetVehicleBroadcastEventChan() chan model.VehicleBroadcastEvent
}

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

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

func (*CollectManager) BroadcastSituationUpdateEvent 

func (manager *CollectManager) BroadcastSituationUpdateEvent(event []*model.SituationUpdateEvent)

func (*CollectManager) BroadcastUpdateEvent 

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

func (*CollectManager) HandlePartnerStatusChange 

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

func (*CollectManager) HandleSituationUpdateEvent 

func (manager *CollectManager) HandleSituationUpdateEvent(SituationUpdateSubscriber SituationUpdateSubscriber)

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)

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

	UpdateSituation(request *SituationUpdateRequest)
	HandleSituationUpdateEvent(SituationUpdateSubscriber)
	BroadcastSituationUpdateEvent(event []*model.SituationUpdateEvent)
}

func NewCollectManager 

func NewCollectManager(referential *Referential) CollectManagerInterface

func NewTestCollectManager 

func NewTestCollectManager() CollectManagerInterface

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
	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
}

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 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 *[]*model.SituationUpdateEvent, xmlResponse *sxml.XMLGeneralMessageDelivery, producerRef string)

func (*GeneralMessageUpdateEventBuilder) SetGeneralMessageResponseUpdateEvents 

func (builder *GeneralMessageUpdateEventBuilder) SetGeneralMessageResponseUpdateEvents(event *[]*model.SituationUpdateEvent, 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

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) 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) 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) 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

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) 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) 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) 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) 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) RequestAllSituationsUpdate 

func (connector *SIRIGeneralMessageRequestCollector) RequestAllSituationsUpdate()

func (*SIRIGeneralMessageRequestCollector) RequestSituationUpdate 

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

func (*SIRIGeneralMessageRequestCollector) SetSituationUpdateSubscriber 

func (connector *SIRIGeneralMessageRequestCollector) SetSituationUpdateSubscriber(situationUpdateSubscriber SituationUpdateSubscriber)

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.GeneralMessageBroadcastEvent)

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) 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) 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(situationUpdateSubscriber SituationUpdateSubscriber)

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) 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) 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) 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) 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) 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) 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 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) 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) RequestAllSituationsUpdate 

func (connector *SIRISituationExchangeRequestCollector) RequestAllSituationsUpdate()

func (*SIRISituationExchangeRequestCollector) RequestSituationUpdate 

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

func (*SIRISituationExchangeRequestCollector) SetSituationUpdateSubscriber 

func (connector *SIRISituationExchangeRequestCollector) SetSituationUpdateSubscriber(situationUpdateSubscriber SituationUpdateSubscriber)

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 NewSIRISituationExchangeSubscriber 

func NewSIRISituationExchangeSubscriber(connector *SIRISituationExchangeSubscriptionCollector) SIRISituationExchangeSubscriber

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) 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(situationUpdateSubscriber SituationUpdateSubscriber)

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) 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) 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) 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) 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) 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) 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

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) 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) 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) 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) 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 SXSubscriber 

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

type ServiceRequestBroadcaster 

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

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(event *[]*model.SituationUpdateEvent, xmlSituationExchangeDelivery *sxml.XMLSituationExchangeDelivery, producerRef string)

func (*SituationExchangeUpdateEventBuilder) SetSituationExchangeUpdateEvents 

func (builder *SituationExchangeUpdateEventBuilder) SetSituationExchangeUpdateEvents(event *[]*model.SituationUpdateEvent, 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 SituationUpdateSubscriber 

type SituationUpdateSubscriber func([]*model.SituationUpdateEvent)

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) 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) BroadcastSituationUpdateEvent 

func (manager *TestCollectManager) BroadcastSituationUpdateEvent(event []*model.SituationUpdateEvent)

func (*TestCollectManager) BroadcastUpdateEvent 

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

func (*TestCollectManager) HandlePartnerStatusChange 

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

func (*TestCollectManager) HandleSituationUpdateEvent 

func (manager *TestCollectManager) HandleSituationUpdateEvent(SituationUpdateSubscriber)

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

type TestGeneralMessageSubscriptionBroadcaster 

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

func NewTestGeneralMessageSubscriptionBroadcaster 

func NewTestGeneralMessageSubscriptionBroadcaster() *TestGeneralMessageSubscriptionBroadcaster

func (*TestGeneralMessageSubscriptionBroadcaster) HandleGeneralMessageBroadcastEvent 

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

func (*TestGeneralMessageSubscriptionBroadcaster) Partner 

func (c *TestGeneralMessageSubscriptionBroadcaster) Partner() *Partner

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) 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) 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

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

type TestValidationConnector 

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

func (*TestValidationConnector) Partner 

func (c *TestValidationConnector) Partner() *Partner

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) 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) 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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.