config

Documentation

Index

• func IsE2ETestTransactionID(tid string, e2eTestUUIDs []string) bool
• type AppConfig
  • func NewAppConfig(configFileName string, log *logger.UPPLogger) (*AppConfig, error)
  • func (cfg *AppConfig) GetCapability(metricAlias string) *Capability
• type Capability
• type HealthConfig
• type MetricConfig
• type Publication
• type PublicationsConfig
  • func (cfg *PublicationsConfig) GetXReadPolicies() []string
• type QueueConfig
• type SplunkConfig

Functions

func IsE2ETestTransactionID

func IsE2ETestTransactionID(tid string, e2eTestUUIDs []string) bool

Types

type AppConfig

type AppConfig struct {
	Threshold                               int               `json:"threshold"` // pub SLA in seconds, ex. 120
	QueueConf                               QueueConfig       `json:"queueConfig"`
	MetricConf                              []MetricConfig    `json:"metricConfig"`
	SplunkConf                              SplunkConfig      `json:"splunk-config"`
	HealthConf                              HealthConfig      `json:"healthConfig"`
	ValidationEndpoints                     map[string]string `json:"validationEndpoints"` // contentType to validation endpoint mapping
	Capabilities                            []Capability      `json:"capabilities"`
	GraphiteAddress                         string            `json:"graphiteAddress"`
	GraphiteUUID                            string            `json:"graphiteUUID"`
	Environment                             string            `json:"environment"`
	NotificationsPushPublicationMonitorList string            `json:"notificationsPushPublicationMonitorList"`
}

AppConfig holds the application's configuration

func NewAppConfig

func NewAppConfig(configFileName string, log *logger.UPPLogger) (*AppConfig, error)

NewAppConfig opens the file at configFileName and unmarshals it into an AppConfig.

func (*AppConfig) GetCapability

func (cfg *AppConfig) GetCapability(metricAlias string) *Capability

type Capability

type Capability struct {
	Name        string   `json:"name"`
	MetricAlias string   `json:"metricAlias"`
	TestIDs     []string `json:"testIDs"`
}

Capability represents business capability configuration

type HealthConfig

type HealthConfig struct {
	FailureThreshold int `json:"failureThreshold"`
}

HealthConfig holds the application's healthchecks configuration

type MetricConfig

type MetricConfig struct {
	Granularity  int      `json:"granularity"` // how we split up the threshold, ex. 120/12
	Endpoint     string   `json:"endpoint"`
	ContentTypes []string `json:"contentTypes"` // list of valid types for this metric
	Alias        string   `json:"alias"`
	Health       string   `json:"health,omitempty"`
	APIKey       string   `json:"apiKey,omitempty"`
}

MetricConfig is the configuration of a PublishMetric

type Publication

type Publication struct {
	Name string `json:"name"`
	UUID string `json:"uuid"`
}

type PublicationsConfig

type PublicationsConfig struct {
	EnabledPublications []Publication `json:"enabledPublications"`
}

func (*PublicationsConfig) GetXReadPolicies

func (cfg *PublicationsConfig) GetXReadPolicies() []string

type QueueConfig

type QueueConfig struct {
	ClusterARN       string `json:"clusterARN"`
	ConnectionString string `json:"connectionString"`
	Topic            string `json:"topic"`
	ConsumerGroup    string `json:"consumerGroup"`
	LagTolerance     int    `json:"lagTolerance"`
}

QueueConfig is the configuration for kafka consumer queue

type SplunkConfig

type SplunkConfig struct {
	LogPrefix string `json:"logPrefix"`
}

SplunkConfig holds the SplunkFeeder-specific configuration