insitu

Documentation

Index

• type Config
  • func DefaultConfig(complex bool) Config
• type LocalDatapath
  • func NewDatapath(config Config) (*LocalDatapath, error)
  • func (path *LocalDatapath) Capabilities() []selector.Capability
  • func (path *LocalDatapath) Close() error
  • func (path *LocalDatapath) Location() string
  • func (path *LocalDatapath) NewChannel(config processor.ChannelConfig) (processor.Channel, error)
  • func (path *LocalDatapath) String() string

Types

type Config

type Config struct {
	ProcessorManager *processormanager.ProcessorManager `validate:"required"`
	DeviceManager    *devicemanager.DeviceManager       `validate:"required"`
}

Config defines the running paramers of the Device

func DefaultConfig

func DefaultConfig(complex bool) Config

DefaultConfig return the configuration for a local Datapath with 10 devices. If complex is set to false, only direct graph will be used

type LocalDatapath

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

LocalDatapath connect insitu processor with insitu device manager

func NewDatapath

func NewDatapath(config Config) (*LocalDatapath, error)

NewDatapath returns a new LocalDatapath compliant with processor.Processor

func (*LocalDatapath) Capabilities

func (path *LocalDatapath) Capabilities() []selector.Capability

Capabilities returns the capabilities of the Datapath

func (*LocalDatapath) Close

func (path *LocalDatapath) Close() error

Close gracefully shutdowns the datapath

func (*LocalDatapath) Location

func (path *LocalDatapath) Location() string

Location returns the node where the Processor is running

func (*LocalDatapath) NewChannel

func (path *LocalDatapath) NewChannel(config processor.ChannelConfig) (processor.Channel, error)

NewChannel returns a new channel associated to the Processor

func (*LocalDatapath) String

func (path *LocalDatapath) String() string

String returns a descriptive name for the Processor