processor

Documentation

Index

• type ContainerRunner
• type ImageFinder
• type Processor
  • func New(imageFinder ImageFinder, containerCLI ContainerRunner, ...) *Processor
  • func (p *Processor) Handle(topic string, message []byte)

Types

type ContainerRunner

type ContainerRunner interface {
	Run(context.Context, *types.ImageRunnerInput) ([]byte, error)
}

ContainerRunner ...

type ImageFinder

type ImageFinder interface {
	GetImages(context.Context, string) ([]string, error)
}

ImageFinder get the list of images to run based on topic

type Processor

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

Processor ...

func New

func New(imageFinder ImageFinder, containerCLI ContainerRunner,
	outputChan chan *faas.Output,
	functionTimeout time.Duration) *Processor

New ...

func (*Processor) Handle

func (p *Processor) Handle(topic string, message []byte)

Handle ...