package
0.7.0
Repository: https://github.com/polarstreams/polar.git
Documentation: pkg.go.dev

# Functions

Returns the first non nil error in the slice or nil.
BinarySize gets the amount of bytes required to write the value, validating that all types are fixed-sized.
Collects single messages from each channel.
No description provided by the author
No description provided by the author
No description provided by the author
Creates a debouncer that will stop the previous timer when the time that has passed is below the threshold.
No description provided by the author
No description provided by the author
GetServiceAddress determines whether it should be bind to all interfaces or it should use a single host name.
No description provided by the author
Runs in parallel and collects the results in channels.
Runs in parallel and returns an error if any is found.
Returns true for 2xx status code.
Adds a +-5% jitter to the duration with millisecond resolution.
MaxVersion gets the maximum version value of the non-nil generations provided.
No description provided by the author
NewBufferCap returns a buffer with the initial provided initial capacity.
No description provided by the author
Returns a reader that wraps multiple []byte buffers and tries to read without allocating new buffers.
No description provided by the author
Sets the response status as 204 (NoContent) w/ no cache and optionally setting the retry after header.
For fatal errors, it logs and exists.
Reads the body as a string and closes it.
Reads from the reader into the provided buffers until length, returning an error otherwise.
Writes a text message in the response.
No description provided by the author
No description provided by the author
ToHandle wraps a handle func with error and converts it to a `httprouter.Handle`.
ToPostHandle wraps a handle func with error, returns plain text "OK" and converts it to a `httprouter.Handle`.
No description provided by the author
For a given number, it returns the last ring length that can contain it.
Writes the buffer, validating for "short writes".

# Structs

CopyOnWriteMap provides basic functionality of a copy-on-write dictionary that uses a valueCreator function (instead of a value like sync.Map).

# Interfaces

Represents a reader that attempts to read without allocating new buffers.

# Type aliases

No description provided by the author
No description provided by the author