node

Documentation

Index

• func NodeCheck(p unsafe.Pointer) int
• func NodeClose(p unsafe.Pointer) int
• func NodeDetails(p unsafe.Pointer) *C.char
• func NodeGetNetemFDs(p unsafe.Pointer) (unsafe.Pointer, int)
• func NodeGetPollFDs(p unsafe.Pointer) (unsafe.Pointer, int)
• func NodeParse(p unsafe.Pointer, c unsafe.Pointer) int
• func NodePause(p unsafe.Pointer) int
• func NodePrepare(p unsafe.Pointer) int
• func NodeRead(p unsafe.Pointer, smps []Sample) (int, error)
• func NodeRestart(p unsafe.Pointer) int
• func NodeResume(p unsafe.Pointer) int
• func NodeReverse(p unsafe.Pointer) int
• func NodeStart(p unsafe.Pointer) int
• func NodeStop(p unsafe.Pointer) error
• func NodeWrite(p unsafe.Pointer, smps []Sample) (int, int)
• type CreateNode
• type ExampleNode
  • func (n *ExampleNode) Check() error
  • func (n *ExampleNode) Close() error
  • func (n *ExampleNode) Details() string
  • func (n *ExampleNode) GetNetemFDs() ([]int, error)
  • func (n *ExampleNode) GetPollFDs() ([]int, error)
  • func (n *ExampleNode) Parse(cfg []byte) error
  • func (n *ExampleNode) Pause() error
  • func (n *ExampleNode) Prepare() error
  • func (n *ExampleNode) Read(smps []Sample) (int, error)
  • func (n *ExampleNode) Restart() error
  • func (n *ExampleNode) Resume() error
  • func (n *ExampleNode) Reverse() error
  • func (n *ExampleNode) Start() error
  • func (n *ExampleNode) Stop() error
  • func (n *ExampleNode) Write(smps []Sample) (int, error)
• type Node
  • func NewExampleNode() Node
• type Sample
• type Signal

Functions

func NodeCheck

func NodeCheck(p unsafe.Pointer) int

func NodeClose

func NodeClose(p unsafe.Pointer) int

func NodeDetails

func NodeDetails(p unsafe.Pointer) *C.char

func NodeGetNetemFDs

func NodeGetNetemFDs(p unsafe.Pointer) (unsafe.Pointer, int)

func NodeGetPollFDs

func NodeGetPollFDs(p unsafe.Pointer) (unsafe.Pointer, int)

func NodeParse

func NodeParse(p unsafe.Pointer, c unsafe.Pointer) int

func NodePause

func NodePause(p unsafe.Pointer) int

func NodePrepare

func NodePrepare(p unsafe.Pointer) int

func NodeRead

func NodeRead(p unsafe.Pointer, smps []Sample) (int, error)

func NodeRestart

func NodeRestart(p unsafe.Pointer) int

func NodeResume

func NodeResume(p unsafe.Pointer) int

func NodeReverse

func NodeReverse(p unsafe.Pointer) int

func NodeStart

func NodeStart(p unsafe.Pointer) int

func NodeStop

func NodeStop(p unsafe.Pointer) error

func NodeWrite

func NodeWrite(p unsafe.Pointer, smps []Sample) (int, int)

Types

type CreateNode

type CreateNode func() Node

type ExampleNode

type ExampleNode struct {
	Node
}

func (*ExampleNode) Check

func (n *ExampleNode) Check() error

func (*ExampleNode) Close

func (n *ExampleNode) Close() error

func (*ExampleNode) Details

func (n *ExampleNode) Details() string

func (*ExampleNode) GetNetemFDs

func (n *ExampleNode) GetNetemFDs() ([]int, error)

func (*ExampleNode) GetPollFDs

func (n *ExampleNode) GetPollFDs() ([]int, error)

func (*ExampleNode) Parse

func (n *ExampleNode) Parse(cfg []byte) error

func (*ExampleNode) Pause

func (n *ExampleNode) Pause() error

func (*ExampleNode) Prepare

func (n *ExampleNode) Prepare() error

func (*ExampleNode) Read

func (n *ExampleNode) Read(smps []Sample) (int, error)

func (*ExampleNode) Restart

func (n *ExampleNode) Restart() error

func (*ExampleNode) Resume

func (n *ExampleNode) Resume() error

func (*ExampleNode) Reverse

func (n *ExampleNode) Reverse() error

func (*ExampleNode) Start

func (n *ExampleNode) Start() error

func (*ExampleNode) Stop

func (n *ExampleNode) Stop() error

func (*ExampleNode) Write

func (n *ExampleNode) Write(smps []Sample) (int, error)

type Node

type Node interface {
	Close() error

	Prepare() error

	Parse(cfg []byte) error

	Check() error

	Start() error
	Stop() error

	Pause() error
	Resume() error
	Restart() error

	Read(smps []Sample) (int, error)
	Write(smps []Sample) (int, error)

	Reverse() error

	GetPollFDs() ([]int, error)
	GetNetemFDs() ([]int, error)

	Details() string
}

func NewExampleNode

func NewExampleNode() Node

type Sample

type Sample struct {
	Timestamp struct {
		Origin   time.Time
		Received time.Time
	}

	Data []interface{}
}

type Signal

type Signal struct {
}