Skip to content
Snippets Groups Projects
Commit 78b669bd authored by Pavel Antonov's avatar Pavel Antonov :asterisk:
Browse files

Merge branch 'feature/init-repo' into 'master'

Реализована golang библиотека для разработки программного обеспечения на базе Perxis

See merge request perxis/perxis-go!1
parents 7c3a6d19 4832e934
No related branches found
No related tags found
No related merge requests found
Showing
with 13316 additions and 0 deletions
.idea
\ No newline at end of file
[submodule "perxis-proto"]
path = perxis-proto
url = https://git.perx.ru/perxis/perxis-proto.git
Makefile 0 → 100644
PROTODIR=perxis-proto/proto
DSTDIR=clients
ALLPROTO?=$(shell find $(PROTODIR) -name '*.proto' )
# Убираем status.proto нужен только для front
PROTOFILES= $(filter-out $(PROTODIR)/status/status.proto, $(ALLPROTO))
PROTOGOFILES=$(PROTOFILES:.proto=.pb.go)
PROTOGOGRPCFILES=$(PROTOFILES:.proto=_grpc.pb.go)
# Генерация grpc-клиентов для go
proto: protoc-check protoc-gen-go-check $(PROTOGOFILES) $(PROTOGOGRPCFILES)
@echo "Generated all protobuf Go files"
%.pb.go %_grpc.pb.go: %.proto
@protoc -I=$(PROTODIR) --experimental_allow_proto3_optional --go_out=$(DSTDIR) --go-grpc_out=$(DSTDIR) --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative "$<"
proto-clean:
@rm -f $(PROTOGOFILES) -f $(PROTOGOGRPCFILES)
# Helpers
#
# Проверка, что установлен компилятор для Protobuf
protoc-check:
ifeq (,$(shell which protoc))
$(error "Protocol Buffers not found. Run \"brew install protobuf\" \
or visit \"https://grpc.io/docs/protoc-installation/#install-using-a-package-manager\" for more.\n")
endif
# Проверяется, установлен ли 'protoc-gen-go' - плагин для генерации GRPC-Go клиента
protoc-gen-go-check:
ifeq (,$(wildcard $(GOPATH)/bin/protoc-gen-go))
$(error "Protocol Buffers Go plugin not found. \
Run \"go get -u google.golang.org/protobuf/cmd/protoc-gen-go google.golang.org/grpc/cmd/protoc-gen-go-grpc\" \
or visit \"https://github.com/golang/protobuf/tree/v1.3.2#installation\" for more.\n")
endif
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.20.1
// source: clients/clients.proto
package clients
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
// 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
// ClientsClient is the client API for Clients 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 ClientsClient interface {
// Create - создает клиента (приложение) для работы с API
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
// Get - возвращает клиента по id
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
// GetByClientID - возвращает клиента по clientId системы авторизации
GetBy(ctx context.Context, in *GetByRequest, opts ...grpc.CallOption) (*GetByResponse, error)
// Update - обновляет параметры клиента
Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// List - возвращает список клиентов созданных в пространстве
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
// Delete - удаляет указанного клиента из пространстве
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Enable - активирует/деактивирует клиента. Клиент не сможет обращаться к API платформы
Enable(ctx context.Context, in *EnableRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
type clientsClient struct {
cc grpc.ClientConnInterface
}
func NewClientsClient(cc grpc.ClientConnInterface) ClientsClient {
return &clientsClient{cc}
}
func (c *clientsClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
out := new(CreateResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Create", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
out := new(GetResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Get", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) GetBy(ctx context.Context, in *GetByRequest, opts ...grpc.CallOption) (*GetByResponse, error) {
out := new(GetByResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/GetBy", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Update", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
out := new(ListResponse)
err := c.cc.Invoke(ctx, "/content.clients.Clients/List", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Delete", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *clientsClient) Enable(ctx context.Context, in *EnableRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.clients.Clients/Enable", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// ClientsServer is the server API for Clients service.
// All implementations must embed UnimplementedClientsServer
// for forward compatibility
type ClientsServer interface {
// Create - создает клиента (приложение) для работы с API
Create(context.Context, *CreateRequest) (*CreateResponse, error)
// Get - возвращает клиента по id
Get(context.Context, *GetRequest) (*GetResponse, error)
// GetByClientID - возвращает клиента по clientId системы авторизации
GetBy(context.Context, *GetByRequest) (*GetByResponse, error)
// Update - обновляет параметры клиента
Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)
// List - возвращает список клиентов созданных в пространстве
List(context.Context, *ListRequest) (*ListResponse, error)
// Delete - удаляет указанного клиента из пространстве
Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
// Enable - активирует/деактивирует клиента. Клиент не сможет обращаться к API платформы
Enable(context.Context, *EnableRequest) (*emptypb.Empty, error)
mustEmbedUnimplementedClientsServer()
}
// UnimplementedClientsServer must be embedded to have forward compatible implementations.
type UnimplementedClientsServer struct {
}
func (UnimplementedClientsServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
}
func (UnimplementedClientsServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
}
func (UnimplementedClientsServer) GetBy(context.Context, *GetByRequest) (*GetByResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetBy not implemented")
}
func (UnimplementedClientsServer) Update(context.Context, *UpdateRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
}
func (UnimplementedClientsServer) List(context.Context, *ListRequest) (*ListResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
}
func (UnimplementedClientsServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
}
func (UnimplementedClientsServer) Enable(context.Context, *EnableRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Enable not implemented")
}
func (UnimplementedClientsServer) mustEmbedUnimplementedClientsServer() {}
// UnsafeClientsServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ClientsServer will
// result in compilation errors.
type UnsafeClientsServer interface {
mustEmbedUnimplementedClientsServer()
}
func RegisterClientsServer(s grpc.ServiceRegistrar, srv ClientsServer) {
s.RegisterService(&Clients_ServiceDesc, srv)
}
func _Clients_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Create(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Create",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Create(ctx, req.(*CreateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Get(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Get",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Get(ctx, req.(*GetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_GetBy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetByRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).GetBy(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/GetBy",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).GetBy(ctx, req.(*GetByRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Update(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Update",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Update(ctx, req.(*UpdateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).List(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/List",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).List(ctx, req.(*ListRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Delete(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Delete",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Delete(ctx, req.(*DeleteRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Clients_Enable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EnableRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ClientsServer).Enable(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.clients.Clients/Enable",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ClientsServer).Enable(ctx, req.(*EnableRequest))
}
return interceptor(ctx, in, info, handler)
}
// Clients_ServiceDesc is the grpc.ServiceDesc for Clients service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Clients_ServiceDesc = grpc.ServiceDesc{
ServiceName: "content.clients.Clients",
HandlerType: (*ClientsServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Create",
Handler: _Clients_Create_Handler,
},
{
MethodName: "Get",
Handler: _Clients_Get_Handler,
},
{
MethodName: "GetBy",
Handler: _Clients_GetBy_Handler,
},
{
MethodName: "Update",
Handler: _Clients_Update_Handler,
},
{
MethodName: "List",
Handler: _Clients_List_Handler,
},
{
MethodName: "Delete",
Handler: _Clients_Delete_Handler,
},
{
MethodName: "Enable",
Handler: _Clients_Enable_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "clients/clients.proto",
}
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.20.1
// source: collaborators/collaborators.proto
package collaborators
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
// 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
// CollaboratorsClient is the client API for Collaborators 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 CollaboratorsClient interface {
Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
ListCollaborators(ctx context.Context, in *ListCollaboratorsRequest, opts ...grpc.CallOption) (*ListCollaboratorsResponse, error)
ListSpaces(ctx context.Context, in *ListSpacesRequest, opts ...grpc.CallOption) (*ListSpacesResponse, error)
}
type collaboratorsClient struct {
cc grpc.ClientConnInterface
}
func NewCollaboratorsClient(cc grpc.ClientConnInterface) CollaboratorsClient {
return &collaboratorsClient{cc}
}
func (c *collaboratorsClient) Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/Set", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
out := new(GetResponse)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/Get", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/Remove", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) ListCollaborators(ctx context.Context, in *ListCollaboratorsRequest, opts ...grpc.CallOption) (*ListCollaboratorsResponse, error) {
out := new(ListCollaboratorsResponse)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/ListCollaborators", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collaboratorsClient) ListSpaces(ctx context.Context, in *ListSpacesRequest, opts ...grpc.CallOption) (*ListSpacesResponse, error) {
out := new(ListSpacesResponse)
err := c.cc.Invoke(ctx, "/content.collaborators.Collaborators/ListSpaces", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// CollaboratorsServer is the server API for Collaborators service.
// All implementations must embed UnimplementedCollaboratorsServer
// for forward compatibility
type CollaboratorsServer interface {
Set(context.Context, *SetRequest) (*emptypb.Empty, error)
Get(context.Context, *GetRequest) (*GetResponse, error)
Remove(context.Context, *RemoveRequest) (*emptypb.Empty, error)
ListCollaborators(context.Context, *ListCollaboratorsRequest) (*ListCollaboratorsResponse, error)
ListSpaces(context.Context, *ListSpacesRequest) (*ListSpacesResponse, error)
mustEmbedUnimplementedCollaboratorsServer()
}
// UnimplementedCollaboratorsServer must be embedded to have forward compatible implementations.
type UnimplementedCollaboratorsServer struct {
}
func (UnimplementedCollaboratorsServer) Set(context.Context, *SetRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Set not implemented")
}
func (UnimplementedCollaboratorsServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
}
func (UnimplementedCollaboratorsServer) Remove(context.Context, *RemoveRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Remove not implemented")
}
func (UnimplementedCollaboratorsServer) ListCollaborators(context.Context, *ListCollaboratorsRequest) (*ListCollaboratorsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListCollaborators not implemented")
}
func (UnimplementedCollaboratorsServer) ListSpaces(context.Context, *ListSpacesRequest) (*ListSpacesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListSpaces not implemented")
}
func (UnimplementedCollaboratorsServer) mustEmbedUnimplementedCollaboratorsServer() {}
// UnsafeCollaboratorsServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to CollaboratorsServer will
// result in compilation errors.
type UnsafeCollaboratorsServer interface {
mustEmbedUnimplementedCollaboratorsServer()
}
func RegisterCollaboratorsServer(s grpc.ServiceRegistrar, srv CollaboratorsServer) {
s.RegisterService(&Collaborators_ServiceDesc, srv)
}
func _Collaborators_Set_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).Set(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/Set",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).Set(ctx, req.(*SetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).Get(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/Get",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).Get(ctx, req.(*GetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_Remove_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RemoveRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).Remove(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/Remove",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).Remove(ctx, req.(*RemoveRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_ListCollaborators_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListCollaboratorsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).ListCollaborators(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/ListCollaborators",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).ListCollaborators(ctx, req.(*ListCollaboratorsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collaborators_ListSpaces_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListSpacesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollaboratorsServer).ListSpaces(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collaborators.Collaborators/ListSpaces",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollaboratorsServer).ListSpaces(ctx, req.(*ListSpacesRequest))
}
return interceptor(ctx, in, info, handler)
}
// Collaborators_ServiceDesc is the grpc.ServiceDesc for Collaborators service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Collaborators_ServiceDesc = grpc.ServiceDesc{
ServiceName: "content.collaborators.Collaborators",
HandlerType: (*CollaboratorsServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Set",
Handler: _Collaborators_Set_Handler,
},
{
MethodName: "Get",
Handler: _Collaborators_Get_Handler,
},
{
MethodName: "Remove",
Handler: _Collaborators_Remove_Handler,
},
{
MethodName: "ListCollaborators",
Handler: _Collaborators_ListCollaborators_Handler,
},
{
MethodName: "ListSpaces",
Handler: _Collaborators_ListSpaces_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "collaborators/collaborators.proto",
}
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.20.1
// source: collections/collections.proto
package collections
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
emptypb "google.golang.org/protobuf/types/known/emptypb"
)
// 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
// CollectionsClient is the client API for Collections 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 CollectionsClient interface {
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
SetSchema(ctx context.Context, in *SetSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
type collectionsClient struct {
cc grpc.ClientConnInterface
}
func NewCollectionsClient(cc grpc.ClientConnInterface) CollectionsClient {
return &collectionsClient{cc}
}
func (c *collectionsClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
out := new(CreateResponse)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Create", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
out := new(GetResponse)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Get", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
out := new(ListResponse)
err := c.cc.Invoke(ctx, "/content.collections.Collections/List", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Update", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) SetSchema(ctx context.Context, in *SetSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collections.Collections/SetSchema", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *collectionsClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
out := new(emptypb.Empty)
err := c.cc.Invoke(ctx, "/content.collections.Collections/Delete", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// CollectionsServer is the server API for Collections service.
// All implementations must embed UnimplementedCollectionsServer
// for forward compatibility
type CollectionsServer interface {
Create(context.Context, *CreateRequest) (*CreateResponse, error)
Get(context.Context, *GetRequest) (*GetResponse, error)
List(context.Context, *ListRequest) (*ListResponse, error)
Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)
SetSchema(context.Context, *SetSchemaRequest) (*emptypb.Empty, error)
Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
mustEmbedUnimplementedCollectionsServer()
}
// UnimplementedCollectionsServer must be embedded to have forward compatible implementations.
type UnimplementedCollectionsServer struct {
}
func (UnimplementedCollectionsServer) Create(context.Context, *CreateRequest) (*CreateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
}
func (UnimplementedCollectionsServer) Get(context.Context, *GetRequest) (*GetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
}
func (UnimplementedCollectionsServer) List(context.Context, *ListRequest) (*ListResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
}
func (UnimplementedCollectionsServer) Update(context.Context, *UpdateRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
}
func (UnimplementedCollectionsServer) SetSchema(context.Context, *SetSchemaRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method SetSchema not implemented")
}
func (UnimplementedCollectionsServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
}
func (UnimplementedCollectionsServer) mustEmbedUnimplementedCollectionsServer() {}
// UnsafeCollectionsServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to CollectionsServer will
// result in compilation errors.
type UnsafeCollectionsServer interface {
mustEmbedUnimplementedCollectionsServer()
}
func RegisterCollectionsServer(s grpc.ServiceRegistrar, srv CollectionsServer) {
s.RegisterService(&Collections_ServiceDesc, srv)
}
func _Collections_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Create(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Create",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Create(ctx, req.(*CreateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Get(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Get",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Get(ctx, req.(*GetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).List(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/List",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).List(ctx, req.(*ListRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Update(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Update",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Update(ctx, req.(*UpdateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_SetSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SetSchemaRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).SetSchema(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/SetSchema",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).SetSchema(ctx, req.(*SetSchemaRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Collections_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CollectionsServer).Delete(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/content.collections.Collections/Delete",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CollectionsServer).Delete(ctx, req.(*DeleteRequest))
}
return interceptor(ctx, in, info, handler)
}
// Collections_ServiceDesc is the grpc.ServiceDesc for Collections service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Collections_ServiceDesc = grpc.ServiceDesc{
ServiceName: "content.collections.Collections",
HandlerType: (*CollectionsServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Create",
Handler: _Collections_Create_Handler,
},
{
MethodName: "Get",
Handler: _Collections_Get_Handler,
},
{
MethodName: "List",
Handler: _Collections_List_Handler,
},
{
MethodName: "Update",
Handler: _Collections_Update_Handler,
},
{
MethodName: "SetSchema",
Handler: _Collections_SetSchema_Handler,
},
{
MethodName: "Delete",
Handler: _Collections_Delete_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "collections/collections.proto",
}
This diff is collapsed.
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.20.1
// source: delivery/delivery.proto
package delivery
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
// DeliveryClient is the client API for Delivery 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 DeliveryClient interface {
ListLocales(ctx context.Context, in *ListLocalesRequest, opts ...grpc.CallOption) (*ListLocalesResponse, error)
GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*GetEnvironmentResponse, error)
ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)
GetCollection(ctx context.Context, in *GetCollectionRequest, opts ...grpc.CallOption) (*GetCollectionResponse, error)
ListCollections(ctx context.Context, in *ListCollectionsRequest, opts ...grpc.CallOption) (*ListCollectionsResponse, error)
GetItem(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*GetItemResponse, error)
FindItems(ctx context.Context, in *FindItemsRequest, opts ...grpc.CallOption) (*FindItemsResponse, error)
}
type deliveryClient struct {
cc grpc.ClientConnInterface
}
func NewDeliveryClient(cc grpc.ClientConnInterface) DeliveryClient {
return &deliveryClient{cc}
}
func (c *deliveryClient) ListLocales(ctx context.Context, in *ListLocalesRequest, opts ...grpc.CallOption) (*ListLocalesResponse, error) {
out := new(ListLocalesResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/ListLocales", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*GetEnvironmentResponse, error) {
out := new(GetEnvironmentResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/GetEnvironment", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error) {
out := new(ListEnvironmentsResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/ListEnvironments", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) GetCollection(ctx context.Context, in *GetCollectionRequest, opts ...grpc.CallOption) (*GetCollectionResponse, error) {
out := new(GetCollectionResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/GetCollection", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) ListCollections(ctx context.Context, in *ListCollectionsRequest, opts ...grpc.CallOption) (*ListCollectionsResponse, error) {
out := new(ListCollectionsResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/ListCollections", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) GetItem(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*GetItemResponse, error) {
out := new(GetItemResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/GetItem", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *deliveryClient) FindItems(ctx context.Context, in *FindItemsRequest, opts ...grpc.CallOption) (*FindItemsResponse, error) {
out := new(FindItemsResponse)
err := c.cc.Invoke(ctx, "/delivery.Delivery/FindItems", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// DeliveryServer is the server API for Delivery service.
// All implementations must embed UnimplementedDeliveryServer
// for forward compatibility
type DeliveryServer interface {
ListLocales(context.Context, *ListLocalesRequest) (*ListLocalesResponse, error)
GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentResponse, error)
ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
GetCollection(context.Context, *GetCollectionRequest) (*GetCollectionResponse, error)
ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsResponse, error)
GetItem(context.Context, *GetItemRequest) (*GetItemResponse, error)
FindItems(context.Context, *FindItemsRequest) (*FindItemsResponse, error)
mustEmbedUnimplementedDeliveryServer()
}
// UnimplementedDeliveryServer must be embedded to have forward compatible implementations.
type UnimplementedDeliveryServer struct {
}
func (UnimplementedDeliveryServer) ListLocales(context.Context, *ListLocalesRequest) (*ListLocalesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListLocales not implemented")
}
func (UnimplementedDeliveryServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetEnvironment not implemented")
}
func (UnimplementedDeliveryServer) ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListEnvironments not implemented")
}
func (UnimplementedDeliveryServer) GetCollection(context.Context, *GetCollectionRequest) (*GetCollectionResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetCollection not implemented")
}
func (UnimplementedDeliveryServer) ListCollections(context.Context, *ListCollectionsRequest) (*ListCollectionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListCollections not implemented")
}
func (UnimplementedDeliveryServer) GetItem(context.Context, *GetItemRequest) (*GetItemResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetItem not implemented")
}
func (UnimplementedDeliveryServer) FindItems(context.Context, *FindItemsRequest) (*FindItemsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method FindItems not implemented")
}
func (UnimplementedDeliveryServer) mustEmbedUnimplementedDeliveryServer() {}
// UnsafeDeliveryServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to DeliveryServer will
// result in compilation errors.
type UnsafeDeliveryServer interface {
mustEmbedUnimplementedDeliveryServer()
}
func RegisterDeliveryServer(s grpc.ServiceRegistrar, srv DeliveryServer) {
s.RegisterService(&Delivery_ServiceDesc, srv)
}
func _Delivery_ListLocales_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListLocalesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).ListLocales(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/ListLocales",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).ListLocales(ctx, req.(*ListLocalesRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_GetEnvironment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetEnvironmentRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).GetEnvironment(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/GetEnvironment",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).GetEnvironment(ctx, req.(*GetEnvironmentRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_ListEnvironments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListEnvironmentsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).ListEnvironments(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/ListEnvironments",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).ListEnvironments(ctx, req.(*ListEnvironmentsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_GetCollection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetCollectionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).GetCollection(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/GetCollection",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).GetCollection(ctx, req.(*GetCollectionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_ListCollections_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListCollectionsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).ListCollections(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/ListCollections",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).ListCollections(ctx, req.(*ListCollectionsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_GetItem_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetItemRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).GetItem(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/GetItem",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).GetItem(ctx, req.(*GetItemRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Delivery_FindItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(FindItemsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(DeliveryServer).FindItems(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/delivery.Delivery/FindItems",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(DeliveryServer).FindItems(ctx, req.(*FindItemsRequest))
}
return interceptor(ctx, in, info, handler)
}
// Delivery_ServiceDesc is the grpc.ServiceDesc for Delivery service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Delivery_ServiceDesc = grpc.ServiceDesc{
ServiceName: "delivery.Delivery",
HandlerType: (*DeliveryServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "ListLocales",
Handler: _Delivery_ListLocales_Handler,
},
{
MethodName: "GetEnvironment",
Handler: _Delivery_GetEnvironment_Handler,
},
{
MethodName: "ListEnvironments",
Handler: _Delivery_ListEnvironments_Handler,
},
{
MethodName: "GetCollection",
Handler: _Delivery_GetCollection_Handler,
},
{
MethodName: "ListCollections",
Handler: _Delivery_ListCollections_Handler,
},
{
MethodName: "GetItem",
Handler: _Delivery_GetItem_Handler,
},
{
MethodName: "FindItems",
Handler: _Delivery_FindItems_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "delivery/delivery.proto",
}
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
This diff is collapsed.
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.20.1
// source: extensions/manager.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
// ExtensionManagerClient is the client API for ExtensionManager 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 ExtensionManagerClient 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)
// Получить список зарегистрированных сервисов
ListExtensions(ctx context.Context, in *ListExtensionsRequest, opts ...grpc.CallOption) (*ListExtensionsResponse, error)
}
type extensionManagerClient struct {
cc grpc.ClientConnInterface
}
func NewExtensionManagerClient(cc grpc.ClientConnInterface) ExtensionManagerClient {
return &extensionManagerClient{cc}
}
func (c *extensionManagerClient) RegisterExtensions(ctx context.Context, in *RegisterExtensionsRequest, opts ...grpc.CallOption) (*RegisterExtensionsResponse, error) {
out := new(RegisterExtensionsResponse)
err := c.cc.Invoke(ctx, "/extensions.ExtensionManager/RegisterExtensions", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *extensionManagerClient) UnregisterExtensions(ctx context.Context, in *UnregisterExtensionsRequest, opts ...grpc.CallOption) (*UnregisterExtensionsResponse, error) {
out := new(UnregisterExtensionsResponse)
err := c.cc.Invoke(ctx, "/extensions.ExtensionManager/UnregisterExtensions", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *extensionManagerClient) ListExtensions(ctx context.Context, in *ListExtensionsRequest, opts ...grpc.CallOption) (*ListExtensionsResponse, error) {
out := new(ListExtensionsResponse)
err := c.cc.Invoke(ctx, "/extensions.ExtensionManager/ListExtensions", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// ExtensionManagerServer is the server API for ExtensionManager service.
// All implementations must embed UnimplementedExtensionManagerServer
// for forward compatibility
type ExtensionManagerServer interface {
// ## Регистрация расширений
//
// Регистрация\Дерегистрация происходить через сервис менеджера расширений (Extension Manager). В процессе регистрации сервис сообщает
// о поддерживаемых сервисом действиях (Actions) и версии сервиса и зависимостях:
// 1. Действия (Actions) - перечень действия которые обрабатываются сервисом. Включает в себя как системные действия,
// так и пользовательские, которые могут быть использованы в интерфейсе;
// 2. Имя сервиса/расширения - название сервиса внутри системы;
// 3. Версия сервиса - сервис сообщает текущую версию сервиса. Контроллер сообщает пользователю о возможности обновления
// расширения при смене версии;
// 4. Описание версии - содержит информацию об изменениях в последних версиях расширения;
// 5. Зависимости - перечень расширений которые необходимы сервису для функционирования. При установке сервиса
// все расширения от которых он зависит, будут так же установлены.
RegisterExtensions(context.Context, *RegisterExtensionsRequest) (*RegisterExtensionsResponse, error)
UnregisterExtensions(context.Context, *UnregisterExtensionsRequest) (*UnregisterExtensionsResponse, error)
// Получить список зарегистрированных сервисов
ListExtensions(context.Context, *ListExtensionsRequest) (*ListExtensionsResponse, error)
mustEmbedUnimplementedExtensionManagerServer()
}
// UnimplementedExtensionManagerServer must be embedded to have forward compatible implementations.
type UnimplementedExtensionManagerServer struct {
}
func (UnimplementedExtensionManagerServer) RegisterExtensions(context.Context, *RegisterExtensionsRequest) (*RegisterExtensionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method RegisterExtensions not implemented")
}
func (UnimplementedExtensionManagerServer) UnregisterExtensions(context.Context, *UnregisterExtensionsRequest) (*UnregisterExtensionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method UnregisterExtensions not implemented")
}
func (UnimplementedExtensionManagerServer) ListExtensions(context.Context, *ListExtensionsRequest) (*ListExtensionsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ListExtensions not implemented")
}
func (UnimplementedExtensionManagerServer) mustEmbedUnimplementedExtensionManagerServer() {}
// UnsafeExtensionManagerServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ExtensionManagerServer will
// result in compilation errors.
type UnsafeExtensionManagerServer interface {
mustEmbedUnimplementedExtensionManagerServer()
}
func RegisterExtensionManagerServer(s grpc.ServiceRegistrar, srv ExtensionManagerServer) {
s.RegisterService(&ExtensionManager_ServiceDesc, srv)
}
func _ExtensionManager_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.(ExtensionManagerServer).RegisterExtensions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.ExtensionManager/RegisterExtensions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionManagerServer).RegisterExtensions(ctx, req.(*RegisterExtensionsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _ExtensionManager_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.(ExtensionManagerServer).UnregisterExtensions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.ExtensionManager/UnregisterExtensions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionManagerServer).UnregisterExtensions(ctx, req.(*UnregisterExtensionsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _ExtensionManager_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.(ExtensionManagerServer).ListExtensions(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/extensions.ExtensionManager/ListExtensions",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ExtensionManagerServer).ListExtensions(ctx, req.(*ListExtensionsRequest))
}
return interceptor(ctx, in, info, handler)
}
// ExtensionManager_ServiceDesc is the grpc.ServiceDesc for ExtensionManager service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ExtensionManager_ServiceDesc = grpc.ServiceDesc{
ServiceName: "extensions.ExtensionManager",
HandlerType: (*ExtensionManagerServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "RegisterExtensions",
Handler: _ExtensionManager_RegisterExtensions_Handler,
},
{
MethodName: "UnregisterExtensions",
Handler: _ExtensionManager_UnregisterExtensions_Handler,
},
{
MethodName: "ListExtensions",
Handler: _ExtensionManager_ListExtensions_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "extensions/manager.proto",
}
This diff is collapsed.
This diff is collapsed.
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment