Versions in this module Expand all Collapse all v0 v0.5.0 Dec 30, 2024 Changes in this version + const AllocationDeploymentBehavior + const AllocationDeploymentTimeout + const AllocationNamespace + const AllocationRestartBehavior + const AllocationShutdownTimeout + const AllocationStartBehavior + const AllocationStartTimeout + const BidReplyBehavior + const BidRequestBehavior + const BidRequestTimeout + const BidRequestTopic + const CommitDeploymentBehavior + const CommitDeploymentTimeout + const DeploymentStatusCommitting + const DeploymentStatusCompleted + const DeploymentStatusFailed + const DeploymentStatusGenerating + const DeploymentStatusPreparing + const DeploymentStatusProvisioning + const DeploymentStatusRunning + const DeploymentStatusShuttingDown + const EnsembleNamespace + const MaxBidMultiplier + const MaxPermutations + const MinEnsembleDeploymentTime + const NodeNamespace + const RevertDeploymentBehavior + const SubnetCreateTimeout + const SubnetDestroyTimeout + const VerifyEdgeConstraintBehavior + const VerifyEdgeConstraintTimeout + var AllocationLogsBehavior = EnsembleNamespace + "/allocation/logs" + var AllocationShutdownBehavior = EnsembleNamespace + "/allocation/shutdown" + var ErrDeploymentFailed = errors.New("failed to create deployment") + var ErrProvisioningFailed = errors.New("failed to provision the ensemble") + var ErrTODO = errors.New("TODO") + var RegisterHealthcheckBehavior = "/dms/actor/healthcheck/register" + var SubnetAcceptPeerBehavior = AllocationNamespace + "/subnet/accept-peer" + var SubnetAddPeerBehavior = AllocationNamespace + "/subnet/add-peer" + var SubnetCreateBehavior = types.Behavior + var SubnetDNSAddRecordsBehavior = AllocationNamespace + "/subnet/dns/add-records" + var SubnetDNSRemoveRecordBehavior = AllocationNamespace + "/subnet/dns/remove-record" + var SubnetDestroyBehavior = types.Behavior + var SubnetMapPortBehavior = AllocationNamespace + "/subnet/map-port" + var SubnetRemovePeerBehavior = AllocationNamespace + "/subnet/remove-peer" + var SubnetUnmapPortBehavior = AllocationNamespace + "/subnet/unmap-port" + func EnsembleIDFromBehavior(b string) (string, error) + type Allocation struct + Actor actor.Actor + ID string + Job Job + func NewAllocation(id string, fs afero.Afero, dmsConfig config.Config, actor actor.Actor, ...) (*Allocation, error) + func (a *Allocation) Cleanup() error + func (a *Allocation) ExecutionID() string + func (a *Allocation) GetPortMapping() map[int]int + func (a *Allocation) Restart(ctx context.Context) error + func (a *Allocation) Run(ctx context.Context, subnetIP string, gatewayIP string, ...) error + func (a *Allocation) SetHealthCheck(f func() error) + func (a *Allocation) Start() error + func (a *Allocation) Status(_ context.Context) Status + func (a *Allocation) Stop(ctx context.Context) error + func (a *Allocation) Terminate(ctx context.Context) error + type AllocationDeploymentConfig struct + Execution types.SpecConfig + Executor AllocationExecutor + ProvisionScripts map[string][]byte + Resources types.Resources + type AllocationDeploymentRequest struct + Allocations map[string]AllocationDeploymentConfig + EnsembleID string + NodeID string + type AllocationDeploymentResponse struct + Allocations map[string]actor.Handle + Error string + OK bool + type AllocationDetails struct + Job Job + NodeID string + SourceID string + type AllocationExecutor = job_types.AllocationExecutor + type AllocationLogsRequest struct + AllocName string + type AllocationLogsResponse struct + Error string + Stderr []byte + Stdout []byte + type AllocationManifest = job_types.AllocationManifest + type AllocationRestartResponse struct + Error string + OK bool + type AllocationShutdownRequest struct + AllocationID string + type AllocationShutdownResponse struct + Error string + OK bool + type AllocationStartRequest struct + GatewayIP string + PortMapping map[int]int + SubnetIP string + type AllocationStartResponse struct + Error string + OK bool + type AllocationStatus string + const Completed + const Failed + const Pending + const Running + const Stopped + const Terminated + type AllocationStopRequest struct + AllocationID string + type AllocationStopResponse struct + Error string + OK bool + type Bid = job_types.Bid + type BidRequest = job_types.BidRequest + type CommitDeploymentRequest struct + AllocationName string + EnsembleID string + NodeID string + PortMapping map[int]int + Resources types.Resources + type CommitDeploymentResponse struct + Error string + OK bool + type Coordinate struct + func (c *Coordinate) Empty() bool + type DeploymentSnapshot = job_types.DeploymentSnapshot + type DeploymentStatus = job_types.DeploymentStatus + type EdgeConstraint = job_types.EdgeConstraint + type EnsembleBidRequest = job_types.EnsembleBidRequest + type EnsembleConfig = job_types.EnsembleConfig + type EnsembleManifest = job_types.EnsembleManifest + type GeoLocator struct + func NewGeoLocator() (*GeoLocator, error) + func (geo *GeoLocator) Coordinate(loc Location) (Coordinate, error) + type HealthCheckResponse struct + Error string + OK bool + type Job struct + Execution types.SpecConfig + ProvisionScripts map[string][]byte + Resources types.Resources + type Location = job_types.Location + type LocationConstraints = job_types.LocationConstraints + type NodeConfig = job_types.NodeConfig + type NodeManifest = job_types.NodeManifest + type Orchestrator struct + func NewOrchestrator(ctx context.Context, id string, actor actor.Actor, network network.Network, ...) (*Orchestrator, error) + func RestoreDeployment(actr actor.Actor, net network.Network, id string, cfg EnsembleConfig, ...) (*Orchestrator, error) + func (o *Orchestrator) ActorPrivateKey() crypto.PrivKey + func (o *Orchestrator) Config() EnsembleConfig + func (o *Orchestrator) Deploy(expiry time.Time) error + func (o *Orchestrator) DeploymentSnapshot() DeploymentSnapshot + func (o *Orchestrator) GetAllocationLogs(name string) (AllocationLogsResponse, error) + func (o *Orchestrator) ID() string + func (o *Orchestrator) Manifest() EnsembleManifest + func (o *Orchestrator) Shutdown() + func (o *Orchestrator) Status() DeploymentStatus + func (o *Orchestrator) Stop() + type OrchestratorView = job_types.OrchestratorView + type RegisterHealthcheckRequest struct + EnsembleID string + HealthCheck types.HealthCheckManifest + type RegisterHealthcheckResponse struct + Error string + OK bool + type RevertDeploymentMessage struct + AllocsByName []string + EnsembleID string + type Status struct + JobResources types.Resources + Status AllocationStatus + type SubnetAcceptPeerRequest struct + IP string + PeerID string + SubnetID string + type SubnetAcceptPeerResponse struct + Error string + OK bool + type SubnetAddPeerRequest struct + IP string + PeerID string + SubnetID string + type SubnetAddPeerResponse struct + Error string + OK bool + type SubnetCreateRequest struct + IP string + RoutingTable map[string]string + SubnetID string + type SubnetCreateResponse struct + Error string + OK bool + type SubnetDNSAddRecordsRequest struct + Records map[string]string + SubnetID string + type SubnetDNSAddRecordsResponse struct + Error string + OK bool + type SubnetDNSRemoveRecordRequest struct + DomainName string + SubnetID string + type SubnetDNSRemoveRecordResponse struct + Error string + OK bool + type SubnetDestroyRequest struct + SubnetID string + type SubnetDestroyResponse struct + Error string + OK bool + type SubnetMapPortRequest struct + DestIP string + DestPort string + Protocol string + SourceIP string + SourcePort string + SubnetID string + type SubnetMapPortResponse struct + Error string + OK bool + type SubnetRemovePeerRequest struct + IP string + PeerID string + SubnetID string + type SubnetRemovePeerResponse struct + Error string + OK bool + type SubnetUnmapPortRequest struct + DestIP string + DestPort string + Protocol string + SourceIP string + SourcePort string + SubnetID string + type SubnetUnmapPortResponse struct + Error string + OK bool + type VerifyEdgeConstraintRequest struct + BW uint + EnsembleID string + RTT uint + S string + T string + type VerifyEdgeConstraintResponse struct + Error string + OK bool v0.5.0-rc2 Dec 13, 2024 v0.5.0-rc1-p1 Nov 19, 2024 v0.5.0-rc1 Nov 10, 2024 v0.5.0-boot-p3 Oct 1, 2024 v0.5.0-boot-p2 Sep 25, 2024 v0.5.0-boot-p1 Sep 20, 2024 v0.5.0-boot Sep 17, 2024
Go to main page