engine

package
v0.0.14 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CMD = &cobra.Command{
	Use:   "node",
	RunE:  RunEngine,
	Short: "run a hydra node",
}

Functions

func RunEngine 

func RunEngine(cmd *cobra.Command, args []string) error

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