Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Remove outputs blocking inputs when output is slow #4938

Merged
merged 28 commits into from
Nov 5, 2018
Merged

Remove outputs blocking inputs when output is slow #4938

merged 28 commits into from
Nov 5, 2018

Commits on Nov 2, 2018

  1. Remove Buffer.IsEmpty function

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    6fc5b05 View commit details
    Browse the repository at this point in the history

  2. Add mutex to Buffer.Len

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    13118dc View commit details
    Browse the repository at this point in the history

  3. Use require in place of assert in buffer tests

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    258758e View commit details
    Browse the repository at this point in the history

  4. Don't remove batches from metric buffer until successfully sent.

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    cdf1bd4 View commit details
    Browse the repository at this point in the history

  5. Refactor agent pipeline

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    8f2f597 View commit details
    Browse the repository at this point in the history

  6. Commit working batch to metric buffer without blocking

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    3c17364 View commit details
    Browse the repository at this point in the history

  7. Add support for tracking metrics

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    db8577b View commit details
    Browse the repository at this point in the history

  8. Add durable handling to amqp_consumer

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    fefbea1 View commit details
    Browse the repository at this point in the history

  9. Add durable metric handling to kafka_consumer

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    964fd1b View commit details
    Browse the repository at this point in the history

  10. Fix full buffer wrap around during write

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    18d6182 View commit details
    Browse the repository at this point in the history

  11. Update logging format for outputs

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    d268217 View commit details
    Browse the repository at this point in the history

  12. Add per output flush interval, batch size and buffer limit

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    7fd0f72 View commit details
    Browse the repository at this point in the history

  13. Add tracking metric support to topk processor

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    86a35e4 View commit details
    Browse the repository at this point in the history

  14. Use AddMetric in socket_listener

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    a32f9d5 View commit details
    Browse the repository at this point in the history

  15. Rename Metric.Remove to Metric.Drop

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    d884831 View commit details
    Browse the repository at this point in the history

  16. Don't log when message from previous amqp connection is delivered

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    6dd08a7 View commit details
    Browse the repository at this point in the history

  17. Add tracking limiting to mqtt_consumer

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    548bccd View commit details
    Browse the repository at this point in the history

  18. Add tracking limiting to nats_consumer

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    48060cf View commit details
    Browse the repository at this point in the history

  19. Change accumulator log error string

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    6ddbb53 View commit details
    Browse the repository at this point in the history

  20. Simplify delivery info handling in amqp_consumer

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    ba04ffa View commit details
    Browse the repository at this point in the history

  21. Remove unneeded context done check in mqtt_consumer

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    ef9c197 View commit details
    Browse the repository at this point in the history

  22. Add tracking support to nsq_consumer

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    09981fc View commit details
    Browse the repository at this point in the history

  23. Document that accumulator cannot be used after Stop is called

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    f413825 View commit details
    Browse the repository at this point in the history

  24. Add module to agent log message

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    ef34637 View commit details
    Browse the repository at this point in the history

  25. Standardize variable name and comment for max_undelivered_messages

    @danielnelson
    danielnelson committed Nov 2, 2018
    Configuration menu
    Copy the full SHA
    b545796 View commit details
    Browse the repository at this point in the history

Commits on Nov 3, 2018

  1. Split contributing documentation

    @danielnelson
    danielnelson committed Nov 3, 2018
    Configuration menu
    Copy the full SHA
    9d61020 View commit details
    Browse the repository at this point in the history

  2. Add basic guide for using tracking metrics

    @danielnelson
    danielnelson committed Nov 3, 2018
    Configuration menu
    Copy the full SHA
    48026b8 View commit details
    Browse the repository at this point in the history

Commits on Nov 5, 2018

  1. Update comment

    @danielnelson
    danielnelson committed Nov 5, 2018
    Configuration menu
    Copy the full SHA
    02d87f7 View commit details
    Browse the repository at this point in the history