api

func ErrorInterceptor() grpc.UnaryServerInterceptor

func ErrorStreamInterceptor() grpc.StreamServerInterceptor

func GRPCGateway(ctx context.Context, conf Config, metricsHandler http.HandlerFunc, oauthHandlers map[string]http.HandlerFunc) (http.Handler, error)

func NewAuthAPI(svc *auth.Server) pb.AuthServer

func NewClusterAPI(radosSvc *rados.Svc) pb.ClusterServer

func NewCrushRuleAPI(radosSvc *rados.Svc) pb.CrushRuleServer

func NewGrpcServer(conf Config,
	clusterAPI pb.ClusterServer,
	usersAPI pb.UsersServer,
	authAPI pb.AuthServer,
	crushRuleAPI pb.CrushRuleServer,
	statusAPI pb.StatusServer,
	authN grpc_auth.AuthFunc,
	tracer otel_trace.TracerProvider,
	logConf log.Config) *grpc.Server

func NewStatusAPI(radosSvc *rados.Svc) pb.StatusServer

func NewUsersAPI(svc *user.Service) pb.UsersServer

func Serve(ctx context.Context, conf Config, grpcServer *grpc.Server, httpServer http.Handler) (start func(context.Context) error, stop func(context.Context) error, err error)