endpointstate

type RestorationNotifier interface {
	// RestorationNotify is called once the "old" endpoints have been read from disk.
	// The Endpoints are not yet exposed to the EndpointManager.
	RestorationNotify(possible map[uint16]*endpoint.Endpoint)
}

type RestorationNotifierOut struct {
	cell.Out

	Restorer RestorationNotifier `group:"endpointRestorationNotifiers"`
}

type Restorer interface {
	// WaitForEndpointRestoreWithoutRegeneration blocks the caller until either the context is
	// cancelled or all the endpoints from a previous run have been restored.
	WaitForEndpointRestoreWithoutRegeneration(ctx context.Context) error

	// WaitForEndpointRestore blocks the caller until either the context is
	// cancelled or all the endpoints from a previous run have been restored and regenerated.
	WaitForEndpointRestore(ctx context.Context) error

	// WaitForInitialPolicy blocks the caller until either the context is
	// cancelled or initial policies of all restored endpoints have been computed.
	WaitForInitialPolicy(ctx context.Context) error
}