resource_space

package
v0.53.1 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SpaceContentsResource 

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

SpaceContentsResource provides streaming plugin status for a mounted space.

func NewSpaceContentsResource 

func NewSpaceContentsResource(le *logrus.Entry, b bus.Bus, engine world.Engine, spaceID, engineID string) *SpaceContentsResource

NewSpaceContentsResource creates a new SpaceContentsResource.

func (*SpaceContentsResource) GetMux 

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

GetMux returns the rpc mux.

func (*SpaceContentsResource) Release 

func (r *SpaceContentsResource) Release()

Release releases the controller reference.

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) StartController added in v0.51.7 

func (r *SpaceContentsResource) StartController(conf *plugin_space.Config)

StartController starts the plugin/space controller behind this resource.

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 owning 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) 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) DeployManifest 

func (r *SpaceResource) DeployManifest(strm s4wave_space.SRPCSpaceResourceService_DeployManifestStream) error

DeployManifest handles the bidirectional deploy manifest 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 activates plugins for the space and returns a sub-resource for monitoring plugin status.

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.

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.