kernel

Documentation

Index

• func Dispatch(ctx context.Context, e event.Event) error
• type Kernel
  • func New(options ...KernelOption) *Kernel
  • func NewDefaultKernel(options ...KernelOption) *Kernel
  • func (k *Kernel) Bootstrap(ctx context.Context) error
  • func (k *Kernel) Dispatch(ctx context.Context, e event.Event) error
  • func (k *Kernel) Run(ctx context.Context) error
  • func (k *Kernel) RunHttpServer(ctx context.Context) error
  • func (k *Kernel) RunListeners(ctx context.Context)
  • func (k *Kernel) RunServices(ctx context.Context) error
• type KernelConfig
• type KernelOption
  • func Bootstrap(bootstrap ...func(context.Context) error) KernelOption
  • func Config(cb func() *KernelConfig) KernelOption
  • func InitRoutes(cb func(r *router.Router)) KernelOption
  • func Listeners(listeners ...*Listener) KernelOption
  • func RootHandler(rootHandler func() http.Handler) KernelOption
  • func Services(services ...Service) KernelOption
• type Listener
  • func NewListener[E event.Event](cb func(ctx context.Context, event E) error) *Listener
• type Restarter
• type Service
• type ServiceFunc
  • func (s ServiceFunc) Restart() bool
  • func (s ServiceFunc) Run(ctx context.Context, k *Kernel) error
• type ServiceFuncRestart
  • func (s ServiceFuncRestart) Run(ctx context.Context, k *Kernel) error

Functions

func Dispatch

func Dispatch(ctx context.Context, e event.Event) error

Types

type Kernel

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

func New

func New(options ...KernelOption) *Kernel

func NewDefaultKernel

func NewDefaultKernel(options ...KernelOption) *Kernel

func (*Kernel) Bootstrap

func (k *Kernel) Bootstrap(ctx context.Context) error

func (*Kernel) Dispatch

func (k *Kernel) Dispatch(ctx context.Context, e event.Event) error

func (*Kernel) Run

func (k *Kernel) Run(ctx context.Context) error

func (*Kernel) RunHttpServer

func (k *Kernel) RunHttpServer(ctx context.Context) error

func (*Kernel) RunListeners

func (k *Kernel) RunListeners(ctx context.Context)

func (*Kernel) RunServices

func (k *Kernel) RunServices(ctx context.Context) error

type KernelConfig

type KernelConfig struct {
	Port int
}

type KernelOption

type KernelOption func(*Kernel) *Kernel

func Bootstrap

func Bootstrap(bootstrap ...func(context.Context) error) KernelOption

func Config

func Config(cb func() *KernelConfig) KernelOption

func InitRoutes

func InitRoutes(cb func(r *router.Router)) KernelOption

func Listeners

func Listeners(listeners ...*Listener) KernelOption

func RootHandler

func RootHandler(rootHandler func() http.Handler) KernelOption

func Services

func Services(services ...Service) KernelOption

type Listener

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

func NewListener

func NewListener[E event.Event](cb func(ctx context.Context, event E) error) *Listener

type Restarter

type Restarter interface {
	Restart()
}

type Service

type Service interface {
	Run(ctx context.Context, k *Kernel) error
	Name() string
}

type ServiceFunc

type ServiceFunc func(k *Kernel) error

func (ServiceFunc) Restart

func (s ServiceFunc) Restart() bool

func (ServiceFunc) Run

func (s ServiceFunc) Run(ctx context.Context, k *Kernel) error

type ServiceFuncRestart

type ServiceFuncRestart func(k *Kernel) error

func (ServiceFuncRestart) Run

func (s ServiceFuncRestart) Run(ctx context.Context, k *Kernel) error