settings

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: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LOCAL_CREDENTIAL  = "local_credential"
	LOCAL_CREDENTIALS = "local_credentials"
	LOCAL_URL         = "local_url"
	RATE_LIMIT_PER_IP = "rate_limit_per_ip"

	PARTNER_MAX_RETRY = "partner.status.maximum_retry"

	REMOTE_CREDENTIAL                 = "remote_credential"
	REMOTE_CODE_SPACE                 = "remote_code_space"
	VEHICLE_REMOTE_CODE_SPACE         = "vehicle_remote_code_space"
	VEHICLE_JOURNEY_REMOTE_CODE_SPACE = "vehicle_journey_remote_code_space"
	REMOTE_URL                        = "remote_url"
	NOTIFICATIONS_REMOTE_URL          = "notifications.remote_url"
	SUBSCRIPTIONS_REMOTE_URL          = "subscriptions.remote_url"

	COLLECT_DEFAULT_SRS_NAME         = "collect.default_srs_name"
	COLLECT_EXCLUDE_LINES            = "collect.exclude_lines"
	COLLECT_EXCLUDE_STOP_AREAS       = "collect.exclude_stop_areas"
	COLLECT_FILTER_GENERAL_MESSAGES  = "collect.filter_general_messages" // Kept for retro compatibility
	COLLECT_FILTER_SITUATIONS        = "collect.filter_situations"
	COLLECT_GTFS_TTL                 = "collect.gtfs.ttl"
	COLLECT_INCLUDE_LINES            = "collect.include_lines"
	COLLECT_INCLUDE_STOP_AREAS       = "collect.include_stop_areas"
	COLLECT_PERSISTENT               = "collect.persistent"
	COLLECT_PRIORITY                 = "collect.priority"
	COLLECT_SITUATIONS_INTERNAL_TAGS = "collect.situations.internal_tags"
	COLLECT_SUBSCRIPTIONS_PERSISTENT = "collect.subscriptions.persistent"
	COLLECT_USE_DISCOVERED_LINES     = "collect.use_discovered_lines"
	COLLECT_USE_DISCOVERED_SA        = "collect.use_discovered_stop_areas"

	DISCOVERY_INTERVAL = "discovery_interval"

	BROADCAST_GTFS_CACHE_TIMEOUT                          = "broadcast.gtfs.cache_timeout"
	BROADCAST_GZIP_GTFS                                   = "broadcast.gzip_gtfs"
	BROADCAST_NO_DATAFRAMEREF_REWRITING_FROM              = "broadcast.no_dataframeref_rewriting_from"
	BROADCAST_NO_DESTINATIONREF_REWRITING_FROM            = "broadcast.no_destinationref_rewriting_from"
	BROADCAST_PREFER_REFERENT_STOP_AREAS                  = "broadcast.prefer_referent_stop_areas"
	BROADCAST_RECORDED_CALLS_DURATION                     = "broadcast.recorded_calls.duration"
	BROADCAST_REWRITE_JOURNEY_PATTERN_REF                 = "broadcast.rewrite_journey_pattern_ref"
	BROADCAST_SIRI_IGNORE_TERMINATE_SUBSCRIPTION_REQUESTS = "broadcast.siri.ignore_terminate_subscription_requests"
	BROADCAST_SIRI_SM_MULTIPLE_SUBSCRIPTIONS              = "broadcast.siri.stop_monitoring.multiple_subscriptions"
	BROADCAST_SITUATIONS_INTERNAL_TAGS                    = "broadcast.situations.internal_tags"
	BROADCAST_SUBSCRIPTIONS_PERSISTENT                    = "broadcast.subscriptions.persistent"

	IGNORE_STOP_WITHOUT_LINE        = "ignore_stop_without_line"
	GENERAL_MESSAGE_REQUEST_2_2     = "generalMessageRequest.version2.2"
	SUBSCRIPTIONS_MAXIMUM_RESOURCES = "subscriptions.maximum_resources"

	CACHE_TIMEOUT = "cache_timeout"

	OAUTH_CLIENT_ID     = "remote_authentication.oauth.client_id"
	OAUTH_CLIENT_SECRET = "remote_authentication.oauth.client_secret"
	OAUTH_TOKEN_URL     = "remote_authentication.oauth.token_url"
	OAUTH_SCOPES        = "remote_authentication.oauth.scopes"

	SIRI_ENVELOPE                            = "siri.envelope"
	SIRI_LINE_PUBLISHED_NAME                 = "siri.line.published_name"
	SIRI_DIRECTION_TYPE                      = "siri.direction_type"
	SIRI_PASSAGE_ORDER                       = "siri.passage_order"
	SIRI_CREDENTIAL_HEADER                   = "siri.credential.header"
	SIRI_SOAP_EMPTY_RESPONSE_ON_NOTIFICATION = "siri.soap.empty_response_on_notification"
	DEFAULT_GTFS_TTL                         = 30 * time.Second

	SORT_PAYLOAD_FOR_TEST = "sort_payload_for_test"

	GRAPHQL_MUTABLE_ATTRIBUTES = "graphql.mutable_attributes"
)
View Source 
const (
	MODEL_RELOAD_AT            = "model.reload_at"
	MODEL_PERSISTENCE          = "model.persistence"
	MODEL_REFRESH_TIME         = "model.refresh_time"
	LOGGER_VERBOSE_STOP_AREAS  = "logger.verbose.stop_areas"
	DEFAULT_MODEL_REFRESH_TIME = 50 * time.Second
	MINIMUM_MODEL_REFRESH_TIME = 30 * time.Second
	DEFAULT_MODEL_PERSISTENCE  = 3 * time.Hour
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CollectSettings 

type CollectSettings struct {
	UseDiscoveredSA    bool
	UseDiscoveredLines bool
	// contains filtered or unexported fields
}

func (*CollectSettings) CanCollectLine 

func (cs *CollectSettings) CanCollectLine(lineId string) CollectStatus

func (*CollectSettings) CanCollectLines 

func (cs *CollectSettings) CanCollectLines(lineIds map[string]struct{}) CollectStatus

func (*CollectSettings) CanCollectStop 

func (cs *CollectSettings) CanCollectStop(s string) CollectStatus

func (*CollectSettings) Empty 

func (cs *CollectSettings) Empty() bool

func (*CollectSettings) ExcludeLine 

func (cs *CollectSettings) ExcludeLine(lineId string) CollectStatus

func (*CollectSettings) ExcludeStop 

func (cs *CollectSettings) ExcludeStop(s string) CollectStatus

func (*CollectSettings) IncludeLine 

func (cs *CollectSettings) IncludeLine(lineId string) CollectStatus

func (*CollectSettings) IncludeStop 

func (cs *CollectSettings) IncludeStop(s string) CollectStatus

type CollectStatus 

type CollectStatus int64
const (
	COLLECT_UNKNOWN CollectStatus = iota
	CAN_COLLECT
	CANNOT_COLLECT
)

type PartnerSettings 

type PartnerSettings struct {
	idgen.IdentifierGenerator
	// contains filtered or unexported fields
}

func NewEmptyPartnerSettings 

func NewEmptyPartnerSettings(ug func() uuid.UUIDGenerator) *PartnerSettings

func NewPartnerSettings 

func NewPartnerSettings(generator func() uuid.UUIDGenerator, settings map[string]string) *PartnerSettings

func (*PartnerSettings) Address 

func (s *PartnerSettings) Address() string

func (*PartnerSettings) BroadcastSituationsInternalTags 

func (s *PartnerSettings) BroadcastSituationsInternalTags() []string

func (*PartnerSettings) CacheTimeout 

func (s *PartnerSettings) CacheTimeout(connectorName string) (t time.Duration)

func (*PartnerSettings) CollectFilteredSituations 

func (s *PartnerSettings) CollectFilteredSituations() bool

func (*PartnerSettings) CollectPriority 

func (s *PartnerSettings) CollectPriority() int

func (*PartnerSettings) CollectSettings 

func (s *PartnerSettings) CollectSettings() *CollectSettings

func (*PartnerSettings) CollectSituationsInternalTags 

func (s *PartnerSettings) CollectSituationsInternalTags() []string

func (*PartnerSettings) Credentials 

func (s *PartnerSettings) Credentials() string

func (*PartnerSettings) DefaultSRSName 

func (s *PartnerSettings) DefaultSRSName() string

func (*PartnerSettings) DiscoveryInterval 

func (s *PartnerSettings) DiscoveryInterval() time.Duration

func (*PartnerSettings) GeneralMessageRequestVersion22 

func (s *PartnerSettings) GeneralMessageRequestVersion22() bool

func (*PartnerSettings) GtfsCacheTimeout 

func (s *PartnerSettings) GtfsCacheTimeout() (t time.Duration)

Very specific for now, we'll refacto if we need to cache more

func (*PartnerSettings) GtfsTTL 

func (s *PartnerSettings) GtfsTTL() (t time.Duration)

func (*PartnerSettings) GzipGtfs 

func (s *PartnerSettings) GzipGtfs() bool

func (*PartnerSettings) HTTPClientOAuth 

func (s *PartnerSettings) HTTPClientOAuth() *remote.HTTPClientOAuth

func (*PartnerSettings) HTTPClientOptions 

func (s *PartnerSettings) HTTPClientOptions() remote.HTTPClientOptions

func (*PartnerSettings) IgnoreStopWithoutLine 

func (s *PartnerSettings) IgnoreStopWithoutLine() bool

func (*PartnerSettings) IgnoreTerminateSubscriptionsRequest 

func (s *PartnerSettings) IgnoreTerminateSubscriptionsRequest() bool

func (*PartnerSettings) IsMutable 

func (s *PartnerSettings) IsMutable(attribute string) (ok bool)

func (*PartnerSettings) MaximumChechstatusRetry 

func (s *PartnerSettings) MaximumChechstatusRetry() int

func (*PartnerSettings) NoDataFrameRefRewritingFrom 

func (s *PartnerSettings) NoDataFrameRefRewritingFrom() []string

func (*PartnerSettings) NoDestinationRefRewritingFrom 

func (s *PartnerSettings) NoDestinationRefRewritingFrom() []string

func (*PartnerSettings) PersistentBroadcastSubscriptions 

func (s *PartnerSettings) PersistentBroadcastSubscriptions() bool

func (*PartnerSettings) PersistentCollect 

func (s *PartnerSettings) PersistentCollect() bool

func (*PartnerSettings) PreferReferentStopArea 

func (s *PartnerSettings) PreferReferentStopArea() bool

func (*PartnerSettings) ProducerRef 

func (s *PartnerSettings) ProducerRef() string

func (*PartnerSettings) RateLimit 

func (s *PartnerSettings) RateLimit() float64

func (*PartnerSettings) RecordedCallsDuration 

func (s *PartnerSettings) RecordedCallsDuration() (t time.Duration)

func (*PartnerSettings) RemoteCodeSpace 

func (s *PartnerSettings) RemoteCodeSpace(optionalConnectorName ...string) string

func (*PartnerSettings) RequestorRef 

func (s *PartnerSettings) RequestorRef() string

func (*PartnerSettings) RewriteJourneyPatternRef 

func (s *PartnerSettings) RewriteJourneyPatternRef() bool

func (*PartnerSettings) SIRIDirectionType 

func (s *PartnerSettings) SIRIDirectionType() (string, string, bool)

func (*PartnerSettings) SIRIEnvelopeType 

func (s *PartnerSettings) SIRIEnvelopeType() string

func (*PartnerSettings) SIRILinePublishedName 

func (s *PartnerSettings) SIRILinePublishedName() string

func (*PartnerSettings) SIRIPassageOrder 

func (s *PartnerSettings) SIRIPassageOrder() string

func (*PartnerSettings) SettingsDefinition 

func (s *PartnerSettings) SettingsDefinition() map[string]string

func (*PartnerSettings) SiriCredentialHeader 

func (s *PartnerSettings) SiriCredentialHeader() string

func (*PartnerSettings) SiriEnvelopeType 

func (s *PartnerSettings) SiriEnvelopeType() string

func (*PartnerSettings) SiriSoapEmptyResponseOnNotification 

func (s *PartnerSettings) SiriSoapEmptyResponseOnNotification() bool

func (*PartnerSettings) SmMultipleDeliveriesPerNotify 

func (s *PartnerSettings) SmMultipleDeliveriesPerNotify() bool

func (*PartnerSettings) SortPaylodForTest 

func (s *PartnerSettings) SortPaylodForTest() bool

func (*PartnerSettings) SubscriptionMaximumResources 

func (s *PartnerSettings) SubscriptionMaximumResources() int

func (*PartnerSettings) VehicleJourneyRemoteCodeSpaceWithFallback 

func (s *PartnerSettings) VehicleJourneyRemoteCodeSpaceWithFallback(connectorName string) []string

func (*PartnerSettings) VehicleRemoteCodeSpaceWithFallback 

func (s *PartnerSettings) VehicleRemoteCodeSpaceWithFallback(connectorName string) []string

type ReferentialSettings 

type ReferentialSettings struct {
	Settings
}

func NewReferentialSettings 

func NewReferentialSettings() (rs ReferentialSettings)

func (*ReferentialSettings) LoggerVerboseStopAreas 

func (rs *ReferentialSettings) LoggerVerboseStopAreas() []model.Code

func (*ReferentialSettings) ModelPersistenceDuration 

func (rs *ReferentialSettings) ModelPersistenceDuration() (d time.Duration)

func (*ReferentialSettings) ModelRefreshTime 

func (rs *ReferentialSettings) ModelRefreshTime() (d time.Duration)

func (*ReferentialSettings) NextReloadAtSetting 

func (rs *ReferentialSettings) NextReloadAtSetting() (hour, minute int)

type Settings 

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

func NewSettings 

func NewSettings() Settings

func (*Settings) SetSetting 

func (s *Settings) SetSetting(k, v string)

Should only be used in tests

func (*Settings) SetSettingsDefinition 

func (s *Settings) SetSettingsDefinition(m map[string]string)

func (*Settings) Setting 

func (s *Settings) Setting(key string) string

func (*Settings) SettingsDefinition 

func (s *Settings) SettingsDefinition() (m map[string]string)

func (*Settings) SettingsLen 

func (s *Settings) SettingsLen() int

func (*Settings) ToJson 

func (s *Settings) ToJson() ([]byte, error)

Source Files

View all Source files

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.