processor

Documentation

Index

• type BBWorker
• type CCWorker
• type CFWorker
• type DSPWorker
  • func NewDSPWorkerCC(name, displayName string, inputRate, outputRate int, worker CCWorker, ...) *DSPWorker
  • func NewDSPWorkerCF(name, displayName string, inputRate, outputRate int, worker CFWorker, ...) *DSPWorker
  • func NewDSPWorkerFB(name, displayName string, inputRate, outputRate int, worker FBWorker, ...) *DSPWorker
  • func NewDSPWorkerFF(name, displayName string, inputRate, outputRate int, worker FFWorker, ...) *DSPWorker
• type DSPWorkerOption
  • func ShowFFTBalance() DSPWorkerOption
  • func WithFloatFFTPlot() DSPWorkerOption
  • func WithPlotOptions(opts []viz.PlotOptions) DSPWorkerOption
  • func WithPlotType(plotType viz.PlotType) DSPWorkerOption
  • func WithVizLength(length int) DSPWorkerOption
• type DataType
• type FBWorker
• type FFWorker
• type Processor
  • func NewProcessor(name, inputName string, vizServer *viz.Server) *Processor
  • func (p *Processor) AddBlock(worker *DSPWorker)
  • func (p *Processor) Initialize() error
  • func (p *Processor) ProcessComplexToBinary(input *types.SegmentComplex64, metrics map[string]interface{}) (*types.SegmentBinaryBytes, error)
  • func (p *Processor) ProcessComplexToFloat(input *types.SegmentComplex64, metrics map[string]interface{}) (*types.SegmentFloat32, error)

Types

type BBWorker

type BBWorker interface {
	WorkBuffer([]byte, []byte) int
	PredictOutputSize(int) int
}

type CCWorker

type CCWorker interface {
	WorkBuffer([]complex64, []complex64) int
	PredictOutputSize(int) int
}

Complex in, complex out

type CFWorker

type CFWorker interface {
	WorkBuffer([]complex64, []float32) int
	PredictOutputSize(int) int
}

Complex in, float out

type DSPWorker

type DSPWorker struct {
	Name        string
	DisplayName string
	InputRate   int
	OutputRate  int
	// contains filtered or unexported fields
}

func NewDSPWorkerCC

func NewDSPWorkerCC(name, displayName string, inputRate, outputRate int, worker CCWorker, opts ...DSPWorkerOption) *DSPWorker

func NewDSPWorkerCF

func NewDSPWorkerCF(name, displayName string, inputRate, outputRate int, worker CFWorker, opts ...DSPWorkerOption) *DSPWorker

func NewDSPWorkerFB

func NewDSPWorkerFB(name, displayName string, inputRate, outputRate int, worker FBWorker, opts ...DSPWorkerOption) *DSPWorker

func NewDSPWorkerFF

func NewDSPWorkerFF(name, displayName string, inputRate, outputRate int, worker FFWorker, opts ...DSPWorkerOption) *DSPWorker

type DSPWorkerOption

type DSPWorkerOption func(r *DSPWorker)

func ShowFFTBalance

func ShowFFTBalance() DSPWorkerOption

func WithFloatFFTPlot

func WithFloatFFTPlot() DSPWorkerOption

func WithPlotOptions

func WithPlotOptions(opts []viz.PlotOptions) DSPWorkerOption

func WithPlotType

func WithPlotType(plotType viz.PlotType) DSPWorkerOption

func WithVizLength

func WithVizLength(length int) DSPWorkerOption

type DataType

type DataType int

const (
	DataTypeComplex DataType = iota
	DataTypeFloat
	DataTypeBytes
	DataTypeInt16
)

type FBWorker

type FBWorker interface {
	WorkBuffer([]float32, []byte) int
	PredictOutputSize(int) int
}

Float in, binary bytes out (1 symbol per byte)

type FFWorker

type FFWorker interface {
	WorkBuffer([]float32, []float32) int
	PredictOutputSize(int) int
}

type Processor

type Processor struct {
	Name      string
	InputName string
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(name, inputName string, vizServer *viz.Server) *Processor

func (*Processor) AddBlock

func (p *Processor) AddBlock(worker *DSPWorker)

func (*Processor) Initialize

func (p *Processor) Initialize() error

func (*Processor) ProcessComplexToBinary

func (p *Processor) ProcessComplexToBinary(input *types.SegmentComplex64, metrics map[string]interface{}) (*types.SegmentBinaryBytes, error)

func (*Processor) ProcessComplexToFloat

func (p *Processor) ProcessComplexToFloat(input *types.SegmentComplex64, metrics map[string]interface{}) (*types.SegmentFloat32, error)