NRPC

$ ls
helloworld.proto
$ protoc --go_out=. --nrpc_out=. helloworld.proto
$ ls
helloworld.nrpc.go	helloworld.pb.go	helloworld.proto

option (nrpc.packageSubjectParams) = "instance"; // Параметры темы пакета

service SvcCustomSubject {
	option (nrpc.serviceSubject) = 'custom_subject'; // Уникальная тема сервиса
	rpc MtStreamedReply(StringArg) returns (SimpleStringReply) {
  		option (nrpc.streamedReply) = true;
	}
}

func (s BasicServerImpl) MtStreamedReply(ctx context.Context, req *StringArg, send func(rep *SimpleStringReply)) error {
	if req.GetArg1() == "please fail" {
		panic("Failing")
	}
	if req.GetArg1() == "very long call" {
		select {
			case <-ctx.Done():
				return ctx.Err()
			case <-time.After(time.Minute):
				time.Sleep(time.Minute)
				return nil
		}
	}
	time.Sleep(time.Second)
	send(&SimpleStringReply{Reply: "msg1"})
	time.Sleep(250 * time.Millisecond)
	send(&SimpleStringReply{Reply: "msg2"})
	time.Sleep(250 * time.Millisecond)
	send(&SimpleStringReply{Reply: "msg3"})
	time.Sleep(250 * time.Millisecond)
	return nil
}

client := NewSvcCustomSubjectClient(c, "default") // default — значение параметра темы пакета
err := client.MtStreamedReply(context.Background(), &StringArg{Arg1: "arg"}, func(ctx context.Context, rep *SimpleStringReply) {
	fmt.Println("получено", rep)
	resChan <- rep.GetReply()
})

получено reply:"msg1"
получено reply:"msg2"
получено reply:"msg3"

option (nrpc.packageSubjectParams) = "instance"; // Параметры темы пакета

service SvcCustomSubject {
	option (nrpc.serviceSubject) = 'custom_subject'; // Уникальная тема сервиса
	rpc MtRequestNoReply(StringArg) returns (nrpc.NoReply) {}
}
```**Имплементация серверной части:**
```go
func (s BasicServerImpl) MtRequestNoReply(ctx context.Context, req *StringArg) {
	s.t.Log("Отправлю в MtRequestNoReply")
	s.t.Logf("клиент отправил сообщение = %v\n", *req)
	// TODO: Обработать сообщение от клиента. Для длительных задач можно создать NoRequest API и здесь отправить клиенту сообщение, которое он будет использовать для дальнейшей обработки, например:
	s.handler.MtNoRequestPublish("default", &SimpleStringReply{Reply: "Привет"})
}

#### Mode without request (NoRequest)

The server publishes messages and the client subscribes to them.

- Server generates

  The server **does not create interface methods**, but instead creates a method `RPCMethodName + Publish` used for publishing messages.

- Client generates

  - Method `RPCMethodName + Subject` for obtaining the message topic,
  - Method `RPCMethodName + Subscribe` for asynchronous subscription to the topic,
  - Method `RPCMethodName + SubscribeSync` for synchronous subscription to the topic,
  - Method `RPCMethodName + SubscribeChan` for subscribing through a channel.

**Protocol Proto**:

```protobuf
option (nrpc.packageSubjectParams) = "instance"; // Package subject parameters

service SvcCustomSubject {
	rpc MtNoRequest(nrpc.NoRequest) returns (SimpleStringReply) {}
}

### Protocol Parameters Protobuf

- nrpc.Void — empty parameter

  Does not change the call mode; the server returns a value with errors.

- nrpc.NoReply — changes the call mode
  The client uses the PUB model, and the server does not return anything (no errors).

- nrpc.NoRequest — changes the call mode, does not create interface methods
  The server uses the PUB model for publishing messages, method signature `RPCMethodName + Publish`.
  The client subscribes to messages,

  - subscription method `RPCMethodName + Subscribe[Sync|Chan]`,
  - method for obtaining the subject of the message `RPCMethodName + Subject`.

## Characteristics

For detailed information, follow these links:

- [Load Balancing](https://github.com//nrpc/wiki/Load-Balancing)
- [Metrics Monitoring](https://github.com/teamlint/nrpc/wiki/Metrics-Instrumentation)
  using [Prometheus](https://github.com/prometheus/prometheus)

## Installation

### Installing the Proto protocol

[Download](https://github.com/protocolbuffers/protobuf) and install the protobuf protocol compiler

### Installing the protoc plugin for Go

```shell
$ go install google.golang.org/protobuf/cmd/protoc-gen-go

$ go get github.com/teamlint/nrpc/protoc-gen-nrpc
```

## Примеры

Компиляция и запуск сервера примера `greeter_server`:

```shell
$ go get github.com/teamlint/nrpc/examples/helloworld/greeter_server
$ greeter_server
Сервер работает, ^C завершает работу.
```

Компиляция и запуск клиента примера `greeter_client`:

```shell
$ go get github.com/teamlint/nrpc/examples/helloworld/greeter_client
$ greeter_client
Приветствие: Hello world
```

## Дополнительная информация

Узнайте, как использовать файлы .proto для описания сервисов gRPC, [здесь](https://grpc.io/docs/guides/concepts.html).
Дополнительная информация о NATS доступна на [официальном сайте NATS](https://nats.io/).

## Статус проекта
На данный момент поддерживаются только Go-модули.

Исходная версия была создана командой RapidLoop, а расширена и доработана командой Teamlint.

## Запланированные задачи

- Реализация времени ожидания запроса в клиенте NRPC или использование CallOption или контекста
- Переработка protoc-gen-nrpc с использованием [protogen](google.golang.org/protobuf/compiler/protogen)
- Поддержка динамического вызова различных клиентов через Hub, передача параметров пакета?