fleet

Oct 12, 2026

Changes in this version

+ const DefaultLivenessTick

+ type Hub struct

+ func NewHub[T any](build func(context.Context) (T, error), tick time.Duration) *Hub[T]

+ func (h *Hub[T]) Run(ctx context.Context)

+ func (h *Hub[T]) SnapshotNow(ctx context.Context) (T, error)

+ func (h *Hub[T]) Subscribe() (<-chan T, func())

+ func (h *Hub[T]) Trigger()