bijukunjummen

apiVersion: apps/v1
kind: Deployment
metadata:
  name: hello-skaffold-gke-deployment
  namespace: default
spec:
  replicas: 1
  selector:
    matchLabels:
      app: hello-skaffold-gke

bijukunjummen

apiVersion: apps/v1
kind: Deployment
metadata:
  name: hello-skaffold-gke-deployment
spec:
  replicas: 1
  selector:
    matchLabels:
      app: hello-skaffold-gke
  template:

bijukunjummen

apiVersion: skaffold/v2beta16
kind: Config
metadata:
  name: hello-skaffold-gke
build:
  artifacts:
  - image: hello-skaffold-gke
    jib: {}
deploy:
  kubectl:

bijukunjummen

plugins{
  id 'java'
  id "io.github.bijukunjummen.cloudfunction"
}

dependencies {
 ...
}

cloudFunction {

bijukunjummen

configurations {
  invoker
}

dependencies {
  ...
  invoker("com.google.cloud.functions.invoker:java-function-invoker:1.1.0")
  ...
}

bijukunjummen

import com.google.cloud.functions.HttpFunction;
import com.google.cloud.functions.HttpRequest;
import com.google.cloud.functions.HttpResponse;

public class HelloHttp implements HttpFunction {

    @Override
    public void service(HttpRequest request, HttpResponse response) throws IOException {
        final BufferedWriter writer = response.getWriter();
        response.setContentType("application/html");

bijukunjummen

package org.bk.logback.custom;

import ch.qos.logback.classic.Level;
import ch.qos.logback.classic.spi.ILoggingEvent;
import ch.qos.logback.contrib.json.classic.JsonLayout;
import com.google.cloud.logging.Severity;

import java.util.Map;

public class GcpJsonLayout extends JsonLayout {

bijukunjummen

public Mono<Void> publish(Message message) {
    ByteString data = ByteString.copyFromUtf8(JsonUtils.writeValueAsString(message, objectMapper));
    PubsubMessage pubSubMessage = PubsubMessage.newBuilder().setData(data).build();
    return Mono.fromFuture(pubSubTemplate.publish(pubSubProperties.topic(), pubSubMessage).completable()).then();
}

bijukunjummen

public Mono<Void> publish(Message message) {
    ByteString data = ByteString.copyFromUtf8(JsonUtils.writeValueAsString(message, objectMapper));
    PubsubMessage pubSubMessage = PubsubMessage.newBuilder().setData(data).build();
    ApiFuture<String> messageIdFuture = publisher.publish(pubSubMessage);
    Mono<String> messageIdMono = ApiFutureUtil.toMono(messageIdFuture);
    return messageIdMono.then();
}

bijukunjummen

public record Message(String id, String payload) {
}