Versions in this module Expand all Collapse all v0 v0.2.0 Jun 5, 2026 v0.1.0 Jun 2, 2026 Changes in this version + var ErrClosed = errors.New("generation: publisher closed") + var ErrDrainTimeout = errors.New("generation: drain timeout") + type Generation struct + func (g *Generation[W]) CSR() *csr.CSR[W] + func (g *Generation[W]) Refcount() int64 + type Publisher struct + func New[W any](initial *csr.CSR[W]) *Publisher[W] + func (p *Publisher[W]) Acquire() *Generation[W] + func (p *Publisher[W]) Close() + func (p *Publisher[W]) Current() *Generation[W] + func (p *Publisher[W]) Publish(c *csr.CSR[W]) (*Generation[W], error) + func (p *Publisher[W]) PublishWithDrain(c *csr.CSR[W], timeout time.Duration) (*Generation[W], error) + func (p *Publisher[W]) Release(g *Generation[W])
Go to main page