В текущем проекте я работаю над высоконагруженным микросервисом на Go, который отвечает за обработку и агрегацию данных в реальном времени. Используем gRPC для коммуникации между сервисами и PostgreSQL с TimescaleDB для хранения временных рядов. Основные задачи — оптимизация производительности, написание unit и интеграционных тестов, а также внедрение новых API для взаимодействия с фронтендом и внешними системами.

Пример кода для gRPC-сервиса на Go:

package main

import (
    "context"
    "log"
    "net"

    pb "example.com/project/proto"
    "google.golang.org/grpc"
)

type server struct {
    pb.UnimplementedDataServiceServer
}

func (s *server) GetData(ctx context.Context, req *pb.DataRequest) (*pb.DataResponse, error) {
    // Логика обработки запроса
    return &pb.DataResponse{Data: "response data"}, nil
}

func main() {
    lis, err := net.Listen("tcp", ":50051")
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
    }
    s := grpc.NewServer()
    pb.RegisterDataServiceServer(s, &server{})
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

Расскажите о вашем текущем проекте — на чём работаете?