util

Documentation

Index

• Constants
• Variables
• type Config
  • func LoadConfig(location string) (config Config, err error)

Constants

const CALLER_CAMUNDA_LOOP = "camunda_loop"

const CALLER_RESPONSE = "response"

const CAMUNDA_VARIABLES_INCIDENT = "incident"

const CAMUNDA_VARIABLES_OVERWRITE = "overwrite"

const CAMUNDA_VARIABLES_PAYLOAD = "payload"

const OPTIMISTIC = "optimistic"

const PARALLEL = "parallel"

const PESSIMISTIC = "pessimistic"

const ROUND_ROBIN = "round_robin"

const SEQUENTIAL = "sequential"

Variables

var GetId = func() string {
	return uuid.NewString()
}

to replace when testing

var TimeNow = func() time.Time {
	return time.Now()
}

to replace time when testing

Types

type Config

type Config struct {
	PrometheusPort                  string
	ShardsDb                        string `config:"secret"`
	DeviceRepoUrl                   string
	CompletionStrategy              string
	OptimisticTaskCompletionTimeout int64
	CamundaWorkerTimeout            int64
	CamundaWorkerTasks              int64
	CamundaFetchLockDuration        int64
	CamundaTopic                    string
	CamundaTaskResultName           string
	KafkaUrl                        string
	KafkaConsumerGroup              string
	ResponseTopic                   string
	AuthExpirationTimeBuffer        float64
	AuthEndpoint                    string
	AuthClientId                    string `config:"secret"`
	AuthClientSecret                string `config:"secret"`
	JwtPrivateKey                   string `config:"secret"`
	JwtExpiration                   int64
	JwtIssuer                       string
	KafkaIncidentTopic              string
	Debug                           bool
	MarshallerUrl                   string
	HealthCheckPort                 string
	GroupScheduler                  string

	HandleMissingLastValueTimeAsError bool //set to true for mgw implementations of last-value / TimescaleWrapperUrl
	TimescaleWrapperUrl               string

	HttpCommandConsumerPort string
	HttpCommandConsumerSync bool
	MetadataResponseTo      string
	DisableKafkaConsumer    bool
	DisableHttpConsumer     bool

	AsyncFlushFrequency string
	AsyncCompression    string
	SyncCompression     string
	Sync                bool
	SyncIdempotent      bool
	PartitionNum        int64
	ReplicationFactor   int64
	AsyncFlushMessages  int64

	KafkaConsumerMaxWait  string
	KafkaConsumerMinBytes int64
	KafkaConsumerMaxBytes int64

	SubResultExpirationInSeconds int32
	SubResultDatabaseUrls        []string
	MemcachedTimeout             string
	MemcachedMaxIdleConns        int64

	ResponseWorkerCount int64

	MetadataErrorTo string
	ErrorTopic      string

	CacheTimeout                    string
	CacheInvalidationAllKafkaTopics []string
	DeviceKafkaTopic                string
	DeviceGroupKafkaTopic           string

	KafkaTopicConfigs map[string][]kafka.ConfigEntry

	IgnoreUserMetrics []string
}

func LoadConfig

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