kernel

type Clock interface {
	Now() time.Time
	After(time.Duration) <-chan time.Time
}

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

type ComponentHooks struct {
	Start func(context.Context) error
	Stop  func(context.Context) error
	Kill  func(context.Context) error
}

type ComponentState string

type EndpointHandler func(context.Context, Request) (Response, error)

type Envelope struct {
	Topic         string
	Message       any
	Timestamp     time.Time
	CorrelationID string
}

type Health struct {
	ID        string
	State     ComponentState
	LastError string
}

type LiveClock struct{}

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

type MsgBusConfig struct {
	Clock         Clock
	DefaultBuffer int
}

type MsgBusStats struct {
	Published int64
	Dropped   int64
}

type Request struct {
	Endpoint      string
	Payload       any
	CorrelationID string
	Timestamp     time.Time
}

type Response struct {
	CorrelationID string
	Payload       any
}

type Subscription interface {
	C() <-chan Envelope
	Close() error
}

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