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

# Functions

No description provided by the author
Gets the formatted file name based on the segment id.
Gets the formatted value of the id for the file name (%020d) w/o the extension, e.g.
No description provided by the author
Enables profiling when the build tag is set.
No description provided by the author

# Constants

Url for client discovery service.
No description provided by the author
No description provided by the author
No description provided by the author
Url consuming messages.
Port defaults.
Port defaults.
Port defaults.
Port defaults.
Port defaults.
Port defaults.
Port defaults.
No description provided by the author
Send/receive my info to the peer.
Send/receive consumer manual commit from peer.
Send/receive consumer groups info.
Send/receive consumer offsets.
Send/receive consumer register from peer.
Send/receive consumer unregister from peer.
Url for setting the generation and transaction as committed for token.
Url for setting one generation as proposed/accepted or two generations as accepted.
Url for requesting the token range to be split as a consequence of scaling up.
Url for getting/setting the generation by token.
Send/receive message that a broker is shutting down.
No description provided by the author
Reads the file names of a given topic & offset (topic, token, range, version and offset).
Reads the producer offset, with params: topic, token, range, version.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Use page cache for index file as it's not critical and it won't abuse the cache space.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Use page cache for max offset producer file as it won't abuse the cache space.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Url for producing messages.
Used for non-k8s envs.

# Variables

No description provided by the author

# Interfaces

No description provided by the author
Config represents the application configuration.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author