util

package

v0.0.41 Latest Latest Go to latest Published: Dec 18, 2025 License: Apache-2.0 Imports: 11 Imported by: 7

Documentation ¶

Index ¶

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

Constants ¶

const CALLER_CAMUNDA_LOOP = "camunda_loop"

View Source

const CALLER_RESPONSE = "response"

View Source

const CAMUNDA_VARIABLES_INCIDENT = "incident"

View Source

const CAMUNDA_VARIABLES_OVERWRITE = "overwrite"

View Source

const CAMUNDA_VARIABLES_PAYLOAD = "payload"

View Source

const OPTIMISTIC = "optimistic"

View Source

const PARALLEL = "parallel"

View Source

const PESSIMISTIC = "pessimistic"

View Source

const ROUND_ROBIN = "round_robin"

View Source

const SEQUENTIAL = "sequential"

Variables ¶

View Source

var GetId = 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 ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	PrometheusPort                  string
	ShardsDb                        string `config:"secret"`
	DeviceRepoUrl                   string
	CompletionStrategy              string
	OptimisticTaskCompletionTimeout int64
	CamundaLongPollTimeout          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
	UseHttpIncidentProducer         bool
	IncidentApiUrl                  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

	ApiDocsProviderBaseUrl string

	InitTopics bool
}

func LoadConfig ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL