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.

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

WIP - MetricsReporter for Producers #128

Draft
wants to merge 1 commit into
base: main
Choose a base branch
from
Draft

WIP - MetricsReporter for Producers #128

wants to merge 1 commit into from

Conversation

etspaceman
Copy link
Owner

@etspaceman etspaceman commented May 16, 2023

Changes Introduced

Introduces MetricsReporter, with NoOp and CloudWatch variants. CloudWatch will only work for the java client for now as we do not yet have the cloudwatch client set up for the smithy4s client.

The intent is to publish the same metrics that the KPL publishes today. See https://docs.aws.amazon.com/streams/latest/dev/monitoring-with-kpl.html

Applicable linked issues

#74

Checklist (check all that apply)

  • This change maintains backwards compatibility
  • I have introduced tests for all new features and changes
  • I have added documentation covering all new features and changes
  • This pull-request is ready for review

import kinesis4cats.compat.retry._
import kinesis4cats.logging._

abstract class MetricsReporter[F[_], PutRes](
Copy link
Owner Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Setting this up very similarly to the FS2Producer, so that we can have a defined, configurable rate of metrics publishing.

unit: StandardUnit
)

object Metric {
Copy link
Owner Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant