Select Git revision
server.microgen.go
server.microgen.go 2.24 KiB
// Code generated by microgen 0.9.1. DO NOT EDIT.
package transport
import (
"context"
collections "git.perx.ru/perxis/perxis-go/pkg/collections"
endpoint "github.com/go-kit/kit/endpoint"
)
func Endpoints(svc collections.Collections) EndpointsSet {
return EndpointsSet{
CreateEndpoint: CreateEndpoint(svc),
DeleteEndpoint: DeleteEndpoint(svc),
GetEndpoint: GetEndpoint(svc),
ListEndpoint: ListEndpoint(svc),
SetSchemaEndpoint: SetSchemaEndpoint(svc),
UpdateEndpoint: UpdateEndpoint(svc),
}
}
func CreateEndpoint(svc collections.Collections) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*CreateRequest)
res0, res1 := svc.Create(arg0, req.Collection)
return &CreateResponse{Created: res0}, res1
}
}
func GetEndpoint(svc collections.Collections) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*GetRequest)
res0, res1 := svc.Get(arg0, req.SpaceId, req.EnvId, req.CollectionId, req.Options...)
return &GetResponse{Collection: res0}, res1
}
}
func ListEndpoint(svc collections.Collections) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*ListRequest)
res0, res1 := svc.List(arg0, req.SpaceId, req.EnvId, req.Filter)
return &ListResponse{Collections: res0}, res1
}
}
func UpdateEndpoint(svc collections.Collections) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*UpdateRequest)
res0 := svc.Update(arg0, req.Coll)
return &UpdateResponse{}, res0
}
}
func SetSchemaEndpoint(svc collections.Collections) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*SetSchemaRequest)
res0 := svc.SetSchema(arg0, req.SpaceId, req.EnvId, req.CollectionId, req.Schema)
return &SetSchemaResponse{}, res0
}
}
func DeleteEndpoint(svc collections.Collections) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*DeleteRequest)
res0 := svc.Delete(arg0, req.SpaceId, req.EnvId, req.CollectionId)
return &DeleteResponse{}, res0
}
}