Versions in this module Expand all Collapse all v0 v0.1.14 Apr 23, 2024 v0.1.13 Mar 5, 2024 Changes in this version + const SuicideExitCode + var StatsSamplePeriod = 30 * time.Second + var StatsSampleSize = 20 + type Client struct + func New(cfg config.Configuration, cmps Components) (*Client, error) + func (c *Client) ProcessMessage(ctx context.Context, am service.AckMessage) (err error) + func (c *Client) Stop() + type Components struct + Communicator comms.Communicator + Filter *flow.Filter + ServiceFactories map[string]service.Factory + Signers []signer.Signer + Stats stats.Collector