processormanager

Documentation

Index

• Variables
• type Config
• type ProcessorManager
  • func New(config Config) (*ProcessorManager, error)
  • func (pm *ProcessorManager) Close() error
  • func (pm *ProcessorManager) GetProcessor(processorID string) (processor.Processor, error)
  • func (pm *ProcessorManager) SelectAndReserve(capabilities ...selector.Capability) (processor.Processor, error)

Variables

var (
	// ErrProcessorManager is the root for the errors
	ErrProcessorManager = errors.NewClass("ProcessorManager Error")

	// ErrArg describes the family of calling errors
	ErrArg = ErrProcessorManager.NewClass("Argument error")

	// ErrRutime describes the family of system errors
	ErrRuntime = ErrProcessorManager.NewClass("Runtime error")

	// ErrInvalid is used for invalid arguments
	ErrInvalid = ErrArg.New("Invalid argument")

	// ErrNotFound indicates that the processor ask by key is not available
	ErrNotFound = ErrRuntime.New("Processor not found")

	// ErrClosed indicates the processor manager is closed
	ErrClosed = ErrRuntime.New("Processor Manager is closed")
)

Types

type Config

type Config struct {
	Peer     *peer.Peer        `validate:"required"`
	Selector selector.Selector `validate:"required"`
}

Config includes the execution paramers for the ProcessorManager

type ProcessorManager

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

ProcessorManager provides clustered access to the Processors

func New

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

func (*ProcessorManager) Close

func (pm *ProcessorManager) Close() error

Close closes the device manager

func (*ProcessorManager) GetProcessor

func (pm *ProcessorManager) GetProcessor(processorID string) (processor.Processor, error)

GetProcessor returns a connector to the Processor identified by processorID

func (*ProcessorManager) SelectAndReserve

func (pm *ProcessorManager) SelectAndReserve(capabilities ...selector.Capability) (processor.Processor, error)

SelectAndReserve selects and reserves one of the available Processors in the cluster based on the capability contrains. It returns the Processor ID