engine

package
v0.0.16 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartEngine added in v0.0.15 

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

StartEngine starts the Hydra engine and returns the server address

func StartMetricsUpdater added in v0.0.15 

func StartMetricsUpdater(server *WorldServer)

Types

type Bus 

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

func NewBus 

func NewBus() *Bus

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

type WorldServer added in v0.0.12 

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

func NewWorldServer added in v0.0.12 

func NewWorldServer() *WorldServer

func (*WorldServer) EntityCount added in v0.0.15 

func (s *WorldServer) EntityCount() int

func (*WorldServer) GetEntity added in v0.0.12 

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

func (*WorldServer) GetTimeline added in v0.0.12 

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

func (*WorldServer) ListEntities added in v0.0.12 

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

func (*WorldServer) MoveTimeline added in v0.0.12 

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

func (*WorldServer) Observe added in v0.0.12 

func (s *WorldServer) Observe(
	ctx context.Context,
	req *connect.Request[pb.ObserverRequest],
	stream *connect.ServerStream[pb.ObserverState],
) error

func (*WorldServer) Push added in v0.0.12 

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

func (*WorldServer) RunTask added in v0.0.13 

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

func (*WorldServer) WatchEntities added in v0.0.12 

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

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.