mirror of
https://github.com/luxfi/zap.git
synced 2026-10-30 15:04:16 +00:00
zeekay
af88152c6f
There is one perfected typed ZAP layer and it lives at github.com/luxfi/zap/v1 — forwards-only, no backwards-compat baggage, never a breaking major. Mechanical, behavior-preserving: v2/ -> v1/ (git mv), package zapv2 -> zapv1, import path .../zap/v2 -> .../zap/v1 (incl. the codegen's emitted banner + import so generated files reference /v1). Codegen golden tests pass; typed layer vets clean. (Pre-existing CGO 'resolv' link failures in the root package are unrelated env noise.)
101 lines
3.2 KiB
Go
101 lines
3.2 KiB
Go
// Copyright (C) 2026, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package examples
|
|
|
|
import (
|
|
"github.com/luxfi/zap/v1"
|
|
)
|
|
|
|
// KindBatch is the wire discriminator for BatchTx. Distinct from
|
|
// KindAdvanceTime so Registry dispatch can tell them apart.
|
|
const KindBatch zapv1.KindByte = 0x21
|
|
|
|
// BatchSchema is a small, multi-element schema used to exercise the
|
|
// generic [zapv1.List] iter.Seq path in tests. Object layout:
|
|
//
|
|
// @0: KindBatch (uint8)
|
|
// @1: BatchID (uint64)
|
|
// @9: Items (list pointer: relOffset uint32 + length uint32)
|
|
//
|
|
// Each list element is an [ItemSchema] (16 bytes: id uint64 + value
|
|
// uint64).
|
|
type BatchSchema struct{}
|
|
|
|
func (BatchSchema) Kind() zapv1.KindByte { return KindBatch }
|
|
func (BatchSchema) Size() int { return 17 }
|
|
func (BatchSchema) Name() string { return "BatchTx" }
|
|
|
|
// KindItem identifies ItemSchema. Items live inside BatchTx lists; an
|
|
// Item is never a top-level message, but it has a Kind anyway so the
|
|
// generic List[Item] code can use the same machinery.
|
|
const KindItem zapv1.KindByte = 0x22
|
|
|
|
// ItemSchema is the per-element schema for BatchTx.Items.
|
|
type ItemSchema struct{}
|
|
|
|
func (ItemSchema) Kind() zapv1.KindByte { return KindItem }
|
|
func (ItemSchema) Size() int { return 16 } // 8 + 8
|
|
func (ItemSchema) Name() string { return "BatchItem" }
|
|
|
|
// BatchFields declares the offsets for BatchSchema.
|
|
var BatchFields = struct {
|
|
ID zapv1.Field[BatchSchema, uint64]
|
|
}{
|
|
ID: zapv1.At[BatchSchema, uint64](1),
|
|
}
|
|
|
|
// ItemFields declares the offsets for ItemSchema.
|
|
var ItemFields = struct {
|
|
ID zapv1.Field[ItemSchema, uint64]
|
|
Value zapv1.Field[ItemSchema, uint64]
|
|
}{
|
|
ID: zapv1.At[ItemSchema, uint64](0),
|
|
Value: zapv1.At[ItemSchema, uint64](8),
|
|
}
|
|
|
|
// OffsetBatchItems is the byte offset of the list pointer for Items
|
|
// within the BatchSchema fixed payload. Items is a variable-length
|
|
// list, so it lives outside the [zapv1.Field] generic vocabulary; it
|
|
// is read via [zapv1.ListAt] instead.
|
|
const OffsetBatchItems uint32 = 9
|
|
|
|
// Items returns the list of items in the batch as an [iter.Seq]-ready
|
|
// [zapv1.List][ItemSchema]. Range-over-func:
|
|
//
|
|
// for item := range examples.Items(batchView).All() {
|
|
// id := zapv1.Read(item, examples.ItemFields.ID)
|
|
// value := zapv1.Read(item, examples.ItemFields.Value)
|
|
// // ...
|
|
// }
|
|
func Items(v zapv1.View[BatchSchema]) zapv1.List[ItemSchema] {
|
|
return zapv1.ListAt[BatchSchema, ItemSchema](v, OffsetBatchItems)
|
|
}
|
|
|
|
// Item is a value-shaped helper for batch-construction tests.
|
|
type Item struct {
|
|
ID uint64
|
|
Value uint64
|
|
}
|
|
|
|
// NewBatch builds a BatchTx with the given ID and items.
|
|
func NewBatch(id uint64, items []Item) (zapv1.View[BatchSchema], []byte) {
|
|
return zapv1.Build[BatchSchema](func(s zapv1.Setter[BatchSchema]) {
|
|
zapv1.Write(s, BatchFields.ID, id)
|
|
zapv1.WriteList[BatchSchema, ItemSchema](s, OffsetBatchItems,
|
|
func(es *zapv1.ElemSetter[ItemSchema]) {
|
|
for _, it := range items {
|
|
es.Append(func(e zapv1.Setter[ItemSchema]) {
|
|
zapv1.Write(e, ItemFields.ID, it.ID)
|
|
zapv1.Write(e, ItemFields.Value, it.Value)
|
|
})
|
|
}
|
|
})
|
|
})
|
|
}
|
|
|
|
func init() {
|
|
zapv1.Register[BatchSchema](zapv1.DefaultRegistry)
|
|
zapv1.Register[ItemSchema](zapv1.DefaultRegistry)
|
|
}
|