Versions in this module Expand all Collapse all v0 v0.3.1 May 29, 2020 v0.3.0 Nov 20, 2019 Changes in this version + const ZInfoPeerKey + const ZInfoPeerPidKey + const ZInfoPidKey + const ZPasswdKey + const ZUserKey + func RNameIntersect(rname1 string, rname2 string) bool + func VleDecode(buf []byte) (int, []byte) + func VleEncode(value int) []byte + type DataHandler func(rid string, data []byte, info *DataInfo) + type DataInfo = C.z_data_info_t + func (info *DataInfo) Encoding() uint8 + func (info *DataInfo) Flags() uint + func (info *DataInfo) Kind() uint8 + func (info *DataInfo) Tstamp() Timestamp + type Eval struct + type Publisher = C.z_pub_t + func (p *Publisher) StreamCompactData(payload []byte) error + func (p *Publisher) StreamData(payload []byte) error + func (p *Publisher) StreamDataWO(payload []byte, encoding uint8, kind uint8) error + type QueryDest = C.z_query_dest_t + func NewQueryDest(kind QueryDestKind) QueryDest + func NewQueryDestWithNb(kind QueryDestKind, nb C.uint8_t) QueryDest + type QueryDestKind = C.uint8_t + const ZAll + const ZBestMatch + const ZComplete + const ZNone + type QueryHandler func(rname string, predicate string, sendReplies *RepliesSender) + type RepliesSender struct + func (rs *RepliesSender) SendReplies(replies []Resource) + type ReplyHandler func(reply *ReplyValue) + type ReplyKind = C.char + const ZEvalData + const ZEvalFinal + const ZReplyFinal + const ZStorageData + const ZStorageFinal + type ReplyValue = C.z_reply_value_t + func (r *ReplyValue) Data() []byte + func (r *ReplyValue) Info() DataInfo + func (r *ReplyValue) Kind() ReplyKind + func (r *ReplyValue) RName() string + func (r *ReplyValue) RSN() uint64 + func (r *ReplyValue) SrcID() []byte + type Resource struct + Data []byte + Encoding uint8 + Kind uint8 + RName string + type Storage struct + type SubMode = C.z_sub_mode_t + func NewSubMode(kind SubModeKind) SubMode + func NewSubModeWithTime(kind SubModeKind, origin C.ulong, period C.ulong, duration C.ulong) SubMode + type SubModeKind = C.uint8_t + const ZPeriodicPullMode + const ZPeriodicPushMode + const ZPullMode + const ZPushMode + type Subscriber struct + func (s *Subscriber) Pull() error + type Timestamp = C.z_timestamp_t + func (ts *Timestamp) Before(ots *Timestamp) bool + func (ts *Timestamp) ClockID() [16]byte + func (ts *Timestamp) GoTime() time.Time + func (ts *Timestamp) String() string + func (ts *Timestamp) Time() uint64 + type ZError struct + func (e *ZError) Error() string + type Zenoh = C.z_zenoh_t + func ZOpen(locator *string, properties map[int][]byte) (*Zenoh, error) + func (z *Zenoh) Close() error + func (z *Zenoh) DeclareEval(resource string, handler QueryHandler) (*Eval, error) + func (z *Zenoh) DeclarePublisher(resource string) (*Publisher, error) + func (z *Zenoh) DeclareStorage(resource string, dataHandler DataHandler, queryHandler QueryHandler) (*Storage, error) + func (z *Zenoh) DeclareSubscriber(resource string, mode SubMode, dataHandler DataHandler) (*Subscriber, error) + func (z *Zenoh) Info() map[int][]byte + func (z *Zenoh) Query(resource string, predicate string, replyHandler ReplyHandler) error + func (z *Zenoh) QueryWO(resource string, predicate string, replyHandler ReplyHandler, ...) error + func (z *Zenoh) UndeclareEval(e *Eval) error + func (z *Zenoh) UndeclarePublisher(p *Publisher) error + func (z *Zenoh) UndeclareStorage(s *Storage) error + func (z *Zenoh) UndeclareSubscriber(s *Subscriber) error + func (z *Zenoh) WriteData(resource string, payload []byte) error + func (z *Zenoh) WriteDataWO(resource string, payload []byte, encoding uint8, kind uint8) error