config

Documentation

Index

• func GetConfigProperty[T any](config ConfigProperties, name string) T
• type Config
• type ConfigProperties
• type ConfigSettings
• type DataConnectorConfig
  • func (s *DataConnectorConfig) GetProperty(name string) interface{}
• type EndpointConfig
  • func (s *EndpointConfig) GetProperty(name string) interface{}
• type LinkConfig
  • func (s *LinkConfig) GetProperty(name string) interface{}
• type LinkId
• type ProjectSettings
  • func (s *ProjectSettings) GetProperty(name string) interface{}
• type RuntimeConfig
• type ServiceAppConfig
  • func (cfg *ServiceAppConfig) GetConfig() Config
  • func (cfg *ServiceAppConfig) GetDataConnectorById(id int) *DataConnectorConfig
  • func (cfg *ServiceAppConfig) GetEndpointConfigById(id int) *EndpointConfig
  • func (cfg *ServiceAppConfig) GetLink(from int, to int) *LinkConfig
  • func (cfg *ServiceAppConfig) GetServiceConfig() *ServiceAppConfig
  • func (cfg *ServiceAppConfig) GetServiceConfigById(id int) *ServiceConfig
  • func (cfg *ServiceAppConfig) GetServiceConfigByName(name string) *ServiceConfig
  • func (cfg *ServiceAppConfig) GetStreamConfigById(id int) *StreamConfig
  • func (cfg *ServiceAppConfig) GetStreamConfigByName(name string) *StreamConfig
  • func (cfg *ServiceAppConfig) InitRuntimeConfig()
• type ServiceConfig
  • func (s *ServiceConfig) GetProperty(name string) interface{}
• type StreamConfig
  • func (s *StreamConfig) GetProperty(name string) interface{}
  • func (s *StreamConfig) GetTransformationName() string

Functions

func GetConfigProperty

func GetConfigProperty[T any](config ConfigProperties, name string) T

Types

type Config

type Config interface {
	GetServiceConfig() *ServiceAppConfig
}

type ConfigProperties

type ConfigProperties interface {
	GetProperty(name string) interface{}
}

type ConfigSettings

type ConfigSettings struct {
}

ConfigSettings /* Settings how the service will get access to config and config update options

type DataConnectorConfig

type DataConnectorConfig struct {
	Id         int                    `yaml:"id"`
	Name       string                 `yaml:"name"`
	Type       api.DataConnectorType  `yaml:"type"`
	Properties map[string]interface{} `mapstructure:",remain"`
}

func (*DataConnectorConfig) GetProperty

func (s *DataConnectorConfig) GetProperty(name string) interface{}

type EndpointConfig

type EndpointConfig struct {
	Id              int                    `yaml:"id"`
	Name            string                 `yaml:"name"`
	IdDataConnector int                    `yaml:"idDataConnector"`
	Properties      map[string]interface{} `mapstructure:",remain"`
}

func (*EndpointConfig) GetProperty

func (s *EndpointConfig) GetProperty(name string) interface{}

type LinkConfig

type LinkConfig struct {
	From          int                    `yaml:"from"`
	To            int                    `yaml:"to"`
	CallSemantics api.CallSemantics      `yaml:"callSemantics"`
	Timeout       *int                   `yaml:"timeout"`
	Properties    map[string]interface{} `mapstructure:",remain"`
}

func (*LinkConfig) GetProperty

func (s *LinkConfig) GetProperty(name string) interface{}

type LinkId

type LinkId struct {
	From int
	To   int
}

type ProjectSettings

type ProjectSettings struct {
	GolangVersion string                 `yaml:"golangVersion"`
	ModulePath    string                 `yaml:"modulePath"`
	Name          string                 `yaml:"name"`
	Properties    map[string]interface{} `mapstructure:",remain"`
}

func (*ProjectSettings) GetProperty

func (s *ProjectSettings) GetProperty(name string) interface{}

type RuntimeConfig

type RuntimeConfig struct {
	StreamsByName        map[string]*StreamConfig
	ServicesByName       map[string]*ServiceConfig
	LinksById            map[LinkId]*LinkConfig
	DataConnectorsByName map[string]*DataConnectorConfig
	EndpointsByName      map[string]*EndpointConfig
	StreamsById          map[int]*StreamConfig
	ServicesById         map[int]*ServiceConfig
	DataConnectorsById   map[int]*DataConnectorConfig
	EndpointsById        map[int]*EndpointConfig
}

type ServiceAppConfig

type ServiceAppConfig struct {
	Streams        []StreamConfig        `yaml:"streams"`
	Services       []ServiceConfig       `yaml:"services"`
	Links          []LinkConfig          `yaml:"links"`
	DataConnectors []DataConnectorConfig `yaml:"dataConnectors"`
	Endpoints      []EndpointConfig      `yaml:"endpoints"`
	Settings       ProjectSettings       `yaml:"settings"`
	// contains filtered or unexported fields
}

func (*ServiceAppConfig) GetConfig

func (cfg *ServiceAppConfig) GetConfig() Config

func (*ServiceAppConfig) GetDataConnectorById

func (cfg *ServiceAppConfig) GetDataConnectorById(id int) *DataConnectorConfig

func (*ServiceAppConfig) GetEndpointConfigById

func (cfg *ServiceAppConfig) GetEndpointConfigById(id int) *EndpointConfig

func (*ServiceAppConfig) GetLink

func (cfg *ServiceAppConfig) GetLink(from int, to int) *LinkConfig

func (*ServiceAppConfig) GetServiceConfig

func (cfg *ServiceAppConfig) GetServiceConfig() *ServiceAppConfig

func (*ServiceAppConfig) GetServiceConfigById

func (cfg *ServiceAppConfig) GetServiceConfigById(id int) *ServiceConfig

func (*ServiceAppConfig) GetServiceConfigByName

func (cfg *ServiceAppConfig) GetServiceConfigByName(name string) *ServiceConfig

func (*ServiceAppConfig) GetStreamConfigById

func (cfg *ServiceAppConfig) GetStreamConfigById(id int) *StreamConfig

func (*ServiceAppConfig) GetStreamConfigByName

func (cfg *ServiceAppConfig) GetStreamConfigByName(name string) *StreamConfig

func (*ServiceAppConfig) InitRuntimeConfig

func (cfg *ServiceAppConfig) InitRuntimeConfig()

type ServiceConfig

type ServiceConfig struct {
	Id                 int                    `yaml:"id"`
	Name               string                 `yaml:"name"`
	MonitoringPort     int                    `yaml:"monitoringPort"`
	MonitoringHost     string                 `yaml:"monitoringHost"`
	GrpcPort           int                    `yaml:"grpcPort"`
	GrpcHost           string                 `yaml:"grpcHost"`
	ShutdownTimeout    int                    `yaml:"shutdownTimeout"`
	Color              string                 `yaml:"color"`
	DefaultGrpcTimeout int                    `yaml:"defaultGrpcTimeout"`
	Environment        string                 `yaml:"environment"`
	MetricsEngine      api.MetricsEngine      `yaml:"metricsEngine"`
	DelayExecutors     int                    `yaml:"delayExecutors"`
	Properties         map[string]interface{} `mapstructure:",remain"`
}

func (*ServiceConfig) GetProperty

func (s *ServiceConfig) GetProperty(name string) interface{}

type StreamConfig

type StreamConfig struct {
	Id          int                    `yaml:"id"`
	Name        string                 `yaml:"name"`
	Type        api.TransformationType `yaml:"type"`
	IdService   int                    `yaml:"idService"`
	IdSource    int                    `yaml:"idSource"`
	IdSources   []int                  `yaml:"idSources"`
	XPos        int                    `yaml:"xPos"`
	YPos        int                    `yaml:"yPos"`
	TTL         *int64                 `yaml:"ttl"`
	RenewTTL    *bool                  `yaml:"renewTTL"`
	Duration    *int64                 `yaml:"duration"`
	JoinStorage *api.JoinStorageType   `yaml:"joinStorage"`
	Properties  map[string]interface{} `mapstructure:",remain"`
}

func (*StreamConfig) GetProperty

func (s *StreamConfig) GetProperty(name string) interface{}

func (*StreamConfig) GetTransformationName

func (s *StreamConfig) GetTransformationName() string