Skip to content

Commit

Permalink
Make addFirewallRule return Operation
Browse files Browse the repository at this point in the history
  • Loading branch information
rtitle committed Mar 21, 2020
1 parent d96c86a commit 3ac1b9a
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -119,11 +119,11 @@ private[google2] class GoogleComputeInterpreter[F[_]: Async: StructuredLogger: T
}

override def addFirewallRule(project: GoogleProject,
firewall: Firewall)(implicit ev: ApplicativeAsk[F, TraceId]): F[Unit] =
firewall: Firewall)(implicit ev: ApplicativeAsk[F, TraceId]): F[Operation] =
retryF(
Async[F].delay(firewallClient.insertFirewall(project.value, firewall)),
s"com.google.cloud.compute.v1.FirewallClient.insertFirewall(${project.value}, ${firewall.getName})"
).void
)

override def getFirewallRule(project: GoogleProject, firewallRuleName: FirewallRuleName)(
implicit ev: ApplicativeAsk[F, TraceId]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ trait GoogleComputeService[F[_]] {
instanceName: InstanceName,
metadata: Map[String, String])(implicit ev: ApplicativeAsk[F, TraceId]): F[Unit]

def addFirewallRule(project: GoogleProject, firewall: Firewall)(implicit ev: ApplicativeAsk[F, TraceId]): F[Unit]
def addFirewallRule(project: GoogleProject, firewall: Firewall)(implicit ev: ApplicativeAsk[F, TraceId]): F[Operation]

def getFirewallRule(project: GoogleProject, firewallRuleName: FirewallRuleName)(
implicit ev: ApplicativeAsk[F, TraceId]
Expand Down

0 comments on commit 3ac1b9a

Please sign in to comment.