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

Adding code for pubsub connectors #1007

Merged
merged 5 commits into from
May 17, 2021
Merged

Conversation

jigyasak05
Copy link
Contributor

@jigyasak05 jigyasak05 commented May 12, 2021

Signed-off-by: Jigyasa jigyasakhaneja05@gmail.com

Pull request

Description

Added code for Google Cloud Pubsub connectors

Related

#724

Checklist

  • The RFC, if required, has been submitted and approved
  • Any user-facing impact of the changes is reflected in docs.tremor.rs
  • The code is tested
  • Use of unsafe code is reasoned about in a comment
  • Update CHANGELOG.md appropriately, recording any changes, bug fixes, or other observable changes in behavior
  • The performance impact of the change is measured (see below)

Performance

@coveralls
Copy link
Collaborator

coveralls commented May 12, 2021

Coverage Status

Coverage increased (+0.005%) to 83.824% when pulling b4b5573 on jigyasak05:pubsub-connector into 0fb05df on tremor-rs:main.

src/sink/gpub.rs Outdated Show resolved Hide resolved
src/sink/gpub.rs Outdated Show resolved Hide resolved
src/sink/gpub.rs Outdated Show resolved Hide resolved
src/sink/gpub.rs Outdated Show resolved Hide resolved
src/source.rs Outdated Show resolved Hide resolved
Comment on lines +136 to +139
let file;
match env::var("GOOGLE_APPLICATION_CREDENTIALS") {
Ok(val) => file = val,
Err(_e) => file = "service account file not found".to_string(),
}
Copy link
Member

Choose a reason for hiding this comment

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

This could work nicer as:

let file = env::var("GOOGLE_APPLICATION_CREDENTIALS").map_err("service account file not found")?;

@jigyasak05 jigyasak05 force-pushed the pubsub-connector branch 2 times, most recently from f58e538 to a6608e7 Compare May 17, 2021 11:42
Signed-off-by: Jigyasa <jigyasakhaneja05@gmail.com>
Signed-off-by: Jigyasa <jigyasakhaneja05@gmail.com>
Signed-off-by: Jigyasa <jigyasakhaneja05@gmail.com>
Signed-off-by: Jigyasa <jigyasakhaneja05@gmail.com>
Signed-off-by: Jigyasa <jigyasakhaneja05@gmail.com>
Copy link
Member

@Licenser Licenser left a comment

Choose a reason for hiding this comment

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

You are on fire :D great job!

@Licenser Licenser merged commit a667992 into tremor-rs:main May 17, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants