resource

Documentation

Overview

Package resource implements virtual resources, which simulate some real-world resources without actually consuming them.

Index

• Variables
• type CPU
  • func NewCPU(hz int) *CPU
  • func (c *CPU) Consume(ctx Ctx, t time.Duration) error
  • func (c *CPU) Provide(ctx Ctx) error
• type Ctx
• type LicenseSvc
  • func NewLicenseSvc(cfg LicenseSvcConfig) *LicenseSvc
  • func (s *LicenseSvc) Call(ctx Ctx, percentFail int) (err error)
• type LicenseSvcConfig

Variables

var (
	ErrRPCTimeout  = errors.New("RPC timed out")
	ErrRPCInternal = errors.New("RPC failed")
)

Errors.

Types

type CPU

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

CPU implements app.CPU interface.

func NewCPU

func NewCPU(hz int) *CPU

NewCPU creates and returns new CPU.

func (*CPU) Consume

func (c *CPU) Consume(ctx Ctx, t time.Duration) error

Consume implements app.CPU interface.

func (*CPU) Provide

func (c *CPU) Provide(ctx Ctx) error

Provide should be started in background once per each CPU instance. It'll return nil when ctx is done.

When Provide is not running Consume won't be able to consume resources and will return only when their ctx is done.

type Ctx

type Ctx = context.Context

type LicenseSvc

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

LicenseSvc implements app.LicenseSvc interface.

func NewLicenseSvc

func NewLicenseSvc(cfg LicenseSvcConfig) *LicenseSvc

NewLicenseSvc creates and returns new LicenseSvc.

func (*LicenseSvc) Call

func (s *LicenseSvc) Call(ctx Ctx, percentFail int) (err error)

Call implements app.LicenseSvc interface.

type LicenseSvcConfig

type LicenseSvcConfig struct {
	Seed           int64
	PercentTimeout int
	MinDelay       time.Duration
	MaxDelay       time.Duration
	TimeoutDelay   time.Duration
}

LicenseSvcConfig contains configuration for LicenseSvc.