config

Apr 10, 2024

Changes in this version

type Config

+ GlobalConfigFile string

+ PluginConfigFile string

Mar 15, 2024

Changes in this version

+ const DefaultActionTimeout

type PluginConfig

+ ActionTimeout time.Duration

Mar 3, 2024

Changes in this version

+ const DefaultPolicy

+ const DefaultPolicyTimeout

type PluginConfig

+ DefaultPolicy string

+ Policies []Policy

+ PolicyTimeout time.Duration

type Policy

+ Metadata map[string]any

+ Name string

+ Policy string

Jan 29, 2024

Changes in this version

type Plugin

+ URL string

Nov 19, 2023

Changes in this version

+ const DefaultAcceptancePolicy

+ const DefaultBackoff

+ const DefaultBackoffMultiplier

+ const DefaultCompatibilityPolicy

+ const DefaultDialTimeout

+ const DefaultDisableBackoffCaps

+ const DefaultPluginStartTimeout

+ const DefaultRetries

+ const DefaultTerminationPolicy

+ const DefaultVerificationPolicy

+ var AcceptancePolicies = map[string]AcceptancePolicy

+ var CompatibilityPolicies = map[string]CompatibilityPolicy

+ var ConsoleTimeFormats = map[string]string

+ var LogLevels = map[string]zerolog.Level

+ var TerminationPolicies = map[string]TerminationPolicy

+ var TimeFormats = map[string]string

+ var VerificationPolicies = map[string]VerificationPolicy

+ func Exists[T comparable, V any](map_ map[T]V, key T) bool

+ func If[T any](predicate bool, truthy, falsy T) T

type Client

+ Backoff time.Duration

+ BackoffMultiplier float64

+ DialTimeout time.Duration

+ DisableBackoffCaps bool

+ Retries int

type GlobalConfig

+ func (gc GlobalConfig) Filter(groupName string) *GlobalConfig

type PluginConfig

+ StartTimeout time.Duration

Nov 5, 2023

Changes in this version

+ const DefaultHandshakeTimeout

type Server

+ CertFile string

+ EnableTLS bool

+ HandshakeTimeout time.Duration

+ KeyFile string

Oct 18, 2023

Changes in this version

+ const DefaultEngineStopTimeout

Sep 26, 2023

Changes in this version

+ const DefaultMetricsServerTimeout

+ const DefaultReadHeaderTimeout

type Metrics

+ CertFile string

+ KeyFile string

+ ReadHeaderTimeout time.Duration

+ Timeout time.Duration

+ func (m Metrics) GetReadHeaderTimeout() time.Duration

+ func (m Metrics) GetTimeout() time.Duration

Sep 21, 2023

Changes in this version

+ const DefaultReceiveTimeout

type Client

+ ReceiveTimeout time.Duration

+ func (c Client) GetReceiveTimeout() time.Duration

Jun 3, 2023

Changes in this version

type Client

+ func (c Client) GetReceiveChunkSize() int

+ func (c Client) GetReceiveDeadline() time.Duration

+ func (c Client) GetSendDeadline() time.Duration

+ func (c Client) GetTCPKeepAlivePeriod() time.Duration

type Proxy

+ func (pr Proxy) GetHealthCheckPeriod() time.Duration

type Server

+ func (s Server) GetRLimits(logger zerolog.Logger) (uint64, uint64)

+ func (s Server) GetTickInterval() time.Duration

May 31, 2023

Changes in this version

type Config

+ func (c *Config) ValidateGlobalConfig(ctx context.Context)

type PluginConfig

+ func (p PluginConfig) GetTerminationPolicy() TerminationPolicy

May 28, 2023

Changes in this version

+ const GlobalConfigFilename

+ const PluginsConfigFilename

+ func GetDefaultConfigFilePath(filename string) string

May 23, 2023

Changes in this version

type PluginConfig

+ TerminationPolicy string

+ type TerminationPolicy uint

+ const Continue

+ const Stop

May 22, 2023

Changes in this version

+ const DefaultAddress

+ const DefaultNetwork

+ const DefaultNoColor

+ const DefaultTCPKeepAliveDuration

+ const DefaultTCPNoDelay

Mar 12, 2023

Changes in this version

+ const DefaultPluginTimeout

type PluginConfig

+ Timeout time.Duration

Mar 5, 2023

Changes in this version

type PluginConfig

+ ReloadOnCrash bool

+ func (p PluginConfig) GetPlugins(name ...string) []Plugin

Mar 5, 2023

Changes in this version

+ const DefaultGRPCAPIAddress

+ const DefaultGRPCAPINetwork

+ const DefaultHTTPAPIAddress

+ type API struct

+ Enabled bool

+ GRPCAddress string

+ GRPCNetwork string

+ HTTPAddress string

type GlobalConfig

+ API API

Feb 19, 2023

Changes in this version

+ const TracerName

type Config

+ func (c *Config) InitConfig(ctx context.Context)

type IConfig

+ InitConfig func(context.Context)

Feb 7, 2023

Changes in this version

type PluginConfig

+ EnableMetricsMerger bool

Feb 5, 2023

Changes in this version

type GlobalConfig

+ Proxies map[string]Proxy

+ Servers map[string]Server

Feb 1, 2023

Changes in this version

+ const DefaultPluginHealthCheckPeriod

type PluginConfig

+ HealthCheckPeriod time.Duration

Jan 23, 2023

Changes in this version

+ const DefaultAttachStacktrace

+ const DefaultFlushTimeout

+ const DefaultTraceSampleRate

type Logger

+ LocalTime bool

Jan 22, 2023

Changes in this version

+ const DefaultConsoleTimeFormat

+ const DefaultLocalTime

+ const DefaultRSyslogAddress

+ const DefaultRSyslogNetwork

+ const DefaultSyslogTag

+ const DefaultTimeFormat

+ var DefaultSyslogPriority = syslog.LOG_LOCAL0 | syslog.LOG_DEBUG

type LogOutput

+ const RSyslog

+ const Syslog

type Logger

+ ConsoleTimeFormat string

+ RSyslogAddress string

+ RSyslogNetwork string

+ SyslogPriority string

+ func (l Logger) GetConsoleTimeFormat() string

+ func (l Logger) GetSyslogPriority() syslog.Priority

Jan 22, 2023

Changes in this version

+ const DefaultPluginAddress

+ const Name

+ var Version = ""

+ var VersionDetails = ""

+ func VersionInfo() string

+ type Config struct

+ Global GlobalConfig

+ GlobalKoanf *koanf.Koanf

+ Plugin PluginConfig

+ PluginKoanf *koanf.Koanf

+ func NewConfig(globalConfigFile, pluginConfigFile string, logger zerolog.Logger) *Config

+ func (c *Config) LoadDefaults()

+ func (c *Config) LoadGlobalConfigFile()

+ func (c *Config) LoadGlobalEnvVars()

+ func (c *Config) LoadPluginConfigFile()

+ func (c *Config) LoadPluginEnvVars()

+ func (c *Config) MergeGlobalConfig(updatedGlobalConfig map[string]interface{})

+ func (c *Config) UnmarshalGlobalConfig()

+ func (c *Config) UnmarshalPluginConfig()

+ type IConfig interface

+ LoadDefaults func()

+ LoadGlobalConfigFile func()

+ LoadGlobalEnvVars func()

+ LoadPluginConfigFile func()

+ LoadPluginEnvVars func()

+ MergeGlobalConfig func(map[string]interface{})

Jan 20, 2023

Changes in this version

+ const DefaultMetricsAddress

+ const DefaultMetricsMergerPeriod

+ const DefaultMetricsPath

type GlobalConfig

+ Metrics map[string]Metrics

+ type Metrics struct

+ Address string

+ Enabled bool

+ Path string

type PluginConfig

+ MetricsMergerPeriod time.Duration

Jan 15, 2023

Changes in this version

+ const DefaultCompress

+ const DefaultMaxAge

+ const DefaultMaxBackups

+ const DefaultMaxSize

type Logger

+ Compress bool

+ MaxAge int

+ MaxBackups int

+ MaxSize int

Jan 14, 2023

Changes in this version

+ type AcceptancePolicy uint

+ const Accept

+ const Reject

+ type CompatibilityPolicy uint

type PluginConfig

+ AcceptancePolicy string

+ func (p PluginConfig) GetAcceptancePolicy() AcceptancePolicy

+ func (p PluginConfig) GetPluginCompatibilityPolicy() CompatibilityPolicy

+ type VerificationPolicy uint

Jan 10, 2023

Changes in this version

+ const DefaultHealthCheckPeriod

type Proxy

+ HealthCheckPeriod time.Duration

Jan 10, 2023

Changes in this version

+ const EnvPrefix

+ func LoadEnvVars(cfg *koanf.Koanf)

Jan 6, 2023

Changes in this version

+ const ChecksumBufferSize

+ const Default

+ const DefaultBufferSize

+ const DefaultChunkSize

+ const DefaultListenAddress

+ const DefaultListenNetwork

+ const DefaultLoadBalancer

+ const DefaultLogFileName

+ const DefaultLogFilePermission

+ const DefaultLogLevel

+ const DefaultLogOutput

+ const DefaultMaxPort

+ const DefaultMinPort

+ const DefaultPoolSize

+ const DefaultReceiveDeadline

+ const DefaultSeed

+ const DefaultSendDeadline

+ const DefaultTCPKeepAlive

+ const DefaultTCPKeepAlivePeriod

+ const DefaultTickInterval

+ const EmptyPoolCapacity

+ const LoggerName

+ const MinimumPoolSize

+ const PluginPriorityStart

+ func LoadGlobalConfigDefaults(cfg *koanf.Koanf)

+ func LoadPluginConfigDefaults(cfg *koanf.Koanf)

+ type Client struct

+ Address string

+ Network string

+ ReceiveBufferSize int

+ ReceiveChunkSize int

+ ReceiveDeadline time.Duration

+ SendDeadline time.Duration

+ TCPKeepAlive bool

+ TCPKeepAlivePeriod time.Duration

+ type CompatPolicy uint

+ const Loose

+ const Strict

+ type GlobalConfig struct

+ Clients map[string]Client

+ Loggers map[string]Logger

+ Pools map[string]Pool

+ Proxy map[string]Proxy

+ Server Server

+ type LogOutput uint

+ const Buffer

+ const Console

+ const File

+ const Stderr

+ const Stdout

+ type Logger struct

+ FileName string

+ Level string

+ NoColor bool

+ Output string

+ Permission uint32

+ StartupMsg bool

+ TimeFormat string

+ func (l Logger) GetLevel() zerolog.Level

+ func (l Logger) GetOutput() LogOutput

+ func (l Logger) GetTimeFormat() string

+ type Plugin struct

+ Args []string

+ Checksum string

+ Enabled bool

+ Env []string

+ LocalPath string

+ Name string

+ type PluginConfig struct

+ CompatibilityPolicy string

+ Plugins []Plugin

+ VerificationPolicy string

+ func (p PluginConfig) GetPluginCompatPolicy() CompatPolicy

+ func (p PluginConfig) GetVerificationPolicy() Policy

+ type Policy uint

+ const Abort

+ const Ignore

+ const PassDown

+ const Remove

+ type Pool struct

+ Size int

+ func (p Pool) GetSize() int

+ type Proxy struct

+ Elastic bool

+ ReuseElasticClients bool

+ type Server struct

+ Address string

+ EnableTicker bool

+ HardLimit uint64

+ LoadBalancer string

+ LockOSThread bool

+ MultiCore bool

+ Network string

+ ReadBufferCap int

+ ReuseAddress bool

+ ReusePort bool

+ SocketRecvBuffer int

+ SocketSendBuffer int

+ SoftLimit uint64

+ TCPKeepAlive time.Duration

+ TCPNoDelay bool

+ TickInterval time.Duration

+ WriteBufferCap int

+ func (s Server) GetLoadBalancer() gnet.LoadBalancing

+ func (s Server) GetTCPNoDelay() gnet.TCPSocketOpt

+ type Status uint

+ const Running

+ const Stopped