service

Documentation

Index

• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) AddTask(ctx context.Context, req *pb.AddTaskReq) (res *pb.AddTaskReply, err error)
  • func (s *Service) AddTemplate(ctx context.Context, req *pb.AddTemplateReq) (res *pb.AddTemplateReply, err error)
  • func (s *Service) CheckUploadFile(data []byte) (err error)
  • func (s *Service) Close()
  • func (s *Service) DeleteTask(ctx context.Context, req *pb.DeleteTaskReq) (res *pb.DeleteTaskReply, err error)
  • func (s *Service) Ping(c context.Context) (err error)
  • func (s *Service) TaskInfo(ctx context.Context, req *pb.TaskInfoReq) (res *pb.TaskInfoReply, err error)
  • func (s *Service) TaskList(ctx context.Context, req *pb.TaskListReq) (res *pb.TaskListReply, err error)
  • func (s *Service) TemplateList(ctx context.Context, req *pb.TemplateListReq) (res *pb.TemplateListReply, err error)
  • func (s *Service) UpdateTask(ctx context.Context, req *pb.UpdateTaskReq) (res *pb.UpdateTaskReply, err error)
  • func (s *Service) UpdateTemplate(ctx context.Context, req *pb.UpdateTemplateReq) (res *pb.UpdateTemplateReply, err error)
  • func (s *Service) Upload(dir, path string, data []byte) (err error)

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service is service.

func New

func New(c *conf.Config) (s *Service)

New is workflow-admin service implementation.

func (*Service) AddTask

func (s *Service) AddTask(ctx context.Context, req *pb.AddTaskReq) (res *pb.AddTaskReply, err error)

AddTask add task

func (*Service) AddTemplate

func (s *Service) AddTemplate(ctx context.Context, req *pb.AddTemplateReq) (res *pb.AddTemplateReply, err error)

AddTemplate add template

func (*Service) CheckUploadFile

func (s *Service) CheckUploadFile(data []byte) (err error)

CheckUploadFile checks uploaded content validation.

func (*Service) Close

func (s *Service) Close()

Close consumer close.

func (*Service) DeleteTask

func (s *Service) DeleteTask(ctx context.Context, req *pb.DeleteTaskReq) (res *pb.DeleteTaskReply, err error)

DeleteTask delete task

func (*Service) Ping

func (s *Service) Ping(c context.Context) (err error)

Ping check server ok.

func (*Service) TaskInfo

func (s *Service) TaskInfo(ctx context.Context, req *pb.TaskInfoReq) (res *pb.TaskInfoReply, err error)

TaskInfo get task info

func (*Service) TaskList

func (s *Service) TaskList(ctx context.Context, req *pb.TaskListReq) (res *pb.TaskListReply, err error)

TaskList get task list

func (*Service) TemplateList

func (s *Service) TemplateList(ctx context.Context, req *pb.TemplateListReq) (res *pb.TemplateListReply, err error)

TemplateList template list

func (*Service) UpdateTask

func (s *Service) UpdateTask(ctx context.Context, req *pb.UpdateTaskReq) (res *pb.UpdateTaskReply, err error)

UpdateTask update task

func (*Service) UpdateTemplate

func (s *Service) UpdateTemplate(ctx context.Context, req *pb.UpdateTemplateReq) (res *pb.UpdateTemplateReply, err error)

UpdateTemplate update template

func (*Service) Upload

func (s *Service) Upload(dir, path string, data []byte) (err error)

Upload add mids file.