Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.