service

Documentation

Index

• type WordcloudTask
• type WordcloudTaskImpl
  • func NewWordcloudTask(conf *config.Config, db wrapper.GddDB) *WordcloudTaskImpl
  • func (receiver *WordcloudTaskImpl) TaskFail(ctx context.Context, payload vo.TaskFail) (data string, err error)
  • func (receiver *WordcloudTaskImpl) TaskFailRpc(ctx context.Context, request *pb.TaskFail) (*pb.TaskFailRpcResponse, error)
  • func (receiver *WordcloudTaskImpl) TaskPage(ctx context.Context, pq vo.PageQuery) (data vo.TaskPageRet, err error)
  • func (receiver *WordcloudTaskImpl) TaskPageRpc(ctx context.Context, request *pb.PageQuery) (*pb.TaskPageRet, error)
  • func (receiver *WordcloudTaskImpl) TaskSave(ctx context.Context, payload vo.TaskPayload) (data int, err error)
  • func (receiver *WordcloudTaskImpl) TaskSaveRpc(ctx context.Context, request *pb.TaskPayload) (*pb.TaskSaveRpcResponse, error)
  • func (receiver *WordcloudTaskImpl) TaskSuccess(ctx context.Context, payload vo.TaskSuccess) (data string, err error)
  • func (receiver *WordcloudTaskImpl) TaskSuccessRpc(ctx context.Context, request *pb.TaskSuccess) (*pb.TaskSuccessRpcResponse, error)

Types

type WordcloudTask

type WordcloudTask interface {
	// TaskSave save word cloud task 保存词云图任务
	TaskSave(ctx context.Context, payload vo.TaskPayload) (

		data int, err error)

	// TaskSuccess task success 任务执行成功接口
	TaskSuccess(ctx context.Context, payload vo.TaskSuccess) (

		data string, err error)

	// TaskFail task fail 任务执行失败接口
	TaskFail(ctx context.Context, payload vo.TaskFail) (

		data string, err error)

	// TaskPage
	TaskPage(ctx context.Context,

		query vo.PageQuery) (

		data vo.TaskPageRet,

		err error)
}

type WordcloudTaskImpl

type WordcloudTaskImpl struct {
	pb.UnimplementedWordcloudTaskServiceServer
	// contains filtered or unexported fields
}

func NewWordcloudTask

func NewWordcloudTask(conf *config.Config, db wrapper.GddDB) *WordcloudTaskImpl

func (*WordcloudTaskImpl) TaskFail

func (receiver *WordcloudTaskImpl) TaskFail(ctx context.Context, payload vo.TaskFail) (data string, err error)

func (*WordcloudTaskImpl) TaskFailRpc

func (receiver *WordcloudTaskImpl) TaskFailRpc(ctx context.Context, request *pb.TaskFail) (*pb.TaskFailRpcResponse, error)

func (*WordcloudTaskImpl) TaskPage

func (receiver *WordcloudTaskImpl) TaskPage(ctx context.Context, pq vo.PageQuery) (data vo.TaskPageRet, err error)

func (*WordcloudTaskImpl) TaskPageRpc

func (receiver *WordcloudTaskImpl) TaskPageRpc(ctx context.Context, request *pb.PageQuery) (*pb.TaskPageRet, error)

func (*WordcloudTaskImpl) TaskSave

func (receiver *WordcloudTaskImpl) TaskSave(ctx context.Context, payload vo.TaskPayload) (data int, err error)

func (*WordcloudTaskImpl) TaskSaveRpc

func (receiver *WordcloudTaskImpl) TaskSaveRpc(ctx context.Context, request *pb.TaskPayload) (*pb.TaskSaveRpcResponse, error)

func (*WordcloudTaskImpl) TaskSuccess

func (receiver *WordcloudTaskImpl) TaskSuccess(ctx context.Context, payload vo.TaskSuccess) (data string, err error)

func (*WordcloudTaskImpl) TaskSuccessRpc

func (receiver *WordcloudTaskImpl) TaskSuccessRpc(ctx context.Context, request *pb.TaskSuccess) (*pb.TaskSuccessRpcResponse, error)