config

package
v2.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCustomMetricsSpec 

func NewCustomMetricsSpec(config *Config) *models.CustomMetricsSpec

NewCustomMetricsSpec returns a *CustomMetricsSpec by reading config key (DEPRECATED)

func NewDefaultCustomMetricsSpec 

func NewDefaultCustomMetricsSpec() *models.CustomMetricsSpec

NewDefaultCustomMetricsSpec returns an empty *CustomMetricsSpec

Types

type BuilderConfig 

type BuilderConfig struct {
	Pitaya  PitayaConfig
	Metrics struct {
		Prometheus struct {
			Enabled bool `mapstructure:"enabled"`
		} `mapstructure:"prometheus"`
		Statsd struct {
			Enabled bool `mapstructure:"enabled"`
		} `mapstructure:"statsd"`
	} `mapstructure:"metrics"`
	DefaultPipelines struct {
		StructValidation struct {
			Enabled bool `mapstructure:"enabled"`
		} `mapstructure:"structvalidation"`
	} `mapstructure:"defaultpipelines"`
}

BuilderConfig provides configuration for Builder

func NewBuilderConfig 

func NewBuilderConfig(config *Config) *BuilderConfig

NewBuilderConfig reads from config to build builder configuration

func NewDefaultBuilderConfig 

func NewDefaultBuilderConfig() *BuilderConfig

NewDefaultBuilderConfig provides default builder configuration

type Config 

type Config struct {
	// contains filtered or unexported fields
}

Config is a wrapper around a viper config

func NewConfig 

func NewConfig(cfgs ...*viper.Viper) *Config

NewConfig creates a new config with a given viper config if given

func (*Config) Get 

func (c *Config) Get(s string) interface{}

Get returns an interface from the inner config

func (*Config) GetBool 

func (c *Config) GetBool(s string) bool

GetBool returns an boolean from the inner config

func (*Config) GetDuration 

func (c *Config) GetDuration(s string) time.Duration

GetDuration returns a duration from the inner config

func (*Config) GetInt 

func (c *Config) GetInt(s string) int

GetInt returns an int from the inner config

func (*Config) GetString 

func (c *Config) GetString(s string) string

GetString returns a string from the inner config

func (*Config) GetStringMapString 

func (c *Config) GetStringMapString(s string) map[string]string

GetStringMapString returns a string map string from the inner config

func (*Config) GetStringSlice 

func (c *Config) GetStringSlice(s string) []string

GetStringSlice returns a string slice from the inner config

func (*Config) Unmarshal 

func (c *Config) Unmarshal(v interface{}) error

Unmarshal unmarshals config into v

func (*Config) UnmarshalKey 

func (c *Config) UnmarshalKey(key string, rawVal interface{}, opts ...viper.DecoderConfigOption) error

UnmarshalKey unmarshals key into v

type ETCDBindingConfig 

type ETCDBindingConfig struct {
	DialTimeout time.Duration `mapstructure:"dialtimeout"`
	Endpoints   []string      `mapstructure:"endpoints"`
	Prefix      string        `mapstructure:"prefix"`
	LeaseTTL    time.Duration `mapstructure:"leasettl"`
}

ETCDBindingConfig provides configuration for ETCDBindingStorage

func NewDefaultETCDBindingConfig 

func NewDefaultETCDBindingConfig() *ETCDBindingConfig

NewDefaultETCDBindingConfig provides default configuration for ETCDBindingStorage

func NewETCDBindingConfig 

func NewETCDBindingConfig(config *Config) *ETCDBindingConfig

NewETCDBindingConfig reads from config to build ETCDBindingStorage configuration

type EnqueueOpts 

type EnqueueOpts struct {
	Enabled     bool `mapstructure:"enabled"`
	Max         int  `mapstructure:"max"`
	Exponential int  `mapstructure:"exponential"`
	MinDelay    int  `mapstructure:"mindelay"`
	MaxDelay    int  `mapstructure:"maxdelay"`
	MaxRandom   int  `mapstructure:"maxrandom"`
}

EnqueueOpts has retry options for worker

func NewDefaultEnqueueOpts 

func NewDefaultEnqueueOpts() *EnqueueOpts

NewDefaultEnqueueOpts provides default EnqueueOpts

func NewEnqueueOpts 

func NewEnqueueOpts(config *Config) *EnqueueOpts

NewEnqueueOpts reads from config to build *EnqueueOpts

type EtcdGroupServiceConfig 

type EtcdGroupServiceConfig struct {
	DialTimeout        time.Duration `mapstructure:"dialtimeout"`
	Endpoints          []string      `mapstructure:"endpoints"`
	Prefix             string        `mapstructure:"prefix"`
	TransactionTimeout time.Duration `mapstructure:"transactiontimeout"`
}

EtcdGroupServiceConfig provides ETCD configuration

func NewDefaultEtcdGroupServiceConfig 

func NewDefaultEtcdGroupServiceConfig() *EtcdGroupServiceConfig

NewDefaultEtcdGroupServiceConfig provides default ETCD configuration

func NewEtcdGroupServiceConfig 

func NewEtcdGroupServiceConfig(config *Config) *EtcdGroupServiceConfig

NewEtcdGroupServiceConfig reads from config to build ETCD configuration

type EtcdServiceDiscoveryConfig 

type EtcdServiceDiscoveryConfig struct {
	Endpoints   []string      `mapstructure:"endpoints"`
	User        string        `mapstructure:"user"`
	Pass        string        `mapstructure:"pass"`
	DialTimeout time.Duration `mapstructure:"dialtimeout"`
	Prefix      string        `mapstructure:"prefix"`
	Heartbeat   struct {
		TTL time.Duration `mapstructure:"ttl"`
		Log bool          `mapstructure:"log"`
	} `mapstructure:"heartbeat"`
	SyncServers struct {
		Interval    time.Duration `mapstructure:"interval"`
		Parallelism int           `mapstructure:"parallelism"`
	} `mapstructure:"syncservers"`
	Revoke struct {
		Timeout time.Duration `mapstructure:"timeout"`
	} `mapstructure:"revoke"`
	GrantLease struct {
		Timeout       time.Duration `mapstructure:"timeout"`
		MaxRetries    int           `mapstructure:"maxretries"`
		RetryInterval time.Duration `mapstructure:"retryinterval"`
	} `mapstructure:"grantlease"`
	Shutdown struct {
		Delay time.Duration `mapstructure:"delay"`
	} `mapstructure:"shutdown"`
	ServerTypesBlacklist []string `mapstructure:"servertypesblacklist"`
}

EtcdServiceDiscoveryConfig Etcd service discovery config

func NewDefaultEtcdServiceDiscoveryConfig 

func NewDefaultEtcdServiceDiscoveryConfig() *EtcdServiceDiscoveryConfig

NewDefaultEtcdServiceDiscoveryConfig Etcd service discovery default config

func NewEtcdServiceDiscoveryConfig 

func NewEtcdServiceDiscoveryConfig(config *Config) *EtcdServiceDiscoveryConfig

NewEtcdServiceDiscoveryConfig Etcd service discovery config with default config paths

type GRPCClientConfig 

type GRPCClientConfig struct {
	DialTimeout    time.Duration `mapstructure:"dialtimeout"`
	LazyConnection bool          `mapstructure:"lazyconnection"`
	RequestTimeout time.Duration `mapstructure:"requesttimeout"`
}

GRPCClientConfig rpc client config struct

func NewDefaultGRPCClientConfig 

func NewDefaultGRPCClientConfig() *GRPCClientConfig

NewDefaultGRPCClientConfig rpc client default config struct

func NewGRPCClientConfig 

func NewGRPCClientConfig(config *Config) *GRPCClientConfig

NewGRPCClientConfig reads from config to build GRPCCLientConfig

type GRPCServerConfig 

type GRPCServerConfig struct {
	Port int `mapstructure:"port"`
}

GRPCServerConfig provides configuration for GRPCServer

func NewDefaultGRPCServerConfig 

func NewDefaultGRPCServerConfig() *GRPCServerConfig

NewDefaultGRPCServerConfig returns a default GRPCServerConfig

func NewGRPCServerConfig 

func NewGRPCServerConfig(config *Config) *GRPCServerConfig

NewGRPCServerConfig reads from config to build GRPCServerConfig

type InfoRetrieverConfig 

type InfoRetrieverConfig struct {
	Region string `mapstructure:"region"`
}

InfoRetrieverConfig provides InfoRetriever configuration

func NewDefaultInfoRetrieverConfig 

func NewDefaultInfoRetrieverConfig() *InfoRetrieverConfig

NewDefaultInfoRetrieverConfig provides default configuration for InfoRetriever

func NewInfoRetrieverConfig 

func NewInfoRetrieverConfig(c *Config) *InfoRetrieverConfig

NewInfoRetrieverConfig reads from config to build configuration for InfoRetriever

type MemoryGroupConfig 

type MemoryGroupConfig struct {
	TickDuration time.Duration `mapstructure:"tickduration"`
}

MemoryGroupConfig provides configuration for MemoryGroup

func NewDefaultMemoryGroupConfig 

func NewDefaultMemoryGroupConfig() *MemoryGroupConfig

NewDefaultMemoryGroupConfig returns a new, default group instance

func NewMemoryGroupConfig 

func NewMemoryGroupConfig(conf *Config) *MemoryGroupConfig

NewMemoryGroupConfig returns a new, default group instance

type NatsRPCClientConfig 

type NatsRPCClientConfig struct {
	Connect                string        `mapstructure:"connect"`
	MaxReconnectionRetries int           `mapstructure:"maxreconnectionretries"`
	RequestTimeout         time.Duration `mapstructure:"requesttimeout"`
	ConnectionTimeout      time.Duration `mapstructure:"connectiontimeout"`
}

NatsRPCClientConfig provides nats client configuration

func NewDefaultNatsRPCClientConfig 

func NewDefaultNatsRPCClientConfig() *NatsRPCClientConfig

NewDefaultNatsRPCClientConfig provides default nats client configuration

func NewNatsRPCClientConfig 

func NewNatsRPCClientConfig(config *Config) *NatsRPCClientConfig

NewNatsRPCClientConfig reads from config to build nats client configuration

type NatsRPCServerConfig 

type NatsRPCServerConfig struct {
	Connect                string `mapstructure:"connect"`
	MaxReconnectionRetries int    `mapstructure:"maxreconnectionretries"`
	Buffer                 struct {
		Messages int `mapstructure:"messages"`
		Push     int `mapstructure:"push"`
	} `mapstructure:"buffer"`
	Services          int           `mapstructure:"services"`
	ConnectionTimeout time.Duration `mapstructure:"connectiontimeout"`
}

NatsRPCServerConfig provides nats server configuration

func NewDefaultNatsRPCServerConfig 

func NewDefaultNatsRPCServerConfig() *NatsRPCServerConfig

NewDefaultNatsRPCServerConfig provides default nats server configuration

func NewNatsRPCServerConfig 

func NewNatsRPCServerConfig(config *Config) *NatsRPCServerConfig

NewNatsRPCServerConfig reads from config to build nats server configuration

type PitayaConfig 

type PitayaConfig struct {
	Heartbeat struct {
		Interval time.Duration `mapstructure:"interval"`
	} `mapstructure:"heartbeat"`
	Handler struct {
		Messages struct {
			Compression bool `mapstructure:"compression"`
		} `mapstructure:"messages"`
	} `mapstructure:"handler"`
	Buffer struct {
		Agent struct {
			Messages int `mapstructure:"messages"`
		} `mapstructure:"agent"`
		Handler struct {
			LocalProcess  int `mapstructure:"localprocess"`
			RemoteProcess int `mapstructure:"remoteprocess"`
		} `mapstructure:"handler"`
	} `mapstructure:"buffer"`
	Concurrency struct {
		Handler struct {
			Dispatch int `mapstructure:"dispatch"`
		} `mapstructure:"handler"`
	} `mapstructure:"concurrency"`
	Session struct {
		Unique bool `mapstructure:"unique"`
		Drain  struct {
			Enabled bool          `mapstructure:"enabled"`
			Timeout time.Duration `mapstructure:"timeout"`
			Period  time.Duration `mapstructure:"period"`
		} `mapstructure:"drain"`
	} `mapstructure:"session"`
	Metrics struct {
		Period time.Duration `mapstructure:"period"`
	} `mapstructure:"metrics"`
	Acceptor struct {
		ProxyProtocol bool `mapstructure:"proxyprotocol"`
	} `mapstructure:"acceptor"`
}

PitayaConfig provides configuration for a pitaya app

func NewDefaultPitayaConfig 

func NewDefaultPitayaConfig() *PitayaConfig

NewDefaultPitayaConfig provides default configuration for Pitaya App

func NewPitayaConfig 

func NewPitayaConfig(config *Config) *PitayaConfig

NewPitayaConfig returns a config instance with values extracted from default config paths

type PrometheusConfig 

type PrometheusConfig struct {
	Prometheus struct {
		Port             int               `mapstructure:"port"`
		AdditionalLabels map[string]string `mapstructure:"additionallabels"`
	} `mapstructure:"prometheus"`
	Game        string            `mapstructure:"game"`
	ConstLabels map[string]string `mapstructure:"constlabels"`
}

PrometheusConfig provides configuration for PrometheusReporter

func NewDefaultPrometheusConfig 

func NewDefaultPrometheusConfig() *PrometheusConfig

NewDefaultPrometheusConfig provides default configuration for PrometheusReporter

func NewPrometheusConfig 

func NewPrometheusConfig(config *Config) *PrometheusConfig

NewPrometheusConfig reads from config to build configuration for PrometheusReporter

type RateLimitingConfig 

type RateLimitingConfig struct {
	Limit        int           `mapstructure:"limit"`
	Interval     time.Duration `mapstructure:"interval"`
	ForceDisable bool          `mapstructure:"forcedisable"`
}

RateLimitingConfig rate limits config

func NewDefaultRateLimitingConfig 

func NewDefaultRateLimitingConfig() *RateLimitingConfig

NewDefaultRateLimitingConfig rate limits default config

func NewRateLimitingConfig 

func NewRateLimitingConfig(config *Config) *RateLimitingConfig

NewRateLimitingConfig reads from config to build rate limiting configuration

type StatsdConfig 

type StatsdConfig struct {
	Statsd struct {
		Host   string  `mapstructure:"host"`
		Prefix string  `mapstructure:"prefix"`
		Rate   float64 `mapstructure:"rate"`
	} `mapstructure:"statsd"`
	ConstLabels map[string]string `mapstructure:"consttags"`
}

StatsdConfig provides configuration for statsd

func NewDefaultStatsdConfig 

func NewDefaultStatsdConfig() *StatsdConfig

NewDefaultStatsdConfig provides default configuration for statsd

func NewStatsdConfig 

func NewStatsdConfig(config *Config) *StatsdConfig

NewStatsdConfig reads from config to build configuration for statsd

type WorkerConfig 

type WorkerConfig struct {
	Redis struct {
		ServerURL string `mapstructure:"serverurl"`
		Pool      string `mapstructure:"pool"`
		Password  string `mapstructure:"password"`
	} `mapstructure:"redis"`
	Namespace   string `mapstructure:"namespace"`
	Concurrency int    `mapstructure:"concurrency"`
}

WorkerConfig provides worker configuration

func NewDefaultWorkerConfig 

func NewDefaultWorkerConfig() *WorkerConfig

NewDefaultWorkerConfig provides worker default configuration

func NewWorkerConfig 

func NewWorkerConfig(config *Config) *WorkerConfig

NewWorkerConfig provides worker configuration based on default string paths

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.