marvin

type Bus interface {
	Name() BusName
	Run(context.Context, BusBundle) error
	SendMessage(ctx context.Context, address any, text string)
}

type BusAssembler func(BusName, arbitraryConfig) (Bus, error)

type BusBundle struct {
	Events  chan<- Event
	Replies <-chan Reply
	Errors  chan<- error
}

type BusName string

type Config struct {
	Name     string
	LogLevel slog.Level `toml:"log_level"`
	Bus      map[string]arbitraryConfig
	Reactor  map[string]arbitraryConfig
	// contains filtered or unexported fields
}

type Event struct {
	Text      string
	SourceBus BusName
	Address   any
	// contains filtered or unexported fields
}

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

type Reactor interface {
	Run(context.Context, ReactorBundle) error
}

type ReactorAssembler func(ReactorName, arbitraryConfig) (Reactor, error)

type ReactorBundle struct {
	Events  <-chan Event
	Replies chan<- Reply
	Errors  chan<- error
}

type ReactorName string

type Registry interface {
	BusFor(string) BusAssembler
	ReactorFor(string) ReactorAssembler
}

type Reply struct {
	Bus     BusName
	Address any
	Text    string
}