rbus

README

rbus-go

A go implementation of rbus client (and maybe the server too).

Table of Contents

• Code of Conduct
• Examples
• Contributing

Code of Conduct

This project and everyone participating in it are governed by the XMiDT Code Of Conduct. By participating, you agree to this Code.

Examples

To use the rbus-go library, it first should be added as an import in the file you plan to use it. Examples can be found at the top of the GoDoc.

Contributing

Refer to CONTRIBUTING.md.

Documentation

Overview

SPDX-FileCopyrightText: 2023 Comcast Cable Communications Management, LLC SPDX-License-Identifier: Apache-2.0

Index

• Constants
• Variables
• type Message
  • func Decode(buf []byte) (m *Message, err error)
  • func (m Message) Encode() ([]byte, error)

Constants

const (
	FLAGS_REQUEST = 1 << iota
	FLAGS_RESPONSE
	FLAGS_UNDELIVERABLE
	FLAGS_TAINTED
	FLAGS_RAW_BINARY
	FLAGS_ENCRYPTED
)

Variables

var (
	ErrInvalidMsg = errors.New("invalid message")
)

Types

type Message

type Message struct {
	SeqNum     uint32
	CtrlData   uint32
	Flags      uint32
	Topic      string
	ReplyTopic string
	Payload    []byte
	Times      [5]uint32
}

func Decode

func Decode(buf []byte) (m *Message, err error)

func (Message) Encode

func (m Message) Encode() ([]byte, error)