managed

package

Go to main page

Versions in this module

v0

v0.2.15

Apr 10, 2024

Changes in this version

+ func AddHealth(ic inverse.Container)

+ func AddHttp(ic inverse.Container)

+ func AddHttpConfig(ic inverse.Container, conf map[string]string)

+ func AddHttpHandler(ic inverse.Container, ij inverse.Injector[http.Handler])

+ func AddQualifiedRetry(ic inverse.Container, qualifier string)

+ func AddRetry(ic inverse.Container)

type Configuration

+ func GetConfig(container inverse.Container, ctx context.Context, component string) (Configuration, error)

type Health

+ func GetHealth(container inverse.Container, ctx context.Context) (Health, error)

type Lifecycle

+ func GetLifecycle(container inverse.Container, ctx context.Context) (Lifecycle, error)

type Retry

+ func GetQualifiedRetry(container inverse.Container, ctx context.Context, qualifier string) (Retry, error)

+ func GetRetry(container inverse.Container, ctx context.Context) (Retry, error)

v0.2.14

Apr 10, 2024

v0.2.13

Apr 10, 2024

v0.2.12

Apr 10, 2024

v0.2.11

Apr 10, 2024

Changes in this version

+ const QualifierComponent

+ const QualifierConfiguration

+ const QualifierService

+ func AddComponent(ic inverse.Container, comp Component)

+ func AddConfiguration(ic inverse.Container, component string, configuration map[string]string)

+ func AddService(ic inverse.Container, svc Service)

v0.2.10

Apr 10, 2024

v0.2.9

Apr 10, 2024

v0.2.8

Apr 10, 2024

v0.2.7

Apr 10, 2024

v0.2.6

Apr 10, 2024

v0.2.5

Apr 10, 2024

Changes in this version

+ const ConfHttpPort

+ const ConfHttpReadTimeoutMillisecond

+ const ConfHttpTlsCertPath

+ const ConfHttpTlsKeyPath

+ const ConfHttpWriteTimeoutMillisecond

+ const ConfManagerName

+ const ConfManagerQualifier

+ const ConfManagerRuntimeQualifier

+ const ConfRetryAbsorbError

+ const ConfRetryAttempts

+ const ConfRetryDelayMillisecond

+ const ConfRetryMaxDelayMillisecond

+ const ConfRetryMaxJitterMillisecond

+ const DefaultManagerRuntimeQualifier

+ const QualifierConfigPrefix

+ const QualifierHealth

+ const QualifierHttpHandler

+ const QualifierLifecycle

+ const QualifierRetry

+ var ErrChannelRuntimeNoChannel = errors.New("functional runtime no Channel function provided")

+ var ErrConfigMissingTarget = errors.New("configuration target missing")

+ var ErrHttpFailedToInitialiseTls = errors.New("http runtime failed to start tls")

+ var ErrHttpMissingHandler = errors.New("http runtime no handler provided")

+ var ErrHttpMissingServer = errors.New("http runtime no server provided")

+ var ErrLifecycleStartError = errors.New("lifecycle start failed")

+ var ErrLoopRuntimeInitialise = errors.New("functional runtime initialise function failed")

+ var ErrLoopRuntimeNoLoop = errors.New("functional runtime no loop function provided")

+ var ErrRetryStopped = errors.New("retry stopped")

+ var ErrRunnerRuntimeNoRunnable = errors.New("runner runtime no runnable provided")

+ var ErrRunnerRuntimeRunnableStart = errors.New("runner runtime runnable failed to start")

+ func AlwaysTry(err error) bool

+ func New(services []Service, components []Component, configurations []Configuration) runtime.Runtime

+ type Channel interface

+ Channel func() (<-chan T, error)

+ Loop func(T) error

+ type Component interface

+ Clean func() error

+ Name func() string

+ Register func(context.Context, inverse.Container) error

+ Resolve func(context.Context, inverse.Container) error

+ type Configuration interface

+ Get func() map[string]string

+ GetBool func(key string, defaultValue bool) bool

+ GetInt32 func(key string, defaultValue int32) int32

+ GetInt64 func(key string, defaultValue int64) int64

+ GetString func(key string, defaultValue string) string

+ GetUint32 func(key string, defaultValue uint32) uint32

+ GetUint64 func(key string, defaultValue uint64) uint64

+ Has func(key string) bool

+ func EmptyConfig(component string) Configuration

+ func NewConfig(component string, configuration map[string]string) Configuration

+ func ResolveConfig(ctx context.Context, container inverse.Container, component string) (Configuration, error)

+ type Health interface

+ DecInt func(component string, key string, value int64)

+ GetBool func() map[string]bool

+ GetInt func() map[string]int64

+ GetString func() map[string]string

+ IncInt func(component string, key string, value int64)

+ SetBool func(component string, key string, value bool)

+ SetInt func(component string, key string, value int64)

+ SetString func(component string, key string, value string)

+ func NewHealth() Health

+ func ResolveHealth(ctx context.Context, container inverse.Container) (Health, error)

+ type Lifecycle interface

+ Error func(error)

+ Running func() bool

+ func ResolveLifecycle(ctx context.Context, container inverse.Container) (Lifecycle, error)

+ type Loop interface

+ Loop func() error

+ type Retry interface

+ Do func(fnToDo func(int64) error) error

+ func NewQualifiedRetry(qualifier string) Retry

+ func NewRetry() Retry

+ func ResolveRetry(ctx context.Context, container inverse.Container, qualifier string) (Retry, error)

+ type Runnable interface

+ Run func() error

+ type Service interface

+ Start func() error

+ Stop func() error

+ func NewChannel[T any](channel Channel[T]) Service

+ func NewHttp() []Service

+ func NewLoop(loop Loop) []Service

+ func NewRunner(runnable Runnable) Service

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