remoteengine

type Connector struct {
	// Discover adds and removes remote engines as they become available and
	// unavailable, as described by
	// [github.com/dogmatiq/runkit.RemoteEngineDiscoverer].
	Discover func(
		ctx context.Context,
		add func(conn grpc.ClientConnInterface) (remove func()),
	) error

	// EventStreams is the catalog to which each available remote engine's
	// event streams are added.
	EventStreams *eventstream.Catalog

	// EventTypeIDs is the set of event types to deliver from each remote
	// engine.
	//
	// If it is empty, remote engines are not watched at all, as watching for
	// an empty set of types would deliver events of every type.
	EventTypeIDs *uuidcollection.Set

	// Logger is the target for log messages produced by the connector and its
	// connections to remote engines.
	Logger *slog.Logger
}