task

package

v0.0.12 Latest Latest Go to latest Published: Jan 16, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Package task provides the server implemenetation for the task service

View Source

const Version string = "task/v1"

This section is empty.

This section is empty.

type NewServiceOption func(s *TaskService)

func WithExchange(e *events.Exchange) NewServiceOption

func WithLogger(l logger.Logger) NewServiceOption

type TaskService struct {
	tasksv1.UnimplementedTaskServiceServer
	// contains filtered or unexported fields
}

func NewService(repo repository.TaskRepository, opts ...NewServiceOption) *TaskService

func (c *TaskService) Create(ctx context.Context, req *tasksv1.CreateRequest) (*tasksv1.CreateResponse, error)

func (c *TaskService) Delete(ctx context.Context, req *tasksv1.DeleteRequest) (*tasksv1.DeleteResponse, error)

func (c *TaskService) Get(ctx context.Context, req *tasksv1.GetRequest) (*tasksv1.GetResponse, error)

func (c *TaskService) Kill(ctx context.Context, req *tasksv1.KillRequest) (*tasksv1.KillResponse, error)

func (c *TaskService) List(ctx context.Context, req *tasksv1.ListRequest) (*tasksv1.ListResponse, error)

func (c *TaskService) Patch(ctx context.Context, req *tasksv1.PatchRequest) (*tasksv1.PatchResponse, error)

func (c *TaskService) Register(server *grpc.Server) error

func (c *TaskService) Start(ctx context.Context, req *tasksv1.StartRequest) (*tasksv1.StartResponse, error)

func (c *TaskService) Update(ctx context.Context, req *tasksv1.UpdateRequest) (*tasksv1.UpdateResponse, error)

func (c *TaskService) UpdateStatus(ctx context.Context, req *tasksv1.UpdateStatusRequest) (*tasksv1.UpdateStatusResponse, error)