core

Jul 22, 2019

Changes in this version

+ func CleanValue(v interface{}) interface

+ func IsBOS(item interface{}) bool

+ func IsEOS(item interface{}) bool

+ type Binary []byte

+ func (b *Binary) MarshalYAML() (interface{}, error)

+ func (b *Binary) UnmarshalJSON(bytes []byte) error

+ func (b Binary) MarshalJSON() ([]byte, error)

+ type Blueprint struct

+ Connections map[string][]string

+ DelegateDefs map[string]*DelegateDef

+ Elementary uuid.UUID

+ Geometry ...

+ Id uuid.UUID

+ InstanceDefs InstanceDefList

+ Meta BlueprintMetaDef

+ PropertyDefs TypeDefMap

+ ServiceDefs map[string]*ServiceDef

+ TestCases []TestCaseDef

+ func ParseJSONOperatorDef(defStr string) (Blueprint, error)

+ func ParseYAMLOperatorDef(defStr string) (Blueprint, error)

+ func (d *Blueprint) SpecifyGenericPorts(generics map[string]*TypeDef) error

+ func (d *Blueprint) Validate() error

+ func (d Blueprint) Copy(recursive bool) Blueprint

+ func (d Blueprint) GenericsSpecified() error

+ func (d Blueprint) Valid() bool

+ func (def *Blueprint) SpecifyOperator(gens Generics, props Properties) error

+ type BlueprintMetaDef struct

+ Description string

+ DocURL string

+ Icon string

+ Name string

+ ShortDescription string

+ Tags []string

+ func (d *BlueprintMetaDef) Valid() bool

+ func (d *BlueprintMetaDef) Validate() error

type InstanceDef

+ Blueprint Blueprint

+ func (d InstanceDef) Copy(recursive bool) InstanceDef

+ type MapStr map[string]interface

+ func (ms *MapStr) UnmarshalYAML(unmarshal func(interface{}) error) error

type Operator

+ func (o *Operator) Id() uuid.UUID

type Port

+ func ParsePortReference(refStr string, par *Operator) (*Port, error)

+ func (p *Port) Closed() bool

+ func (p *Port) MapEntryNames() []string

+ func (p *Port) MapLength() int

+ func (p *Port) MapType() bool

+ func (p *Port) PrimitiveType() bool

+ func (p *Port) String() string

+ func (p *Port) TriggerType() bool

+ func (p *Port) WalkPrimitivePorts(handle func(p *Port))

+ type SlangBundle struct

+ Args struct{ ... }

+ Blueprints map[uuid.UUID]Blueprint

+ Main uuid.UUID

+ func (sb *SlangBundle) Validate() error

+ func (sb SlangBundle) Valid() bool

+ type TestCaseDef struct

+ Data struct{ ... }

+ Description string

+ Generics Generics

+ Name string

+ Properties Properties

+ func (tc *TestCaseDef) Validate() error

+ func (tc TestCaseDef) Valid() bool

type TypeDef

+ func ParseTypeDef(defStr string) TypeDef

Jan 30, 2019

Changes in this version

type DelegateDef

+ Geometry *PortGeometryDef

type InstanceDef

+ Geometry ...

type OperatorDef

+ Geometry ...

+ type PortGeometryDef struct

+ In struct{ ... }

+ Out struct{ ... }

type ServiceDef

+ Geometry *PortGeometryDef

Jan 23, 2019

Changes in this version

type OperatorDef

+ Description string

+ DisplayName string

+ Icon string

+ Name string

+ ShortDescription string

+ type PackageDef struct

+ Description string

+ DisplayName string

+ Name string

+ ShortDescription string

Aug 31, 2018

Changes in this version

+ var PHMultiple = &PH

+ var PHSingle = &PH

type Operator

+ func (o *Operator) Stopped() bool

+ type PH struct

+ func (ph *PH) MarshalJSON() ([]byte, error)

type Port

+ func (p *Port) MapEntries() []string

+ func (p *Port) Primitive() bool

Aug 8, 2018

Changes in this version

+ const DIRECTION_IN

+ const DIRECTION_OUT

+ const TYPE_BINARY

+ const TYPE_BOOLEAN

+ const TYPE_GENERIC

+ const TYPE_MAP

+ const TYPE_NUMBER

+ const TYPE_PRIMITIVE

+ const TYPE_STREAM

+ const TYPE_STRING

+ const TYPE_TRIGGER

+ var CHANNEL_DYNAMIC = false

+ var CHANNEL_SIZE = 1 << 15

+ var MAIN_SERVICE = "main"

+ func ExpandExpression(expr string, props Properties, propDefs map[string]*TypeDef) ([]string, error)

+ func IsMarker(item interface{}) bool

+ type BOS struct

+ type CFunc func(op *Operator, dst, src *Port) error

+ type Delegate struct

+ func NewDelegate(name string, op *Operator, def DelegateDef) (*Delegate, error)

+ func (d *Delegate) Define() DelegateDef

+ func (d *Delegate) In() *Port

+ func (d *Delegate) Name() string

+ func (d *Delegate) Operator() *Operator

+ func (d *Delegate) Out() *Port

+ type DelegateDef struct

+ In TypeDef

+ Out TypeDef

+ func (d *DelegateDef) Valid() bool

+ func (d *DelegateDef) Validate() error

+ func (d DelegateDef) Copy() DelegateDef

+ type EOS struct

+ type Generics map[string]*TypeDef

+ type InstanceDef struct

+ Generics Generics

+ Name string

+ Operator string

+ OperatorDef OperatorDef

+ Properties Properties

+ func (d *InstanceDef) Validate() error

+ func (d InstanceDef) Valid() bool

+ type InstanceDefList []*InstanceDef

+ func (ol *InstanceDefList) UnmarshalJSON(data []byte) error

+ func (ol *InstanceDefList) UnmarshalYAML(unmarshal func(v interface{}) error) error

+ func (ol InstanceDefList) MarshalJSON() ([]byte, error)

+ func (ol InstanceDefList) MarshalYAML() (interface{}, error)

+ type OFunc func(op *Operator)

+ type Operator struct

+ func NewOperator(name string, f OFunc, c CFunc, gens Generics, props Properties, ...) (*Operator, error)

+ func (o *Operator) BasePort() *Port

+ func (o *Operator) Builtin() bool

+ func (o *Operator) CheckStop() bool

+ func (o *Operator) Child(name string) *Operator

+ func (o *Operator) Children() map[string]*Operator

+ func (o *Operator) Compile() (compiled int, depth int)

+ func (o *Operator) CorrectlyCompiled() error

+ func (o *Operator) Define() (OperatorDef, error)

+ func (o *Operator) Delegate(del string) *Delegate

+ func (o *Operator) Main() *Service

+ func (o *Operator) Name() string

+ func (o *Operator) Parent() *Operator

+ func (o *Operator) Property(prop string) interface{}

+ func (o *Operator) Service(srv string) *Service

+ func (o *Operator) SetParent(par *Operator)

+ func (o *Operator) SetProperties(properties Properties)

+ func (o *Operator) Start()

+ func (o *Operator) Stop()

+ func (o *Operator) WaitForStop()

+ type OperatorDef struct

+ Connections map[string][]string

+ DelegateDefs map[string]*DelegateDef

+ Elementary string

+ InstanceDefs InstanceDefList

+ PropertyDefs TypeDefMap

+ ServiceDefs map[string]*ServiceDef

+ func (d *OperatorDef) SpecifyGenericPorts(generics map[string]*TypeDef) error

+ func (d *OperatorDef) Validate() error

+ func (d OperatorDef) Copy() OperatorDef

+ func (d OperatorDef) GenericsSpecified() error

+ func (d OperatorDef) Valid() bool

+ func (def *OperatorDef) SpecifyOperator(gens Generics, props Properties) error

+ type Port struct

+ func NewPort(srv *Service, del *Delegate, def TypeDef, dir int) (*Port, error)

+ func (p *Port) Bufferize()

+ func (p *Port) Close()

+ func (p *Port) Connect(q *Port) (err error)

+ func (p *Port) Connected(q *Port) bool

+ func (p *Port) Define() TypeDef

+ func (p *Port) Delegate() *Delegate

+ func (p *Port) Direction() int

+ func (p *Port) DirectlyConnected() error

+ func (p *Port) Disconnect(q *Port) error

+ func (p *Port) Map(name string) *Port

+ func (p *Port) MapSize() interface{}

+ func (p *Port) Merge() bool

+ func (p *Port) Name() string

+ func (p *Port) NewBOS() BOS

+ func (p *Port) NewEOS() EOS

+ func (p *Port) Open()

+ func (p *Port) Operator() *Operator

+ func (p *Port) OwnBOS(i interface{}) bool

+ func (p *Port) OwnEOS(i interface{}) bool

+ func (p *Port) ParentStream() *Port

+ func (p *Port) Poll() interface{}

+ func (p *Port) Pull() interface{}

+ func (p *Port) PullBOS() bool

+ func (p *Port) PullBinary() (utils.Binary, interface{})

+ func (p *Port) PullBoolean() (bool, interface{})

+ func (p *Port) PullEOS() bool

+ func (p *Port) PullFloat64() (float64, interface{})

+ func (p *Port) PullInt() (int, interface{})

+ func (p *Port) PullString() (string, interface{})

+ func (p *Port) Push(item interface{})

+ func (p *Port) PushBOS()

+ func (p *Port) PushEOS()

+ func (p *Port) PushNoTriggerBOS()

+ func (p *Port) SetStreamSource(srcStr *Port)

+ func (p *Port) Stream() *Port

+ func (p *Port) StreamSource() *Port

+ func (p *Port) StringifyComplete() string

+ func (p *Port) Type() int

+ type Properties utils.MapStr

+ func (p Properties) Clean()

+ type Service struct

+ func NewService(name string, op *Operator, def ServiceDef) (*Service, error)

+ func (s *Service) Define() ServiceDef

+ func (s *Service) In() *Port

+ func (s *Service) Name() string

+ func (s *Service) Operator() *Operator

+ func (s *Service) Out() *Port

+ type ServiceDef struct

+ In TypeDef

+ Out TypeDef

+ func (d *ServiceDef) Valid() bool

+ func (d *ServiceDef) Validate() error

+ func (d ServiceDef) Copy() ServiceDef

+ type Synchronizer struct

+ func (s *Synchronizer) Init(in, out *Port)

+ func (s *Synchronizer) Pull(token int64, pull pullFunc)

+ func (s *Synchronizer) Push(push pushFunc) int64

+ func (s *Synchronizer) Worker()

+ type TypeDef struct

+ Generic string

+ Map map[string]*TypeDef

+ Stream *TypeDef

+ Type string

+ func (d *TypeDef) ApplyProperties(props Properties, propDefs map[string]*TypeDef) error

+ func (d *TypeDef) SpecifyGenerics(generics map[string]*TypeDef) error

+ func (d *TypeDef) Valid() bool

+ func (d *TypeDef) Validate() error

+ func (d TypeDef) Copy() TypeDef

+ func (d TypeDef) Equals(p TypeDef) bool

+ func (d TypeDef) GenericsSpecified() error

+ func (d TypeDef) VerifyData(data interface{}) error

+ type TypeDefMap map[string]*TypeDef

+ func (t TypeDefMap) GenericsSpecified() error

+ func (t TypeDefMap) SpecifyGenerics(generics map[string]*TypeDef) error

+ func (t TypeDefMap) VerifyData(data map[string]interface{}) error