sims

Documentation

Index

• type Simulation
• type SimulationEngine
  • func NewSimulationEngine() (*SimulationEngine, error)
  • func (s *SimulationEngine) GetSimulationHandler(rw http.ResponseWriter, req *http.Request)
  • func (s *SimulationEngine) Lookup(info simulationState) (Simulation, error)
  • func (s *SimulationEngine) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (s *SimulationEngine) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (s *SimulationEngine) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (s *SimulationEngine) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

Types

type Simulation

type Simulation interface {
	io.Closer
	GetState() simulationState
	SetConfig(vals map[string]interface{}) error
	NewFrame(size int) *data.Frame
	GetValues(t time.Time) map[string]interface{}
}

type SimulationEngine

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

func NewSimulationEngine

func NewSimulationEngine() (*SimulationEngine, error)

func (*SimulationEngine) GetSimulationHandler

func (s *SimulationEngine) GetSimulationHandler(rw http.ResponseWriter, req *http.Request)

func (*SimulationEngine) Lookup

func (s *SimulationEngine) Lookup(info simulationState) (Simulation, error)

func (*SimulationEngine) PublishStream

func (s *SimulationEngine) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*SimulationEngine) QueryData

func (s *SimulationEngine) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

func (*SimulationEngine) RunStream

func (s *SimulationEngine) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error

func (*SimulationEngine) SubscribeStream

func (s *SimulationEngine) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)