Function NewRemoteUnloaderAdapter

core/services/nodes/unloader.go:63–70

NewRemoteUnloaderAdapter creates a new adapter. installTimeout and upgradeTimeout govern the NATS request-reply deadlines for backend.install and backend.upgrade respectively. Use DistributedConfig.BackendInstallTimeoutOrDefault() / BackendUpgradeTimeoutOrDefault() at construction.

(registry ModelLocator, nats messaging.MessagingClient, installTimeout, upgradeTimeout time.Duration)

// DistributedConfig.BackendInstallTimeoutOrDefault() /
// BackendUpgradeTimeoutOrDefault() at construction.
func NewRemoteUnloaderAdapter(registry ModelLocator, nats messaging.MessagingClient, installTimeout, upgradeTimeout time.Duration) *RemoteUnloaderAdapter {
	return &RemoteUnloaderAdapter{
		registry:       registry,
		nats:           nats,
		installTimeout: installTimeout,
		upgradeTimeout: upgradeTimeout,
	}
}

// InstallTimeout returns the configured backend.install round-trip timeout.
// Used by DistributedBackendManager to push NextRetryAt out by this duration