Documentation
¶
Index ¶
- type SharedObjectResource
- func (r *SharedObjectResource) GetMux() srpc.Invoker
- func (r *SharedObjectResource) MountSharedObjectBody(ctx context.Context, req *s4wave_sobject.MountSharedObjectBodyRequest) (response *s4wave_sobject.MountSharedObjectBodyResponse, mountErr error)
- func (r *SharedObjectResource) OpenReadCheckpoint(ctx context.Context, _ *s4wave_sobject.OpenReadCheckpointRequest) (*s4wave_sobject.OpenReadCheckpointResponse, error)
- func (r *SharedObjectResource) SetAppPluginIDs(ids []string)
- func (r *SharedObjectResource) SetBindingRegistry(registry *process_binding.BindingRegistry)
- func (r *SharedObjectResource) WatchSharedObjectHealth(req *s4wave_sobject.WatchSharedObjectHealthRequest, ...) error
- func (r *SharedObjectResource) WatchSharedObjectParticipation(_ *s4wave_sobject.WatchSharedObjectParticipationRequest, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SharedObjectResource ¶
type SharedObjectResource struct {
// contains filtered or unexported fields
}
SharedObjectResource wraps a core shared object for resource access.
func NewSharedObjectResource ¶
func NewSharedObjectResource( le *logrus.Entry, b bus.Bus, so sobject.SharedObject, meta *sobject.SharedObjectMeta, ref *sobject.SharedObjectRef, sessionPeerID string, ) *SharedObjectResource
NewSharedObjectResource creates a new SharedObjectResource.
func NewSharedObjectResourceWithHostPluginID ¶ added in v0.51.3
func NewSharedObjectResourceWithHostPluginID( le *logrus.Entry, b bus.Bus, so sobject.SharedObject, meta *sobject.SharedObjectMeta, ref *sobject.SharedObjectRef, sessionPeerID string, hostPluginID string, ) *SharedObjectResource
NewSharedObjectResourceWithHostPluginID creates a new SharedObjectResource with the plugin id that owns the resource root.
func (*SharedObjectResource) GetMux ¶
func (r *SharedObjectResource) GetMux() srpc.Invoker
GetMux returns the rpc mux.
func (*SharedObjectResource) MountSharedObjectBody ¶
func (r *SharedObjectResource) MountSharedObjectBody(ctx context.Context, req *s4wave_sobject.MountSharedObjectBodyRequest) (response *s4wave_sobject.MountSharedObjectBodyResponse, mountErr error)
MountSharedObjectBody mounts the body of a shared object.
func (*SharedObjectResource) OpenReadCheckpoint ¶
func (r *SharedObjectResource) OpenReadCheckpoint( ctx context.Context, _ *s4wave_sobject.OpenReadCheckpointRequest, ) (*s4wave_sobject.OpenReadCheckpointResponse, error)
OpenReadCheckpoint opens retained World history without live body or write authority.
func (*SharedObjectResource) SetAppPluginIDs ¶
func (r *SharedObjectResource) SetAppPluginIDs(ids []string)
SetAppPluginIDs supplies application composition before the resource is published.
func (*SharedObjectResource) SetBindingRegistry ¶
func (r *SharedObjectResource) SetBindingRegistry(registry *process_binding.BindingRegistry)
SetBindingRegistry supplies the Resource root's binding event source.
func (*SharedObjectResource) WatchSharedObjectHealth ¶
func (r *SharedObjectResource) WatchSharedObjectHealth( req *s4wave_sobject.WatchSharedObjectHealthRequest, strm s4wave_sobject.SRPCSharedObjectResourceService_WatchSharedObjectHealthStream, ) error
WatchSharedObjectHealth streams health for the mounted shared object.
func (*SharedObjectResource) WatchSharedObjectParticipation ¶
func (r *SharedObjectResource) WatchSharedObjectParticipation( _ *s4wave_sobject.WatchSharedObjectParticipationRequest, stream s4wave_sobject.SRPCSharedObjectResourceService_WatchSharedObjectParticipationStream, ) error
WatchSharedObjectParticipation observes accepted authority without requiring body decryption.
Source Files