runtime

package
v3.0.0 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 2024 License: AGPL-3.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SetDefaultLimitsForYAMLUnmarshalling

func SetDefaultLimitsForYAMLUnmarshalling(defaults Config)

SetDefaultLimitsForYAMLUnmarshalling sets global default limits, used when loading Limits from YAML files. This is used to ensure per-tenant limits are defaulted to those values.

Types

type Config

type Config struct {
	LogStreamCreation     bool `yaml:"log_stream_creation"`
	LogPushRequest        bool `yaml:"log_push_request"`
	LogPushRequestStreams bool `yaml:"log_push_request_streams"`

	// LimitedLogPushErrors is to be implemented and will allow logging push failures at a controlled pace.
	LimitedLogPushErrors bool `yaml:"limited_log_push_errors"`
}

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet

type TenantConfigProvider

type TenantConfigProvider interface {
	TenantConfig(userID string) *Config
}

TenantConfigProvider serves a tenant or default config.

type TenantConfigs

type TenantConfigs struct {
	TenantConfigProvider
}

TenantConfigs periodically fetch a set of per-user configs, and provides convenience functions for fetching the correct value.

func DefaultTenantConfigs

func DefaultTenantConfigs() *TenantConfigs

DefaultTenantConfigs creates and returns a new TenantConfigs with the defaults populated. Only useful for testing, the provider will ignore any tenants passed in.

func NewTenantConfigs

func NewTenantConfigs(configProvider TenantConfigProvider) (*TenantConfigs, error)

NewTenantConfigs makes a new TenantConfigs

func (*TenantConfigs) LimitedLogPushErrors

func (o *TenantConfigs) LimitedLogPushErrors(userID string) bool

func (*TenantConfigs) LogPushRequest

func (o *TenantConfigs) LogPushRequest(userID string) bool

func (*TenantConfigs) LogPushRequestStreams

func (o *TenantConfigs) LogPushRequestStreams(userID string) bool

func (*TenantConfigs) LogStreamCreation

func (o *TenantConfigs) LogStreamCreation(userID string) bool

Jump to

Keyboard shortcuts

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