Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
KafkaUrl string `json:"kafka_url"`
KafkaResponseTopic string `json:"kafka_response_topic"`
KafkaGroupName string `json:"kafka_group_name"`
FatalKafkaError bool `json:"fatal_kafka_error"`
Protocol string `json:"protocol"`
DeviceManagerUrl string `json:"device_manager_url"`
DeviceRepoUrl string `json:"device_repo_url"`
AuthClientId string `json:"auth_client_id" config:"secret"`
AuthClientSecret string `json:"auth_client_secret" config:"secret"`
AuthExpirationTimeBuffer float64 `json:"auth_expiration_time_buffer"`
AuthEndpoint string `json:"auth_endpoint"`
JwtPrivateKey string `json:"jwt_private_key" config:"secret"`
JwtExpiration int64 `json:"jwt_expiration"`
JwtIssuer string `json:"jwt_issuer" config:"secret"`
DeviceExpiration int32 `json:"device_expiration"`
DeviceTypeExpiration int32 `json:"device_type_expiration"`
TokenCacheExpiration int32 `json:"token_cache_expiration"`
IotCacheUrl []string `json:"iot_cache_url"`
TokenCacheUrl []string `json:"token_cache_url" config:"secret"`
SyncKafka bool `json:"sync_kafka"`
SyncKafkaIdempotent bool `json:"sync_kafka_idempotent"`
Debug bool `json:"debug"`
MqttBroker string `json:"mqtt_broker"`
MqttClientId string `json:"mqtt_client_id"`
Qos byte `json:"qos"`
MqttLogLevel string `json:"mqtt_log_level"`
MqttVersion string `json:"mqtt_version"`
MqttAuthMethod string `json:"mqtt_auth_method"` // Whether the MQTT broker uses a username/password or client certificate authetication
WebhookPort string `json:"webhook_port"`
HttpCommandConsumerPort string `json:"http_command_consumer_port"`
ActuatorTopicPattern string `json:"actuator_topic_pattern"`
SerializationFallback string `json:"serialization_fallback"`
Validate bool `json:"validate"`
ValidateAllowUnknownField bool `json:"validate_allow_unknown_field"`
ValidateAllowMissingField bool `json:"validate_allow_missing_field"`
KafkaProducerSlowTimeoutSec int64 `json:"kafka_producer_slow_timeout_sec"`
KafkaPartitionNum int `json:"kafka_partition_num"`
KafkaReplicationFactor int `json:"kafka_replication_factor"`
PublishToPostgres bool `json:"publish_to_postgres"`
PostgresHost string `json:"postgres_host"`
PostgresPort int `json:"postgres_port"`
PostgresUser string `json:"postgres_user" config:"secret"`
PostgresPw string `json:"postgres_pw" config:"secret"`
PostgresDb string `json:"postgres_db"`
AsyncPgThreadMax int64 `json:"async_pg_thread_max"`
AsyncFlushMessages int64 `json:"async_flush_messages"`
AsyncFlushFrequency string `json:"async_flush_frequency"`
AsyncCompression string `json:"async_compression"`
SyncCompression string `json:"sync_compression"`
KafkaConsumerMaxWait string `json:"kafka_consumer_max_wait"`
KafkaConsumerMinBytes int64 `json:"kafka_consumer_min_bytes"`
KafkaConsumerMaxBytes int64 `json:"kafka_consumer_max_bytes"`
IotCacheMaxIdleConns int64 `json:"iot_cache_max_idle_conns"`
IotCacheTimeout string `json:"iot_cache_timeout"`
CommandWorkerCount int64 `json:"command_worker_count"`
SubscriptionDbConStr string `json:"subscription_db_con_str"`
DeviceLogTopic string `json:"device_log_topic"`
DeviceTypeTopic string `json:"device_type_topic"`
NotificationUrl string `json:"notification_url"`
PermissionsV2Url string `json:"permissions_v2_url"`
NotificationsIgnoreDuplicatesWithinS int `json:"notifications_ignore_duplicates_within_s"`
NotificationUserOverwrite string `json:"notification_user_overwrite"`
DeveloperNotificationUrl string `json:"developer_notification_url"`
MutedUserNotificationTitles []string `json:"muted_user_notification_titles"`
SecRemoteProtocol string `json:"sec_remote_protocol"`
KafkaTopicConfigs map[string][]kafka.ConfigEntry `json:"kafka_topic_configs"`
ConnectionCheckUrl string
ConnectionCheckHttpTimeout string
ApiDocsProviderBaseUrl string `json:"api_docs_provider_base_url"`
StartupDelay int64 `json:"startup_delay"`
InitTopics bool `json:"init_topics"`
}
func LoadConfig ¶
func LoadConfigFlag ¶
Click to show internal directories.
Click to hide internal directories.