app

Documentation

Index

• Variables
• func MockCtx() *mockCtx
• func MockStart(s Service) func()
• func MountSpaUI(fs fs.FS) func(*mainServer) spaFS
• func ParseDuration(dur string) (result time.Duration, err error)
• func Run(ctx context.Context, f Factories)
• func Shrink(body string) string
• type Config
  • func (c Config) BoolOr(key string, def bool) bool
  • func (c Config) DurOr(key string, def time.Duration) time.Duration
  • func (c Config) IntOr(key string, def int) int
  • func (c Config) StrOr(key, def string) string
• type Context
• type Err
  • func ShErr(err error) Err
  • func (err Err) Error() string
• type Fabric
  • func (f *Fabric) Start(ctx context.Context)
• type Factories
  • func (c Factories) Init() Singletons
• type MockRuntime
  • func MockStartSpin[T any](this *T, other ...any) (*T, MockRuntime)
  • func (r MockRuntime) Context(main ...string) context.Context
  • func (r MockRuntime) Stop()
• type NotFound
  • func (nf NotFound) Error() string
• type Service
• type Singletons
  • func (s Singletons) MockStart() MockRuntime
  • func (s Singletons) Monitor() *monitorServers

Variables

var Log passLogger

var Prefix = "slrp"

Prefix is the env var prefix

Functions

func MockCtx

func MockCtx() *mockCtx

func MockStart

func MockStart(s Service) func()

func MountSpaUI

func MountSpaUI(fs fs.FS) func(*mainServer) spaFS

func ParseDuration

func ParseDuration(dur string) (result time.Duration, err error)

maybe not the most performant duration parser, but at least it supports days and weeks

func Run

func Run(ctx context.Context, f Factories)

func Shrink

func Shrink(body string) string

Types

type Config

type Config map[string]string

func (Config) BoolOr

func (c Config) BoolOr(key string, def bool) bool

func (Config) DurOr

func (c Config) DurOr(key string, def time.Duration) time.Duration

func (Config) IntOr

func (c Config) IntOr(key string, def int) int

func (Config) StrOr

func (c Config) StrOr(key, def string) string

type Context

type Context interface {
	Ctx() context.Context

	// Propagates Done channel from parent context.
	Done() <-chan struct{}

	// Heartbeat used as signal to Fabric that marks related service for the next storage
	// flush event, in case BinaryMarshaller/BinaryUnmarshaller interfaces are implemented.
	// Second major use is as unit testing blocking hook.
	Heartbeat()
}

type Err

type Err struct {
	Err error
	// contains filtered or unexported fields
}

func ShErr

func ShErr(err error) Err

func (Err) Error

func (err Err) Error() string

type Fabric

type Fabric struct {
	State     string
	Factories Factories
	// contains filtered or unexported fields
}

func (*Fabric) Start

func (f *Fabric) Start(ctx context.Context)

type Factories

type Factories map[string]interface{}

func (Factories) Init

func (c Factories) Init() Singletons

type MockRuntime

type MockRuntime map[string]*mockCtx

func MockStartSpin

func MockStartSpin[T any](this *T, other ...any) (*T, MockRuntime)

func (MockRuntime) Context

func (r MockRuntime) Context(main ...string) context.Context

func (MockRuntime) Stop

func (r MockRuntime) Stop()

type NotFound

type NotFound string

func (NotFound) Error

func (nf NotFound) Error() string

type Service

type Service interface {
	// TODO: Start(Context) error
	Start(Context)
}

type Singletons

type Singletons map[string]interface{}

func (Singletons) MockStart

func (s Singletons) MockStart() MockRuntime

func (Singletons) Monitor

func (s Singletons) Monitor() *monitorServers