nodespace

package
v0.13.0 Latest Latest
Warning

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

Go to latest
Published: Aug 6, 2026 License: MIT Imports: 35 Imported by: 3

Documentation

Index

Constants

View Source
const CName = "node.nodespace"

Variables

View Source
var ErrSpaceStatus = errors.New("space status error")

Functions

func NewStreamOpener added in v0.4.0

func NewStreamOpener() streamhandler.StreamHandler

Types

type NodeSpace added in v0.3.1

type NodeSpace interface {
	commonspace.Space
}

type Service

type Service interface {
	GetSpace(ctx context.Context, id string) (NodeSpace, error)
	PickSpace(ctx context.Context, id string) (NodeSpace, error)
	EvictSpace(ctx context.Context, id string) error
	Cache() ocache.OCache
	GetStats(ctx context.Context, id string, treeTop int) (nodestorage.SpaceStats, error)
	// SetAclObserver registers a callback invoked with a spaceId whenever that
	// space's ACL changes (new consensus records applied). Used by the pubsub
	// relay to re-check subscriber membership. Only one observer is supported.
	SetAclObserver(observer func(spaceId string))
	app.ComponentRunnable
}

func New

func New() Service

Directories

Path Synopsis
Package mock_nodespace is a generated GoMock package.
Package mock_nodespace is a generated GoMock package.
Package pubsubrelay wires the any-sync commonspace/pubsub engine into the node as a relay: it authorizes subscribe/publish against the hosted space ACL, forwards client-originated messages to the other responsible nodes, and evicts removed members when a space's ACL changes.
Package pubsubrelay wires the any-sync commonspace/pubsub engine into the node as a relay: it authorizes subscribe/publish against the hosted space ACL, forwards client-originated messages to the other responsible nodes, and evicts removed members when a space's ACL changes.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL