client.microgen.go

// Code generated by microgen 0.9.1. DO NOT EDIT.

package transport

import (
	"context"
	"errors"
	collections "git.perx.ru/perxis/perxis-go/pkg/collections"
	environments "git.perx.ru/perxis/perxis-go/pkg/environments"
	items "git.perx.ru/perxis/perxis-go/pkg/items"
	locales "git.perx.ru/perxis/perxis-go/pkg/locales"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

func (set EndpointsSet) ListLocales(arg0 context.Context, arg1 string) (res0 []*locales.Locale, res1 error) {
	request := ListLocalesRequest{SpaceId: arg1}
	response, res1 := set.ListLocalesEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*ListLocalesResponse).Locales, res1
}

func (set EndpointsSet) GetEnvironment(arg0 context.Context, arg1 string, arg2 string) (res0 *environments.Environment, res1 error) {
	request := GetEnvironmentRequest{
		EnvId:   arg2,
		SpaceId: arg1,
	}
	response, res1 := set.GetEnvironmentEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*GetEnvironmentResponse).Env, res1
}

func (set EndpointsSet) ListEnvironments(arg0 context.Context, arg1 string) (res0 []*environments.Environment, res1 error) {
	request := ListEnvironmentsRequest{SpaceId: arg1}
	response, res1 := set.ListEnvironmentsEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*ListEnvironmentsResponse).Envs, res1
}

func (set EndpointsSet) GetCollection(arg0 context.Context, arg1 string, arg2 string, arg3 string) (res0 *collections.Collection, res1 error) {
	request := GetCollectionRequest{
		CollectionId: arg3,
		EnvId:        arg2,
		SpaceId:      arg1,
	}
	response, res1 := set.GetCollectionEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*GetCollectionResponse).Collection, res1
}

func (set EndpointsSet) ListCollections(arg0 context.Context, arg1 string, arg2 string) (res0 []*collections.Collection, res1 error) {
	request := ListCollectionsRequest{
		EnvId:   arg2,
		SpaceId: arg1,
	}
	response, res1 := set.ListCollectionsEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*ListCollectionsResponse).Collections, res1
}

func (set EndpointsSet) GetItem(arg0 context.Context, arg1 string, arg2 string, arg3 string, arg4 string, arg5 ...*items.GetPublishedOptions) (res0 *items.Item, res1 error) {
	request := GetItemRequest{
		CollectionId: arg3,
		EnvId:        arg2,
		ItemId:       arg4,
		Options:      arg5,
		SpaceId:      arg1,
	}
	response, res1 := set.GetItemEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*GetItemResponse).Item, res1
}

func (set EndpointsSet) FindItems(arg0 context.Context, arg1 string, arg2 string, arg3 string, arg4 *items.Filter, arg5 ...*items.FindPublishedOptions) (res0 []*items.Item, res1 int, res2 error) {
	request := FindItemsRequest{
		CollectionId: arg3,
		EnvId:        arg2,
		Filter:       arg4,
		Options:      arg5,
		SpaceId:      arg1,
	}
	response, res2 := set.FindItemsEndpoint(arg0, &request)
	if res2 != nil {
		if e, ok := status.FromError(res2); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res2 = errors.New(e.Message())
		}
		return
	}
	return response.(*FindItemsResponse).Items, response.(*FindItemsResponse).Total, res2
}

func (set EndpointsSet) Aggregate(arg0 context.Context, arg1 string, arg2 string, arg3 string, arg4 *items.Filter, arg5 ...*items.AggregatePublishedOptions) (res0 map[string]interface{}, res1 error) {
	request := AggregateRequest{
		CollectionId: arg3,
		EnvId:        arg2,
		Filter:       arg4,
		Options:      arg5,
		SpaceId:      arg1,
	}
	response, res1 := set.AggregateEndpoint(arg0, &request)
	if res1 != nil {
		if e, ok := status.FromError(res1); ok || e.Code() == codes.Internal || e.Code() == codes.Unknown {
			res1 = errors.New(e.Message())
		}
		return
	}
	return response.(*AggregateResponse).Result, res1
}