handler

Jun 12, 2023

Changes in this version

type Runner

+ func (r *Runner) CleanUp() (err error)

type Service

+ func (svc *Service) GetModelEnvironmentService() (modelTaskSvc interfaces.GrpcClientModelEnvironmentService)

Dec 29, 2022

Changes in this version

type Service

+ func (svc *Service) Fetch()

+ func (svc *Service) GetFetchInterval() (interval time.Duration)

+ func (svc *Service) SetFetchInterval(interval time.Duration)

May 15, 2022

Changes in this version

+ func GetTaskHandlerService(path string, opts ...Option) (svr interfaces.TaskHandlerService, err error)

+ func NewTaskHandlerService(opts ...Option) (svc2 interfaces.TaskHandlerService, err error)

+ func NewTaskRunner(id primitive.ObjectID, svc interfaces.TaskHandlerService, opts ...RunnerOption) (r2 interfaces.TaskRunner, err error)

+ func ProvideGetTaskHandlerService(path string, opts ...Option) func() (svr interfaces.TaskHandlerService, err error)

+ func ProvideTaskHandlerService(path string, opts ...Option) func() (svc interfaces.TaskHandlerService, err error)

+ type Option func(svc interfaces.TaskHandlerService)

+ func WithCancelTimeout(timeout time.Duration) Option

+ func WithConfigPath(path string) Option

+ func WithExitWatchDuration(duration time.Duration) Option

+ func WithReportInterval(interval time.Duration) Option

+ type Runner struct

+ func (r *Runner) Cancel() (err error)

+ func (r *Runner) Dispose() (err error)

+ func (r *Runner) GetTaskId() (id primitive.ObjectID)

+ func (r *Runner) Init() (err error)

+ func (r *Runner) Run() (err error)

+ func (r *Runner) SetLogDriverType(driverType string)

+ func (r *Runner) SetSubscribeTimeout(timeout time.Duration)

+ type RunnerOption func(r interfaces.TaskRunner)

+ func WithLogDriverType(driverType string) RunnerOption

+ func WithSubscribeTimeout(timeout time.Duration) RunnerOption

+ type Service struct

+ func (svc *Service) Cancel(taskId primitive.ObjectID) (err error)

+ func (svc *Service) GetCancelTimeout() (timeout time.Duration)

+ func (svc *Service) GetCurrentNode() (n interfaces.Node, err error)

+ func (svc *Service) GetExitWatchDuration() (duration time.Duration)

+ func (svc *Service) GetModelService() (modelSvc interfaces.GrpcClientModelService)

+ func (svc *Service) GetModelSpiderService() (modelSpiderSvc interfaces.GrpcClientModelSpiderService)

+ func (svc *Service) GetModelTaskService() (modelTaskSvc interfaces.GrpcClientModelTaskService)

+ func (svc *Service) GetModelTaskStatService() (modelTaskSvc interfaces.GrpcClientModelTaskStatService)

+ func (svc *Service) GetNodeConfigService() (cfgSvc interfaces.NodeConfigService)

+ func (svc *Service) GetReportInterval() (interval time.Duration)

+ func (svc *Service) GetSpiderById(id primitive.ObjectID) (s interfaces.Spider, err error)

+ func (svc *Service) GetTaskById(id primitive.ObjectID) (t interfaces.Task, err error)

+ func (svc *Service) IsSyncLocked(spiderId primitive.ObjectID) (ok bool)

+ func (svc *Service) LockSync(spiderId primitive.ObjectID)

+ func (svc *Service) ReportStatus()

+ func (svc *Service) Reset()

+ func (svc *Service) Run(taskId primitive.ObjectID) (err error)

+ func (svc *Service) SetCancelTimeout(timeout time.Duration)

+ func (svc *Service) SetExitWatchDuration(duration time.Duration)

+ func (svc *Service) SetReportInterval(interval time.Duration)

+ func (svc *Service) Start()

+ func (svc *Service) UnlockSync(spiderId primitive.ObjectID)