worker

Documentation

Index

• Variables
• type Allocator
  • func NewFixedPoolWorkerAllocator(parentLogger nuclio.Logger, workers []*Worker) (Allocator, error)
  • func NewSingletonWorkerAllocator(parentLogger nuclio.Logger, worker *Worker) (Allocator, error)
• type Factory
  • func (waf *Factory) CreateFixedPoolWorkerAllocator(logger nuclio.Logger, numWorkers int, runtimeConfiguration *viper.Viper) (Allocator, error)
  • func (waf *Factory) CreateSingletonPoolWorkerAllocator(logger nuclio.Logger, runtimeConfiguration *viper.Viper) (Allocator, error)
• type Statistics
• type Worker
  • func NewWorker(parentLogger nuclio.Logger, index int, runtime runtime.Runtime) (*Worker, error)
  • func (w *Worker) GetIndex() int
  • func (w *Worker) GetRuntime() runtime.Runtime
  • func (w *Worker) GetStatistics() *Statistics
  • func (w *Worker) ProcessEvent(event nuclio.Event, functionLogger nuclio.Logger) (interface{}, error)

Variables

var ErrNoAvailableWorkers = errors.New("No available workers")

errors

var WorkerFactorySingleton = Factory{}

global singleton

Types

type Allocator

type Allocator interface {

	// allocate a worker
	Allocate(timeout time.Duration) (*Worker, error)

	// release a worker
	Release(worker *Worker)

	// true if the several go routines can share this allocator
	Shareable() bool

	// get direct access to all workers for things like management / housekeeping
	GetWorkers() []*Worker
}

func NewFixedPoolWorkerAllocator

func NewFixedPoolWorkerAllocator(parentLogger nuclio.Logger, workers []*Worker) (Allocator, error)

func NewSingletonWorkerAllocator

func NewSingletonWorkerAllocator(parentLogger nuclio.Logger, worker *Worker) (Allocator, error)

type Factory

type Factory struct{}

func (*Factory) CreateFixedPoolWorkerAllocator

func (waf *Factory) CreateFixedPoolWorkerAllocator(logger nuclio.Logger,
	numWorkers int,
	runtimeConfiguration *viper.Viper) (Allocator, error)

func (*Factory) CreateSingletonPoolWorkerAllocator

func (waf *Factory) CreateSingletonPoolWorkerAllocator(logger nuclio.Logger,
	runtimeConfiguration *viper.Viper) (Allocator, error)

type Statistics

type Statistics struct {
	EventsHandleSuccess uint64
	EventsHandleError   uint64
}

type Worker

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

func NewWorker

func NewWorker(parentLogger nuclio.Logger,
	index int,
	runtime runtime.Runtime) (*Worker, error)

func (*Worker) GetIndex

func (w *Worker) GetIndex() int

func (*Worker) GetRuntime

func (w *Worker) GetRuntime() runtime.Runtime

func (*Worker) GetStatistics

func (w *Worker) GetStatistics() *Statistics

func (*Worker) ProcessEvent

func (w *Worker) ProcessEvent(event nuclio.Event, functionLogger nuclio.Logger) (interface{}, error)

called by event sources