mirror of
https://github.com/hanzokv/go.git
synced 2026-09-24 00:31:51 +00:00
zeekay
2016e30150
KV lives in its own org now, like hanzokms / hanzos3 / hanzo-ds. The repo moved hanzoai/kv-go -> hanzokv/go, so the module path follows: a Go module path must match where the repo actually is, or the proxy cannot resolve it. The name is `go`, not `kv-go`, following the hanzo-ds convention — that org holds go, mock, native, sqlbuilder, sqlparser, each named for its language or concern with the ORG supplying the product noun. Repeating "kv" inside a repo that already lives under hanzokv is the compound-word habit we are dropping. 349 occurrences across 188 files: the root module, all four extra/* modules, every example module, imports throughout the tree, and the docs. Builds clean. The package is still `package redis` and the extra dirs are still named redis*. That rename is deliberately NOT bundled here: it is 5,771 occurrences, it breaks all 11 consumers at once, and a large share are WIRE CONTRACTS rather than branding — the redis:// scheme parser, the "redis: nil" error string, RESP command names. Renaming those breaks protocol compatibility with the Valkey server. It needs the same our-vocabulary-vs-the-wire split the argo sweep used, as its own change. GitHub keeps the old path redirecting, and versions already published under github.com/hanzoai/kv-go/v9 stay resolvable, so nothing breaks the moment this lands. Consumers move on their own schedule.
77 lines
3.2 KiB
Go
77 lines
3.2 KiB
Go
package maintnotifications
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/hanzokv/go/v9/internal/maintnotifications/logs"
|
|
)
|
|
|
|
// Configuration errors
|
|
var (
|
|
ErrInvalidRelaxedTimeout = errors.New(logs.InvalidRelaxedTimeoutError())
|
|
ErrInvalidHandoffTimeout = errors.New(logs.InvalidHandoffTimeoutError())
|
|
ErrInvalidHandoffWorkers = errors.New(logs.InvalidHandoffWorkersError())
|
|
ErrInvalidHandoffQueueSize = errors.New(logs.InvalidHandoffQueueSizeError())
|
|
ErrInvalidPostHandoffRelaxedDuration = errors.New(logs.InvalidPostHandoffRelaxedDurationError())
|
|
ErrInvalidEndpointType = errors.New(logs.InvalidEndpointTypeError())
|
|
ErrInvalidMaintNotifications = errors.New(logs.InvalidMaintNotificationsError())
|
|
ErrMaxHandoffRetriesReached = errors.New(logs.MaxHandoffRetriesReachedError())
|
|
|
|
// Configuration validation errors
|
|
|
|
// ErrInvalidHandoffRetries is returned when the number of handoff retries is invalid
|
|
ErrInvalidHandoffRetries = errors.New(logs.InvalidHandoffRetriesError())
|
|
)
|
|
|
|
// Integration errors
|
|
var (
|
|
// ErrInvalidClient is returned when the client does not support push notifications
|
|
ErrInvalidClient = errors.New(logs.InvalidClientError())
|
|
)
|
|
|
|
// Handoff errors
|
|
var (
|
|
// ErrHandoffQueueFull is returned when the handoff queue is full
|
|
ErrHandoffQueueFull = errors.New(logs.HandoffQueueFullError())
|
|
)
|
|
|
|
// Notification errors
|
|
var (
|
|
// ErrInvalidNotification is returned when a notification is in an invalid format
|
|
ErrInvalidNotification = errors.New(logs.InvalidNotificationError())
|
|
)
|
|
|
|
// connection handoff errors
|
|
var (
|
|
// ErrConnectionMarkedForHandoff is returned when a connection is marked for handoff
|
|
// and should not be used until the handoff is complete
|
|
ErrConnectionMarkedForHandoff = errors.New(logs.ConnectionMarkedForHandoffErrorMessage)
|
|
// ErrConnectionMarkedForHandoffWithState is returned when a connection is marked for handoff
|
|
// and should not be used until the handoff is complete
|
|
ErrConnectionMarkedForHandoffWithState = errors.New(logs.ConnectionMarkedForHandoffErrorMessage + " with state")
|
|
// ErrConnectionInvalidHandoffState is returned when a connection is in an invalid state for handoff
|
|
ErrConnectionInvalidHandoffState = errors.New(logs.ConnectionInvalidHandoffStateErrorMessage)
|
|
)
|
|
|
|
// shutdown errors
|
|
var (
|
|
// ErrShutdown is returned when the maintnotifications manager is shutdown
|
|
ErrShutdown = errors.New(logs.ShutdownError())
|
|
)
|
|
|
|
// circuit breaker errors
|
|
var (
|
|
// ErrCircuitBreakerOpen is returned when the circuit breaker is open
|
|
ErrCircuitBreakerOpen = errors.New(logs.CircuitBreakerOpenErrorMessage)
|
|
)
|
|
|
|
// circuit breaker configuration errors
|
|
var (
|
|
// ErrInvalidCircuitBreakerFailureThreshold is returned when the circuit breaker failure threshold is invalid
|
|
ErrInvalidCircuitBreakerFailureThreshold = errors.New(logs.InvalidCircuitBreakerFailureThresholdError())
|
|
// ErrInvalidCircuitBreakerResetTimeout is returned when the circuit breaker reset timeout is invalid
|
|
ErrInvalidCircuitBreakerResetTimeout = errors.New(logs.InvalidCircuitBreakerResetTimeoutError())
|
|
// ErrInvalidCircuitBreakerMaxRequests is returned when the circuit breaker max requests is invalid
|
|
ErrInvalidCircuitBreakerMaxRequests = errors.New(logs.InvalidCircuitBreakerMaxRequestsError())
|
|
)
|