orkestra

package
v0.4.7 Latest Latest
Warning

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

Go to latest
Published: May 15, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Orkestra

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

func NewOrkestra

func NewOrkestra(timeout time.Duration, logLevel string) *Orkestra

func (*Orkestra) AddPostStartHook

func (o *Orkestra) AddPostStartHook(comp domain.Komponent, hook func(context.Context))

AddPostStartHook: for services that need to start after Orkestra has started

func (*Orkestra) GetKomponent

func (o *Orkestra) GetKomponent(name string) domain.Komponent

GetKomponent returns a komponent if present

func (*Orkestra) OnShutdown

func (o *Orkestra) OnShutdown(fn func(context.Context))

OnShutdown registers a function to be called after all komponents have stopped, within the graceful shutdown timeout.

Use this for cleanup that must happen after the operator stops processing but before the process exits:

  • RBAC deletion (security.rbac.cleanupOnShutdown: true)
  • Deletion protection webhook removal
  • Temp file cleanup (generated TLS certs)

Hooks are called in registration order, sequentially. If the shutdown timeout is exceeded before all hooks run, remaining hooks are skipped — the process is exiting regardless.

func (*Orkestra) Register

func (o *Orkestra) Register(c []domain.Komponent)

Register all komponents

func (*Orkestra) Shutdown

func (o *Orkestra) Shutdown(ctx context.Context)

func (*Orkestra) Start

func (o *Orkestra) Start(ctx context.Context) error

func (*Orkestra) Wait

func (o *Orkestra) Wait()

Listening to done channel

Jump to

Keyboard shortcuts

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