engine

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 8, 2026

Changes in this version

+ var NodeTLSCert *tls.Certificate

+ func NewBuiltinServer(handler http.Handler) *http.Server

type EngineConfig

+ AdvertiseURL string

+ type EntityMetricsCollector struct

+ func NewEntityMetricsCollector(server *WorldServer) *EntityMetricsCollector

+ func (c *EntityMetricsCollector) Collect(ch chan<- prometheus.Metric)

+ func (c *EntityMetricsCollector) Describe(ch chan<- *prometheus.Desc)

type PolicyEvaluator

+ func (pe *PolicyEvaluator) AllowMedia(remoteAddr string) bool

type WorldServer

+ func (s *WorldServer) GetSelf(ctx context.Context, req *connect.Request[pb.GetSelfRequest]) (*connect.Response[pb.GetSelfResponse], error)

+ func (s *WorldServer) InitNodeSecrets()

+ func (s *WorldServer) LoadDefaultEntities(entities []*pb.Entity) error

v0

v0.0.23

Jun 8, 2026

Changes in this version

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

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

+ func DefaultPolicy() *pb.PolicyComponent

type EngineConfig

+ DisableSecurity bool

+ LogRing *LogRing

type LogRing

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

+ type PolicyEvaluator struct

+ func NewPolicyEvaluator(world *WorldServer) *PolicyEvaluator

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

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

+ func (pe *PolicyEvaluator) Rebuild()

type WorldServer

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

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

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

v0.0.22

Apr 29, 2026

Changes in this version

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

type WorldServer

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

v0.0.21

Apr 13, 2026

Changes in this version

type EngineConfig

+ LogHandler http.Handler

+ type LogRing struct

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

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

type WorldServer

+ func (s *WorldServer) GC()

+ func (s *WorldServer) SetNodeID(id string)

v0.0.20

Mar 19, 2026

Changes in this version

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

type Bus

+ func (b *Bus) CloseAll()

type Store

+ func (s *Store) Reset()

type WorldServer

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

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

v0.0.19

Mar 5, 2026

Changes in this version

type WorldServer

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

v0.0.18

Feb 12, 2026

Changes in this version

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

+ func StartMetricsUpdater(server *WorldServer)

+ type Bus struct

+ func NewBus() *Bus

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

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

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

+ type Consumer struct

+ func NewConsumer(world *WorldServer, ability *policy.Ability, limiter *pb.WatchBehavior, ...) *Consumer

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

+ type EngineConfig struct

+ NoDefaults bool

+ PolicyFile string

+ WorldFile string

+ type Event struct

+ Entity *pb.Entity

+ type Store struct

+ func NewStore() *Store

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

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

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

+ type WorldServer struct

+ func NewWorldServer() *WorldServer

+ func (s *WorldServer) EntityCount() int

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

+ func (s *WorldServer) FlushToFile() error

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

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

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

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

+ func (s *WorldServer) InitNodeIdentity()

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

+ func (s *WorldServer) LoadFromBytes(b []byte) error

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

+ func (s *WorldServer) MoveTimeline(ctx context.Context, req *connect.Request[pb.MoveTimelineRequest]) (*connect.Response[pb.MoveTimelineResponse], error)

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

+ func (s *WorldServer) Reconcile(ctx context.Context, req *connect.Request[pb.ControllerReconciliationRequest], ...) error

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

+ func (s *WorldServer) SetWorldFile(path string)

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

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

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