hostbridge

type Bridge ¶

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

Bridge consumes Events from a Source and drives an mdns.Publisher, maintaining an internal set of currently-published records so that Close cleanly withdraws every advertisement on shutdown.

func New(pub mdns.Publisher, src Source, log *zap.Logger) *Bridge

func (b *Bridge) Active() []mdns.Record

func (b *Bridge) Run(ctx context.Context) error

type Event ¶

type Event struct {
	Type   EventType
	Record mdns.Record
}

Event is a single domain registration change delivered by a Source.

type EventType ¶

type EventType int

EventType distinguishes a domain registration from a de-registration.

const (
	// EventAdded indicates a domain has been registered with the emulator
	// and should be advertised on the host.
	EventAdded EventType = iota
	// EventRemoved indicates a domain has been de-registered and should
	// be withdrawn from the host advertisement.
	EventRemoved
)

func (t EventType) String() string

type Source ¶

type Source interface {
	Watch(ctx context.Context) (<-chan Event, error)
}

Source is the upstream feed of domain events. The overcast host CLI implementation of Source tails the emulator's /_internal/domains/watch SSE endpoint; tests can supply an in-memory channel instead.

Watch must return a channel that is closed when the underlying feed terminates (either cleanly or due to an error). Implementations should honour ctx cancellation to unblock the caller promptly.