config

package
v0.0.130 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 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 {
	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"`
	IncomeCallSemantics *api.CallSemantics     `yaml:"incomeCallSemantics"`
	Timeout             *int                   `yaml:"timeout"`
	PoolName            *string                `yaml:"poolName"`
	IncomePoolName      *string                `yaml:"incomePoolName"`
	Priority            *int                   `yaml:"priority"`
	IncomePriority      *int                   `yaml:"incomePriority"`
	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 {
	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
	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) 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 (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) 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"`
	DefaultCallSemantics api.CallSemantics      `yaml:"defaultCallSemantics"`
	Properties           map[string]interface{} `mapstructure:",remain"`
}

func (*ServiceConfig) GetProperty 

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

type ServiceEnvironmentConfig added in v0.0.124 

type ServiceEnvironmentConfig interface {
	GetConfig() *ServiceAppConfig
	GetServiceConfig() *ServiceConfig
}

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

func (*StreamConfig) GetProperty 

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

func (*StreamConfig) GetTransformationName 

func (s *StreamConfig) GetTransformationName() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.