service

Documentation

Index

• func Close() error
• func Init(cc client.Client, conf config.Rabbit) error
• type Executor
• type Service
  • func New(conf config.Secret) *Service
  • func (s *Service) CreateTask(ctx context.Context, req *pb.CreateTaskRequest, rsp *pb.CreateTaskResponse) error
  • func (s *Service) DeleteTask(ctx context.Context, req *pb.DeleteTaskRequest, _ *emptypb.Empty) error
  • func (s *Service) DispatchTasks(_ context.Context, req *pb.DispatchTasksRequest, _ *emptypb.Empty) error
  • func (s *Service) GetTask(ctx context.Context, req *pb.GetTaskRequest, rsp *pb.GetTaskResponse) error
  • func (s *Service) GetTasks(ctx context.Context, req *pb.GetTasksRequest, rsp *pb.GetTasksResponse) error
  • func (s *Service) UpdateTask(ctx context.Context, req *pb.UpdateTaskRequest, _ *emptypb.Empty) error

Functions

func Close

func Close() error

func Init

func Init(cc client.Client, conf config.Rabbit) error

Types

type Executor

type Executor interface {
	Kind() string
	Execute([]byte) (string, error)
}

type Service

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

func New

func New(conf config.Secret) *Service

func (*Service) CreateTask

func (s *Service) CreateTask(ctx context.Context, req *pb.CreateTaskRequest, rsp *pb.CreateTaskResponse) error

func (*Service) DeleteTask

func (s *Service) DeleteTask(ctx context.Context, req *pb.DeleteTaskRequest, _ *emptypb.Empty) error

func (*Service) DispatchTasks

func (s *Service) DispatchTasks(_ context.Context, req *pb.DispatchTasksRequest, _ *emptypb.Empty) error

func (*Service) GetTask

func (s *Service) GetTask(ctx context.Context, req *pb.GetTaskRequest, rsp *pb.GetTaskResponse) error

func (*Service) GetTasks

func (s *Service) GetTasks(ctx context.Context, req *pb.GetTasksRequest, rsp *pb.GetTasksResponse) error

func (*Service) UpdateTask

func (s *Service) UpdateTask(ctx context.Context, req *pb.UpdateTaskRequest, _ *emptypb.Empty) error