server

Documentation

Index

• func ExtractUserEmail(ctx context.Context) (string, error)
• func ExtractUserID(ctx context.Context) (string, error)
• func TransformTask(st *storage.Task) *task_pb.Task
• type Server
  • func NewServer(cfg *common.Config) (*Server, error)
  • func (s *Server) CreateTask(ctx context.Context, req *task_pb.CreateTaskRequest) (*task_pb.CreateTaskResponse, error)
  • func (s *Server) DeleteTask(ctx context.Context, req *task_pb.DeleteTaskRequest) (*task_pb.DeleteTaskResponse, error)
  • func (s *Server) GetTask(ctx context.Context, req *task_pb.GetTaskRequest) (*task_pb.GetTaskResponse, error)
  • func (s *Server) ListTasks(ctx context.Context, req *task_pb.ListTasksRequest) (*task_pb.ListTasksResponse, error)
  • func (s *Server) UpdateTask(ctx context.Context, req *task_pb.UpdateTaskRequest) (*task_pb.UpdateTaskResponse, error)

Functions

func ExtractUserEmail

func ExtractUserEmail(ctx context.Context) (string, error)

func ExtractUserID

func ExtractUserID(ctx context.Context) (string, error)

func TransformTask

func TransformTask(st *storage.Task) *task_pb.Task

Types

type Server

type Server struct {
	pb.UnimplementedTaskServiceServer
	Publisher events.RabbitMQBrokerInterface
	Storage   storage.StorageInterface
	Logger    *logrus.Entry
}

Server implements the TaskServiceServer interface

func NewServer

func NewServer(cfg *common.Config) (*Server, error)

func (*Server) CreateTask

func (s *Server) CreateTask(ctx context.Context, req *task_pb.CreateTaskRequest) (*task_pb.CreateTaskResponse, error)

Createtask creates a task with given details

func (*Server) DeleteTask

func (s *Server) DeleteTask(ctx context.Context, req *task_pb.DeleteTaskRequest) (*task_pb.DeleteTaskResponse, error)

func (*Server) GetTask

func (s *Server) GetTask(ctx context.Context, req *task_pb.GetTaskRequest) (*task_pb.GetTaskResponse, error)

func (*Server) ListTasks

func (s *Server) ListTasks(ctx context.Context, req *task_pb.ListTasksRequest) (*task_pb.ListTasksResponse, error)

func (*Server) UpdateTask

func (s *Server) UpdateTask(ctx context.Context, req *task_pb.UpdateTaskRequest) (*task_pb.UpdateTaskResponse, error)