config

package
v0.0.158 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 28, 2024 License: BSD-3-Clause Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetConfigProperty

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

Types

type Config

type Config interface {
	GetAppConfig() *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 added in v0.0.125

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

func (*PoolConfig) GetProperty added in v0.0.125

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) GetAppConfig added in v0.0.146

func (cfg *ServiceAppConfig) GetAppConfig() *ServiceAppConfig

func (*ServiceAppConfig) GetDataConnectorById

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

func (*ServiceAppConfig) GetEndpointConfigById

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

func (*ServiceAppConfig) GetPoolByName added in v0.0.125

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

Jump to

Keyboard shortcuts

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