kernel

Documentation

Index

• Variables
• func AddClosableResource(ctx context.Context, closer io.Closer)
• type Kernel
  • func New(options ...KernelOption) *Kernel
  • func (k *Kernel) APIDoc(ctx context.Context) (*spec.Swagger, error)
  • func (k *Kernel) Bootstrap(ctx context.Context) error
  • func (k *Kernel) Config() salusaconfig.Config
  • func (k *Kernel) RootHandler() http.Handler
  • func (k *Kernel) Run(ctx context.Context) error
  • func (k *Kernel) RunHttpServer(ctx context.Context) error
  • func (k *Kernel) RunServices(ctx context.Context)
  • func (k *Kernel) Validate(ctx context.Context) error
• type KernelOption
  • func APIDocumentation(options ...openapidoc.SwaggerOption) KernelOption
  • func Bootstrap(bootstrap ...func(context.Context) error) KernelOption
  • func Config[T salusaconfig.Config](cb func() T) KernelOption
  • func InitRoutes(cb func(r *router.Router)) KernelOption
  • func Middleware(globalMiddleware []router.MiddlewareFunc) KernelOption
  • func RootHandler(rootHandler func(ctx context.Context) http.Handler) KernelOption
  • func Services(services ...Service) KernelOption
• type Restarter
• type Service
• type ServiceFunc
  • func (s ServiceFunc) Restart() bool
  • func (s ServiceFunc) Run(ctx context.Context) error
• type ServiceFuncRestart
  • func (s ServiceFuncRestart) Run(ctx context.Context) error
• type StdoutResponseWriter
  • func NewStdoutResponseWriter() *StdoutResponseWriter
  • func (s *StdoutResponseWriter) Header() http.Header
  • func (w *StdoutResponseWriter) Ok() bool
  • func (w *StdoutResponseWriter) Status() int
  • func (s *StdoutResponseWriter) Write(b []byte) (int, error)
  • func (s *StdoutResponseWriter) WriteHeader(statusCode int)
• type Validator

Variables

var (
	ErrAlreadyBootstrapped = errors.New("kernel already bootstrapped")
)

var ErrNotInKernel = errors.New("not in kernel")

Functions

func AddClosableResource

func AddClosableResource(ctx context.Context, closer io.Closer)

Types

type Kernel

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

func New

func New(options ...KernelOption) *Kernel

func (*Kernel) APIDoc

func (k *Kernel) APIDoc(ctx context.Context) (*spec.Swagger, error)

Operation implements openapidoc.Operationer.

func (*Kernel) Bootstrap

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

func (*Kernel) Config

func (k *Kernel) Config() salusaconfig.Config

func (*Kernel) RootHandler

func (k *Kernel) RootHandler() http.Handler

func (*Kernel) Run

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

func (*Kernel) RunHttpServer

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

func (*Kernel) RunServices

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

func (*Kernel) Validate

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

type KernelOption

type KernelOption func(*Kernel) *Kernel

func APIDocumentation

func APIDocumentation(options ...openapidoc.SwaggerOption) KernelOption

func Bootstrap

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

func Config

func Config[T salusaconfig.Config](cb func() T) KernelOption

func InitRoutes

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

func Middleware

func Middleware(globalMiddleware []router.MiddlewareFunc) KernelOption

func RootHandler

func RootHandler(rootHandler func(ctx context.Context) http.Handler) KernelOption

func Services

func Services(services ...Service) KernelOption

type Restarter

type Restarter interface {
	Restart()
}

type Service

type Service interface {
	Run(ctx context.Context) error
	Name() string
}

type ServiceFunc

type ServiceFunc func() error

func (ServiceFunc) Restart

func (s ServiceFunc) Restart() bool

func (ServiceFunc) Run

func (s ServiceFunc) Run(ctx context.Context) error

type ServiceFuncRestart

type ServiceFuncRestart func() error

func (ServiceFuncRestart) Run

func (s ServiceFuncRestart) Run(ctx context.Context) error

type StdoutResponseWriter

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

func NewStdoutResponseWriter

func NewStdoutResponseWriter() *StdoutResponseWriter

func (*StdoutResponseWriter) Header

func (s *StdoutResponseWriter) Header() http.Header

Header implements http.ResponseWriter.

func (*StdoutResponseWriter) Ok

func (w *StdoutResponseWriter) Ok() bool

func (*StdoutResponseWriter) Status

func (w *StdoutResponseWriter) Status() int

func (*StdoutResponseWriter) Write

func (s *StdoutResponseWriter) Write(b []byte) (int, error)

Write implements http.ResponseWriter.

func (*StdoutResponseWriter) WriteHeader

func (s *StdoutResponseWriter) WriteHeader(statusCode int)

WriteHeader implements http.ResponseWriter.

type Validator

type Validator interface {
	Validate(ctx context.Context) error
}