engine

package
v0.0.20 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2026 License: Apache-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAPIMux added in v0.0.20 

func NewAPIMux(engine *WorldServer, promHandler http.Handler, bridges *media.BridgeManager) *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 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
	PolicyFile string
	NoDefaults bool
}

EngineConfig holds configuration for starting the engine

type Event 

type Event struct {
	Entity *pb.Entity
}

type Store 

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

remember to design this to sync over nats AND into kv

func NewStore 

func NewStore() *Store

func (*Store) GetEventsInTimeRange 

func (s *Store) GetEventsInTimeRange(targetTime time.Time) []*pb.Entity

func (*Store) GetTimeline 

func (s *Store) GetTimeline() (time.Time, time.Time)

func (*Store) Push 

func (s *Store) Push(ctx context.Context, e Event) error

func (*Store) Reset added in v0.0.20 

func (s *Store) Reset()

type WorldServer 

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

func NewWorldServer 

func NewWorldServer() *WorldServer

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) 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) GetTimeline 

func (s *WorldServer) GetTimeline(ctx context.Context, req *connect.Request[pb.GetTimelineRequest], stream *connect.ServerStream[pb.GetTimelineResponse]) error

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, stamping lifetime.from to now if not set. Entities that don't yet exist in head are inserted; existing ones are merged.

func (*WorldServer) LoadFromFile 

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

func (*WorldServer) MoveTimeline 

func (s *WorldServer) MoveTimeline(ctx context.Context, req *connect.Request[pb.MoveTimelineRequest]) (*connect.Response[pb.MoveTimelineResponse], 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) 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) 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.