23 lines
511 B
Go
23 lines
511 B
Go
package echoservice
|
|
|
|
import (
|
|
"context"
|
|
"github.com/nats-io/nats.go/micro"
|
|
nats_service "github.com/telemac/plugisservice/pkg/nats-service"
|
|
"time"
|
|
)
|
|
|
|
var pingEndpoint = nats_service.EndpointConfig{
|
|
Name: "ping",
|
|
Handler: func(ctx context.Context, request micro.Request) (any, error) {
|
|
data := request.Data()
|
|
_ = data
|
|
return "ping: " + string(data), nil
|
|
},
|
|
MaxConcurrency: 10,
|
|
RequestTimeout: 2 * time.Second,
|
|
Metadata: map[string]string{
|
|
"description": "ping",
|
|
"version": "0.0.1",
|
|
},
|
|
}
|