diff options
| author | demo <demo@antix1> | 2026-05-27 11:59:08 -0400 |
|---|---|---|
| committer | demo <demo@antix1> | 2026-05-27 11:59:40 -0400 |
| commit | 81ee780aca0aa0d9ce6999a23ef94e986307e060 (patch) | |
| tree | 18165a8619727c94c4361134ed9d9730f337c1d4 /packet.go | |
| parent | 1190174edda07fea3f956b58a782eaff2d2213b8 (diff) | |
refactor: move packet definitions to their own file
I also decided to make the packet datatype package private.
Diffstat (limited to 'packet.go')
| -rw-r--r-- | packet.go | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/packet.go b/packet.go new file mode 100644 index 0000000..5b3a5ba --- /dev/null +++ b/packet.go @@ -0,0 +1,35 @@ +package main + +import ( + "fmt" + "net/url" +) + +// packet accrues data as it passes through our concurrent +// pipeline. Formerly the web crawler only transmitted [url.URL]'s, +// but usingn a compound data type allows us to add URL +// depth-tracking. +type packet struct { + url url.URL + depth int +} + +// String implements the Stringer interface. We need this mainly +// because a [url.URL]'s String method only works when that URL is a +// pointer. +func (p packet) String() string { + return fmt.Sprintf("[%d] %s", p.depth, &p.url) +} + +// convertToPackets converts the batch of URLs to a slice of packet +// structs, configuring each one with the given depth. +func convertToPackets(batch []url.URL, depth int) []packet { + var ps []packet + + for _, u := range batch { + newPacket := packet{u, depth} + ps = append(ps, newPacket) + } + + return ps +} |
