Versions in this module Expand all Collapse all v0 v0.1.1 Jul 7, 2020 v0.1.0 Jul 6, 2020 Changes in this version + const BestEffortReliability + const InitAll + const InitDefault + const InitLogging + const InitMonitoring + const InitProcessReg + const InitPublisher + const InitRPC + const InitService + const InitSubscriber + const InitTimeSync + const KeepAllHistoryQOS + const KeepLastHistoryQOS + const ReliableReliability + const SModeAuto + const SModeNone + const SModeOff + const SModeOn + const TLayerAll + const TLayerInProc + const TLayerNone + const TLayerSHM + const TlayerUDPMc + func Finalize(components uint) error + func Initialize(args []string, unitName string, components uint) error + func Ok() bool + func ProcessSleepMS(sleepTimeMs int64) + type Message struct + Content []byte + Timestamp int64 + type PublisherIf interface + Destroy func() error + Dump func() ([]byte, error) + GetDescription func() string + GetEventChannel func() <-chan bool + GetHandle func() uintptr + GetID func() int64 + GetInputChannel func() chan<- Message + GetLayerMode func() (int, int) + GetMaxBandwidthUDP func() int64 + GetQoS func() (WriterQOS, error) + GetTopic func() string + GetType func() string + IsDestroyed func() bool + IsStopped func() bool + IsSubscribed func() bool + SetDescription func(topicDesc string) error + SetID func(id int64) error + SetLayerMode func(layerMode int, sendMode int) error + SetMaxBandwidthUDP func(bandwidth int64) error + SetQoS func(qos WriterQOS) error + ShareDescription func(state int) error + ShareType func(state int) error + Start func() error + Stop func() error + func PublisherCreate(topicName string, topicType string, topicDesc string, start bool) (PublisherIf, chan<- Message, error) + type ReaderQOS struct + HistoryKind int + Reliability int + type SubscriberIf interface + Destroy func() error + Dump func() ([]byte, error) + GetBufferSize func() int + GetDescription func() string + GetEventChannel func() <-chan bool + GetHandle func() uintptr + GetIDs func() []int64 + GetOutputChannel func() <-chan Message + GetQoS func() (ReaderQOS, error) + GetTimeout func() int + GetTopic func() string + GetType func() string + IsDestroyed func() bool + IsStopped func() bool + SetIDs func(id []int64) error + SetQoS func(qos ReaderQOS) error + SetTimeout func(timeout int) error + Start func() error + Stop func() error + func SubscriberCreate(topicName string, topicType string, topicDesc string, start bool, ...) (SubscriberIf, <-chan Message, error) + type WriterQOS struct + HistoryKind int + Reliability int