Versions in this module Expand all Collapse all v0 v0.30.2 Mar 23, 2022 Changes in this version + func LeaseBasedProcessor(ctx context.Context, f *Forwarder, accept statProcessor) error + func StatefulSetBasedProcessor(ctx context.Context, f *Forwarder, accept statProcessor) error + type Forwarder struct + func New(ctx context.Context, bs *hash.BucketSet) *Forwarder + func (f *Forwarder) Cancel() + func (f *Forwarder) IsBucketOwner(bkt string) bool + func (f *Forwarder) Process(sm asmetrics.StatMessage)