grpc

Documentation

Index

• type CNS
  • 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
  • func NewServer(settings ServerSettings, cnsService pb.CNSServer, logger *zap.Logger) (*Server, error)
  • func (s *Server) Start() error
• type ServerSettings

Types

type CNS

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

CNSService defines the CNS gRPC service.

func (*CNS) GetNodeInfo

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

func (*CNS) SetOrchestratorInfo

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

type Server

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

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

NewServer initializes a new gRPC server instance.

func (*Server) Start

func (s *Server) Start() error

Start starts the gRPC server.

type ServerSettings

type ServerSettings struct {
	IPAddress string
	Port      uint16
}

GrpcServerSettings holds the gRPC server settings.