Versions in this module Expand all Collapse all v1 v1.0.0 Aug 26, 2026 Changes in this version + const MaxCapabilitiesPerWorker + const MaxIdentityBytes + const MaxQueuesPerWorker + const MaxWorkerConcurrency + var ErrInvalidTelemetryConfiguration = errors.New("fleet: invalid telemetry configuration") + type Capability string + const CapabilityBulkRetry + const CapabilityDeadLetters + const CapabilityDelete + const CapabilityDrain + const CapabilityFailures + const CapabilityPause + const CapabilityPurge + const CapabilityQueueStatus + const CapabilityReplay + const CapabilityResume + const CapabilityRetentionBytes + const CapabilityRetentionCount + const CapabilityRetentionTime + const CapabilityRetry + const CapabilityTerminate + const CapabilityWorkerStatus + type Compatibility struct + ControlPlaneOnly []Capability + Enabled []Capability + State CompatibilityState + WorkerOnly []Capability + func Negotiate(supported ProtocolRange, worker ProtocolVersion, ...) Compatibility + type CompatibilityState string + const CompatibilityCompatible + const CompatibilityUnknown + const CompatibilityWorkerNewer + const CompatibilityWorkerOlder + type DrainState string + const DrainCompleted + const DrainInProgress + const DrainNotRequested + const DrainRequested + const DrainTimedOut + type Heartbeat struct + Backend string + Capabilities []Capability + Concurrency uint32 + CurrentJobs uint32 + DrainStatus DrainState + ObservedAt time.Time + Protocol ProtocolVersion + Queues []string + StartedAt time.Time + State State + TenantID string + Version string + WorkerID string + func (h Heartbeat) EffectiveState(now time.Time, staleAfter time.Duration) State + func (h Heartbeat) Validate() error + type HeartbeatDisposition string + const HeartbeatAccepted + const HeartbeatCapacityExceeded + const HeartbeatConflict + const HeartbeatDuplicate + const HeartbeatInvalid + const HeartbeatReordered + type HeartbeatValidationError struct + Field string + Problem string + func (e *HeartbeatValidationError) Error() string + type Projection struct + func NewProjection(maxQueues int) *Projection + func (p *Projection) Observe(event queue.Event) + func (p *Projection) Snapshot() ProjectionSnapshot + type ProjectionSnapshot struct + Overflow QueueMetrics + Queues []QueueSnapshot + type ProtocolRange struct + Maximum ProtocolVersion + Minimum ProtocolVersion + type ProtocolVersion struct + Major uint16 + Minor uint16 + type QueueMetrics struct + Enqueued uint64 + Failed uint64 + Runtime time.Duration + Succeeded uint64 + type QueueSnapshot struct + Backend string + Metrics QueueMetrics + Queue string + type Registry struct + func NewRegistry(maxWorkers int) *Registry + func (r *Registry) RegisterTelemetry(meter metric.Meter, now func() time.Time, staleAfter time.Duration) (metric.Registration, error) + func (r *Registry) Snapshot(now time.Time, staleAfter time.Duration) RegistrySnapshot + func (r *Registry) SnapshotTenant(tenant string, now time.Time, staleAfter time.Duration) RegistrySnapshot + func (r *Registry) Upsert(heartbeat Heartbeat) HeartbeatDisposition + type RegistrySnapshot struct + Rejected uint64 + Workers []WorkerSnapshot + type State string + const StateDraining + const StatePaused + const StateRunning + const StateStale + const StateStopped + const StateUnknown + type WorkerSnapshot struct + State State
Go to main page