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 PoolConfig
  • func (s *PoolConfig) GetProperty(name string) interface{}
• type ProjectSettings
  • func (s *ProjectSettings) GetProperty(name string) interface{}
• type RuntimeConfig
• type ServiceAppConfig
  • func (cfg *ServiceAppConfig) AppConfig() *ServiceAppConfig
  • 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) GetPoolByName(name string) *PoolConfig
  • 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 {
	AppConfig() *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 {
	api.DataConnector `mapstructure:",squash"`
	Properties        map[string]interface{} `mapstructure:",remain"`
}

func (*DataConnectorConfig) GetProperty

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

type EndpointConfig

type EndpointConfig struct {
	api.Endpoint `mapstructure:",squash"`
	Properties   map[string]interface{} `mapstructure:",remain"`
}

func (*EndpointConfig) GetProperty

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

type LinkConfig

type LinkConfig struct {
	api.Link   `mapstructure:",squash"`
	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 PoolConfig

type PoolConfig struct {
	Name           string                 `yaml:"name"`
	ExecutorsCount int                    `yaml:"executorsCount"`
	Properties     map[string]interface{} `mapstructure:",remain"`
}

func (*PoolConfig) GetProperty

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

type ProjectSettings

type ProjectSettings struct {
	api.ProjectSettings `mapstructure:",squash"`
	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
	PoolByName           map[string]*PoolConfig
}

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"`
	Pools          []PoolConfig          `yaml:"pools"`
	Settings       ProjectSettings       `yaml:"settings"`
	// contains filtered or unexported fields
}

func (*ServiceAppConfig) AppConfig

func (cfg *ServiceAppConfig) AppConfig() *ServiceAppConfig

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) GetPoolByName

func (cfg *ServiceAppConfig) GetPoolByName(name string) *PoolConfig

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 {
	api.Service `mapstructure:",squash"`
	Properties  map[string]interface{} `mapstructure:",remain"`
}

func (*ServiceConfig) GetProperty

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

type StreamConfig

type StreamConfig struct {
	api.Stream `mapstructure:",squash"`
	Properties map[string]interface{} `mapstructure:",remain"`
}

func (*StreamConfig) GetProperty

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

func (*StreamConfig) GetTransformationName

func (s *StreamConfig) GetTransformationName() string