()
| 113 | type BuildRequestFunc func() (RequestParts, error) |
| 114 | |
| 115 | type StreamFunc func( |
| 116 | ctx context.Context, |
| 117 | url string, |
| 118 | headers map[string]string, |
| 119 | body []byte, |
| 120 | ) <-chan EventResult |
| 121 | |
| 122 | type RetryableError struct { |
| 123 | Message string |
| 124 | } |
| 125 | |
| 126 | func (e RetryableError) Error() string { |
| 127 | return e.Message |
| 128 | } |
| 129 | |
| 130 | func NewRetryableError(message string) error { |
| 131 | return RetryableError{Message: message} |
no outgoing calls
no test coverage detected