Lobs communication spike

[tleed5]

Description

This is a POC to evaluate ways of handling communication between processes for live kubernetes object status

Includes changes from main...robe/reverse-tentacle
Octopus Server side: https://github.com/OctopusDeploy/OctopusDeploy/compare/robe/reverse-tentacle

What it does

• Configures a kestrel server to run when the tentacle process is running to handle gRPC requests
• Creates a basic gRPC service that forwards along a message to Octopus server using existing Halibut polling connections by creating a Halibut client for a service that exists in Octopus server using the polling tentacle service endpoint and making a request with it.

Example with simple Go App hitting the gRPC service in Tentacle all running in a cluster

Top left terminal is the Go App's pod logs, top right terminal is Tentacles pod logs and bottom terminal is Octopus server's logs

Screen.Recording.2024-05-27.at.4.05.04.pm.mov

Go app

package main

//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative greet.proto

import (
	"context"
	"flag"
	"log"
	"time"

	pb "LobsCommsSpike/protos"
	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"
)

const (
	defaultName = "world"
)

var (
	addr = flag.String("addr", "agent-service.octopus-agent-agent.svc.cluster.local:5002", "the address to connect to")
	name = flag.String("name", defaultName, "Name to greet")
)

func main() {
	flag.Parse()
	// Set up a connection to the server.
	conn, err := grpc.NewClient(*addr, grpc.WithTransportCredentials(insecure.NewCredentials()))
	if err != nil {
		log.Fatalf("did not connect: %v", err)
	}
	defer conn.Close()
	c := pb.NewGreeterClient(conn)

	for {
		// Contact the server and print out its response.
		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
		r, err := c.SayHello(ctx, &pb.HelloRequest{Name: *name})
		time.Sleep(3 * time.Second)

		if err != nil {
			log.Fatalf("could not greet: %v", err)
		}
		log.Printf("Greeting: %s", r.GetMessage())
		cancel()
	}
}

[tleed5]

This is just so I could get it running locally on my mac https://learn.microsoft.com/en-us/aspnet/core/grpc/troubleshoot?view=aspnetcore-8.0#unable-to-start-aspnet-core-grpc-app-on-macos

[tleed5]

Had to update Autofac so I could easily get the existing container services into the Kestrel's container to allow for DI in the gRPC service