subscriber

Documentation

Overview

Implementation for cgo preamble functions

Index

• Variables
• type DataType
• type Subscriber
  • func New(topic string, datatype DataType) (*Subscriber, error)
  • func (p *Subscriber) Delete()
  • func (p *Subscriber) Receive(timeout time.Duration) ([]byte, error)

Variables

var (
	ErrFailedNew  = errors.New("failed to create new subscriber")
	ErrRcvTimeout = errors.New("timed out")
	ErrRcvBadType = errors.New("receive could not handle type")
)

Types

type DataType

type DataType = ecal.DataType

type Subscriber

type Subscriber struct {
	Messages chan any

	Deserialize func(unsafe.Pointer, int) any
	// contains filtered or unexported fields
}

func New

func New(topic string, datatype DataType) (*Subscriber, error)

func (*Subscriber) Delete

func (p *Subscriber) Delete()

func (*Subscriber) Receive

func (p *Subscriber) Receive(timeout time.Duration) ([]byte, error)

Receive a new message from the eCAL receive callback.