pixelpipe

Documentation

Index

• func NewSimplePipeIntersection(id pipepart.ID, inputs map[pipepart.ID]hardware.FrameSource, ...) pipepart.PixelPiper
• type FramePipeline
  • func NewEmptyFramePipeline(id pipepart.ID, logger *zap.Logger) *FramePipeline
  • func (me *FramePipeline) AddPipeBefore(id pipepart.ID, newPipe pipepart.PixelPiper)
  • func (me *FramePipeline) GetID() pipepart.ID
  • func (me *FramePipeline) GetOutput(id pipepart.ID) hardware.FrameSource
  • func (me *FramePipeline) GetParams() []pipepart.PipeParam
  • func (me *FramePipeline) GetPipeByID(id pipepart.ID) (pipepart.PixelPiper, error)
  • func (me *FramePipeline) GetPipes() pipepart.PipesMarshal
  • func (me *FramePipeline) GetPrevID() pipepart.ID
  • func (me *FramePipeline) GetType() pipepart.PipeType
  • func (me *FramePipeline) Marshal() *pipepart.Marshal
  • func (me *FramePipeline) RunPipe(destroyCtx context.Context, wg *sync.WaitGroup)
  • func (me *FramePipeline) SetInput(prevID pipepart.ID, inputChan hardware.FrameSource)

Functions

func NewSimplePipeIntersection

func NewSimplePipeIntersection(
	id pipepart.ID,
	inputs map[pipepart.ID]hardware.FrameSource,
	emptyInput hardware.FrameSource,
	numOutputChannels int,
	logger *zap.Logger,
) pipepart.PixelPiper

NewSimplePipeIntersection creates a pipe intersection which wil put each frame from any input channel to all output channels

Types

type FramePipeline

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

FramePipeline is a struct which defines a

func NewEmptyFramePipeline

func NewEmptyFramePipeline(id pipepart.ID, logger *zap.Logger) *FramePipeline

NewEmptyFramePipeline creates a new, empty FramePipeline which can hold multiple pipes end-to-end connected to each other

func (*FramePipeline) AddPipeBefore

func (me *FramePipeline) AddPipeBefore(id pipepart.ID, newPipe pipepart.PixelPiper)

AddPipeBefore adds a pipe segment before id

func (*FramePipeline) GetID

func (me *FramePipeline) GetID() pipepart.ID

GetID implements PixelPiper interface

func (*FramePipeline) GetOutput

func (me *FramePipeline) GetOutput(id pipepart.ID) hardware.FrameSource

GetOutput implements PixelPiper interface

func (*FramePipeline) GetParams

func (me *FramePipeline) GetParams() []pipepart.PipeParam

GetParams implements PixelPiper interface

func (*FramePipeline) GetPipeByID

func (me *FramePipeline) GetPipeByID(id pipepart.ID) (pipepart.PixelPiper, error)

GetPipeByID implements PixelPiperWithSubPipes interface

func (*FramePipeline) GetPipes

func (me *FramePipeline) GetPipes() pipepart.PipesMarshal

GetPipes implements PixelPiperWithSubPipes interface

func (*FramePipeline) GetPrevID

func (me *FramePipeline) GetPrevID() pipepart.ID

GetPrevID implements PixelPiper interface

func (*FramePipeline) GetType

func (me *FramePipeline) GetType() pipepart.PipeType

GetType implements PixelPiper interface

func (*FramePipeline) Marshal

func (me *FramePipeline) Marshal() *pipepart.Marshal

Marshal implements PixelPiper interface

func (*FramePipeline) RunPipe

func (me *FramePipeline) RunPipe(destroyCtx context.Context, wg *sync.WaitGroup)

RunPipe implements PixelPiper interface

func (*FramePipeline) SetInput

func (me *FramePipeline) SetInput(prevID pipepart.ID, inputChan hardware.FrameSource)

SetInput implements PixelPiper interface