grpc

Documentation

Overview

Package grpc provides the gRPC server for Liqo Controller Manager.

Index

• type Server
  • func NewGrpcServer(cl client.Client) *Server
  • func (s *Server) GetOfferResourcesByClusterID(clusterID string) (map[string]*resource.Quantity, error)
  • func (s *Server) NotifyChange(ctx context.Context, req *resourcemonitors.ClusterIdentity) error
  • func (s *Server) ReadResources(ctx context.Context, req *resourcemonitors.ClusterIdentity) (*resourcemonitors.PoolResourceList, error)
  • func (s *Server) RemoveCluster(ctx context.Context, req *resourcemonitors.ClusterIdentity) (*resourcemonitors.Empty, error)
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Subscribe(req *resourcemonitors.Empty, ...) error
  • func (s *Server) UpdatePeeringOffer(clusterID string)

Types

type Server

type Server struct {
	Server *grpc.Server

	resourcemonitors.ResourceReaderServer
	// contains filtered or unexported fields
}

Server is the object that contains all the logical data stractures of the REAR gRPC Server.

func NewGrpcServer

func NewGrpcServer(cl client.Client) *Server

NewGrpcServer creates a new gRPC server.

func (*Server) GetOfferResourcesByClusterID

func (s *Server) GetOfferResourcesByClusterID(clusterID string) (map[string]*resource.Quantity, error)

GetOfferResourcesByClusterID is the method that returns the resources assigned to a specific ClusterID.

func (*Server) NotifyChange

func (s *Server) NotifyChange(ctx context.Context, req *resourcemonitors.ClusterIdentity) error

NotifyChange is the method that notifies a change to the Liqo controller manager.

func (*Server) ReadResources

func (s *Server) ReadResources(ctx context.Context, req *resourcemonitors.ClusterIdentity) (*resourcemonitors.PoolResourceList, error)

ReadResources is the method that returns the resources assigned to a specific ClusterID.

func (*Server) RemoveCluster

func (s *Server) RemoveCluster(ctx context.Context, req *resourcemonitors.ClusterIdentity) (*resourcemonitors.Empty, error)

RemoveCluster is the method that removes a cluster from the gRPC server.

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

Start starts the gRPC server.

func (*Server) Subscribe

func (s *Server) Subscribe(req *resourcemonitors.Empty, srv resourcemonitors.ResourceReader_SubscribeServer) error

Subscribe is the method that subscribes a the Liqo controller manager to the gRPC server.

func (*Server) UpdatePeeringOffer

func (s *Server) UpdatePeeringOffer(clusterID string)

UpdatePeeringOffer is the method that updates the peering offer.