SS.Distributed 1.3.0

export function affinePartition(double[] localValues, double scale, double offset)->DistributedResult

export function allPartitions(int globalCount, int workers, int haloWidth)->Partition1D[]

export function allReduceSum(double[] rankValues, int workers)->Collective

export function assign(TaskRequirement task, WorkerCapability[] workers)->ScheduleAssignment

export record AuthorizedEnvelope(public string schema, public TransportEnvelope message, public string workerId, public long generation, public string nonce, public string authorizationTag)

export function authorizeEnvelope(TransportEnvelope message, string workerId, long generation, string nonce, string authorizationTag)->AuthorizedEnvelope

export function broadcast(double[] rootValues, int rootRank, int workers)->Collective

export function cancelWorker(WorkerState worker)->WorkerState

export function checkpoint(string jobId, int completedEpoch, int totalEpochs, double[] state, string sourceDigest)->DistributedCheckpoint

export function clusterBarrier(Communicator context, WorkerObservation[] participants, long barrierEpoch, long heartbeatDeadline)->ClusterBarrierResult

export record ClusterBarrierResult(public long epoch, public int participants, public int arrived, public bool complete, public string diagnostic)

export record ClusterKit(public string schema, public string packageVersion, public string runtimeTarget, public string launchCommand, public string manifestDigest, public bool requiresHostTransport, public string licensingBoundary)

export record Collective(public string operation, public double[] values, public int participants, public bool deterministic)

export function communicator(string jobId, int size, long generation, string authorizationId)->Communicator

export record Communicator(public string schema, public string jobId, public int size, public long generation, public string authorizationId)

export function distributedAffineSweep(double[] parameters, double scale, double offset, int workers)->DistributedResult

export record DistributedCheckpoint(public string schema, public string jobId, public int completedEpoch, public int totalEpochs, public double[] state, public string sourceDigest)

export function distributedExecute(Communicator context, WorkerObservation[] workers, string operation, double[] values, double scale, double offset)->RemoteExecution

export record DistributedGather(public double[] values, public int participants, public bool cancelled, public bool complete, public string diagnostic)

export record DistributedHaloExchange(public Halo[] halos, public long version, public int exchangedValues, public bool ordered, public string diagnostic)

export record DistributedResult(public double[] values, public int partitions, public int exchangedValues, public string algorithm)

export record DistributedScatter(public Partition1D[] partitions, public TransportEnvelope[] messages, public int values, public string checksum)

export function envelope(string jobId, int sourceRank, int targetRank, int workers, int tag, long sequence, double[] payload, string checksum)->TransportEnvelope

export function exchangeDistributedHalos(Communicator context, Partition1D[] partitions, double[][] localValues, long version)->DistributedHaloExchange

export function gatherDistributed(Communicator context, AuthorizedEnvelope[] results, int targetRank, int tag, long firstSequence, string checksum, string[] workerIds, string[] nonces, string[] authorizationTags, bool cancelled)->DistributedGather

export record Halo(public bool hasLeft, public double left, public bool hasRight, public double right)

export function haloFromGlobal(double[] globalValues, Partition1D partition)->Halo

export function heartbeat(WorkerState worker, long value)->WorkerState

export function launchRemoteWorkers(RemoteLaunchPlan plan, WorkerObservation[] processObservations, long expectedGeneration)->RemoteWorkerLaunchResult

export function observeWorker(WorkerState worker, int exitCode, long observedHeartbeat, long heartbeatDeadline)->WorkerObservation

export function orderedPayloads(TransportEnvelope[] values, string jobId, int targetRank, int tag, int workers, long firstSequence, string checksum)->double[]

export function partition1d(int globalCount, int workers, int rank, int haloWidth)->Partition1D

export record Partition1D(public int rank, public int workers, public int globalCount, public int offset, public int count, public int halo, public int ghostStart, public int ghostEnd)

export function portableKit(string runtimeTarget, string launchCommand, string manifestDigest)->ClusterKit

export function prefixScan(double[] rankValues, int workers)->Collective

export function receiveAuthorizedEnvelopesAt(string address, int port, int backlog, int workers, string expectedJob, int expectedTarget, int expectedTag, long firstSequence, string expectedChecksum, long expectedGeneration, string[] expectedWorkerIds, string[] expectedNonces, string[] expectedAuthorizationTags, int timeoutMilliseconds)->AuthorizedEnvelope[]

export function receiveEnvelopesAt(string address, int port, int backlog, int count, int workers, string expectedJob, int expectedTarget, int expectedTag, long firstSequence, string expectedChecksum, int timeoutMilliseconds)->TransportEnvelope[]

export function recover(DistributedCheckpoint saved, int requestedWorkers, int failedWorkers, bool cancelled, string expectedDigest)->RecoveryDecision

export record RecoveryDecision(public string action, public int resumeEpoch, public int survivingWorkers, public bool safe, public string diagnostic)

export function reduceSum(double[] rankValues, int workers)->Collective

export function relaunchWorker(WorkerObservation failed, int workers, long nextGeneration, long heartbeat)->WorkerState

export record RemoteExecution(public DistributedResult result, public string mode, public int workers, public bool remoteSideEffects, public string diagnostic)

export function remoteLaunchPlan(Communicator context, string coordinatorHost, RemoteWorkerSpec[] workers, int startupTimeoutMilliseconds, bool isolatedNodes, bool encryptedHostChannel)->RemoteLaunchPlan

export record RemoteLaunchPlan(public string schema, public Communicator communicator, public string coordinatorHost, public RemoteWorkerSpec[] workers, public int startupTimeoutMilliseconds, public bool isolatedNodes, public bool encryptedHostChannel)

export function remoteWorker(string workerId, int rank, int workers, string host, int port, string operatingSystem, string launcher, string launchCommand, string artifactDigest, string authorizationId)->RemoteWorkerSpec

export record RemoteWorkerLaunchResult(public WorkerObservation[] workers, public int launched, public bool authenticated, public bool running, public string diagnostic)

export record RemoteWorkerSpec(public string workerId, public int rank, public string host, public int port, public string operatingSystem, public string launcher, public string launchCommand, public string artifactDigest, public string authorizationId)

export function scatterDistributed(Communicator context, double[] values, int haloWidth, int tag, long firstSequence, string checksum)->DistributedScatter

export record ScheduleAssignment(public string taskId, public string workerId, public bool assigned, public string diagnostic)

export function sendAuthorizedEnvelopeTo(string host, int port, int timeoutMilliseconds, AuthorizedEnvelope value, int workers)->bool

export function sendEnvelopeTo(string host, int port, int timeoutMilliseconds, TransportEnvelope value, int workers)->bool

export function startWorker(string workerId, int rank, int workers, long generation, long heartbeat)->WorkerState

export function stencilPartition(double[] localValues, Partition1D partition, Halo halo)->DistributedResult

export function stencilStep(double[] globalValues, int workers)->DistributedResult

export function stopWorker(WorkerState worker)->WorkerState

export function supercomputingExecute(Communicator context, WorkerObservation[] workers, bool clusterAuthorized, string operation, double[] values, double scale, double offset)->RemoteExecution

export record TaskRequirement(public string taskId, public int minimumThreads, public long minimumMemoryBytes, public string accelerator, public int priority)

export record TransportEnvelope(public string schema, public string jobId, public int sourceRank, public int targetRank, public int tag, public long sequence, public double[] payload, public string checksum)

export function validateAuthorizedEnvelope(AuthorizedEnvelope value, int workers, string expectedChecksum, string expectedWorkerId, long expectedGeneration, string expectedNonce, string expectedAuthorizationTag)->bool

export function validateEnvelope(TransportEnvelope value, int workers, string expectedChecksum)->bool

export record WorkerCapability(public string workerId, public int cpuThreads, public long memoryBytes, public string accelerator, public string operatingSystem, public string identity)

export record WorkerObservation(public string workerId, public int rank, public long generation, public string state, public long heartbeat, public int exitCode, public bool relaunchAllowed, public string diagnostic)

export record WorkerState(public string workerId, public int rank, public string state, public long generation, public long heartbeat, public bool cancelled)