tasks

Documentation

Index

• Constants
• Variables
• func NewChatTask(req *pb.ChatRequest) (*asynq.Task, error)
• func NewExecuteTask(req *pb.ExecuteRequest) (*asynq.Task, error)
• func NewSearchTask(req *pb.SearchRequest) (*asynq.Task, error)
• type TaskHandler
  • func NewTaskHandler(transport transport.Transport, vectorStore vector.Store) *TaskHandler
  • func (h TaskHandler) ProcessTask(ctx context.Context, t *asynq.Task) error

Constants

const (
	TypeChat    = "awe:chat"
	TypeSearch  = "awe:search"
	TypeExecute = "awe:execute"
)

Variables

var (
	DefaultWorkflowChat   = "qrouter"
	DefaultWorkflowSearch = "search_web"
)

Functions

func NewChatTask

func NewChatTask(req *pb.ChatRequest) (*asynq.Task, error)

func NewExecuteTask

func NewExecuteTask(req *pb.ExecuteRequest) (*asynq.Task, error)

func NewSearchTask

func NewSearchTask(req *pb.SearchRequest) (*asynq.Task, error)

Types

type TaskHandler

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

func NewTaskHandler

func NewTaskHandler(transport transport.Transport, vectorStore vector.Store) *TaskHandler

func (TaskHandler) ProcessTask

func (h TaskHandler) ProcessTask(ctx context.Context, t *asynq.Task) error