tmrgo/demo/micro-go-course-master/section25/comment/endpoint/endpoints.go

package endpoint

import (
	"context"
	"github.com/go-kit/kit/endpoint"
	"github.com/longjoy/micro-go-course/section25/comment/service"
)

type CommentsEndpoints struct {
	CommentsListEndpoint endpoint.Endpoint
}

// 服务发现请求结构体
type CommentsListRequest struct {
	Id string
}

// 服务发现响应结构体
type CommentsListResponse struct {
	Detail service.CommentListVO `json:"detail"`
	Error  string                `json:"error"`
}

// 创建服务发现的 Endpoint
func MakeCommentsListEndpoint(svc service.Service) endpoint.Endpoint {
	return func(ctx context.Context, request interface{}) (response interface{}, err error) {
		println("MakeCommentsListEndpoint")
		req := request.(CommentsListRequest)
		detail, err := svc.GetCommentsList(ctx, req.Id)
		var errString = ""
		if err != nil {
			errString = err.Error()
		}
		return &CommentsListResponse{
			Detail: detail,
			Error:  errString,
		}, nil
	}
}