runtime

Documentation

Index

• Variables
• type Entry
• type Runtime
  • func NewRuntime(c context.Context) (r *Runtime, e error)
  • func (m *Runtime) ApplyPatch(patch *RuntimePatch) (e error)
• type RuntimePatch
  • func (m *RuntimePatch) ApplyBlocklistIps(_ *Storage, bl *blocklist.Blocklist) (e error)
  • func (m *RuntimePatch) ApplyLogLevel(st *Storage, param StorageParam) (e error)
  • func (m *RuntimePatch) ApplyLotteryChance(st *Storage) (e error)
  • func (m *RuntimePatch) ApplyQualityLevel(st *Storage) (e error)
  • func (m *RuntimePatch) ApplySwitch(st *Storage, param StorageParam) (e error)
• type RuntimePatchType
• type Storage
  • func NewStorage(c context.Context) (st *Storage, _ error)
  • func (m *Storage) Get(param StorageParam) interface{}
  • func (m *Storage) Set(param StorageParam, val interface{})
  • func (m *Storage) SetSmoothly(param StorageParam, val interface{})
• type StorageParam

Variables

var (
	ErrRuntimeUndefinedPatch = errors.New("given patch payload is undefined")

	RuntimeUtilsBindings = map[string]RuntimePatchType{
		utils.CfgLotteryChance:     RuntimePatchLottery,
		utils.CfgQualityLevel:      RuntimePatchQuality,
		utils.CfgBlockList:         RuntimePatchBlocklistIps,
		utils.CfgBlockListSwitcher: RuntimePatchBlocklist,
		utils.CfgLimiterSwitcher:   RuntimePatchLimiter,
		utils.CfgAccessLogStdout:   RuntimePatchAccessStdout,
		utils.CfgAccessLogLevel:    RuntimePatchAccessLevel,
	}
)

var (
	ErrConfigInvalidStep = errors.New("config storage - softer-step must be >= 0 and < 100")
)

var GetNameByParam = map[StorageParam]string{
	ParamLottery:      runtimeChangesHumanize[RuntimePatchLottery],
	ParamQuality:      runtimeChangesHumanize[RuntimePatchQuality],
	ParamBlocklist:    runtimeChangesHumanize[RuntimePatchBlocklist],
	ParamBlocklistIps: runtimeChangesHumanize[RuntimePatchBlocklistIps],
	ParamLimiter:      runtimeChangesHumanize[RuntimePatchLimiter],
	ParamAccessStdout: runtimeChangesHumanize[RuntimePatchAccessStdout],
	ParamAccessLevel:  runtimeChangesHumanize[RuntimePatchAccessLevel],
}

var ParamDefaults = map[StorageParam]interface{}{
	ParamLottery:      100,
	ParamQuality:      utils.TitleQualityHD,
	ParamBlocklist:    1,
	ParamBlocklistIps: []string{},
	ParamLimiter:      0,
	ParamAccessStdout: 1,
	ParamAccessLevel:  zerolog.InfoLevel,
}

Types

type Entry

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

type Runtime

type Runtime struct {
	Config *Storage
	// contains filtered or unexported fields
}

func NewRuntime

func NewRuntime(c context.Context) (r *Runtime, e error)

func (*Runtime) ApplyPatch

func (m *Runtime) ApplyPatch(patch *RuntimePatch) (e error)

type RuntimePatch

type RuntimePatch struct {
	Type  RuntimePatchType
	Patch []byte
}

func (*RuntimePatch) ApplyBlocklistIps

func (m *RuntimePatch) ApplyBlocklistIps(_ *Storage, bl *blocklist.Blocklist) (e error)

func (*RuntimePatch) ApplyLogLevel

func (m *RuntimePatch) ApplyLogLevel(st *Storage, param StorageParam) (e error)

func (*RuntimePatch) ApplyLotteryChance

func (m *RuntimePatch) ApplyLotteryChance(st *Storage) (e error)

func (*RuntimePatch) ApplyQualityLevel

func (m *RuntimePatch) ApplyQualityLevel(st *Storage) (e error)

func (*RuntimePatch) ApplySwitch

func (m *RuntimePatch) ApplySwitch(st *Storage, param StorageParam) (e error)

type RuntimePatchType

type RuntimePatchType uint8

const (
	RuntimePatchLottery RuntimePatchType = iota
	RuntimePatchQuality
	RuntimePatchBlocklist
	RuntimePatchBlocklistIps
	RuntimePatchLimiter
	RuntimePatchAccessStdout
	RuntimePatchAccessLevel
)

type Storage

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

func NewStorage

func NewStorage(c context.Context) (st *Storage, _ error)

func (*Storage) Get

func (m *Storage) Get(param StorageParam) interface{}

func (*Storage) Set

func (m *Storage) Set(param StorageParam, val interface{})

func (*Storage) SetSmoothly

func (m *Storage) SetSmoothly(param StorageParam, val interface{})

type StorageParam

type StorageParam uint8

const (
	ParamLottery StorageParam = iota
	ParamQuality
	ParamBlocklist
	ParamBlocklistIps
	ParamLimiter
	ParamAccessStdout
	ParamAccessLevel
)