server

Documentation

Overview

Package server provides a ResourceDiscovery gRPC server implementation. It can either be used a standalone server, using the binary in the "cmd" subdirectory, or it can run as a part of the cloudprober binary.

Index

• type Provider
• type Server
  • func New(initCtx context.Context, c *configpb.ServerConf, providers map[string]Provider, ...) (*Server, error)
  • func (s *Server) ListResources(ctx context.Context, req *pb.ListResourcesRequest) (*pb.ListResourcesResponse, error)
  • func (s *Server) RegisterWithGRPC(grpcServer *grpc.Server)

Types

type Provider

type Provider interface {
	ListResources(req *pb.ListResourcesRequest) (*pb.ListResourcesResponse, error)
}

Provider is a resource provider, e.g. GCP provider.

type Server

type Server struct {

	// Required for all gRPC server implementations.
	spb.UnimplementedResourceDiscoveryServer
	// contains filtered or unexported fields
}

Server implements a ResourceDiscovery gRPC server.

func New

func New(initCtx context.Context, c *configpb.ServerConf, providers map[string]Provider, l *logger.Logger) (*Server, error)

New creates a new instance of the ResourceDiscovery Server using the server conf.

func (*Server) ListResources

func (s *Server) ListResources(ctx context.Context, req *pb.ListResourcesRequest) (*pb.ListResourcesResponse, error)

ListResources implements the ListResources method of the ResourceDiscovery service.

func (*Server) RegisterWithGRPC

func (s *Server) RegisterWithGRPC(grpcServer *grpc.Server)

RegisterWithGRPC registers the RDS servers with the given gRPC server.