Help us shape the future of Go! Take the 2026 Go Developer Survey

resource_space

package
v0.57.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 27, 2026 License: Apache-2.0 Imports: 73 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AttachedRpcServiceController 

type AttachedRpcServiceController struct {
	// RpcServiceController provides the RPC route after it receives a context.
	*bifrost_rpc.RpcServiceController
	// contains filtered or unexported fields
}

AttachedRpcServiceController routes the RPC services under a prefix to an attached client and signals when the route can resolve calls.

func NewAttachedRpcServiceController 

func NewAttachedRpcServiceController(prefix string, client srpc.Invoker) *AttachedRpcServiceController

NewAttachedRpcServiceController constructs a route of the services under prefix to client. The prefix is stripped before the call reaches client.

func (*AttachedRpcServiceController) Execute 

func (c *AttachedRpcServiceController) Execute(ctx context.Context) error

Execute initializes the RPC service controller and then signals readiness.

func (*AttachedRpcServiceController) Ready 

func (c *AttachedRpcServiceController) Ready() <-chan struct{}

Ready returns a channel closed once the route can resolve calls.

type SpaceContentsResource 

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

SpaceContentsResource provides streaming plugin status for one contents mount of a Space. Every mount of the Space shares one plugin runtime.

func NewSpaceContentsResource 

func NewSpaceContentsResource(
	le *logrus.Entry,
	b bus.Bus,
	engine world.Engine,
	spaceID string,
	engineID string,
	runtime *plugin_space_runtime.Controller,
	runtimeRef directive.Reference,
) *SpaceContentsResource

NewSpaceContentsResource creates a contents mount of the Space runtime. The mount owns runtimeRef and releases it in Release.

func (*SpaceContentsResource) BindAttachedRpcService added in v0.57.2 

func (r *SpaceContentsResource) BindAttachedRpcService(
	req *s4wave_space.BindAttachedRpcServiceRequest,
	strm s4wave_space.SRPCSpaceContentsResourceService_BindAttachedRpcServiceStream,
) error

BindAttachedRpcService publishes a caller-attached Resource under one private service ID prefix for the caller attachment lifetime. The route follows the running generation of the shared Space runtime, and the prefix is reserved across every mount of the Space.

func (*SpaceContentsResource) GetMux 

func (r *SpaceContentsResource) GetMux() srpc.Invoker

GetMux returns the rpc mux.

func (*SpaceContentsResource) Release 

func (r *SpaceContentsResource) Release()

Release ends the calls of the mount and drops its runtime reference. The runtime stops after the last mount of the Space is released.

func (*SpaceContentsResource) SetProcessBinding 

func (r *SpaceContentsResource) SetProcessBinding(
	ctx context.Context,
	req *s4wave_space.SetProcessBindingRequest,
) (*s4wave_space.SetProcessBindingResponse, error)

SetProcessBinding sets the state for a process binding.

func (*SpaceContentsResource) WatchState 

func (r *SpaceContentsResource) WatchState(
	req *s4wave_space.WatchSpaceContentsStateRequest,
	strm s4wave_space.SRPCSpaceContentsResourceService_WatchStateStream,
) error

WatchState streams the current plugin and process state for the space.

type SpaceResource 

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

SpaceResource wraps a Space for resource access.

func NewSpaceResource 

func NewSpaceResource(le *logrus.Entry, b bus.Bus, sp space.SpaceSharedObjectBody) *SpaceResource

NewSpaceResource creates a new SpaceResource.

func NewSpaceResourceWithSessionPeerID added in v0.51.2 

func NewSpaceResourceWithSessionPeerID(
	le *logrus.Entry,
	b bus.Bus,
	sp space.SpaceSharedObjectBody,
	sessionPeerID string,
) *SpaceResource

NewSpaceResourceWithSessionPeerID creates a new SpaceResource with the mounted local session peer ID.

func NewSpaceResourceWithSessionPeerIDAndHostPluginID added in v0.51.3 

func NewSpaceResourceWithSessionPeerIDAndHostPluginID(
	le *logrus.Entry,
	b bus.Bus,
	sp space.SpaceSharedObjectBody,
	sessionPeerID string,
	hostPluginID string,
) *SpaceResource

NewSpaceResourceWithSessionPeerIDAndHostPluginID creates a SpaceResource with the mounted local session peer ID and host plugin ID.

func (*SpaceResource) AccessWorld 

func (r *SpaceResource) AccessWorld(
	ctx context.Context,
	req *s4wave_space.AccessWorldRequest,
) (*s4wave_space.AccessWorldResponse, error)

AccessWorld accesses the World associated with the space.

func (*SpaceResource) AddSpacePlugin 

func (r *SpaceResource) AddSpacePlugin(
	ctx context.Context,
	req *s4wave_space.AddSpacePluginRequest,
) (*s4wave_space.AddSpacePluginResponse, error)

AddSpacePlugin adds a plugin manifest ID to the SpaceSettings plugin list.

func (*SpaceResource) BuildSpacePlugin 

func (r *SpaceResource) BuildSpacePlugin(ctx context.Context, req *s4wave_space.BuildSpacePluginRequest) (*s4wave_space.BuildSpacePluginResponse, error)

BuildSpacePlugin queues an immutable source snapshot through the existing Forge owner. The mounted session supplies the sender; the selected Device supplies execution identity.

func (*SpaceResource) CreateSecret added in v0.51.6 

func (r *SpaceResource) CreateSecret(
	ctx context.Context,
	req *s4wave_space.CreateSecretRequest,
) (*s4wave_space.CreateSecretResponse, error)

CreateSecret creates a Secret object and grants an optional reader key.

func (*SpaceResource) DeployManifests added in v0.57.2 

func (r *SpaceResource) DeployManifests(strm s4wave_space.SRPCSpaceResourceService_DeployManifestsStream) error

DeployManifests handles the bidirectional manifest-set deployment stream.

func (*SpaceResource) GetMux 

func (r *SpaceResource) GetMux() srpc.Invoker

GetMux returns the rpc mux.

func (*SpaceResource) GetWorldEngine added in v0.51.2 

func (r *SpaceResource) GetWorldEngine() world.Engine

GetWorldEngine returns the Space world engine.

func (*SpaceResource) GetWorldEngineBucketID added in v0.51.2 

func (r *SpaceResource) GetWorldEngineBucketID() string

GetWorldEngineBucketID returns the Space world engine bucket id.

func (*SpaceResource) GetWorldEngineID added in v0.51.2 

func (r *SpaceResource) GetWorldEngineID() string

GetWorldEngineID returns the Space world engine id.

func (*SpaceResource) MountSpaceContents 

func (r *SpaceResource) MountSpaceContents(
	ctx context.Context,
	req *s4wave_space.MountSpaceContentsRequest,
) (*s4wave_space.MountSpaceContentsResponse, error)

MountSpaceContents mounts the shared plugin runtime of the space and returns a sub-resource for monitoring plugin status. Mounts of the same Space share one runtime, which stops after the last mount is released.

func (*SpaceResource) NewWorldEngineResource 

func (r *SpaceResource) NewWorldEngineResource() (*resource_world.EngineResource, error)

NewWorldEngineResource carries this mounted Space's session authority into an Engine capability. The receiving Resource connection owns the capability.

func (*SpaceResource) OpenPluginFrontend 

func (r *SpaceResource) OpenPluginFrontend(ctx context.Context, request *s4wave_space.BuildSpacePluginRequest) (*s4wave_space.OpenPluginFrontendResponse, error)

OpenPluginFrontend grants one Resource a live compiler on the selected device. The source stays in this World; the Resource owns the temporary execution grant.

func (*SpaceResource) ReadSecretPayload added in v0.51.7 

func (r *SpaceResource) ReadSecretPayload(
	ctx context.Context,
	req *s4wave_space.ReadSecretPayloadRequest,
) (*s4wave_space.ReadSecretPayloadResponse, error)

ReadSecretPayload reads a Secret payload under the mounted session authority.

func (*SpaceResource) RemoveSpacePlugin 

func (r *SpaceResource) RemoveSpacePlugin(
	ctx context.Context,
	req *s4wave_space.RemoveSpacePluginRequest,
) (*s4wave_space.RemoveSpacePluginResponse, error)

RemoveSpacePlugin removes a plugin manifest ID from the SpaceSettings plugin list.

func (*SpaceResource) WatchSpaceSharingState 

func (r *SpaceResource) WatchSpaceSharingState(
	req *s4wave_space.WatchSpaceSharingStateRequest,
	strm s4wave_space.SRPCSpaceResourceService_WatchSpaceSharingStateStream,
) error

WatchSpaceSharingState watches the sharing snapshot for the space.

All change sources (SO state, mailbox metadata) are folded into one local broadcast so the watch loop reads every input snapshot under the same HoldLock that obtains the wait channel. This eliminates the missed-wakeup race that the previous dual-channel select had to defend against with per-source buffered signals, and coalesces near-simultaneous source changes into a single emission instead of one emission per source.

func (*SpaceResource) WatchSpaceState 

func (r *SpaceResource) WatchSpaceState(
	req *s4wave_space.WatchSpaceStateRequest,
	strm s4wave_space.SRPCSpaceResourceService_WatchSpaceStateStream,
) error

WatchSpaceState watches the SpaceState for the component.

func (*SpaceResource) WriteSecretPayload 

func (r *SpaceResource) WriteSecretPayload(ctx context.Context, req *s4wave_space.WriteSecretPayloadRequest) (*s4wave_space.WriteSecretPayloadResponse, error)

WriteSecretPayload replaces a Secret payload under the mounted session writer grant.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.