zap

package module

Go to main page

Versions in this module

v0

v0.8.1

Jun 6, 2026

v0.8.0

Jun 6, 2026

Changes in this version

+ func ParseHeader(data []byte) ([]byte, int, error)

type Message

+ func WrapBuffer(data []byte) *Message

+ func (m *Message) Release()

+ func (m *Message) Retain()

+ func (m *Message) RootObjectAt(off int) Object

type Object

+ func (o Object) BytesFixedSlice(fieldOffset, n int) []byte

+ func (o Object) Message() *Message

+ func (o Object) Offset() int

type ObjectBuilder

+ func (ob *ObjectBuilder) ReserveFixed(dataSize int)

+ func (ob *ObjectBuilder) SetBytesFixed(fieldOffset int, v []byte)

+ type TransportStream interface

+ Close func() error

+ ReadFrame func() ([]byte, error)

+ WriteFrame func(frame []byte) error

+ type TransportStreamer interface

+ AcceptCallStream func(ctx context.Context) (TransportStream, error)

+ OpenCallStream func(ctx context.Context) (TransportStream, error)

v0.7.2

Jun 2, 2026

Changes in this version

type Object

+ func (o Object) ListStride(fieldOffset int, minStride uint32) List

v0.7.1

Jun 2, 2026

Changes in this version

+ const Version1

+ const Version2

type Builder

+ func NewBuilderV1(capacity int) *Builder

type Message

+ func (m *Message) Version() uint16

v0.7.0

Jun 2, 2026

v0.6.1

Jun 2, 2026

Changes in this version

+ const MaxPQRecord

+ var ErrNotPQConn = errors.New("zap: not a ZAP-PQ connection")

+ var ErrRegistrationMalformed = errors.New("zap-pq: VMRegistration malformed")

+ var ErrTransportUnavailable = errors.New("zap: transport unavailable (did you import _ \"github.com/luxfi/zap/quic\"?)")

+ func AsPQConn(c net.Conn) (*pqConn, error)

+ func DecodeNodeIDHandshake(data []byte) (string, bool)

+ func EncodeNodeIDHandshake(nodeID string) []byte

+ func RegisterTransport(t Transport, f TransportFactory)

+ func UnwrapCorrelated(data []byte) (reqID uint32, flag uint32, body []byte, ok bool)

+ func VerifyRegistration(reg *VMRegistration, chainAuthority *mldsa.PublicKey, mode RegistrationMode) (*mldsa.PublicKey, error)

+ func WrapCorrelated(reqID uint32, flag uint32, body []byte) []byte

+ func WrapPQ(conn net.Conn, sess *handshake.Session) net.Conn

type NodeConfig

+ QUICConfig any

+ Transport Transport

+ type RegistrationMode int

+ const ModeInitial

+ const ModeRotation

+ type StaticVMRegistry struct

+ func NewStaticVMRegistry() *StaticVMRegistry

+ func (r *StaticVMRegistry) Add(reg *VMRegistration)

+ func (r *StaticVMRegistry) Lookup(vmID [32]byte) (*VMRegistration, bool)

+ type Transport int

+ const TransportQUIC

+ const TransportTCP

+ type TransportConn interface

+ Close func() error

+ Recv func() ([]byte, error)

+ RemoteAddr func() string

+ Send func(frame []byte) error

+ type TransportFactory interface

+ Dial func(ctx context.Context, cfg NodeConfig, addr string) (peerID string, conn TransportConn, err error)

+ Listen func(ctx context.Context, cfg NodeConfig, ...) (string, func() error, error)

+ type VMRegistration struct

+ AuthoritySig []byte

+ PrevVMPubKey []byte

+ PrevVMSig []byte

+ VMID [32]byte

+ VMPubKey []byte

+ type VMRegistry interface

+ Lookup func(vmID [32]byte) (*VMRegistration, bool)

v0.6.0

May 16, 2026

v0.5.0

May 13, 2026

v0.4.1

May 13, 2026

v0.3.1

May 13, 2026

Changes in this version

+ func TLSCertFingerprintFromBytes(certDER []byte) [32]byte

+ func TranscriptHash(ctx *AttestationContext) [48]byte

+ type Attestation struct

+ PubKey []byte

+ Sig []byte

+ func (a *Attestation) HasPQEvidence() bool

+ type AttestationContext struct

+ ChainID [32]byte

+ Nonce [32]byte

+ PeerMLKEMPub []byte

+ TLSCertFingerprint [32]byte

+ Timestamp uint64

v0.3.0

Apr 26, 2026

Changes in this version

+ const DefaultPort

type NodeConfig

+ TLS *tls.Config

v0.2.1

Apr 10, 2026

v0.2.0

Feb 16, 2026

v0.1.0

Feb 10, 2026

Changes in this version

+ const AddressSize

+ const Alignment

+ const BloomSize

+ const FieldReqFlag

+ const FieldReqID

+ const FlagCompressed

+ const FlagEncrypted

+ const FlagNone

+ const FlagSigned

+ const HashSize

+ const HeaderSize

+ const Magic

+ const ReqFlagReq

+ const ReqFlagResp

+ const SignatureSize

+ const Version

+ var BlockHeaderSchema = ...()

+ var ErrBufferTooSmall = errors.New("zap: buffer too small")

+ var ErrInvalidMagic = errors.New("zap: invalid magic bytes")

+ var ErrInvalidOffset = errors.New("zap: invalid offset")

+ var ErrInvalidVersion = errors.New("zap: unsupported version")

+ var ErrOutOfBounds = errors.New("zap: offset out of bounds")

+ var LogSchema = ...()

+ var TransactionSchema = ...()

+ func TypeSize(t Type) int

+ type Address [AddressSize]byte

+ var ZeroAddress Address

+ func AddressFromHex(s string) (Address, error)

+ func (a Address) Hex() string

+ func (a Address) IsZero() bool

+ func (a Address) String() string

+ type Bloom [BloomSize]byte

+ type Builder struct

+ func NewBuilder(capacity int) *Builder

+ func (b *Builder) Finish() []byte

+ func (b *Builder) FinishWithFlags(flags uint16) []byte

+ func (b *Builder) Reset()

+ func (b *Builder) StartList(elemSize int) *ListBuilder

+ func (b *Builder) StartObject(dataSize int) *ObjectBuilder

+ func (b *Builder) WriteBytes(data []byte) int

+ func (b *Builder) WriteText(s string) int

+ type Conn struct

+ Addr string

+ NodeID string

+ func (c *Conn) Recv() (*Message, error)

+ func (c *Conn) Send(msg *Message) error

+ type Enum struct

+ Name string

+ Type Type

+ Values map[string]uint64

+ type Field struct

+ Default any

+ ListElem Type

+ Name string

+ Offset int

+ StructName string

+ Type Type

+ type Handler func(ctx context.Context, from string, msg *Message) (*Message, error)

+ type Hash [HashSize]byte

+ var ZeroHash Hash

+ func HashFromHex(s string) (Hash, error)

+ func (h Hash) Bytes32() [32]byte

+ func (h Hash) Hex() string

+ func (h Hash) IsZero() bool

+ func (h Hash) String() string

+ type List struct

+ func (l List) Address(i int) Address

+ func (l List) Bytes() []byte

+ func (l List) Hash(i int) Hash

+ func (l List) IsNull() bool

+ func (l List) Len() int

+ func (l List) Object(i int, elemSize int) Object

+ func (l List) Uint32(i int) uint32

+ func (l List) Uint64(i int) uint64

+ func (l List) Uint8(i int) uint8

+ type ListBuilder struct

+ func (lb *ListBuilder) AddBytes(data []byte)

+ func (lb *ListBuilder) AddUint32(v uint32)

+ func (lb *ListBuilder) AddUint64(v uint64)

+ func (lb *ListBuilder) AddUint8(v uint8)

+ func (lb *ListBuilder) Finish() (offset int, length int)

+ type Message struct

+ func Parse(data []byte) (*Message, error)

+ func (m *Message) Bytes() []byte

+ func (m *Message) Flags() uint16

+ func (m *Message) Root() Object

+ func (m *Message) Size() int

+ type Node struct

+ func NewNode(cfg NodeConfig) *Node

+ func (n *Node) Broadcast(ctx context.Context, msg *Message) map[string]error

+ func (n *Node) Call(ctx context.Context, peerID string, msg *Message) (*Message, error)

+ func (n *Node) ConnectDirect(addr string) error

+ func (n *Node) Handle(msgType uint16, handler Handler)

+ func (n *Node) NodeID() string

+ func (n *Node) Peers() []string

+ func (n *Node) Send(ctx context.Context, peerID string, msg *Message) error

+ func (n *Node) Start() error

+ func (n *Node) Stop()

+ type NodeConfig struct

+ Logger *slog.Logger

+ Metadata map[string]string

+ NoDiscovery bool

+ NodeID string

+ Port int

+ ServiceType string

+ type Object struct

+ func (o Object) Address(fieldOffset int) Address

+ func (o Object) AddressSlice(fieldOffset int) []byte

+ func (o Object) Bool(fieldOffset int) bool

+ func (o Object) Bytes(fieldOffset int) []byte

+ func (o Object) Float32(fieldOffset int) float32

+ func (o Object) Float64(fieldOffset int) float64

+ func (o Object) Hash(fieldOffset int) Hash

+ func (o Object) HashSlice(fieldOffset int) []byte

+ func (o Object) Int16(fieldOffset int) int16

+ func (o Object) Int32(fieldOffset int) int32

+ func (o Object) Int64(fieldOffset int) int64

+ func (o Object) Int8(fieldOffset int) int8

+ func (o Object) IsNull() bool

+ func (o Object) List(fieldOffset int) List

+ func (o Object) Object(fieldOffset int) Object

+ func (o Object) Signature(fieldOffset int) Signature

+ func (o Object) Text(fieldOffset int) string

+ func (o Object) Uint16(fieldOffset int) uint16

+ func (o Object) Uint32(fieldOffset int) uint32

+ func (o Object) Uint64(fieldOffset int) uint64

+ func (o Object) Uint8(fieldOffset int) uint8

+ type ObjectBuilder struct

+ func (ob *ObjectBuilder) Finish() int

+ func (ob *ObjectBuilder) FinishAsRoot() int

+ func (ob *ObjectBuilder) SetAddress(fieldOffset int, addr Address)

+ func (ob *ObjectBuilder) SetBool(fieldOffset int, v bool)

+ func (ob *ObjectBuilder) SetBytes(fieldOffset int, v []byte)

+ func (ob *ObjectBuilder) SetFloat32(fieldOffset int, v float32)

+ func (ob *ObjectBuilder) SetFloat64(fieldOffset int, v float64)

+ func (ob *ObjectBuilder) SetHash(fieldOffset int, h Hash)

+ func (ob *ObjectBuilder) SetInt16(fieldOffset int, v int16)

+ func (ob *ObjectBuilder) SetInt32(fieldOffset int, v int32)

+ func (ob *ObjectBuilder) SetInt64(fieldOffset int, v int64)

+ func (ob *ObjectBuilder) SetInt8(fieldOffset int, v int8)

+ func (ob *ObjectBuilder) SetList(fieldOffset int, listOffset int, length int)

+ func (ob *ObjectBuilder) SetObject(fieldOffset int, objOffset int)

+ func (ob *ObjectBuilder) SetSignature(fieldOffset int, sig Signature)

+ func (ob *ObjectBuilder) SetText(fieldOffset int, v string)

+ func (ob *ObjectBuilder) SetUint16(fieldOffset int, v uint16)

+ func (ob *ObjectBuilder) SetUint32(fieldOffset int, v uint32)

+ func (ob *ObjectBuilder) SetUint64(fieldOffset int, v uint64)

+ func (ob *ObjectBuilder) SetUint8(fieldOffset int, v uint8)

+ type Schema struct

+ Enums map[string]*Enum

+ Name string

+ Structs map[string]*Struct

+ func NewSchema(name string) *Schema

+ func (s *Schema) AddEnum(e *Enum)

+ func (s *Schema) AddStruct(st *Struct)

+ type Signature [SignatureSize]byte

+ type Struct struct

+ Fields []Field

+ Name string

+ Size int

+ type StructBuilder struct

+ func NewStructBuilder(name string) *StructBuilder

+ func (sb *StructBuilder) Address(name string) *StructBuilder

+ func (sb *StructBuilder) Bool(name string) *StructBuilder

+ func (sb *StructBuilder) Build() *Struct

+ func (sb *StructBuilder) Bytes(name string) *StructBuilder

+ func (sb *StructBuilder) Float64(name string) *StructBuilder

+ func (sb *StructBuilder) Hash(name string) *StructBuilder

+ func (sb *StructBuilder) Int32(name string) *StructBuilder

+ func (sb *StructBuilder) Int64(name string) *StructBuilder

+ func (sb *StructBuilder) List(name string, elemType Type) *StructBuilder

+ func (sb *StructBuilder) Signature(name string) *StructBuilder

+ func (sb *StructBuilder) Struct(name string, structName string) *StructBuilder

+ func (sb *StructBuilder) Text(name string) *StructBuilder

+ func (sb *StructBuilder) Uint32(name string) *StructBuilder

+ func (sb *StructBuilder) Uint64(name string) *StructBuilder

+ type Type uint8

+ const TypeBool

+ const TypeBytes

+ const TypeEnum

+ const TypeFloat32

+ const TypeFloat64

+ const TypeInt16

+ const TypeInt32

+ const TypeInt64

+ const TypeInt8

+ const TypeList

+ const TypeStruct

+ const TypeText

+ const TypeUint16

+ const TypeUint32

+ const TypeUint64

+ const TypeUint8

+ const TypeUnion

+ const TypeVoid

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL