internal

Documentation

Index

• type ConsoleLifetimeRoutine
  • func (ss *ConsoleLifetimeRoutine) Construct(application host.IHostApplication, ...)
  • func (ss *ConsoleLifetimeRoutine) Start(_ context.Context, wg *sync2.TimeoutWaitGroup)
  • func (ss *ConsoleLifetimeRoutine) Stop(_ context.Context, wg *sync2.TimeoutWaitGroup)
• type Host
  • func NewHost(provider injection.IRoutineProvider) *Host
  • func (ss *Host) Construct(option *option.Option[*HostOption], logger *logging.Logger[Host])
  • func (ss *Host) GetRoutineProvider() injection.IRoutineProvider
  • func (ss *Host) Start(ctx context.Context, wg *sync.TimeoutWaitGroup)
  • func (ss *Host) Stop(ctx context.Context, wg *sync.TimeoutWaitGroup)
• type HostApplication
  • func NewHostApplication() *HostApplication
  • func (ss *HostApplication) OnStarted(listener func())
  • func (ss *HostApplication) OnStopped(listener func())
  • func (ss *HostApplication) OnStopping(listener func())
  • func (ss *HostApplication) StopApplication()
• type HostOption
• type HostedLifecycleRoutineContainer
  • func (ss *HostedLifecycleRoutineContainer) AddHostedLifecycleRoutine(factory func() host.IHostedLifecycleRoutine)
  • func (ss *HostedLifecycleRoutineContainer) BuildHostedLifecycleRoutines()
  • func (ss *HostedLifecycleRoutineContainer) GetHostedLifecycleRoutines() []host.IHostedLifecycleRoutine
• type HostedRoutineContainer
  • func (ss *HostedRoutineContainer) AddHostedRoutine(factory func() host.IHostedRoutine)
  • func (ss *HostedRoutineContainer) BuildHostedRoutines()
  • func (ss *HostedRoutineContainer) GetHostedRoutines() []host.IHostedRoutine
• type RoutineCollection
  • func NewRoutineCollection() *RoutineCollection
  • func (ss *RoutineCollection) AddDescriptor(descriptor *injection.RoutineDescriptor)
  • func (ss *RoutineCollection) GetDescriptor(ty reflect.Type) *injection.RoutineDescriptor
  • func (ss *RoutineCollection) GetDescriptors() []*injection.RoutineDescriptor
  • func (ss *RoutineCollection) GetKeyedDescriptor(key any, ty reflect.Type) *injection.RoutineDescriptor
• type RoutineProvider
  • func NewProvider(descriptors injection.IRoutineCollection, root *RoutineProvider) *RoutineProvider
  • func (ss *RoutineProvider) CreateScope() injection.IRoutineScope
  • func (ss *RoutineProvider) GetKeyedRoutine(key any, ty reflect.Type) any
  • func (ss *RoutineProvider) GetRootScope() injection.IRoutineScope
  • func (ss *RoutineProvider) GetRoutine(ty reflect.Type) any
• type RoutineScope
  • func NewRoutineScope(provider *RoutineProvider) *RoutineScope
  • func (ss *RoutineScope) GetKeyedScopedRoutine(key any, ty reflect.Type) any
  • func (ss *RoutineScope) GetProvider() injection.IRoutineProvider
  • func (ss *RoutineScope) GetRoot() injection.IRoutineScope
  • func (ss *RoutineScope) GetScopedRoutine(ty reflect.Type) any
  • func (ss *RoutineScope) SetKeyedScopedRoutine(key any, ty reflect.Type, value any)
  • func (ss *RoutineScope) SetScopedRoutine(ty reflect.Type, value any)

Types

type ConsoleLifetimeRoutine

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

func (*ConsoleLifetimeRoutine) Construct

func (ss *ConsoleLifetimeRoutine) Construct(application host.IHostApplication, logger *logging.Logger[ConsoleLifetimeRoutine])

func (*ConsoleLifetimeRoutine) Start

func (ss *ConsoleLifetimeRoutine) Start(_ context.Context, wg *sync2.TimeoutWaitGroup)

func (*ConsoleLifetimeRoutine) Stop

func (ss *ConsoleLifetimeRoutine) Stop(_ context.Context, wg *sync2.TimeoutWaitGroup)

type Host

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

func NewHost

func NewHost(provider injection.IRoutineProvider) *Host

func (*Host) Construct

func (ss *Host) Construct(option *option.Option[*HostOption], logger *logging.Logger[Host])

func (*Host) GetRoutineProvider

func (ss *Host) GetRoutineProvider() injection.IRoutineProvider

func (*Host) Start

func (ss *Host) Start(ctx context.Context, wg *sync.TimeoutWaitGroup)

func (*Host) Stop

func (ss *Host) Stop(ctx context.Context, wg *sync.TimeoutWaitGroup)

type HostApplication

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

func NewHostApplication

func NewHostApplication() *HostApplication

func (*HostApplication) OnStarted

func (ss *HostApplication) OnStarted(listener func())

func (*HostApplication) OnStopped

func (ss *HostApplication) OnStopped(listener func())

func (*HostApplication) OnStopping

func (ss *HostApplication) OnStopping(listener func())

func (*HostApplication) StopApplication

func (ss *HostApplication) StopApplication()

type HostOption

type HostOption struct {
	StartWaitTimeoutSeconds int
	StopWaitTimeoutSeconds  int
}

type HostedLifecycleRoutineContainer

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

func (*HostedLifecycleRoutineContainer) AddHostedLifecycleRoutine

func (ss *HostedLifecycleRoutineContainer) AddHostedLifecycleRoutine(factory func() host.IHostedLifecycleRoutine)

func (*HostedLifecycleRoutineContainer) BuildHostedLifecycleRoutines

func (ss *HostedLifecycleRoutineContainer) BuildHostedLifecycleRoutines()

func (*HostedLifecycleRoutineContainer) GetHostedLifecycleRoutines

func (ss *HostedLifecycleRoutineContainer) GetHostedLifecycleRoutines() []host.IHostedLifecycleRoutine

type HostedRoutineContainer

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

func (*HostedRoutineContainer) AddHostedRoutine

func (ss *HostedRoutineContainer) AddHostedRoutine(factory func() host.IHostedRoutine)

func (*HostedRoutineContainer) BuildHostedRoutines

func (ss *HostedRoutineContainer) BuildHostedRoutines()

func (*HostedRoutineContainer) GetHostedRoutines

func (ss *HostedRoutineContainer) GetHostedRoutines() []host.IHostedRoutine

type RoutineCollection

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

func NewRoutineCollection

func NewRoutineCollection() *RoutineCollection

func (*RoutineCollection) AddDescriptor

func (ss *RoutineCollection) AddDescriptor(descriptor *injection.RoutineDescriptor)

func (*RoutineCollection) GetDescriptor

func (ss *RoutineCollection) GetDescriptor(ty reflect.Type) *injection.RoutineDescriptor

func (*RoutineCollection) GetDescriptors

func (ss *RoutineCollection) GetDescriptors() []*injection.RoutineDescriptor

func (*RoutineCollection) GetKeyedDescriptor

func (ss *RoutineCollection) GetKeyedDescriptor(key any, ty reflect.Type) *injection.RoutineDescriptor

type RoutineProvider

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

func NewProvider

func NewProvider(descriptors injection.IRoutineCollection, root *RoutineProvider) *RoutineProvider

func (*RoutineProvider) CreateScope

func (ss *RoutineProvider) CreateScope() injection.IRoutineScope

func (*RoutineProvider) GetKeyedRoutine

func (ss *RoutineProvider) GetKeyedRoutine(key any, ty reflect.Type) any

func (*RoutineProvider) GetRootScope

func (ss *RoutineProvider) GetRootScope() injection.IRoutineScope

func (*RoutineProvider) GetRoutine

func (ss *RoutineProvider) GetRoutine(ty reflect.Type) any

type RoutineScope

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

func NewRoutineScope

func NewRoutineScope(provider *RoutineProvider) *RoutineScope

func (*RoutineScope) GetKeyedScopedRoutine

func (ss *RoutineScope) GetKeyedScopedRoutine(key any, ty reflect.Type) any

func (*RoutineScope) GetProvider

func (ss *RoutineScope) GetProvider() injection.IRoutineProvider

func (*RoutineScope) GetRoot

func (ss *RoutineScope) GetRoot() injection.IRoutineScope

func (*RoutineScope) GetScopedRoutine

func (ss *RoutineScope) GetScopedRoutine(ty reflect.Type) any

func (*RoutineScope) SetKeyedScopedRoutine

func (ss *RoutineScope) SetKeyedScopedRoutine(key any, ty reflect.Type, value any)

func (*RoutineScope) SetScopedRoutine

func (ss *RoutineScope) SetScopedRoutine(ty reflect.Type, value any)