pipeline

type ActionKind string

type Capability struct {
	Name   string
	Routes []Route
	Worker int
	RunKey func(Event) string
	Run    func(ctx context.Context, event Event, emit func(Event))
}

type Config struct {
	Capabilities []Capability
	Bus          *eventbus.Bus[Observation]
}

type Event interface {
	Key() string
}

type Observation struct {
	Action     ActionKind
	Capability string
	Event      Event
}

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

type Route struct {
	From   string
	Accept func(Event) bool
}