drpcauth

Documentation

Overview

Package drpcauth implements the same functionality as package httpauth but with DRPC as transport.

This way the Auth service can be called with libuplink without requiring a HTTP client as a dependency.

Currently no authentication is required for this functionality.

Index

• func StartListen(ctx context.Context, authServer pb.DRPCEdgeAuthServer, ...) (err error)
• type Server
  • func NewServer(log *zap.Logger, db *authdb.Database, endpoint *url.URL, ...) *Server
  • func (g *Server) RegisterAccess(ctx context.Context, request *pb.EdgeRegisterAccessRequest) (_ *pb.EdgeRegisterAccessResponse, err error)

Functions

func StartListen

func StartListen(
	ctx context.Context,
	authServer pb.DRPCEdgeAuthServer,
	maximumBuffer memory.Size,
	listener net.Listener,
) (err error)

StartListen start a DRPC server on the given listener.

Types

type Server

type Server struct {
	pb.DRPCEdgeAuthServer
	// contains filtered or unexported fields
}

Server is a collection of dependencies for the DRPC-based service It is an interface for clients like Uplink to use the auth service.

func NewServer

func NewServer(
	log *zap.Logger,
	db *authdb.Database,
	endpoint *url.URL,
	accessGrantSizeLimit memory.Size,
) *Server

NewServer creates a Server that is not running.

func (*Server) RegisterAccess

func (g *Server) RegisterAccess(
	ctx context.Context,
	request *pb.EdgeRegisterAccessRequest,
) (_ *pb.EdgeRegisterAccessResponse, err error)

RegisterAccess implements interface DRPCEdgeAuthServer. Wraps the actual functionality with logging.