config

Documentation

Index

• func LoadClusterConfig() (armometadata.ClusterConfig, error)
• func LoadServiceURLs(filePath string) (schema.IBackendServices, error)
• type AuthenticationServerConfig
• type Backend
• type Config
  • func LoadConfig(path string) (Config, error)
• type HTTPEndpoint
  • func (c *HTTPEndpoint) ValidateConfig() error
• type InCluster
  • func (c *InCluster) ValidateConfig() error
• type KeepAliveTaskConfig
• type PrometheusConfig
• type ReconciliationTaskConfig
• type Resource
  • func (r Resource) String() string

Functions

func LoadClusterConfig

func LoadClusterConfig() (armometadata.ClusterConfig, error)

func LoadServiceURLs

func LoadServiceURLs(filePath string) (schema.IBackendServices, error)

Types

type AuthenticationServerConfig

type AuthenticationServerConfig struct {
	Url                       string            `mapstructure:"url"`
	HeaderToQueryParamMapping map[string]string `mapstructure:"headerToQueryParamMapping"`
	HeaderToHeaderMapping     map[string]string `mapstructure:"headerToHeaderMapping"`
}

type Backend

type Backend struct {
	Port                 int                         `mapstructure:"port"`
	AuthenticationServer *AuthenticationServerConfig `mapstructure:"authenticationServer"`
	Subscription         string                      `mapstructure:"subscription"`
	PulsarConfig         *pulsarconfig.PulsarConfig  `mapstructure:"pulsarConfig"`
	ProducerTopic        pulsarconnector.TopicName   `mapstructure:"producerTopic"`
	ConsumerTopic        pulsarconnector.TopicName   `mapstructure:"consumerTopic"`
	ConsumerWorkers      int                         `mapstructure:"consumerWorkers"`
	Prometheus           *PrometheusConfig           `mapstructure:"prometheusConfig"`
	ReconciliationTask   *ReconciliationTaskConfig   `mapstructure:"reconciliationTaskConfig"`
	KeepAliveTask        *KeepAliveTaskConfig        `mapstructure:"keepAliveTaskConfig"`
}

type Config

type Config struct {
	Backend      Backend      `mapstructure:"backend"`
	InCluster    InCluster    `mapstructure:"inCluster"`
	HTTPEndpoint HTTPEndpoint `mapstructure:"httpEndpoint"`
}

func LoadConfig

func LoadConfig(path string) (Config, error)

LoadConfig reads configuration from file or environment variables.

type HTTPEndpoint

type HTTPEndpoint struct {
	ServerPort string     `mapstructure:"serverPort"`
	Resources  []Resource `mapstructure:"resources"`
}

func (*HTTPEndpoint) ValidateConfig

func (c *HTTPEndpoint) ValidateConfig() error

type InCluster

type InCluster struct {
	ServerUrl   string     `mapstructure:"serverUrl"`
	Namespace   string     `mapstructure:"namespace"`
	ClusterName string     `mapstructure:"clusterName"`
	Account     string     `mapstructure:"account"`
	AccessKey   string     `mapstructure:"accessKey"`
	Resources   []Resource `mapstructure:"resources"`
}

func (*InCluster) ValidateConfig

func (c *InCluster) ValidateConfig() error

type KeepAliveTaskConfig

type KeepAliveTaskConfig struct {
	TaskIntervalSeconds int `mapstructure:"taskIntervalSeconds"`
}

type PrometheusConfig

type PrometheusConfig struct {
	Enabled bool `mapstructure:"enabled"`
	Port    int  `mapstructure:"port"`
}

type ReconciliationTaskConfig

type ReconciliationTaskConfig struct {
	TaskIntervalSeconds           int `mapstructure:"taskIntervalSeconds"`
	IntervalFromConnectionSeconds int `mapstructure:"intervalFromConnectionSeconds"`
}

type Resource

type Resource struct {
	Group    string          `mapstructure:"group"`
	Version  string          `mapstructure:"version"`
	Resource string          `mapstructure:"resource"`
	Strategy domain.Strategy `mapstructure:"strategy"`
}

func (Resource) String

func (r Resource) String() string

Kind returns group/version/resource as a string.