task-processor/internal/app/client.go

package app

import (
	log "github.com/sirupsen/logrus"
	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"
	sc "task-processor/proto/surugayaScrapper"
	tp "task-processor/proto/taskProcessor"
)

func newApiClient(address string) tp.TaskProcessorClient {
	var opts []grpc.DialOption
	insec := grpc.WithTransportCredentials(insecure.NewCredentials())
	opts = append(opts, insec)

	conn, err := grpc.NewClient(address, opts...)
	if err != nil {
		log.Fatal(err)
	}

	log.WithFields(log.Fields{
		"address": address,
	}).Debug("gRPC | API client")

	return tp.NewTaskProcessorClient(conn)
}

func newSurugayaScrapperClient(address string) sc.SurugayaScrapperClient {
	var opts []grpc.DialOption
	insec := grpc.WithTransportCredentials(insecure.NewCredentials())
	opts = append(opts, insec)

	conn, err := grpc.NewClient(address, opts...)
	if err != nil {
		log.Fatal(err)
	}

	log.WithFields(log.Fields{
		"address": address,
	}).Debug("gRPC | Surugaya scrapper client")

	return sc.NewSurugayaScrapperClient(conn)
}