Skip to content
Snippets Groups Projects
Select Git revision
  • 0c8c31cae5d97635c3355f6ad3e104ee0b353574
  • master default protected
  • feature/PRXS-3421-ImplementNewRefAPI
  • refactor/PRXS-3053-Files
  • feature/3149-LocaleCodeAsID-Feature
  • feature/PRXS-3383-CollectionsSort
  • feature/PRXS-3143-3235-ReferenceOptions
  • feature/PRXS-3143-LimitReferenceFields
  • feature/PRXS-3234-FeaturePruneIdents
  • PRXS-3421-RecursiveReferences
  • feature/3109-SerializeFeature
  • release/0.33
  • feature/3109-RecoverySchema
  • feature/3109-feature
  • fix/PRXS-3369-ValidateFields
  • refactor/PRXS-3306-MovePkgGroup1
  • refactor/6-pkg-refactor-expr
  • fix/PRXS-3360-TemplateBuilderPatch
  • feature/3293-MongoV2
  • feature/3272-GoVersionUp
  • feature/PRXS-3218-HideTemplateActions
  • v0.33.1
  • v0.32.0
  • v0.31.1
  • v0.31.0
  • v0.30.0
  • v0.29.0
  • v0.28.0
  • v0.27.0-alpha.1+16
  • v0.27.0-alpha.1+15
  • v0.27.0-alpha.1+14
  • v0.27.0-alpha.1+13
  • v0.27.0-alpha.1+12
  • v0.27.0-alpha.1+11
  • v0.27.0-alpha.1+10
  • v0.27.0-alpha.1+9
  • v0.27.0-alpha.1+8
  • v0.27.0-alpha.1+7
  • v0.27.0-alpha.1+6
  • v0.27.0-alpha.1+5
  • v0.27.0-alpha.1+4
41 results

error_logging_middleware.go

Blame
  • manager_service_grpc.pb.go 16.56 KiB
    //*
    //
    //# Менеджер расширений
    //
    //Реализует функционал по координации расширений в системе и служит единой точкой доступа для работы с расширениями:
    //- Регистрирует все расширения в едином реестре
    //- Предоставляет доступ к реестру расширений на получение доступных расширений в системе
    //- Контролирует процесс установки расширения, устанавливает все необходимые зависимости в правильном порядке
    //- Контролирует создание системной коллекции `system_extensions` (System/Extensions) и создание/удалений в ней установленных расширений
    //- Контролирует создание системной коллекции `system_actions` (System/Actions). Выполняет удаление всех действий связанных
    //с расширением при его удалении.
    //- Выполняет переадресацию запросов на действия для расширений
    //
    //Менеджер расширений для контроля установленных расширений использует системные коллекции. При обращении к сервису контента
    //используются системный уровень прав для создания необходимых коллекций и получения данных:
    //1. `system_extensions` (System Extensions) - доступна только системным пользователям
    //2. `system_actions` (System Actions) - по умолчанию доступна только системным пользователям, настройки доступа на чтение
    //выдаются пользователям вручную. В зависимости от пользователя в интерфейсе отображаются те или иные доступные действия.
    //
    //Проверка наличия коллекций и создание в случае их отсутствия выполняется в момент установки расширений. После установки
    //расширения в коллекцию `system_extensions` добавляется запись об установленном расширении. Действия добавляются в
    //коллекцию `system_actions` расширениями по собственному усмотрению при установке.
    //
    //Для обращения к расширениям используются права текущего пользователя запрашивающего операцию. Если пользователь не
    //обладает необходимыми правами для выполнения действия то операция вернет ошибку.
    //
    
    // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
    // versions:
    // - protoc-gen-go-grpc v1.3.0
    // - protoc             v4.24.3
    // source: extensions/manager_service.proto
    
    package extensions
    
    import (
    	context "context"
    	grpc "google.golang.org/grpc"
    	codes "google.golang.org/grpc/codes"
    	status "google.golang.org/grpc/status"
    )
    
    // This is a compile-time assertion to ensure that this generated file
    // is compatible with the grpc package it is being compiled against.
    // Requires gRPC-Go v1.32.0 or later.
    const _ = grpc.SupportPackageIsVersion7
    
    const (
    	ExtensionManagerService_RegisterExtensions_FullMethodName       = "/extensions.ExtensionManagerService/RegisterExtensions"
    	ExtensionManagerService_UnregisterExtensions_FullMethodName     = "/extensions.ExtensionManagerService/UnregisterExtensions"
    	ExtensionManagerService_ListRegisteredExtensions_FullMethodName = "/extensions.ExtensionManagerService/ListRegisteredExtensions"
    	ExtensionManagerService_ListExtensions_FullMethodName           = "/extensions.ExtensionManagerService/ListExtensions"
    )
    
    // ExtensionManagerServiceClient is the client API for ExtensionManagerService service.
    //
    // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
    type ExtensionManagerServiceClient interface {
    	// ##  Регистрация расширений
    	//
    	// Регистрация\Дерегистрация происходит через сервис менеджера расширений (Extension Manager). В процессе регистрации сервис сообщает
    	// о поддерживаемых сервисом действиях (Actions) и версии сервиса и зависимостях:
    	// ~~1. Действия (Actions) - перечень действия которые обрабатываются сервисом. Включает в себя как системные действия,
    	// так и пользовательские, которые могут быть использованы в интерфейсе;~~
    	// 2. Имя сервиса/расширения - название сервиса внутри системы;
    	// 3. Версия сервиса - сервис сообщает текущую версию сервиса. Контроллер сообщает пользователю о возможности обновления
    	// расширения при смене версии;
    	// 4. Описание версии - содержит информацию об изменениях в последних версиях расширения;
    	// 5. Зависимости - перечень расширений которые необходимы сервису для функционирования. При установке сервиса
    	// все расширения, от которых он зависит, будут также установлены.
    	RegisterExtensions(ctx context.Context, in *RegisterExtensionsRequest, opts ...grpc.CallOption) (*RegisterExtensionsResponse, error)
    	UnregisterExtensions(ctx context.Context, in *UnregisterExtensionsRequest, opts ...grpc.CallOption) (*UnregisterExtensionsResponse, error)
    	// Получить список зарегистрированных сервисов
    	ListRegisteredExtensions(ctx context.Context, in *ListRegisteredExtensionsRequest, opts ...grpc.CallOption) (*ListRegisteredExtensionsResponse, error)
    	// ListExtensions - получить статус расширения
    	ListExtensions(ctx context.Context, in *ListExtensionsRequest, opts ...grpc.CallOption) (*ListExtensionsResponse, error)
    }
    
    type extensionManagerServiceClient struct {
    	cc grpc.ClientConnInterface
    }
    
    func NewExtensionManagerServiceClient(cc grpc.ClientConnInterface) ExtensionManagerServiceClient {
    	return &extensionManagerServiceClient{cc}
    }
    
    func (c *extensionManagerServiceClient) RegisterExtensions(ctx context.Context, in *RegisterExtensionsRequest, opts ...grpc.CallOption) (*RegisterExtensionsResponse, error) {
    	out := new(RegisterExtensionsResponse)
    	err := c.cc.Invoke(ctx, ExtensionManagerService_RegisterExtensions_FullMethodName, in, out, opts...)
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    func (c *extensionManagerServiceClient) UnregisterExtensions(ctx context.Context, in *UnregisterExtensionsRequest, opts ...grpc.CallOption) (*UnregisterExtensionsResponse, error) {
    	out := new(UnregisterExtensionsResponse)
    	err := c.cc.Invoke(ctx, ExtensionManagerService_UnregisterExtensions_FullMethodName, in, out, opts...)
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    func (c *extensionManagerServiceClient) ListRegisteredExtensions(ctx context.Context, in *ListRegisteredExtensionsRequest, opts ...grpc.CallOption) (*ListRegisteredExtensionsResponse, error) {
    	out := new(ListRegisteredExtensionsResponse)
    	err := c.cc.Invoke(ctx, ExtensionManagerService_ListRegisteredExtensions_FullMethodName, in, out, opts...)
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    func (c *extensionManagerServiceClient) ListExtensions(ctx context.Context, in *ListExtensionsRequest, opts ...grpc.CallOption) (*ListExtensionsResponse, error) {
    	out := new(ListExtensionsResponse)
    	err := c.cc.Invoke(ctx, ExtensionManagerService_ListExtensions_FullMethodName, in, out, opts...)
    	if err != nil {
    		return nil, err
    	}
    	return out, nil
    }
    
    // ExtensionManagerServiceServer is the server API for ExtensionManagerService service.
    // All implementations must embed UnimplementedExtensionManagerServiceServer
    // for forward compatibility
    type ExtensionManagerServiceServer interface {
    	// ##  Регистрация расширений
    	//
    	// Регистрация\Дерегистрация происходит через сервис менеджера расширений (Extension Manager). В процессе регистрации сервис сообщает
    	// о поддерживаемых сервисом действиях (Actions) и версии сервиса и зависимостях:
    	// ~~1. Действия (Actions) - перечень действия которые обрабатываются сервисом. Включает в себя как системные действия,
    	// так и пользовательские, которые могут быть использованы в интерфейсе;~~
    	// 2. Имя сервиса/расширения - название сервиса внутри системы;
    	// 3. Версия сервиса - сервис сообщает текущую версию сервиса. Контроллер сообщает пользователю о возможности обновления
    	// расширения при смене версии;
    	// 4. Описание версии - содержит информацию об изменениях в последних версиях расширения;
    	// 5. Зависимости - перечень расширений которые необходимы сервису для функционирования. При установке сервиса
    	// все расширения, от которых он зависит, будут также установлены.
    	RegisterExtensions(context.Context, *RegisterExtensionsRequest) (*RegisterExtensionsResponse, error)
    	UnregisterExtensions(context.Context, *UnregisterExtensionsRequest) (*UnregisterExtensionsResponse, error)
    	// Получить список зарегистрированных сервисов
    	ListRegisteredExtensions(context.Context, *ListRegisteredExtensionsRequest) (*ListRegisteredExtensionsResponse, error)
    	// ListExtensions - получить статус расширения
    	ListExtensions(context.Context, *ListExtensionsRequest) (*ListExtensionsResponse, error)
    	mustEmbedUnimplementedExtensionManagerServiceServer()
    }
    
    // UnimplementedExtensionManagerServiceServer must be embedded to have forward compatible implementations.
    type UnimplementedExtensionManagerServiceServer struct {
    }
    
    func (UnimplementedExtensionManagerServiceServer) RegisterExtensions(context.Context, *RegisterExtensionsRequest) (*RegisterExtensionsResponse, error) {
    	return nil, status.Errorf(codes.Unimplemented, "method RegisterExtensions not implemented")
    }
    func (UnimplementedExtensionManagerServiceServer) UnregisterExtensions(context.Context, *UnregisterExtensionsRequest) (*UnregisterExtensionsResponse, error) {
    	return nil, status.Errorf(codes.Unimplemented, "method UnregisterExtensions not implemented")
    }
    func (UnimplementedExtensionManagerServiceServer) ListRegisteredExtensions(context.Context, *ListRegisteredExtensionsRequest) (*ListRegisteredExtensionsResponse, error) {
    	return nil, status.Errorf(codes.Unimplemented, "method ListRegisteredExtensions not implemented")
    }
    func (UnimplementedExtensionManagerServiceServer) ListExtensions(context.Context, *ListExtensionsRequest) (*ListExtensionsResponse, error) {
    	return nil, status.Errorf(codes.Unimplemented, "method ListExtensions not implemented")
    }
    func (UnimplementedExtensionManagerServiceServer) mustEmbedUnimplementedExtensionManagerServiceServer() {
    }
    
    // UnsafeExtensionManagerServiceServer may be embedded to opt out of forward compatibility for this service.
    // Use of this interface is not recommended, as added methods to ExtensionManagerServiceServer will
    // result in compilation errors.
    type UnsafeExtensionManagerServiceServer interface {
    	mustEmbedUnimplementedExtensionManagerServiceServer()
    }
    
    func RegisterExtensionManagerServiceServer(s grpc.ServiceRegistrar, srv ExtensionManagerServiceServer) {
    	s.RegisterService(&ExtensionManagerService_ServiceDesc, srv)
    }
    
    func _ExtensionManagerService_RegisterExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    	in := new(RegisterExtensionsRequest)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    		return srv.(ExtensionManagerServiceServer).RegisterExtensions(ctx, in)
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    		FullMethod: ExtensionManagerService_RegisterExtensions_FullMethodName,
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    		return srv.(ExtensionManagerServiceServer).RegisterExtensions(ctx, req.(*RegisterExtensionsRequest))
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    func _ExtensionManagerService_UnregisterExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    	in := new(UnregisterExtensionsRequest)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    		return srv.(ExtensionManagerServiceServer).UnregisterExtensions(ctx, in)
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    		FullMethod: ExtensionManagerService_UnregisterExtensions_FullMethodName,
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    		return srv.(ExtensionManagerServiceServer).UnregisterExtensions(ctx, req.(*UnregisterExtensionsRequest))
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    func _ExtensionManagerService_ListRegisteredExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    	in := new(ListRegisteredExtensionsRequest)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    		return srv.(ExtensionManagerServiceServer).ListRegisteredExtensions(ctx, in)
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    		FullMethod: ExtensionManagerService_ListRegisteredExtensions_FullMethodName,
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    		return srv.(ExtensionManagerServiceServer).ListRegisteredExtensions(ctx, req.(*ListRegisteredExtensionsRequest))
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    func _ExtensionManagerService_ListExtensions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    	in := new(ListExtensionsRequest)
    	if err := dec(in); err != nil {
    		return nil, err
    	}
    	if interceptor == nil {
    		return srv.(ExtensionManagerServiceServer).ListExtensions(ctx, in)
    	}
    	info := &grpc.UnaryServerInfo{
    		Server:     srv,
    		FullMethod: ExtensionManagerService_ListExtensions_FullMethodName,
    	}
    	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
    		return srv.(ExtensionManagerServiceServer).ListExtensions(ctx, req.(*ListExtensionsRequest))
    	}
    	return interceptor(ctx, in, info, handler)
    }
    
    // ExtensionManagerService_ServiceDesc is the grpc.ServiceDesc for ExtensionManagerService service.
    // It's only intended for direct use with grpc.RegisterService,
    // and not to be introspected or modified (even as a copy)
    var ExtensionManagerService_ServiceDesc = grpc.ServiceDesc{
    	ServiceName: "extensions.ExtensionManagerService",
    	HandlerType: (*ExtensionManagerServiceServer)(nil),
    	Methods: []grpc.MethodDesc{
    		{
    			MethodName: "RegisterExtensions",
    			Handler:    _ExtensionManagerService_RegisterExtensions_Handler,
    		},
    		{
    			MethodName: "UnregisterExtensions",
    			Handler:    _ExtensionManagerService_UnregisterExtensions_Handler,
    		},
    		{
    			MethodName: "ListRegisteredExtensions",
    			Handler:    _ExtensionManagerService_ListRegisteredExtensions_Handler,
    		},
    		{
    			MethodName: "ListExtensions",
    			Handler:    _ExtensionManagerService_ListExtensions_Handler,
    		},
    	},
    	Streams:  []grpc.StreamDesc{},
    	Metadata: "extensions/manager_service.proto",
    }