server.microgen.go

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

package transport

import (
	"context"
	clients "git.perx.ru/perxis/perxis-go/pkg/clients"
	endpoint "github.com/go-kit/kit/endpoint"
)

func Endpoints(svc clients.Clients) EndpointsSet {
	return EndpointsSet{
		CreateEndpoint: CreateEndpoint(svc),
		DeleteEndpoint: DeleteEndpoint(svc),
		EnableEndpoint: EnableEndpoint(svc),
		GetByEndpoint:  GetByEndpoint(svc),
		GetEndpoint:    GetEndpoint(svc),
		ListEndpoint:   ListEndpoint(svc),
		UpdateEndpoint: UpdateEndpoint(svc),
	}
}

func CreateEndpoint(svc clients.Clients) endpoint.Endpoint {
	return func(arg0 context.Context, request interface{}) (interface{}, error) {
		req := request.(*CreateRequest)
		res0, res1 := svc.Create(arg0, req.Client)
		return &CreateResponse{Created: res0}, res1
	}
}

func GetEndpoint(svc clients.Clients) endpoint.Endpoint {
	return func(arg0 context.Context, request interface{}) (interface{}, error) {
		req := request.(*GetRequest)
		res0, res1 := svc.Get(arg0, req.SpaceId, req.Id)
		return &GetResponse{Client: res0}, res1
	}
}

func GetByEndpoint(svc clients.Clients) endpoint.Endpoint {
	return func(arg0 context.Context, request interface{}) (interface{}, error) {
		req := request.(*GetByRequest)
		res0, res1 := svc.GetBy(arg0, req.SpaceId, req.Config)
		return &GetByResponse{Client: res0}, res1
	}
}

func ListEndpoint(svc clients.Clients) endpoint.Endpoint {
	return func(arg0 context.Context, request interface{}) (interface{}, error) {
		req := request.(*ListRequest)
		res0, res1 := svc.List(arg0, req.SpaceId)
		return &ListResponse{Clients: res0}, res1
	}
}

func UpdateEndpoint(svc clients.Clients) endpoint.Endpoint {
	return func(arg0 context.Context, request interface{}) (interface{}, error) {
		req := request.(*UpdateRequest)
		res0 := svc.Update(arg0, req.Client)
		return &UpdateResponse{}, res0
	}
}

func DeleteEndpoint(svc clients.Clients) endpoint.Endpoint {
	return func(arg0 context.Context, request interface{}) (interface{}, error) {
		req := request.(*DeleteRequest)
		res0 := svc.Delete(arg0, req.SpaceId, req.Id)
		return &DeleteResponse{}, res0
	}
}

func EnableEndpoint(svc clients.Clients) endpoint.Endpoint {
	return func(arg0 context.Context, request interface{}) (interface{}, error) {
		req := request.(*EnableRequest)
		res0 := svc.Enable(arg0, req.SpaceId, req.Id, req.Enable)
		return &EnableResponse{}, res0
	}
}