grpc

package

v1.6.8 Latest Latest Go to latest Published: Sep 16, 2024 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CNS struct {
	pb.UnimplementedCNSServer
	Logger *zap.Logger
	State  *restserver.HTTPRestService
}

CNSService defines the CNS gRPC service.

func (s *CNS) GetNodeInfo(_ context.Context, req *pb.NodeInfoRequest) (*pb.NodeInfoResponse, error)

func (s *CNS) SetOrchestratorInfo(_ context.Context, req *pb.SetOrchestratorInfoRequest) (*pb.SetOrchestratorInfoResponse, error)

type Server struct {
	Settings   ServerSettings
	CnsService pb.CNSServer
	Logger     *zap.Logger
}

Server struct to hold the gRPC server settings and the CNS service.

func NewServer(settings ServerSettings, cnsService pb.CNSServer, logger *zap.Logger) (*Server, error)

NewServer initializes a new gRPC server instance.

func (s *Server) Start() error

Start starts the gRPC server.

type ServerSettings struct {
	IPAddress string
	Port      uint16
}

GrpcServerSettings holds the gRPC server settings.

Path	Synopsis
v1alpha