Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

omnibuf

package module

Go to main page

Versions in this module

v0

v0.0.4

Oct 25, 2026

v0.0.3

Oct 25, 2026

v0.0.2

Oct 25, 2026

Changes in this version

type SchemaMeta

+ func (meta *SchemaMeta) AppendField0(dst []byte, deterministic bool) []byte

v0.0.1

Oct 25, 2026

Changes in this version

+ const FieldLocCity

+ const FieldLocDatacenter

+ const FieldLocLatitude

+ const FieldLocLongitude

+ const FieldLocRack

+ const FieldLocRegion

+ const FieldNeighEstablished

+ const FieldNeighLatencyUS

+ const FieldNeighPeerASN

+ const FieldNeighRouter

+ const FieldPeerASN

+ const FieldPeerActive

+ const FieldPeerCPULoad

+ const FieldPeerLocation

+ const FieldPeerNeighbors

+ const FieldPeerPrefixes

+ const FieldPeerRouterID

+ const FieldPeerRssiDbm

+ const FieldPeerSequence

+ const FieldPeerTags

+ const FieldPeerUptimeSec

+ const MaxNestingDepth

+ const WireBoolFalse

+ const WireBoolTrue

+ const WireBytes

+ const WireExtended

+ const WireFixed32

+ const WireFixed64

+ const WireFixedArr

+ const WireMap

+ const WireSint

+ const WireSintArr

+ const WireString

+ const WireStringArr

+ const WireSubMsg

+ const WireSubMsgArr

+ const WireUint

+ const WireUintArr

+ func AppendField0SchemaMeta(dst []byte, meta *SchemaMeta) []byte

+ func AppendField0SchemaMetaDeterministic(dst []byte, meta *SchemaMeta, deterministic bool) []byte

+ func AppendStringArrZeroCopy(dst []string, packet []byte, fieldNum uint16) []string

+ func AppendUint32Arr(dst []uint32, packet []byte, fieldNum uint16) []uint32

+ func AppendVarint(dst []byte, v uint64) []byte

+ func BackpatchContainerLen(dst []byte, lenPos int) []byte

+ func CountSubMsgArrElems(arrPayload []byte) (int, bool)

+ func CountedArrLen(packet []byte, fieldNum uint16, expWT uint8) int

+ func DecodeBlind(packet []byte) (map[string]any, error)

+ func DecodePeerCapnpInto(data []byte, out *PeerUpdate, zeroCopy bool) error

+ func DecodePeerFlatBuffersInto(buf []byte, out *PeerUpdate, zeroCopy bool)

+ func DecodePeerOmniBufInto(packet []byte, out *PeerUpdate, zeroCopyStrings bool) error

+ func DecodePeerProtoWireInto(b []byte, out *PeerUpdate, zeroCopy bool) error

+ func DecodeStr(b []byte, zeroCopy bool) string

+ func DecodeVarint(b []byte) (uint64, int)

+ func DecodeZigZag(u uint64) int64

+ func EncodePeerCapnp(scratch []byte, p *PeerUpdate) ([]byte, error)

+ func EncodePeerFlatBuffers(b *flatbuffers.Builder, p *PeerUpdate) []byte

+ func EncodePeerOmniBuf(enc *Encoder, p *PeerUpdate, withField0 bool) []byte

+ func EncodePeerOmniBufDirect(dst []byte, p *PeerUpdate) []byte

+ func EncodePeerProtoWire(dst []byte, p *PeerUpdate) []byte

+ func EncodeSintArr[T intOrUint](dst []byte, items []T) []byte

+ func EncodeStringArr(dst []byte, items []string) []byte

+ func EncodeUintArr[T intOrUint](dst []byte, items []T) []byte

+ func EncodeZigZag(n int64) uint64

+ func LocateField(packet []byte, targetField uint16) (valSlice []byte, wireType uint8, ok bool)

+ func LookupCapnpInPlaceNeighborRouter(data []byte, idx int, zeroCopy bool) (string, bool)

+ func LookupCapnpInPlaceNestedCity(data []byte, zeroCopy bool) (string, bool)

+ func LookupCapnpNeighborRouter(data []byte, idx int, zeroCopy bool) (string, bool)

+ func LookupCapnpNestedCity(data []byte, zeroCopy bool) (string, bool)

+ func LookupFlatBuffersNeighborRouter(buf []byte, idx int, zeroCopy bool) (string, bool)

+ func LookupFlatBuffersNestedCity(buf []byte, zeroCopy bool) (string, bool)

+ func LookupMapStringUint(packet []byte, fieldNum uint16, targetKey string) (uint64, bool)

+ func LookupMsgpackNestedCity(b []byte) (string, bool)

+ func LookupProtoWireNeighborRouter(b []byte, targetIdx int, zeroCopy bool) (string, bool)

+ func LookupProtoWireNestedCity(b []byte, zeroCopy bool) (string, bool)

+ func MapHeaderByte(keyWT, valWT uint8) byte

+ func Marshal(v any) ([]byte, error)

+ func MarshalAppend(dst []byte, v any) ([]byte, error)

+ func MarshalDeterministic(v any) ([]byte, error)

+ func MarshalJSON(p *PeerUpdate) ([]byte, error)

+ func MarshalMsgpack(p *PeerUpdate) ([]byte, error)

+ func MarshalProtoReflect(m protoreflect.Message, includeField0 bool) ([]byte, error)

+ func MarshalProtoReflectAppend(dst []byte, m protoreflect.Message, includeField0 bool) ([]byte, error)

+ func PutOverlong2BVarint(dst []byte, v uint16)

+ func ReadArrNestedString(packet []byte, arrField uint16, index int, targetField uint16) (string, bool)

+ func ReadArrNestedStringZeroCopy(packet []byte, arrField uint16, index int, targetField uint16) (string, bool)

+ func ReadBool(packet []byte, fieldNum uint16) (bool, bool)

+ func ReadBytes(packet []byte, fieldNum uint16) ([]byte, bool)

+ func ReadElem(arrPayload []byte, index int) ([]byte, bool)

+ func ReadFloat32(packet []byte, fieldNum uint16) (float32, bool)

+ func ReadFloat32Arr(packet []byte, fieldNum uint16) ([]float32, bool)

+ func ReadFloat64(packet []byte, fieldNum uint16) (float64, bool)

+ func ReadFloat64Arr(packet []byte, fieldNum uint16) ([]float64, bool)

+ func ReadInt(packet []byte, fieldNum uint16) (int64, bool)

+ func ReadNestedString(packet []byte, subMsgField, targetField uint16) (string, bool)

+ func ReadNestedStringBytes(packet []byte, subMsgField, targetField uint16) ([]byte, bool)

+ func ReadNestedStringZeroCopy(packet []byte, subMsgField, targetField uint16) (string, bool)

+ func ReadSintArr(packet []byte, fieldNum uint16) ([]int64, bool)

+ func ReadString(packet []byte, fieldNum uint16) (string, bool)

+ func ReadStringArr(packet []byte, fieldNum uint16) ([]string, bool)

+ func ReadStringBytes(packet []byte, fieldNum uint16) ([]byte, bool)

+ func ReadStringZeroCopy(packet []byte, fieldNum uint16) (string, bool)

+ func ReadSubMsg(packet []byte, fieldNum uint16) ([]byte, bool)

+ func ReadSubMsgArrElem(packet []byte, fieldNum uint16, index int) ([]byte, bool)

+ func ReadUint(packet []byte, fieldNum uint16) (uint64, bool)

+ func ReadUint32Arr(packet []byte, fieldNum uint16) ([]uint32, bool)

+ func ReadVarintAt(b []byte, pos int) (uint64, int)

+ func SizeLocationProto(loc *Location) int

+ func SizeNeighborProto(nb *Neighbor) int

+ func SkipValue(b []byte, pos int, wireType uint8) (int, error)

+ func SpliceFields(dst, raw []byte, dirtyMask uint16, maxField uint16, ...) []byte

+ func SubMsgArrLen(packet []byte, fieldNum uint16) int

+ func Unmarshal(packet []byte, v any) error

+ func UnmarshalJSON(b []byte, out *PeerUpdate) error

+ func UnmarshalMsgpack(b []byte, out *PeerUpdate) error

+ func UnmarshalProtoReflect(data []byte, m protoreflect.Message) error

+ func UnmarshalZeroCopy(packet []byte, v any) error

+ type Encoder struct

+ func NewEncoder(capacity int) *Encoder

+ func (e *Encoder) BeginSubMsg(fieldNum uint16)

+ func (e *Encoder) BeginSubMsgArr(fieldNum uint16)

+ func (e *Encoder) BeginSubMsgElem()

+ func (e *Encoder) Bytes() []byte

+ func (e *Encoder) EndSubMsg()

+ func (e *Encoder) EndSubMsgArr()

+ func (e *Encoder) EndSubMsgElem()

+ func (e *Encoder) Finish() []byte

+ func (e *Encoder) Reset()

+ func (e *Encoder) WriteBool(fieldNum uint16, v bool)

+ func (e *Encoder) WriteBytes(fieldNum uint16, b []byte)

+ func (e *Encoder) WriteField0Fields(fields map[uint32]string)

+ func (e *Encoder) WriteField0Schema(names []string)

+ func (e *Encoder) WriteField0SchemaMeta(meta *SchemaMeta)

+ func (e *Encoder) WriteFixed32(fieldNum uint16, v uint32)

+ func (e *Encoder) WriteFixed64(fieldNum uint16, v uint64)

+ func (e *Encoder) WriteFloat32(fieldNum uint16, v float32)

+ func (e *Encoder) WriteFloat32Arr(fieldNum uint16, items []float32)

+ func (e *Encoder) WriteFloat64(fieldNum uint16, v float64)

+ func (e *Encoder) WriteFloat64Arr(fieldNum uint16, items []float64)

+ func (e *Encoder) WriteInt(fieldNum uint16, v int64)

+ func (e *Encoder) WriteMapStringUint(fieldNum uint16, m map[string]uint64)

+ func (e *Encoder) WriteMapStringUintDeterministic(fieldNum uint16, m map[string]uint64)

+ func (e *Encoder) WriteRaw(raw []byte)

+ func (e *Encoder) WriteSintArr(fieldNum uint16, items []int64)

+ func (e *Encoder) WriteString(fieldNum uint16, s string)

+ func (e *Encoder) WriteStringArr(fieldNum uint16, items []string)

+ func (e *Encoder) WriteUint(fieldNum uint16, v uint64)

+ func (e *Encoder) WriteUint32Arr(fieldNum uint16, items []uint32)

+ type Location struct

+ City string

+ Datacenter string

+ Latitude float32

+ Longitude float32

+ Rack uint32

+ Region string

+ type MarshalOptions struct

+ Deterministic bool

+ SelfDescribing bool

+ func (o MarshalOptions) Marshal(v any) ([]byte, error)

+ func (o MarshalOptions) MarshalAppend(dst []byte, v any) ([]byte, error)

+ type Neighbor struct

+ Established bool

+ LatencyUS uint32

+ PeerASN uint32

+ Router string

+ type PeerUpdate struct

+ ASN uint32

+ Active bool

+ CPULoad float64

+ Location Location

+ Neighbors []Neighbor

+ Prefixes []uint32

+ RouterID string

+ RssiDbm int32

+ Sequence uint64

+ Tags []string

+ UptimeSec uint64

+ func SamplePeerUpdate() PeerUpdate

+ type SchemaMeta struct

+ Children map[uint32]*SchemaMeta

+ Fields map[uint32]string

+ TypeName string

+ func ReadField0SchemaMeta(packet []byte) (*SchemaMeta, bool)