Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var NewId = func() string { return uuid.NewString() }
to replace when testing
View Source
var TimeNow = func() time.Time { return time.Now() }
to replace time when testing
Functions ¶
Types ¶
type ConfigStruct ¶
type ConfigStruct struct { LogLevel string `json:"log_level"` ApiPort string `json:"api_port"` MetricsPort string `json:"metrics_port"` MarshallerUrl string `json:"marshaller_url"` ConverterUrl string `json:"converter_url"` ExtendedConverterUrl string `json:"extended_converter_url"` KafkaUrl string `json:"kafka_url"` FlowEngineUrl string `json:"flow_engine_url"` FlowParserUrl string `json:"flow_parser_url"` PipelineRepoUrl string `json:"pipeline_repo_url"` ImportDeployUrl string `json:"import_deploy_url"` ConsumerGroup string `json:"consumer_group"` Debug bool `json:"debug"` DeploymentTopic string `json:"deployment_topic"` ConnectivityTest bool `json:"connectivity_test"` EventTriggerUrl string `json:"event_trigger_url"` DevicePathPrefix string `json:"device_path_prefix"` GroupPathPrefix string `json:"group_path_prefix"` ImportPathPrefix string `json:"import_path_prefix"` GenericSourcePathPrefix string `json:"generic_source_path_prefix"` ConditionalEventRepoMongoUrl string `json:"conditional_event_repo_mongo_url"` ConditionalEventRepoMongoTable string `json:"conditional_event_repo_mongo_table"` ConditionalEventRepoMongoDescCollection string `json:"conditional_event_repo_mongo_desc_collection"` ConditionalEventRepoMongoDeploymentsCollection string `json:"conditional_event_repo_mongo_deployments_collection"` ImportRepositoryUrl string `json:"import_repository_url"` DeviceRepositoryUrl string `json:"device_repository_url"` //if not configured: no device-group updates handled DeviceGroupTopic string `json:"device_group_topic"` //if not configured: no deployment done events are published DeploymentDoneTopic string `json:"deployment_done_topic"` //if not configured: events with groups not handled PermSearchUrl string `json:"perm_search_url"` AuthExpirationTimeBuffer float64 `json:"auth_expiration_time_buffer"` AuthEndpoint string `json:"auth_endpoint"` AuthClientId string `json:"auth_client_id"` AuthClientSecret string `json:"auth_client_secret"` AnalyticsPipelineBatchSize int64 `json:"analytics_pipeline_batch_size"` AnalyticsRequestTimeout string `json:"analytics_request_timeout"` HttpClientTimeout string `json:"http_client_timeout"` HttpServerTimeout string `json:"http_server_timeout"` HttpServerReadTimeout string `json:"http_server_read_timeout"` EnableMultiplePaths bool `json:"enable_multiple_paths"` EnableAnalyticsEvents bool `json:"enable_analytics_events"` IgnoreAnalyticsEventErrors bool `json:"ignore_analytics_event_errors"` }
Click to show internal directories.
Click to hide internal directories.