Versions in this module Expand all Collapse all v2 v2.7.1 Jan 15, 2024 v2.7.0 Jan 12, 2024 Changes in this version + func NewCustomMetricsSpec(config *Config) *models.CustomMetricsSpec + func NewDefaultCustomMetricsSpec() *models.CustomMetricsSpec + type BuilderConfig struct + DefaultPipelines struct{ ... } + Metrics struct{ ... } + Pitaya PitayaConfig + func NewBuilderConfig(config *Config) *BuilderConfig + func NewDefaultBuilderConfig() *BuilderConfig + type Config struct + func NewConfig(cfgs ...*viper.Viper) *Config + func (c *Config) Get(s string) interface{} + func (c *Config) GetBool(s string) bool + func (c *Config) GetDuration(s string) time.Duration + func (c *Config) GetInt(s string) int + func (c *Config) GetString(s string) string + func (c *Config) GetStringMapString(s string) map[string]string + func (c *Config) GetStringSlice(s string) []string + func (c *Config) Unmarshal(v interface{}) error + func (c *Config) UnmarshalKey(s string, v interface{}) error + type ETCDBindingConfig struct + DialTimeout time.Duration + Endpoints []string + LeaseTTL time.Duration + Prefix string + func NewDefaultETCDBindingConfig() *ETCDBindingConfig + func NewETCDBindingConfig(config *Config) *ETCDBindingConfig + type EnqueueOpts struct + Enabled bool + Exponential int + Max int + MaxDelay int + MaxRandom int + MinDelay int + func NewDefaultEnqueueOpts() *EnqueueOpts + func NewEnqueueOpts(config *Config) *EnqueueOpts + type EtcdGroupServiceConfig struct + DialTimeout time.Duration + Endpoints []string + Prefix string + TransactionTimeout time.Duration + func NewDefaultEtcdGroupServiceConfig() *EtcdGroupServiceConfig + func NewEtcdGroupServiceConfig(config *Config) *EtcdGroupServiceConfig + type EtcdServiceDiscoveryConfig struct + DialTimeout time.Duration + Endpoints []string + GrantLease struct{ ... } + Heartbeat struct{ ... } + Pass string + Prefix string + Revoke struct{ ... } + ServerTypesBlacklist []string + Shutdown struct{ ... } + SyncServers struct{ ... } + User string + func NewDefaultEtcdServiceDiscoveryConfig() *EtcdServiceDiscoveryConfig + func NewEtcdServiceDiscoveryConfig(config *Config) *EtcdServiceDiscoveryConfig + type GRPCClientConfig struct + DialTimeout time.Duration + LazyConnection bool + RequestTimeout time.Duration + func NewDefaultGRPCClientConfig() *GRPCClientConfig + func NewGRPCClientConfig(config *Config) *GRPCClientConfig + type GRPCServerConfig struct + Port int + func NewDefaultGRPCServerConfig() *GRPCServerConfig + func NewGRPCServerConfig(config *Config) *GRPCServerConfig + type InfoRetrieverConfig struct + Region string + func NewDefaultInfoRetrieverConfig() *InfoRetrieverConfig + func NewInfoRetrieverConfig(c *Config) *InfoRetrieverConfig + type MemoryGroupConfig struct + TickDuration time.Duration + func NewDefaultMemoryGroupConfig() *MemoryGroupConfig + func NewMemoryGroupConfig(conf *Config) *MemoryGroupConfig + type NatsRPCClientConfig struct + Connect string + ConnectionTimeout time.Duration + MaxReconnectionRetries int + RequestTimeout time.Duration + func NewDefaultNatsRPCClientConfig() *NatsRPCClientConfig + func NewNatsRPCClientConfig(config *Config) *NatsRPCClientConfig + type NatsRPCServerConfig struct + Buffer struct{ ... } + Connect string + ConnectionTimeout time.Duration + MaxReconnectionRetries int + Services int + func NewDefaultNatsRPCServerConfig() *NatsRPCServerConfig + func NewNatsRPCServerConfig(config *Config) *NatsRPCServerConfig + type PitayaConfig struct + Acceptor struct{ ... } + Buffer struct{ ... } + Concurrency struct{ ... } + Handler struct{ ... } + Heartbeat struct{ ... } + Metrics struct{ ... } + Session struct{ ... } + func NewDefaultPitayaConfig() *PitayaConfig + func NewPitayaConfig(config *Config) *PitayaConfig + type PrometheusConfig struct + ConstLabels map[string]string + Game string + Prometheus struct{ ... } + func NewDefaultPrometheusConfig() *PrometheusConfig + func NewPrometheusConfig(config *Config) *PrometheusConfig + type RateLimitingConfig struct + ForceDisable bool + Interval time.Duration + Limit int + func NewDefaultRateLimitingConfig() *RateLimitingConfig + func NewRateLimitingConfig(config *Config) *RateLimitingConfig + type StatsdConfig struct + ConstLabels map[string]string + Statsd struct{ ... } + func NewDefaultStatsdConfig() *StatsdConfig + func NewStatsdConfig(config *Config) *StatsdConfig + type WorkerConfig struct + Concurrency int + Namespace string + Redis struct{ ... } + func NewDefaultWorkerConfig() *WorkerConfig + func NewWorkerConfig(config *Config) *WorkerConfig
Go to main page