resource_world

package
v0.51.7 Latest Latest
Warning

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

 Go to latest Published: May 30, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTypedObjectResource 

func RegisterTypedObjectResource(mux srpc.Mux, le *logrus.Entry, b bus.Bus, ws world.WorldState, engine world.Engine)

RegisterTypedObjectResource registers the TypedObjectResourceService on a mux.

Types

type EngineResource 

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

EngineResource wraps an Engine for resource access.

func NewEngineResource 

func NewEngineResource(
	le *logrus.Entry,
	b bus.Bus,
	w world.Engine,
	lookupOp world.LookupOp,
	engineInfo *s4wave_world.EngineInfo,
	opts ...WorldStateResourceOption,
) *EngineResource

NewEngineResource creates a new EngineResource.

func (*EngineResource) AccessTypedObject 

func (r *EngineResource) AccessTypedObject(ctx context.Context, req *s4wave_world.AccessTypedObjectRequest) (*s4wave_world.AccessTypedObjectResponse, error)

AccessTypedObject looks up an object, determines its type, and returns a typed resource.

func (*EngineResource) AccessWorldState 

func (r *EngineResource) AccessWorldState(ctx context.Context, req *s4wave_world.AccessWorldStateRequest) (*s4wave_world.AccessWorldStateResponse, error)

AccessWorldState builds a bucket lookup cursor with an optional ref.

func (*EngineResource) BuildStorageCursor 

func (r *EngineResource) BuildStorageCursor(ctx context.Context, req *s4wave_world.BuildStorageCursorRequest) (*s4wave_world.BuildStorageCursorResponse, error)

BuildStorageCursor builds a cursor to the world storage with an empty ref.

func (*EngineResource) GetEngineInfo 

func (r *EngineResource) GetEngineInfo(ctx context.Context, req *s4wave_world.GetEngineInfoRequest) (*s4wave_world.GetEngineInfoResponse, error)

GetEngineInfo returns information about the world engine.

func (*EngineResource) GetMux 

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

GetMux returns the rpc mux.

func (*EngineResource) GetSeqno 

func (r *EngineResource) GetSeqno(ctx context.Context, req *s4wave_world.GetSeqnoRequest) (*s4wave_world.GetSeqnoResponse, error)

GetSeqno returns the current seqno of the world state.

func (*EngineResource) GetWorldRootSnapshot added in v0.51.7 

func (r *EngineResource) GetWorldRootSnapshot(ctx context.Context, req *s4wave_world.GetWorldRootSnapshotRequest) (*s4wave_world.WorldRootSnapshot, error)

GetWorldRootSnapshot returns the current committed World root.

func (*EngineResource) NewTransaction 

func (r *EngineResource) NewTransaction(ctx context.Context, req *s4wave_world.NewTransactionRequest) (*s4wave_world.NewTransactionResponse, error)

NewTransaction creates a new transaction against the world state.

func (*EngineResource) WaitSeqno 

func (r *EngineResource) WaitSeqno(ctx context.Context, req *s4wave_world.WaitSeqnoRequest) (*s4wave_world.WaitSeqnoResponse, error)

WaitSeqno waits for the seqno of the world state to be >= value.

func (*EngineResource) WatchWorldRootSnapshots added in v0.51.7 

func (r *EngineResource) WatchWorldRootSnapshots(
	req *s4wave_world.WatchWorldRootSnapshotsRequest,
	stream s4wave_world.SRPCEngineResourceService_WatchWorldRootSnapshotsStream,
) error

WatchWorldRootSnapshots streams committed World root snapshots.

func (*EngineResource) WatchWorldState 

func (r *EngineResource) WatchWorldState(
	req *s4wave_world.WatchWorldStateRequest,
	stream s4wave_world.SRPCWatchWorldStateResourceService_WatchWorldStateStream,
) error

WatchWorldState implements the streaming watch RPC. Change detection starts immediately as client accesses resources.

type GraphPathQueryResource added in v0.51.6 

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

GraphPathQueryResource wraps bounded graph path query results.

func NewGraphPathQueryResource added in v0.51.6 

func NewGraphPathQueryResource(
	le *logrus.Entry,
	b bus.Bus,
	result *world.GraphPathQueryResult,
	pageSize uint32,
) *GraphPathQueryResource

NewGraphPathQueryResource creates a graph path query resource.

func (*GraphPathQueryResource) Close added in v0.51.6 

func (r *GraphPathQueryResource) Close(ctx context.Context, req *s4wave_world.CloseGraphPathQueryRequest) (*s4wave_world.CloseGraphPathQueryResponse, error)

Close closes the graph path query resource.

func (*GraphPathQueryResource) GetMux added in v0.51.6 

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

GetMux returns the rpc mux.

func (*GraphPathQueryResource) Next added in v0.51.6 

func (r *GraphPathQueryResource) Next(ctx context.Context, req *s4wave_world.NextGraphPathQueryRequest) (*s4wave_world.NextGraphPathQueryResponse, error)

Next returns the next page of path query results.

type ObjectIteratorResource 

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

ObjectIteratorResource wraps an ObjectIterator for resource access.

func NewObjectIteratorResource 

func NewObjectIteratorResource(le *logrus.Entry, b bus.Bus, iter world.ObjectIterator) *ObjectIteratorResource

NewObjectIteratorResource creates a new ObjectIteratorResource.

func (*ObjectIteratorResource) Close 

func (r *ObjectIteratorResource) Close(ctx context.Context, req *s4wave_world.CloseRequest) (*s4wave_world.CloseResponse, error)

Close closes the iterator.

func (*ObjectIteratorResource) Err 

func (r *ObjectIteratorResource) Err(ctx context.Context, req *s4wave_world.ErrRequest) (*s4wave_world.ErrResponse, error)

Err returns any error that has closed the iterator.

func (*ObjectIteratorResource) GetMux 

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

GetMux returns the rpc mux.

func (*ObjectIteratorResource) Key 

func (r *ObjectIteratorResource) Key(ctx context.Context, req *s4wave_world.KeyRequest) (*s4wave_world.KeyResponse, error)

Key returns the current entry key, or empty if not valid.

func (*ObjectIteratorResource) Next 

func (r *ObjectIteratorResource) Next(ctx context.Context, req *s4wave_world.NextRequest) (*s4wave_world.NextResponse, error)

Next advances to the next entry and returns Valid.

func (*ObjectIteratorResource) Seek 

func (r *ObjectIteratorResource) Seek(ctx context.Context, req *s4wave_world.SeekRequest) (*s4wave_world.SeekResponse, error)

Seek moves the iterator to the first key >= the provided key (or <= in reverse mode).

func (*ObjectIteratorResource) Valid 

func (r *ObjectIteratorResource) Valid(ctx context.Context, req *s4wave_world.ValidRequest) (*s4wave_world.ValidResponse, error)

Valid returns if the iterator points to a valid entry.

type ObjectStateResource 

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

ObjectStateResource wraps an ObjectState for resource access.

func NewObjectStateResource 

func NewObjectStateResource(le *logrus.Entry, b bus.Bus, obj world.ObjectState, lookupOp world.LookupOp) *ObjectStateResource

NewObjectStateResource creates a new ObjectStateResource.

lookupOp may be nil

func (*ObjectStateResource) AccessWorldState 

func (r *ObjectStateResource) AccessWorldState(ctx context.Context, req *s4wave_world.AccessWorldStateRequest) (*s4wave_world.AccessWorldStateResponse, error)

AccessWorldState builds a bucket lookup cursor with an optional ref.

func (*ObjectStateResource) ApplyObjectOp 

func (r *ObjectStateResource) ApplyObjectOp(ctx context.Context, req *s4wave_world.ApplyObjectOpRequest) (*s4wave_world.ApplyObjectOpResponse, error)

ApplyObjectOp applies a batch operation at the object level.

func (*ObjectStateResource) GetKey 

func (r *ObjectStateResource) GetKey(ctx context.Context, req *s4wave_world.GetKeyRequest) (*s4wave_world.GetKeyResponse, error)

GetKey returns the key identifier of the object.

func (*ObjectStateResource) GetMux 

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

GetMux returns the rpc mux.

func (*ObjectStateResource) GetRootRef 

func (r *ObjectStateResource) GetRootRef(ctx context.Context, req *s4wave_world.GetRootRefRequest) (*s4wave_world.GetRootRefResponse, error)

GetRootRef returns the root reference of the object.

func (*ObjectStateResource) IncrementRev 

func (r *ObjectStateResource) IncrementRev(ctx context.Context, req *s4wave_world.IncrementRevRequest) (*s4wave_world.IncrementRevResponse, error)

IncrementRev increments the revision of the object.

func (*ObjectStateResource) SetRootRef 

func (r *ObjectStateResource) SetRootRef(ctx context.Context, req *s4wave_world.SetRootRefRequest) (*s4wave_world.SetRootRefResponse, error)

SetRootRef updates the root reference of the object.

func (*ObjectStateResource) WaitRev 

func (r *ObjectStateResource) WaitRev(ctx context.Context, req *s4wave_world.WaitRevRequest) (*s4wave_world.WaitRevResponse, error)

WaitRev waits until the object rev is >= the specified revision.

type TrackedWorldState 

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

TrackedWorldState wraps a WorldState and records all access patterns. Immediately starts change detection as accesses are recorded.

func NewTrackedWorldState 

func NewTrackedWorldState(ws world.WorldState, initialSeqno uint64, ctx context.Context) *TrackedWorldState

NewTrackedWorldState creates a new TrackedWorldState.

func (*TrackedWorldState) AccessCayleyGraph 

func (t *TrackedWorldState) AccessCayleyGraph(ctx context.Context, write bool, cb func(ctx context.Context, h world.CayleyHandle) error) error

func (*TrackedWorldState) AccessWorldState 

func (t *TrackedWorldState) AccessWorldState(ctx context.Context, ref *bucket.ObjectRef, cb func(*bucket_lookup.Cursor) error) error

func (*TrackedWorldState) ApplyWorldOp 

func (t *TrackedWorldState) ApplyWorldOp(ctx context.Context, op world.Operation, opSender peer.ID) (uint64, bool, error)

func (*TrackedWorldState) BuildStorageCursor 

func (t *TrackedWorldState) BuildStorageCursor(ctx context.Context) (*bucket_lookup.Cursor, error)

func (*TrackedWorldState) Close 

func (t *TrackedWorldState) Close()

Close stops the change detection routine.

func (*TrackedWorldState) CreateObject 

func (t *TrackedWorldState) CreateObject(ctx context.Context, key string, rootRef *bucket.ObjectRef) (world.ObjectState, error)

func (*TrackedWorldState) DeleteGraphObject 

func (t *TrackedWorldState) DeleteGraphObject(ctx context.Context, objKey string) error

func (*TrackedWorldState) DeleteGraphQuad 

func (t *TrackedWorldState) DeleteGraphQuad(ctx context.Context, q world.GraphQuad) error

func (*TrackedWorldState) DeleteObject 

func (t *TrackedWorldState) DeleteObject(ctx context.Context, key string) (bool, error)

func (*TrackedWorldState) GetObject 

func (t *TrackedWorldState) GetObject(ctx context.Context, key string) (world.ObjectState, bool, error)

func (*TrackedWorldState) GetReadOnly 

func (t *TrackedWorldState) GetReadOnly() bool

func (*TrackedWorldState) GetSeqno 

func (t *TrackedWorldState) GetSeqno(ctx context.Context) (uint64, error)

func (*TrackedWorldState) IterateObjects 

func (t *TrackedWorldState) IterateObjects(ctx context.Context, prefix string, reversed bool) world.ObjectIterator

func (*TrackedWorldState) LookupGraphQuads 

func (t *TrackedWorldState) LookupGraphQuads(ctx context.Context, filter world.GraphQuad, limit uint32) ([]world.GraphQuad, error)

func (*TrackedWorldState) LookupGraphQuadsBatch added in v0.51.7 

func (t *TrackedWorldState) LookupGraphQuadsBatch(ctx context.Context, filters []world.GraphQuad, limitPerFilter uint32) ([][]world.GraphQuad, error)

func (*TrackedWorldState) QueryGraphPath added in v0.51.6 

func (t *TrackedWorldState) QueryGraphPath(ctx context.Context, query *world.GraphPathQuery) (*world.GraphPathQueryResult, error)

func (*TrackedWorldState) RenameObject 

func (t *TrackedWorldState) RenameObject(ctx context.Context, oldKey, newKey string, descendants bool) (world.ObjectState, error)

func (*TrackedWorldState) SetGraphQuad 

func (t *TrackedWorldState) SetGraphQuad(ctx context.Context, q world.GraphQuad) error

func (*TrackedWorldState) WaitForChanges 

func (t *TrackedWorldState) WaitForChanges(ctx context.Context) error

WaitForChanges waits until any tracked resource changes. Returns nil when changes detected, error on failure or context cancel.

func (*TrackedWorldState) WaitSeqno 

func (t *TrackedWorldState) WaitSeqno(ctx context.Context, seqno uint64) (uint64, error)

type TxResource 

type TxResource struct {
	*WorldStateResource
	// contains filtered or unexported fields
}

TxResource wraps a Tx for resource access. It embeds WorldStateResource and adds Commit/Discard operations.

func NewTxResource 

func NewTxResource(
	le *logrus.Entry,
	b bus.Bus,
	tx world.Tx,
	lookupOp world.LookupOp,
	engine world.Engine,
	opts ...WorldStateResourceOption,
) *TxResource

NewTxResource creates a new TxResource.

engine is optional - if provided, TypedObjectResourceService is registered on the mux.

func (*TxResource) Commit 

func (r *TxResource) Commit(ctx context.Context, req *s4wave_world.CommitRequest) (*s4wave_world.CommitResponse, error)

Commit commits the transaction.

func (*TxResource) Discard 

func (r *TxResource) Discard(ctx context.Context, req *s4wave_world.DiscardRequest) (*s4wave_world.DiscardResponse, error)

Discard discards the transaction without committing changes.

func (*TxResource) Release added in v0.51.7 

func (r *TxResource) Release()

Release discards the underlying transaction exactly once.

type TypedObjectResource 

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

TypedObjectResource implements TypedObjectResourceService. It provides access to typed resources from world objects.

func NewTypedObjectResource 

func NewTypedObjectResource(le *logrus.Entry, b bus.Bus, ws world.WorldState, engine world.Engine) *TypedObjectResource

NewTypedObjectResource creates a new TypedObjectResource.

func (*TypedObjectResource) AccessTypedObject 

func (r *TypedObjectResource) AccessTypedObject(ctx context.Context, req *s4wave_world.AccessTypedObjectRequest) (*s4wave_world.AccessTypedObjectResponse, error)

AccessTypedObject looks up an object, determines its type, and returns a typed resource. Handles special prefixes:

  • plugin-dist/{plugin-id}: accesses the plugin's distribution filesystem
  • plugin-assets/{plugin-id}: accesses the plugin's assets filesystem

type WorldStateOperationObserver added in v0.51.7 

type WorldStateOperationObserver func(WorldStateOperationRecord)

WorldStateOperationObserver observes WorldStateResource operation records.

type WorldStateOperationRecord added in v0.51.7 

type WorldStateOperationRecord struct {
	// Name is the WorldStateResource method name.
	Name string
	// Duration is the elapsed wall-clock duration.
	Duration time.Duration
	// Error is set when the operation returned an error.
	Error string
	// FilterCount is the number of graph filters in the request.
	FilterCount int
	// Limit is the relevant request limit.
	Limit int
	// ResultSetCount is the number of result groups returned.
	ResultSetCount int
	// ResultQuadCount is the total number of graph quads returned.
	ResultQuadCount int
	// StartKeyCount is the number of graph path start keys.
	StartKeyCount int
	// StepCount is the number of graph path steps.
	StepCount int
	// PageSize is the requested page size for resource-backed operations.
	PageSize int
	// ResultObjectCount is the number of object keys returned by the operation.
	ResultObjectCount int
	// ResourceCreated indicates that the operation attached a resource.
	ResourceCreated bool
	// BlockReadCount is the number of block cursor fetches issued by the operation.
	BlockReadCount uint64
	// BlockReadBytes is the number of block bytes returned to block cursors.
	BlockReadBytes uint64
	// BlockReadMissCount is the number of block cursor fetches that missed.
	BlockReadMissCount uint64
	// ResourceGetBlockCount is the number of Resource SDK GetBlock calls.
	ResourceGetBlockCount uint64
	// ResourceGetBlockRefCount is the number of non-empty refs passed to Resource SDK GetBlock.
	ResourceGetBlockRefCount uint64
	// ResourceGetBlockBytes is the number of bytes returned by found Resource SDK GetBlock calls.
	ResourceGetBlockBytes uint64
	// ResourceGetBlockMissCount is the number of Resource SDK GetBlock calls that missed.
	ResourceGetBlockMissCount uint64
	// DecodedBlockUnmarshalCount is the number of decoded block unmarshals.
	DecodedBlockUnmarshalCount uint64
	// DecodedBlockUnmarshalBytes is the number of bytes passed to decoded block unmarshalling.
	DecodedBlockUnmarshalBytes uint64
	// DecodedBlockCacheAttemptCount is the number of decoded-block cache lookup attempts.
	DecodedBlockCacheAttemptCount uint64
	// DecodedBlockCacheHitCount is the number of decoded-block cache hits.
	DecodedBlockCacheHitCount uint64
	// DecodedBlockCacheMissCount is the number of decoded-block cache misses.
	DecodedBlockCacheMissCount uint64
	// DecodedBlockCloneCount is the number of clone-on-hit decoded block returns.
	DecodedBlockCloneCount uint64
	// DecodedBlockUncloneableCount is the number of cache candidates that could not be cloned.
	DecodedBlockUncloneableCount uint64
	// DecodedBlockUncacheableCount is the number of decoded-block cache bypasses for missing exact keys.
	DecodedBlockUncacheableCount uint64
}

WorldStateOperationRecord describes one WorldStateResource operation.

type WorldStateResource 

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

WorldStateResource wraps a WorldState for resource access.

func NewEngineWorldStateResource added in v0.51.2 

func NewEngineWorldStateResource(
	le *logrus.Entry,
	b bus.Bus,
	ws world.WorldState,
	lookupOp world.LookupOp,
	engine world.Engine,
	opts ...WorldStateResourceOption,
) *WorldStateResource

NewEngineWorldStateResource creates a WorldStateResource with typed object access.

func NewWorldStateResource 

func NewWorldStateResource(
	le *logrus.Entry,
	b bus.Bus,
	ws world.WorldState,
	lookupOp world.LookupOp,
	opts ...WorldStateResourceOption,
) *WorldStateResource

NewWorldStateResource creates a new WorldStateResource.

lookupOp may be nil

func (*WorldStateResource) AccessWorldState 

func (r *WorldStateResource) AccessWorldState(ctx context.Context, req *s4wave_world.AccessWorldStateRequest) (*s4wave_world.AccessWorldStateResponse, error)

AccessWorldState builds a bucket lookup cursor with an optional ref.

func (*WorldStateResource) ApplyWorldOp 

func (r *WorldStateResource) ApplyWorldOp(ctx context.Context, req *s4wave_world.ApplyWorldOpRequest) (*s4wave_world.ApplyWorldOpResponse, error)

ApplyWorldOp applies a batch operation at the world level.

func (*WorldStateResource) BuildStorageCursor 

func (r *WorldStateResource) BuildStorageCursor(ctx context.Context, req *s4wave_world.BuildStorageCursorRequest) (*s4wave_world.BuildStorageCursorResponse, error)

BuildStorageCursor builds a cursor to the world storage with an empty ref.

func (*WorldStateResource) CreateObject 

func (r *WorldStateResource) CreateObject(ctx context.Context, req *s4wave_world.CreateObjectRequest) (*s4wave_world.CreateObjectResponse, error)

CreateObject creates an object with a key and initial root ref.

func (*WorldStateResource) DeleteGraphObject 

func (r *WorldStateResource) DeleteGraphObject(ctx context.Context, req *s4wave_world.DeleteGraphObjectRequest) (*s4wave_world.DeleteGraphObjectResponse, error)

DeleteGraphObject deletes all quads with Subject or Object set to value.

func (*WorldStateResource) DeleteGraphQuad 

func (r *WorldStateResource) DeleteGraphQuad(ctx context.Context, req *s4wave_world.DeleteGraphQuadRequest) (*s4wave_world.DeleteGraphQuadResponse, error)

DeleteGraphQuad deletes a quad from the graph store.

func (*WorldStateResource) DeleteObject 

func (r *WorldStateResource) DeleteObject(ctx context.Context, req *s4wave_world.DeleteObjectRequest) (*s4wave_world.DeleteObjectResponse, error)

DeleteObject deletes an object and associated graph quads by ID.

func (*WorldStateResource) GetMux 

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

GetMux returns the rpc mux.

func (*WorldStateResource) GetObject 

func (r *WorldStateResource) GetObject(ctx context.Context, req *s4wave_world.GetObjectRequest) (*s4wave_world.GetObjectResponse, error)

GetObject looks up an object by key.

func (*WorldStateResource) GetObjectMetadataBatch added in v0.51.6 

func (r *WorldStateResource) GetObjectMetadataBatch(ctx context.Context, req *s4wave_world.GetObjectMetadataBatchRequest) (*s4wave_world.GetObjectMetadataBatchResponse, error)

GetObjectMetadataBatch returns graph metadata for object keys.

func (*WorldStateResource) GetObjectRootRefsBatch added in v0.51.7 

func (r *WorldStateResource) GetObjectRootRefsBatch(ctx context.Context, req *s4wave_world.GetObjectRootRefsBatchRequest) (*s4wave_world.GetObjectRootRefsBatchResponse, error)

GetObjectRootRefsBatch returns root references for object keys.

func (*WorldStateResource) GetReadOnly 

func (r *WorldStateResource) GetReadOnly(ctx context.Context, req *s4wave_world.GetReadOnlyRequest) (*s4wave_world.GetReadOnlyResponse, error)

GetReadOnly returns if the world state is read-only.

func (*WorldStateResource) GetSeqno 

func (r *WorldStateResource) GetSeqno(ctx context.Context, req *s4wave_world.GetSeqnoRequest) (*s4wave_world.GetSeqnoResponse, error)

GetSeqno returns the current seqno of the world state.

func (*WorldStateResource) IterateObjects 

func (r *WorldStateResource) IterateObjects(ctx context.Context, req *s4wave_world.IterateObjectsRequest) (*s4wave_world.IterateObjectsResponse, error)

IterateObjects returns an iterator with the given object key prefix.

func (*WorldStateResource) ListGraphEdgeBuckets added in v0.51.7 

func (r *WorldStateResource) ListGraphEdgeBuckets(ctx context.Context, req *s4wave_world.ListGraphEdgeBucketsRequest) (*s4wave_world.ListGraphEdgeBucketsResponse, error)

ListGraphEdgeBuckets lists grouped inbound/outbound graph edge buckets.

func (*WorldStateResource) ListObjectsWithType 

func (r *WorldStateResource) ListObjectsWithType(ctx context.Context, req *s4wave_world.ListObjectsWithTypeRequest) (*s4wave_world.ListObjectsWithTypeResponse, error)

ListObjectsWithType lists object keys with the given type identifier.

func (*WorldStateResource) LookupGraphQuads 

func (r *WorldStateResource) LookupGraphQuads(ctx context.Context, req *s4wave_world.LookupGraphQuadsRequest) (*s4wave_world.LookupGraphQuadsResponse, error)

LookupGraphQuads searches for graph quads in the store.

func (*WorldStateResource) LookupGraphQuadsBatch added in v0.51.6 

func (r *WorldStateResource) LookupGraphQuadsBatch(ctx context.Context, req *s4wave_world.LookupGraphQuadsBatchRequest) (*s4wave_world.LookupGraphQuadsBatchResponse, error)

LookupGraphQuadsBatch searches for graph quads using bounded indexed filters.

func (*WorldStateResource) QueryGraphPath added in v0.51.6 

func (r *WorldStateResource) QueryGraphPath(ctx context.Context, req *s4wave_world.QueryGraphPathRequest) (*s4wave_world.QueryGraphPathResponse, error)

QueryGraphPath creates a resource for a bounded graph path query.

func (*WorldStateResource) RenameObject 

func (r *WorldStateResource) RenameObject(ctx context.Context, req *s4wave_world.RenameObjectRequest) (*s4wave_world.RenameObjectResponse, error)

RenameObject renames an object key and associated graph quads.

func (*WorldStateResource) SetGraphQuad 

func (r *WorldStateResource) SetGraphQuad(ctx context.Context, req *s4wave_world.SetGraphQuadRequest) (*s4wave_world.SetGraphQuadResponse, error)

SetGraphQuad sets a quad in the graph store.

func (*WorldStateResource) WaitSeqno 

func (r *WorldStateResource) WaitSeqno(ctx context.Context, req *s4wave_world.WaitSeqnoRequest) (*s4wave_world.WaitSeqnoResponse, error)

WaitSeqno waits for the seqno of the world state to be >= value.

type WorldStateResourceOption added in v0.51.7 

type WorldStateResourceOption func(*WorldStateResource)

WorldStateResourceOption configures a WorldStateResource.

func WithWorldStateOperationObserver added in v0.51.7 

func WithWorldStateOperationObserver(observer WorldStateOperationObserver) WorldStateResourceOption

WithWorldStateOperationObserver configures WorldStateResource operation accounting.

Source Files

View all Source files

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.