engine

package
v0.0.23 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2026 License: Apache-2.0 Imports: 59 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuiltinConnContext added in v0.0.23 

func BuiltinConnContext(ctx context.Context, _ net.Conn) context.Context

func ComputeManifest added in v0.0.23 

func ComputeManifest(entities []*pb.Entity, idx missionpkg.Index) *missionpkg.Manifest

ComputeManifest records what's about to be packed so receivers can compare against observed state after apply. Pure function over the snapshotted entities and the already-populated Index. Exported so the CLI's mission build can write the same metadata into offline packs.

func DefaultPolicy added in v0.0.23 

func DefaultPolicy() *pb.PolicyComponent

func NewAPIMux added in v0.0.20 

func NewAPIMux(engine *WorldServer, promHandler http.Handler, bridges *media.BridgeManager, ring *LogRing) *http.ServeMux

NewAPIMux creates an http.ServeMux with the gRPC-Connect APIs, WHEP/media endpoints, healthz, and metrics registered. It does NOT serve the frontend — callers can add a "/" handler for that. Used by both StartEngine and the Wails desktop app.

func ParseEntities added in v0.0.22 

func ParseEntities(b []byte) ([]*pb.Entity, error)

func StartEngine 

func StartEngine(ctx context.Context, cfg EngineConfig) (string, error)

StartEngine starts the Hydris engine and returns the server address. If worldFile is provided, it loads entities from that file on startup and periodically flushes the current state back to the file.

func StartMetricsUpdater 

func StartMetricsUpdater(server *WorldServer)

Types

type Bus 

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

func NewBus 

func NewBus() *Bus

func (*Bus) CloseAll added in v0.0.20 

func (b *Bus) CloseAll()

CloseAll cancels all consumers, forcing their WatchEntities streams to terminate.

func (*Bus) Dirty 

func (b *Bus) Dirty(entityID string, entity *pb.Entity, change pb.EntityChange)

func (*Bus) Register 

func (b *Bus) Register(c *Consumer)

func (*Bus) Unregister 

func (b *Bus) Unregister(c *Consumer)

type Consumer 

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

func NewConsumer 

func NewConsumer(world *WorldServer, limiter *pb.WatchBehavior, filter *pb.EntityFilter) *Consumer

func (*Consumer) SenderLoop 

func (c *Consumer) SenderLoop(ctx context.Context, send func(*pb.EntityChangeEvent) error) error

type EngineConfig 

type EngineConfig struct {
	WorldFile       string
	NoDefaults      bool
	DisableSecurity bool
	LogRing         *LogRing
}

EngineConfig holds configuration for starting the engine

type LogRing added in v0.0.21 

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

LogRing is a lock-free ring buffer that implements io.Writer. Each Write call is stored as one log line with ANSI escapes stripped.

func (*LogRing) ServeHTTP added in v0.0.21 

func (r *LogRing) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP renders the log buffer as plain text.

func (*LogRing) Write added in v0.0.21 

func (r *LogRing) Write(p []byte) (n int, err error)

func (*LogRing) WriteTo added in v0.0.23 

func (r *LogRing) WriteTo(w io.Writer) (int64, error)

WriteTo streams the current ring contents to w as plain text, one line per Write.

type PolicyEvaluator added in v0.0.23 

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

func NewPolicyEvaluator added in v0.0.23 

func NewPolicyEvaluator(world *WorldServer) *PolicyEvaluator

func (*PolicyEvaluator) Interceptor added in v0.0.23 

func (pe *PolicyEvaluator) Interceptor() connect.UnaryInterceptorFunc

func (*PolicyEvaluator) Middleware added in v0.0.23 

func (pe *PolicyEvaluator) Middleware(next http.Handler) http.Handler

Middleware wraps an http.Handler with policy evaluation for non-Connect HTTP endpoints (media, artifacts, plugins, etc.). Connect RPC paths are skipped here because the Connect interceptor handles them with richer request context.

func (*PolicyEvaluator) Rebuild added in v0.0.23 

func (pe *PolicyEvaluator) Rebuild()

Rebuild recompiles the global policy chain from the node entity's PolicyComponent. Caller must NOT hold world.l — this method acquires a read lock.

type WorldServer 

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

func NewWorldServer 

func NewWorldServer() *WorldServer

func (*WorldServer) ConnContext added in v0.0.23 

func (s *WorldServer) ConnContext(ctx context.Context, c net.Conn) context.Context

func (*WorldServer) EntityCount 

func (s *WorldServer) EntityCount() int

func (*WorldServer) ExpireEntity 

func (s *WorldServer) ExpireEntity(ctx context.Context, req *connect.Request[pb.ExpireEntityRequest]) (*connect.Response[pb.ExpireEntityResponse], error)

func (*WorldServer) FlushToFile 

func (s *WorldServer) FlushToFile() error

FlushToFile writes the current head state to the world file atomically. Only local entities (controller.node == this node) are persisted, and only the config and device components are kept. Entities with lifetime.until (expiring/temporary) are skipped entirely.

func (*WorldServer) GC added in v0.0.21 

func (s *WorldServer) GC()

func (*WorldServer) GetEntity 

func (s *WorldServer) GetEntity(ctx context.Context, req *connect.Request[pb.GetEntityRequest]) (*connect.Response[pb.GetEntityResponse], error)

func (*WorldServer) GetHead 

func (s *WorldServer) GetHead(id string) *pb.Entity

func (*WorldServer) GetLocalNode 

func (s *WorldServer) GetLocalNode(ctx context.Context, req *connect.Request[pb.GetLocalNodeRequest]) (*connect.Response[pb.GetLocalNodeResponse], error)

func (*WorldServer) GetSourceURL added in v0.0.20 

func (s *WorldServer) GetSourceURL(entityID string, streamIndex int) string

GetSourceURL returns the original source URL for a camera stream before the MediaTransformer rewrote it to a proxy URL.

func (*WorldServer) HardReset added in v0.0.20 

func (s *WorldServer) HardReset(ctx context.Context, req *connect.Request[pb.HardResetRequest]) (*connect.Response[pb.HardResetResponse], error)

func (*WorldServer) InitNodeIdentity 

func (s *WorldServer) InitNodeIdentity()

InitNodeIdentity finds or creates a stable node identity. It looks for an existing entity with a DeviceComponent containing a NodeDevice. If none is found, it derives one from hardware MAC addresses.

func (*WorldServer) ListEntities 

func (s *WorldServer) ListEntities(ctx context.Context, req *connect.Request[pb.ListEntitiesRequest]) (*connect.Response[pb.ListEntitiesResponse], error)

func (*WorldServer) LoadDefaults added in v0.0.19 

func (s *WorldServer) LoadDefaults(b []byte) error

LoadDefaults loads default entities. Entities that don't yet exist in head are inserted; existing ones are merged. Defaults use a very old timestamp (Unix epoch) so they never overwrite entities that were loaded from persistence with a real timestamp.

func (*WorldServer) LoadFromFile 

func (s *WorldServer) LoadFromFile(path string) error

func (*WorldServer) LoadMission added in v0.0.23 

func (s *WorldServer) LoadMission(ctx context.Context, req *connect.Request[pb.LoadMissionRequest]) (*connect.Response[pb.LoadMissionResponse], error)

func (*WorldServer) Push 

func (s *WorldServer) Push(ctx context.Context, req *connect.Request[pb.EntityChangeRequest]) (*connect.Response[pb.EntityChangeResponse], error)

func (*WorldServer) RunTask 

func (s *WorldServer) RunTask(ctx context.Context, req *connect.Request[pb.RunTaskRequest]) (*connect.Response[pb.RunTaskResponse], error)

func (*WorldServer) SetNodeID added in v0.0.21 

func (s *WorldServer) SetNodeID(id string)

SetNodeID overrides the node identity. Used in tests to simulate distinct nodes on the same machine. Must be called after InitNodeIdentity.

func (*WorldServer) SetStreamEpoch added in v0.0.23 

func (s *WorldServer) SetStreamEpoch(entityID string, streamIndex int, epoch time.Time)

SetStreamEpoch records the epoch for a stream and notifies subscribers.

func (*WorldServer) SetWorldFile 

func (s *WorldServer) SetWorldFile(path string)

SetWorldFile sets the path for world state persistence

func (*WorldServer) StartPeriodicFlush 

func (s *WorldServer) StartPeriodicFlush(interval time.Duration)

StartPeriodicFlush starts a goroutine that periodically flushes the head to the world file. It also starts a debounce goroutine that flushes shortly after config changes.

func (*WorldServer) TimeSync added in v0.0.22 

func (s *WorldServer) TimeSync(ctx context.Context, req *connect.Request[pb.TimeSyncRequest]) (*connect.Response[pb.TimeSyncResponse], error)

func (*WorldServer) WatchEntities 

func (s *WorldServer) WatchEntities(ctx context.Context, req *connect.Request[pb.ListEntitiesRequest], stream *connect.ServerStream[pb.EntityChangeEvent]) error

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.