configuration

Documentation

Index

• type Config
  • func Load(location string) (config Config, err error)
  • func (this Config) HandleFatalError(v ...interface{})
  • func (this Config) LogTrace(key string, values ...interface{})
• type Mode

Types

type Config

type Config struct {
	Debug bool `json:"debug"`
	Mode  Mode `json:"mode"`

	CacheInvalidationKafkaTopics []string `json:"cache_invalidation_kafka_topics"`

	MetricsPort string `json:"metrics_port"`

	ChannelSize        int `json:"channel_size"`
	ChannelWorkerCount int `json:"channel_worker_count"`

	MaxMessageAge string `json:"max_message_age"`

	AuthEndpoint             string  `json:"auth_endpoint"`
	AuthClientId             string  `json:"auth_client_id" config:"secret"`
	AuthExpirationTimeBuffer float64 `json:"auth_expiration_time_buffer"`

	DeviceRepoUrl           string `json:"device_repo_url"`
	DeviceRepoCacheDuration string `json:"device_repo_cache_duration"`

	NotificationUrl                            string `json:"notification_url"`
	NotificationsIgnoreDuplicatesWithinSeconds string `json:"notifications_ignore_duplicates_within_seconds"`

	EventTriggerUrl string `json:"event_trigger_url"` // Cloud: http://engine-wrapper-url:8080/v2/event-trigger or Fog: http://local-camunda-url:8080/engine-rest/message

	//fog
	MgwMqttPw       string `json:"mgw_mqtt_pw" config:"secret"`
	MgwMqttUser     string `json:"mgw_mqtt_user" config:"secret"`
	MgwMqttClientId string `json:"mgw_mqtt_client_id"`
	MgwMqttBroker   string `json:"mgw_mqtt_broker"`
	MgwMqttQos      byte   `json:"mgw_mqtt_qos"`

	MgwProcessSyncClientUrl string `json:"mgw_process_sync_client_url"`

	AuthUserName string `json:"auth_user_name" config:"secret"`
	AuthPassword string `json:"auth_password" config:"secret"`

	FallbackFile string `json:"fallback_file"`

	FogProtocol              interface{} `json:"fog_protocol"`
	FogProtocolDataFieldName string      `json:"fog_protocol_data_field_name"`

	//cloud
	KafkaUrl                            string              `json:"kafka_url"`
	KafkaConsumerGroup                  string              `json:"kafka_consumer_group"`
	DeviceTypeTopic                     string              `json:"device_type_topic"`
	ProcessDeploymentTopic              string              `json:"process_deployment_topic"`
	ProcessDeploymentDoneTopic          string              `json:"process_deployment_done_topic"`
	WatchedProcessDeploymentDoneHandler string              `json:"watched_process_deployment_done_handler"`
	KafkaTopicSliceCount                int                 `json:"kafka_topic_slice_count"`
	KafkaTopicSliceIndex                int                 `json:"kafka_topic_slice_index"`
	InstanceId                          string              `json:"instance_id"`
	ServiceTopicConfig                  []kafka.ConfigEntry `json:"service_topic_config"`

	CloudEventRepoCacheDuration       string `json:"cloud_event_repo_cache_duration"`
	CloudEventRepoMongoUrl            string `json:"cloud_event_repo_mongo_url"`
	CloudEventRepoMongoTable          string `json:"cloud_event_repo_mongo_table"`
	CloudEventRepoMongoDescCollection string `json:"cloud_event_repo_mongo_desc_collection"`

	AuthClientSecret string `json:"auth_client_secret" config:"secret"`

	DebugTraceKeys  []string `json:"debug_trace_keys"`
	DebugTraceIndex map[string]bool

	//all
	FatalErrHandler func(v ...interface{})
}

func Load

func Load(location string) (config Config, err error)

loads config from json in location and used environment variables (e.g KafkaUrl --> KAFKA_URL)

func (Config) HandleFatalError

func (this Config) HandleFatalError(v ...interface{})

func (Config) LogTrace

func (this Config) LogTrace(key string, values ...interface{})

type Mode

type Mode = string

var CloudMode Mode = "cloud"

var FogMode Mode = "fog"