28 lines
555 B
Go
28 lines
555 B
Go
|
package app
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"google.golang.org/grpc"
|
||
|
|
"parsing-service/internal/appState"
|
||
|
|
pb "parsing-service/proto/taskProcessor"
|
||
|
|
)
|
||
|
|
|
||
|
|
type Server struct {
|
||
|
|
pb.UnimplementedTaskProcessorServer
|
||
|
|
state *appState.State
|
||
|
|
}
|
||
|
|
|
||
|
|
func newServer(app *App) *grpc.Server {
|
||
|
|
s := grpc.NewServer()
|
||
|
|
srv := &Server{
|
||
|
|
state: app.State,
|
||
|
|
}
|
||
|
|
pb.RegisterTaskProcessorServer(s, srv)
|
||
|
|
return s
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *Server) ProcessorStatus(_ context.Context, _ *pb.ProcessorStatusRequest) (*pb.ProcessorStatusResponse, error) {
|
||
|
|
resp := s.state.StateResponse()
|
||
|
|
return resp, nil
|
||
|
|
}
|