scenario

Documentation

Index

• type Endpoint
  • func (e Endpoint) About(args int, reply *string) error
  • func (e *Endpoint) WaitForData(args int, reply *string) error
• type Scenario
  • func New() *Scenario
  • func (s *Scenario) Activate(code []byte, id string) error
  • func (s *Scenario) ActivateWithoutCode(id string) error
  • func (s *Scenario) Data(d string, t string)
  • func (s *Scenario) Deactivate()
  • func (s *Scenario) Start() error
  • func (s *Scenario) Stop()

Types

type Endpoint

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

Endpoint for scenario communication

func (Endpoint) About

func (e Endpoint) About(args int, reply *string) error

About let you about who left us alone

func (*Endpoint) WaitForData

func (e *Endpoint) WaitForData(args int, reply *string) error

WaitForData waits for things incomming data

type Scenario

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

Scenario represents rule engine scenario

func New

func New() *Scenario

New creates instance of Scenario instance contains rpc server that is not running, so Start must call.

func (*Scenario) Activate

func (s *Scenario) Activate(code []byte, id string) error

Activate creates or replaces user scenario beacuase there is only one scenario is here with id it starts runner too

func (*Scenario) ActivateWithoutCode

func (s *Scenario) ActivateWithoutCode(id string) error

ActivateWithoutCode just check user scenario existence and starts runner

func (*Scenario) Data

func (s *Scenario) Data(d string, t string)

Data new data is comming

func (*Scenario) Deactivate

func (s *Scenario) Deactivate()

Deactivate scenario runner not its server

func (*Scenario) Start

func (s *Scenario) Start() error

Start runs scenario server

func (*Scenario) Stop

func (s *Scenario) Stop()

Stop scenario server and runner