Documentation
¶
Overview ¶
Package pub implements the queue client.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
New returns a new queue client targeting the given node roles. If no roles are passed, it defaults to databasev1.Role_ROLE_DATA.
func NewWithoutMetadata ¶ added in v0.8.0
NewWithoutMetadata returns a new queue client without metadata, defaulting to data nodes.
Types ¶
type ChunkedSyncClientConfig ¶ added in v0.9.0
type ChunkedSyncClientConfig struct {
ChunkSize uint32 // Size of each chunk in bytes
EnableRetryOnOOO bool // Enable retry on out-of-order errors
MaxOOORetries int // Maximum retries for out-of-order chunks
OOORetryDelay time.Duration // Delay between retries
}
ChunkedSyncClientConfig configures chunked sync client behavior.
type CircuitState ¶ added in v0.9.0
type CircuitState int
CircuitState defines the circuit breaker states.
const ( StateClosed CircuitState = iota // Normal operation StateOpen // Reject requests until cooldown expires StateHalfOpen // Allow a single probe )
CircuitState defines the circuit breaker states.
type LabelSelector ¶ added in v0.8.0
type LabelSelector struct {
// contains filtered or unexported fields
}
LabelSelector is a selector for labels.
func ParseLabelSelector ¶ added in v0.8.0
func ParseLabelSelector(selector string) (*LabelSelector, error)
ParseLabelSelector parses a label selector string.
Source Files
Click to show internal directories.
Click to hide internal directories.