Method Read

cmd/test-streammanager/generator.go:22–40

(p []byte)

}

func (g *TestDataGenerator) Read(p []byte) (n int, err error) {
	if g.generated >= g.totalBytes {
		return 0, io.EOF
	}

	remaining := g.totalBytes - g.generated
	toRead := int64(len(p))
	if toRead > remaining {
		toRead = remaining
	}

	// Sequential pattern using base64 chars (0-63 cycling)
	for i := int64(0); i < toRead; i++ {
		p[i] = Base64Chars[(g.generated+i)%64]
	}

	g.generated += toRead
	return int(toRead), nil
}