util.go 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. package awstesting
  2. import (
  3. "io"
  4. "github.com/aws/aws-sdk-go/private/util"
  5. )
  6. // ZeroReader is a io.Reader which will always write zeros to the byte slice provided.
  7. type ZeroReader struct{}
  8. // Read fills the provided byte slice with zeros returning the number of bytes written.
  9. func (r *ZeroReader) Read(b []byte) (int, error) {
  10. for i := 0; i < len(b); i++ {
  11. b[i] = 0
  12. }
  13. return len(b), nil
  14. }
  15. // ReadCloser is a io.ReadCloser for unit testing.
  16. // Designed to test for leaks and whether a handle has
  17. // been closed
  18. type ReadCloser struct {
  19. Size int
  20. Closed bool
  21. set bool
  22. FillData func(bool, []byte, int, int)
  23. }
  24. // Read will call FillData and fill it with whatever data needed.
  25. // Decrements the size until zero, then return io.EOF.
  26. func (r *ReadCloser) Read(b []byte) (int, error) {
  27. if r.Closed {
  28. return 0, io.EOF
  29. }
  30. delta := len(b)
  31. if delta > r.Size {
  32. delta = r.Size
  33. }
  34. r.Size -= delta
  35. for i := 0; i < delta; i++ {
  36. b[i] = 'a'
  37. }
  38. if r.FillData != nil {
  39. r.FillData(r.set, b, r.Size, delta)
  40. }
  41. r.set = true
  42. if r.Size > 0 {
  43. return delta, nil
  44. }
  45. return delta, io.EOF
  46. }
  47. // Close sets Closed to true and returns no error
  48. func (r *ReadCloser) Close() error {
  49. r.Closed = true
  50. return nil
  51. }
  52. // SortedKeys returns a sorted slice of keys of a map.
  53. func SortedKeys(m map[string]interface{}) []string {
  54. return util.SortedKeys(m)
  55. }