api

package

v0.1.27 Latest Latest Go to latest Published: Aug 24, 2022 License: Apache-2.0 Imports: 16 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Bitspark/slang

Links

Documentation ¶

Index ¶

func Build(opId uuid.UUID, gens core.Generics, props core.Properties, st storage.Storage) (*core.Operator, error)
func BuildAndCompile(opId uuid.UUID, gens core.Generics, props core.Properties, st storage.Storage) (*core.Operator, error)
func BuildOperator(bundle *core.SlangBundle) (*core.Operator, error)
func Compile(op *core.Operator) (*core.Operator, error)
func CreateAndConnectOperator(insName string, def core.Blueprint, ordered bool) (*core.Operator, error)
func CreateBundle(bp *core.Blueprint, st *storage.Storage) (*core.SlangBundle, error)
func JsonRdbuf(rd *bufio.Reader) (interface{}, error)
func JsonWrbuf(wr *bufio.Writer, j interface{}) error
func Rdbuf(rd *bufio.Reader) (string, error)
func Wrbuf(wr *bufio.Writer, msg string) error
type Commander
- func NewCommander(addr string) Commander
type Commands
type PortConnHandler
- func NewPortConnHandler(pmap map[string]string) PortConnHandler
type TestBench
- func NewTestBench(stor *storage.Storage) *TestBench
- func (t TestBench) Run(opId uuid.UUID, writer io.Writer, failFast bool) (int, int, error)
type Worker
- func NewWorker(addr string) Worker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Build ¶ added in v0.1.17

func Build(opId uuid.UUID, gens core.Generics, props core.Properties, st storage.Storage) (*core.Operator, error)

func BuildAndCompile ¶ added in v0.1.17

func BuildAndCompile(opId uuid.UUID, gens core.Generics, props core.Properties, st storage.Storage) (*core.Operator, error)

func BuildOperator ¶ added in v0.1.17

func BuildOperator(bundle *core.SlangBundle) (*core.Operator, error)

todo should be SlangBundle method

func Compile ¶ added in v0.1.17

func Compile(op *core.Operator) (*core.Operator, error)

func CreateAndConnectOperator ¶

func CreateAndConnectOperator(insName string, def core.Blueprint, ordered bool) (*core.Operator, error)

func CreateBundle ¶ added in v0.1.17

func CreateBundle(bp *core.Blueprint, st *storage.Storage) (*core.SlangBundle, error)

func JsonRdbuf ¶ added in v0.1.17

func JsonRdbuf(rd *bufio.Reader) (interface{}, error)

func JsonWrbuf ¶ added in v0.1.17

func JsonWrbuf(wr *bufio.Writer, j interface{}) error

func Rdbuf ¶ added in v0.1.17

func Rdbuf(rd *bufio.Reader) (string, error)

func Wrbuf ¶ added in v0.1.17

func Wrbuf(wr *bufio.Writer, msg string) error

Types ¶

type Commander ¶ added in v0.1.17

type Commander interface {
	Begin(action func(c Commands) error) error
	Addr() string
}

func NewCommander ¶ added in v0.1.17

func NewCommander(addr string) Commander

type Commands ¶ added in v0.1.17

type Commands interface {
	Hello() (string, error)
	Init(a string) (string, error)
	PrtCfg() (string, error)
	Action() error
}

type PortConnHandler ¶ added in v0.1.17

type PortConnHandler interface {
	ListPortRefs() []string
	ConnectTo(p string, hndl func(c net.Conn) bool) error
}

func NewPortConnHandler ¶ added in v0.1.17

func NewPortConnHandler(pmap map[string]string) PortConnHandler

type TestBench ¶ added in v0.1.17

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

func NewTestBench ¶ added in v0.1.17

func NewTestBench(stor *storage.Storage) *TestBench

func (TestBench) Run ¶ added in v0.1.17

func (t TestBench) Run(opId uuid.UUID, writer io.Writer, failFast bool) (int, int, error)

TestOperator reads a file with test data and its corresponding operator and performs the tests. It returns the number of failed and succeeded tests and and error in case something went wrong. Test failures do not lead to an error. Test failures are printed to the writer.

type Worker ¶ added in v0.1.17

type Worker interface {
	Begin(new func() Commands) error
	Addr() string
}

func NewWorker ¶ added in v0.1.17

func NewWorker(addr string) Worker

Source Files ¶

View all Source files

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