core

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Aug 10, 2018 License: Apache-2.0 Imports: 9 Imported by: 9

Documentation

Index

Constants

View Source 
const (
	TYPE_GENERIC   = iota
	TYPE_PRIMITIVE = iota
	TYPE_TRIGGER   = iota
	TYPE_NUMBER    = iota
	TYPE_STRING    = iota
	TYPE_BINARY    = iota
	TYPE_BOOLEAN   = iota
	TYPE_STREAM    = iota
	TYPE_MAP       = iota
)
View Source 
const (
	DIRECTION_IN  = iota
	DIRECTION_OUT = iota
)

Variables

View Source 
var CHANNEL_DYNAMIC = false
View Source 
var CHANNEL_SIZE = 1 << 15
View Source 
var MAIN_SERVICE = "main"

Functions

func ExpandExpression 

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

func IsMarker 

func IsMarker(item interface{}) bool

Types

type BOS 

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

type CFunc 

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

type Delegate 

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

func NewDelegate 

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

func (*Delegate) Define 

func (d *Delegate) Define() DelegateDef

func (*Delegate) In 

func (d *Delegate) In() *Port

func (*Delegate) Name 

func (d *Delegate) Name() string

func (*Delegate) Operator 

func (d *Delegate) Operator() *Operator

func (*Delegate) Out 

func (d *Delegate) Out() *Port

type DelegateDef 

type DelegateDef struct {
	In  TypeDef `json:"in" yaml:"in"`
	Out TypeDef `json:"out" yaml:"out"`
	// contains filtered or unexported fields
}

func (DelegateDef) Copy 

func (d DelegateDef) Copy() DelegateDef

func (*DelegateDef) Valid 

func (d *DelegateDef) Valid() bool

func (*DelegateDef) Validate 

func (d *DelegateDef) Validate() error

type EOS 

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

type Generics 

type Generics map[string]*TypeDef

type InstanceDef 

type InstanceDef struct {
	Name       string     `json:"-" yaml:"-"`
	Operator   string     `json:"operator" yaml:"operator"`
	Properties Properties `json:"properties,omitempty" yaml:"properties,omitempty"`
	Generics   Generics   `json:"generics,omitempty" yaml:"generics,omitempty"`

	OperatorDef OperatorDef `json:"-" yaml:"definition,omitempty"`
	// contains filtered or unexported fields
}

func (InstanceDef) Valid 

func (d InstanceDef) Valid() bool

func (*InstanceDef) Validate 

func (d *InstanceDef) Validate() error

type InstanceDefList 

type InstanceDefList []*InstanceDef

func (InstanceDefList) MarshalJSON 

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

func (InstanceDefList) MarshalYAML 

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

func (*InstanceDefList) UnmarshalJSON 

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

func (*InstanceDefList) UnmarshalYAML 

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

type OFunc 

type OFunc func(op *Operator)

type Operator 

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

func NewOperator 

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

func (*Operator) BasePort 

func (o *Operator) BasePort() *Port

func (*Operator) Builtin 

func (o *Operator) Builtin() bool

func (*Operator) CheckStop 

func (o *Operator) CheckStop() bool

func (*Operator) Child 

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

func (*Operator) Children 

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

func (*Operator) Compile 

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

func (*Operator) CorrectlyCompiled 

func (o *Operator) CorrectlyCompiled() error

func (*Operator) Define 

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

func (*Operator) Delegate 

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

func (*Operator) Main 

func (o *Operator) Main() *Service

func (*Operator) Name 

func (o *Operator) Name() string

func (*Operator) Parent 

func (o *Operator) Parent() *Operator

func (*Operator) Property 

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

func (*Operator) Service 

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

func (*Operator) SetParent 

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

func (*Operator) SetProperties 

func (o *Operator) SetProperties(properties Properties)

func (*Operator) Start 

func (o *Operator) Start()

func (*Operator) Stop 

func (o *Operator) Stop()

func (*Operator) WaitForStop 

func (o *Operator) WaitForStop()

type OperatorDef 

type OperatorDef struct {
	ServiceDefs  map[string]*ServiceDef  `json:"services,omitempty" yaml:"services,omitempty"`
	DelegateDefs map[string]*DelegateDef `json:"delegates,omitempty" yaml:"delegates,omitempty"`
	InstanceDefs InstanceDefList         `json:"operators,omitempty" yaml:"operators,omitempty"`
	PropertyDefs TypeDefMap              `json:"properties,omitempty" yaml:"properties,omitempty"`
	Connections  map[string][]string     `json:"connections,omitempty" yaml:"connections,omitempty"`
	Elementary   string                  `json:"-" yaml:"-"`
	// contains filtered or unexported fields
}

func (OperatorDef) Copy 

func (d OperatorDef) Copy() OperatorDef

func (OperatorDef) GenericsSpecified 

func (d OperatorDef) GenericsSpecified() error

func (*OperatorDef) SpecifyGenericPorts 

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

SpecifyGenerics replaces generic types in the operator definition with the types given in the generics map. The values of the map are the according identifiers. It does not touch referenced values such as *TypeDef but replaces them with a reference on a copy.

func (*OperatorDef) SpecifyOperator 

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

func (OperatorDef) Valid 

func (d OperatorDef) Valid() bool

func (*OperatorDef) Validate 

func (d *OperatorDef) Validate() error

type Port 

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

func NewPort 

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

Makes a new port.

func (*Port) Bufferize 

func (p *Port) Bufferize()

func (*Port) Close 

func (p *Port) Close()

Closes the port by closing all channels

func (*Port) Connect 

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

Connects this port with port p.

func (*Port) Connected 

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

Returns true if p is connected with q.

func (*Port) Define 

func (p *Port) Define() TypeDef

func (*Port) Delegate 

func (p *Port) Delegate() *Delegate

Returns the operator this port is attached to

func (*Port) Direction 

func (p *Port) Direction() int

Returns the direction of the port.

func (*Port) DirectlyConnected 

func (p *Port) DirectlyConnected() error

Checks if this in port is connected completely

func (*Port) Disconnect 

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

Disconnects this port from port q.

func (*Port) Map 

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

Returns the subport with the according name of this port. Port must be of type map.

func (*Port) MapSize 

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

Returns the length of the map ports

func (*Port) Merge 

func (p *Port) Merge() bool

Removes this port and redirects connections.

func (*Port) Name 

func (p *Port) Name() string

Name returns a name generated from operator, directions and port.

func (*Port) NewBOS 

func (p *Port) NewBOS() BOS

func (*Port) NewEOS 

func (p *Port) NewEOS() EOS

func (*Port) Open 

func (p *Port) Open()

Opens the port by opening all channels

func (*Port) Operator 

func (p *Port) Operator() *Operator

Returns the operator this port is attached to

func (*Port) OwnBOS 

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

func (*Port) OwnEOS 

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

func (*Port) ParentStream 

func (p *Port) ParentStream() *Port

Returns the parent stream port. Port must be of type stream.

func (*Port) Poll 

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

Similar to Port.Pull but will return nil when there is no item after timeout

func (*Port) Pull 

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

Pull an item from this port

func (*Port) PullBOS 

func (p *Port) PullBOS() bool

func (*Port) PullBinary 

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

Pull a binary object

func (*Port) PullBoolean 

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

Pull an boolean

func (*Port) PullEOS 

func (p *Port) PullEOS() bool

func (*Port) PullFloat64 

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

Pull a float

func (*Port) PullInt 

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

Pull an int

func (*Port) PullString 

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

Pull a string

func (*Port) Push 

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

Push an item to this port.

func (*Port) PushBOS 

func (p *Port) PushBOS()

func (*Port) PushEOS 

func (p *Port) PushEOS()

func (*Port) PushNoTriggerBOS 

func (p *Port) PushNoTriggerBOS()

func (*Port) SetStreamSource 

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

func (*Port) Stream 

func (p *Port) Stream() *Port

Returns the substream port of this port. Port must be of type stream.

func (*Port) StreamSource 

func (p *Port) StreamSource() *Port

func (*Port) StringifyComplete 

func (p *Port) StringifyComplete() string

func (*Port) Type 

func (p *Port) Type() int

Returns the type of the port.

type Properties 

type Properties utils.MapStr

func (Properties) Clean 

func (p Properties) Clean()

type Service 

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

func NewService 

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

func (*Service) Define 

func (s *Service) Define() ServiceDef

func (*Service) In 

func (s *Service) In() *Port

func (*Service) Name 

func (s *Service) Name() string

func (*Service) Operator 

func (s *Service) Operator() *Operator

func (*Service) Out 

func (s *Service) Out() *Port

type ServiceDef 

type ServiceDef struct {
	In  TypeDef `json:"in" yaml:"in"`
	Out TypeDef `json:"out" yaml:"out"`
	// contains filtered or unexported fields
}

func (ServiceDef) Copy 

func (d ServiceDef) Copy() ServiceDef

func (*ServiceDef) Valid 

func (d *ServiceDef) Valid() bool

func (*ServiceDef) Validate 

func (d *ServiceDef) Validate() error

type Synchronizer 

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

func (*Synchronizer) Init 

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

func (*Synchronizer) Pull 

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

func (*Synchronizer) Push 

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

func (*Synchronizer) Worker 

func (s *Synchronizer) Worker()

type TypeDef 

type TypeDef struct {
	// Type is one of "primitive", "number", "string", "boolean", "stream", "map", "generic"
	Type    string              `json:"type" yaml:"type"`
	Stream  *TypeDef            `json:"stream,omitempty" yaml:"stream,omitempty"`
	Map     map[string]*TypeDef `json:"map,omitempty" yaml:"map,omitempty"`
	Generic string              `json:"generic,omitempty" yaml:"generic,omitempty"`
	// contains filtered or unexported fields
}

func (*TypeDef) ApplyProperties 

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

func (TypeDef) Copy 

func (d TypeDef) Copy() TypeDef

func (TypeDef) Equals 

func (d TypeDef) Equals(p TypeDef) bool

func (TypeDef) GenericsSpecified 

func (d TypeDef) GenericsSpecified() error

func (*TypeDef) SpecifyGenerics 

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

SpecifyGenerics replaces generic types in the port definition with the types given in the generics map. The values of the map are the according identifiers. It does not touch referenced values such as *TypeDef but replaces them with a reference on a copy, which is very important to prevent unintended side effects.

func (*TypeDef) Valid 

func (d *TypeDef) Valid() bool

func (*TypeDef) Validate 

func (d *TypeDef) Validate() error

func (TypeDef) VerifyData 

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

type TypeDefMap 

type TypeDefMap map[string]*TypeDef

func (TypeDefMap) GenericsSpecified 

func (t TypeDefMap) GenericsSpecified() error

func (TypeDefMap) SpecifyGenerics 

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

func (TypeDefMap) VerifyData 

func (t TypeDefMap) VerifyData(data map[string]interface{}) 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.