worker

Documentation

Index

• Variables
• type FaasHttpWorker
  • func NewFaasHttpWorker(address string) (*FaasHttpWorker, error)
  • func (h *FaasHttpWorker) HandleEvent(trigger *triggers.Event) error
  • func (h *FaasHttpWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers.HttpResponse, error)
• type FaasWorker
  • func NewFaasWorker(stream pb.FaasService_TriggerStreamServer) *FaasWorker
  • func (s *FaasWorker) HandleEvent(trigger *triggers.Event) error
  • func (s *FaasWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers.HttpResponse, error)
  • func (s *FaasWorker) Listen(errchan chan error)
• type HttpWorker
  • func NewHttpWorker(address string) (*HttpWorker, error)
  • func (h *HttpWorker) HandleEvent(trigger *triggers.Event) error
  • func (h *HttpWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers.HttpResponse, error)
• type ProcessPool
  • func (p *ProcessPool) AddWorker(wrkr Worker) error
  • func (p *ProcessPool) GetMaxWorkers() int
  • func (p *ProcessPool) GetMinWorkers() int
  • func (p *ProcessPool) GetWorker() (Worker, error)
  • func (p *ProcessPool) GetWorkerCount() int
  • func (p *ProcessPool) Monitor() error
  • func (p *ProcessPool) RemoveWorker(wrkr Worker) error
  • func (p *ProcessPool) WaitForMinimumWorkers(timeout int) error
• type ProcessPoolOptions
• type UnimplementedWorker
  • func (*UnimplementedWorker) HandleEvent(trigger *triggers.Event) error
  • func (*UnimplementedWorker) HandleHttpRequest(trigger *triggers.HttpRequest) *http.Response
• type Worker
• type WorkerPool
  • func NewProcessPool(opts *ProcessPoolOptions) WorkerPool

Variables

var METHOD_TYPE = []byte("POST")

Types

type FaasHttpWorker

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

A Nitric HTTP worker

func NewFaasHttpWorker

func NewFaasHttpWorker(address string) (*FaasHttpWorker, error)

Creates a new FaasHttpWorker Will wait to ensure that the provided address is dialable before proceeding

func (*FaasHttpWorker) HandleEvent

func (h *FaasHttpWorker) HandleEvent(trigger *triggers.Event) error

HandleEvent - Handles an event from a subscription by converting it to an HTTP request.

func (*FaasHttpWorker) HandleHttpRequest

func (h *FaasHttpWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers.HttpResponse, error)

HandleHttpRequest - Handles an HTTP request by forwarding it as an HTTP request.

type FaasWorker

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

FaasWorker Worker representation for a Nitric FaaS function using gRPC

func NewFaasWorker

func NewFaasWorker(stream pb.FaasService_TriggerStreamServer) *FaasWorker

Package private method Only a pool may create a new faas worker

func (*FaasWorker) HandleEvent

func (s *FaasWorker) HandleEvent(trigger *triggers.Event) error

func (*FaasWorker) HandleHttpRequest

func (s *FaasWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers.HttpResponse, error)

func (*FaasWorker) Listen

func (s *FaasWorker) Listen(errchan chan error)

listen

type HttpWorker

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

A Nitric HTTP worker

func NewHttpWorker

func NewHttpWorker(address string) (*HttpWorker, error)

Creates a new HttpWorker Will wait to ensure that the provided address is dialable before proceeding

func (*HttpWorker) HandleEvent

func (h *HttpWorker) HandleEvent(trigger *triggers.Event) error

HandleEvent - Handles an event from a subscription by converting it to an HTTP request.

func (*HttpWorker) HandleHttpRequest

func (h *HttpWorker) HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers.HttpResponse, error)

HandleHttpRequest - Handles an HTTP request by forwarding it as an HTTP request.

type ProcessPool

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

ProcessPool - A worker pool that represent co-located processes

func (*ProcessPool) AddWorker

func (p *ProcessPool) AddWorker(wrkr Worker) error

AddWorker - Adds the given worker to this pool

func (*ProcessPool) GetMaxWorkers

func (p *ProcessPool) GetMaxWorkers() int

GetMaxWorkers - return the maximum number of workers for this pool

func (*ProcessPool) GetMinWorkers

func (p *ProcessPool) GetMinWorkers() int

GetMinWorkers - return the minimum number of workers for this pool

func (*ProcessPool) GetWorker

func (p *ProcessPool) GetWorker() (Worker, error)

GetWorker - Retrieves a worker from this pool

func (*ProcessPool) GetWorkerCount

func (p *ProcessPool) GetWorkerCount() int

func (*ProcessPool) Monitor

func (p *ProcessPool) Monitor() error

Monitor - Blocks the current thread to supervise this worker pool

func (*ProcessPool) RemoveWorker

func (p *ProcessPool) RemoveWorker(wrkr Worker) error

RemoveWorker - Removes the given worker from this pool

func (*ProcessPool) WaitForMinimumWorkers

func (p *ProcessPool) WaitForMinimumWorkers(timeout int) error

WaitForMinimumWorkers - Waits for the configured minimum number of workers to be available in this pool

type ProcessPoolOptions

type ProcessPoolOptions struct {
	MinWorkers int
	MaxWorkers int
}

type UnimplementedWorker

type UnimplementedWorker struct{}

func (*UnimplementedWorker) HandleEvent

func (*UnimplementedWorker) HandleEvent(trigger *triggers.Event) error

func (*UnimplementedWorker) HandleHttpRequest

func (*UnimplementedWorker) HandleHttpRequest(trigger *triggers.HttpRequest) *http.Response

type Worker

type Worker interface {
	HandleEvent(trigger *triggers.Event) error
	HandleHttpRequest(trigger *triggers.HttpRequest) (*triggers.HttpResponse, error)
}

type WorkerPool

type WorkerPool interface {
	// WaitForMinimumWorkers - A blocking method
	WaitForMinimumWorkers(timeout int) error
	GetWorkerCount() int
	GetWorker() (Worker, error)
	AddWorker(Worker) error
	RemoveWorker(Worker) error
	Monitor() error
}

func NewProcessPool

func NewProcessPool(opts *ProcessPoolOptions) WorkerPool

NewProcessPool - Creates a new process pool