NewStreamingMockServer creates a mock server that streams generated data.
(fileSize int64, opts ...MockServerOption)
| 401 | |
| 402 | // NewStreamingMockServer creates a mock server that streams generated data. |
| 403 | func NewStreamingMockServer(fileSize int64, opts ...MockServerOption) *StreamingMockServer { |
| 404 | // Create base server with minimal data |
| 405 | m := &MockServer{ |
| 406 | FileSize: fileSize, |
| 407 | SupportsRanges: true, |
| 408 | ContentType: "application/octet-stream", |
| 409 | Filename: "testfile.bin", |
| 410 | RandomData: false, |
| 411 | } |
| 412 | |
| 413 | for _, opt := range opts { |
| 414 | opt(m) |
| 415 | } |
| 416 | |
| 417 | // Only allocate a small buffer for streaming |
| 418 | m.data = make([]byte, 64*types.KB) // 64KB buffer |
| 419 | if m.RandomData { |
| 420 | _, _ = rand.Read(m.data) |
| 421 | } |
| 422 | |
| 423 | s := &StreamingMockServer{MockServer: m} |
| 424 | m.Server = NewHTTPServer(http.HandlerFunc(s.handleStreamingRequest)) |
| 425 | return s |
| 426 | } |
| 427 | |
| 428 | // NewStreamingMockServerT creates a streaming mock server and skips the test if binding fails. |
| 429 | func NewStreamingMockServerT(t *testing.T, fileSize int64, opts ...MockServerOption) *StreamingMockServer { |
nothing calls this directly
no test coverage detected