Method Chunked

tailnet/proto/response.go:11–22

Chunked splits the response into multiple responses, each containing at most maxPeerUpdatesPerMessage peer updates to stay under the DRPC 4 MiB transport limit.

()

// at most maxPeerUpdatesPerMessage peer updates to stay under the DRPC
// 4 MiB transport limit.
func (r *CoordinateResponse) Chunked() []*CoordinateResponse {
	updates := r.GetPeerUpdates()
	if len(updates) <= maxPeerUpdatesPerMessage {
		return []*CoordinateResponse{r}
	}
	var chunks []*CoordinateResponse
	for i := 0; i < len(updates); i += maxPeerUpdatesPerMessage {
		end := min(i+maxPeerUpdatesPerMessage, len(updates))
		chunks = append(chunks, &CoordinateResponse{PeerUpdates: updates[i:end]})
	}
	return chunks
}