grpc server
This commit is contained in:
24
main.go
24
main.go
@@ -1,19 +1,41 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"context"
|
||||
"log"
|
||||
"net"
|
||||
"time"
|
||||
|
||||
pb "git.h3cx.dev/NulTNL/control-plane-proto-go"
|
||||
"golang.zx2c4.com/wireguard/wgctrl"
|
||||
"golang.zx2c4.com/wireguard/wgctrl/wgtypes"
|
||||
"google.golang.org/grpc"
|
||||
)
|
||||
|
||||
type server struct {
|
||||
pb.UnimplementedControlServiceServer
|
||||
}
|
||||
|
||||
func (s *server) Ping(ctx context.Context, req *pb.PingRequest) (*pb.PingResponse, error) {
|
||||
return &pb.PingResponse{Reply: "Pong: " + req.Message}, nil
|
||||
}
|
||||
|
||||
func main() {
|
||||
client, _ := wgctrl.New()
|
||||
defer client.Close()
|
||||
|
||||
newcfg(client, "OiR2n329loGJaadqvxFKScX4lK7cOpbAcSrBUmyCFD0=")
|
||||
lis, err := net.Listen("tcp", ":50051")
|
||||
if err != nil {
|
||||
log.Fatalf("failed to listen: %v", err)
|
||||
}
|
||||
|
||||
grpcServer := grpc.NewServer()
|
||||
pb.RegisterControlServiceServer(grpcServer, &server{})
|
||||
|
||||
log.Println("gRPC server running on :50051")
|
||||
if err := grpcServer.Serve(lis); err != nil {
|
||||
log.Fatalf("failed to server: %v", err)
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user