process

Documentation

Index

• func Close()
• func DelPipeline(id string)
• func InitPipeline(c Config)
• func InitRTP(port int, kcpKey, kcpSalt string) error
• type Config
• type Pipeline
  • func GetPipeline(id string) *Pipeline
  • func NewPipeline(id string, pub transport.Transport) *Pipeline
  • func (p *Pipeline) AddElement(einfo proto.ElementInfo)
  • func (p *Pipeline) Alive() bool
  • func (p *Pipeline) Close()
  • func (p *Pipeline) DelElement(id string)
  • func (p *Pipeline) GetElement(id string) elements.Element

Functions

func Close

func Close()

Close close all pipelines

func DelPipeline

func DelPipeline(id string)

DelPipeline delete pub

func InitPipeline

func InitPipeline(c Config)

InitPipeline .

func InitRTP

func InitRTP(port int, kcpKey, kcpSalt string) error

InitRTP rtp port

Types

type Config

type Config struct {
	SampleBuilder       samples.BuilderConfig
	GetDefaultElements  getDefaultElementsFn
	GetTogglableElement getTogglableElementFn
}

Config for pipeline

type Pipeline

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

Pipeline constructs a processing graph

+--->element
|

pub--->pubCh-->sampleBuilder-->elementCh---+--->element

|
+--->element

func GetPipeline

func GetPipeline(id string) *Pipeline

GetPipeline get pipeline from map

func NewPipeline

func NewPipeline(id string, pub transport.Transport) *Pipeline

NewPipeline return a new Pipeline

func (*Pipeline) AddElement

func (p *Pipeline) AddElement(einfo proto.ElementInfo)

AddElement add a element to pipeline

func (*Pipeline) Alive

func (p *Pipeline) Alive() bool

Alive return router status

func (*Pipeline) Close

func (p *Pipeline) Close()

Close release all

func (*Pipeline) DelElement

func (p *Pipeline) DelElement(id string)

DelElement del node by id

func (*Pipeline) GetElement

func (p *Pipeline) GetElement(id string) elements.Element

GetElement get a node by id