processor

package
v0.0.0-...-5b6cbe3 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	ID         string       `validate:"required"`
	Parameters *viper.Viper `validate:"required"`
	Hub        *hub.Hub     `validate:"required"`
}

Config defines the running paramers of the Processor

type Processor 

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

Processor is a virtual proxy composed out of a directed acyclic graph

func New 

func New(config Config) (*Processor, error)

New returns a new Processor instance

func (*Processor) Capabilities 

func (p *Processor) Capabilities() []selector.Capability

Capabilities returns the capabilities of the Processor

func (*Processor) Close 

func (p *Processor) Close() error

Close gracefully shutdowns the processor

func (*Processor) Location 

func (p *Processor) Location() string

Location returns the node where the Processor is running

func (*Processor) NewChannel 

func (p *Processor) NewChannel(config processor.ChannelConfig) (processor.Channel, error)

NewChannel returns a new channel associated to the Processor

func (*Processor) String 

func (p *Processor) String() string

String returns a descriptive name for the Processor

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.