task

package

Go to main page

Versions in this module

v1

v1.0.1

Dec 18, 2025

Changes in this version

+ var ErrCommandNotSupported = apperrors.New(apperrors.InvalidInput, "지원하지 않는 명령입니다")

+ var ErrHTMLStructureChanged = apperrors.New(apperrors.ExecutionFailed, ...)

+ var ErrInvalidTaskData = apperrors.New(apperrors.InvalidInput, "작업 데이터가 유효하지 않습니다")

+ var ErrTaskConfigNotFound = apperrors.New(apperrors.NotFound, ...)

+ var ErrTaskNotSupported = apperrors.New(apperrors.InvalidInput, "지원하지 않는 작업입니다")

+ func DecodeMap(d interface{}, m map[string]interface{}) error

+ func EachSourceElementIsInTargetElementOrNot(source, target interface{}, equalFn EqualFunc, onFoundFn OnFoundFunc, ...) error

+ func FetchHTMLDocument(fetcher Fetcher, url string) (*goquery.Document, error)

+ func FetchHTMLSelection(fetcher Fetcher, url string, selector string) (*goquery.Selection, error)

+ func FetchJSON(fetcher Fetcher, method, url string, header map[string]string, body io.Reader, ...) error

+ func Filter(s string, includedKeywords, excludedKeywords []string) bool

+ func NewErrCommandNotSupported(commandID CommandID) error

+ func NewErrHTMLStructureChanged(url, details string) error

+ func NewErrTypeAssertionFailed(targetName string, expected, got interface{}) error

+ func Register(taskID ID, config *Config)

+ func ScrapeHTML(fetcher Fetcher, url string, selector string, ...) error

+ func TakeSliceArg(x interface{}) ([]interface{}, bool)

+ type Canceler interface

+ CancelTask func(instanceID InstanceID) error

+ type CommandConfig struct

+ AllowMultiple bool

+ ID CommandID

+ NewSnapshot NewSnapshotFunc

+ type CommandID string

+ func (id CommandID) IsEmpty() bool

+ func (id CommandID) Match(target CommandID) bool

+ func (id CommandID) String() string

+ func (id CommandID) Validate() error

+ type Config struct

+ Commands []*CommandConfig

+ NewTask NewTaskFunc

+ func (c *Config) Validate() error

+ type ConfigLookup struct

+ Command *CommandConfig

+ Task *Config

+ func FindConfigForTest(taskID ID, commandID CommandID) (*ConfigLookup, error)

+ type EqualFunc func(selem, telem interface{}) (bool, error)

+ type ExecuteFunc func(previousSnapshot interface{}, supportsHTML bool) (string, interface{}, error)

+ type Executor interface

+ type FileTaskResultStorage struct

+ func NewFileTaskResultStorage(appName string) *FileTaskResultStorage

+ func (s *FileTaskResultStorage) Load(taskID ID, commandID CommandID, v interface{}) error

+ func (s *FileTaskResultStorage) Save(taskID ID, commandID CommandID, v interface{}) error

+ func (s *FileTaskResultStorage) SetBaseDir(dir string)

type HTTPFetcher

+ func NewHTTPFetcher() *HTTPFetcher

+ type Handler interface

+ Cancel func()

+ ElapsedTimeAfterRun func() int64

+ GetCommandID func() CommandID

+ GetID func() ID

+ GetInstanceID func() InstanceID

+ GetNotifierID func() string

+ IsCanceled func() bool

+ Run func(taskCtx TaskContext, notificationSender NotificationSender, ...)

+ SetStorage func(storage TaskResultStorage)

+ type ID string

+ func (id ID) IsEmpty() bool

+ func (id ID) String() string

+ func (id ID) Validate() error

+ type InstanceID string

+ func (id InstanceID) IsEmpty() bool

+ func (id InstanceID) String() string

+ func (id InstanceID) Validate() error

+ type NewSnapshotFunc func() interface

+ type NewTaskFunc func(InstanceID, *SubmitRequest, *config.AppConfig) (Handler, error)

+ type NotificationSender interface

+ Notify func(taskCtx TaskContext, notifierID string, message string) bool

+ NotifyDefault func(message string) bool

+ SupportsHTML func(notifierID string) bool

+ type OnFoundFunc func(selem, telem interface{})

+ type OnNotFoundFunc func(selem interface{})

+ type Registry struct

+ func (r *Registry) Register(taskID ID, config *Config)

+ func (r *Registry) RegisterForTest(taskID ID, config *Config)

type RetryFetcher

+ func NewRetryFetcherFromConfig(maxRetries int, retryDelayStr string) *RetryFetcher

+ type RunBy int

+ const RunByScheduler

+ const RunByUnknown

+ const RunByUser

+ func (t RunBy) IsValid() bool

+ func (t RunBy) String() string

+ func (t RunBy) Validate() error

+ type Service struct

+ func (s *Service) CancelTask(instanceID InstanceID) (err error)

+ func (s *Service) SetNotificationSender(notificationSender NotificationSender)

+ func (s *Service) Start(serviceStopCtx context.Context, serviceStopWG *sync.WaitGroup) error

+ func (s *Service) SubmitTask(req *SubmitRequest) (err error)

+ type SubmitRequest struct

+ CommandID CommandID

+ NotifierID string

+ NotifyOnStart bool

+ RunBy RunBy

+ TaskContext TaskContext

+ TaskID ID

+ func (r *SubmitRequest) Validate() error

+ type Submitter interface

+ SubmitTask func(req *SubmitRequest) error

+ type Task struct

+ func NewBaseTask(id ID, commandID CommandID, instanceID InstanceID, notifierID string, ...) Task

+ func (t *Task) Cancel()

+ func (t *Task) ElapsedTimeAfterRun() int64

+ func (t *Task) GetCommandID() CommandID

+ func (t *Task) GetFetcher() Fetcher

+ func (t *Task) GetID() ID

+ func (t *Task) GetInstanceID() InstanceID

+ func (t *Task) GetNotifierID() string

+ func (t *Task) GetRunBy() RunBy

+ func (t *Task) IsCanceled() bool

+ func (t *Task) Run(taskCtx TaskContext, notificationSender NotificationSender, ...)

+ func (t *Task) SetExecute(fn ExecuteFunc)

+ func (t *Task) SetFetcher(f Fetcher)

+ func (t *Task) SetRunBy(runBy RunBy)

+ func (t *Task) SetStorage(storage TaskResultStorage)

type TaskContext

+ func NewTaskContext() TaskContext

+ GetCommandID func() CommandID

+ GetElapsedTimeAfterRun func() int64

+ GetID func() ID

+ GetInstanceID func() InstanceID

+ GetTitle func() string

+ IsErrorOccurred func() bool

+ WithTitle func(title string) TaskContext

+ type TaskResultStorage interface

+ Load func(taskID ID, commandID CommandID, v interface{}) error

+ Save func(taskID ID, commandID CommandID, v interface{}) error

v1.0.0

Dec 3, 2025

Changes in this version

+ const TcidKurlyWatchProductPrice

+ const TidKurly

+ const WatchProductColumnName

+ const WatchProductColumnNo

+ const WatchProductColumnWatchStatus

+ const WatchStatusDisabled

+ const WatchStatusEnabled

+ func CleanupTestFile(t *task) error

+ func CreateTestCSVFile(t *testing.T, filename string, content string) string

+ func CreateTestConfig() *config.AppConfig

+ func CreateTestConfigWithTasks(tasks []struct{ ... }) *config.AppConfig

+ func CreateTestTask(id TaskID, commandID TaskCommandID, instanceID TaskInstanceID) *task

+ func CreateTestTempDir(t *testing.T) string

+ func LoadTestData(t *testing.T, filename string) []byte

+ func LoadTestDataAsString(t *testing.T, filename string) string

+ type CommandExecutor interface

+ StartCommand func(name string, args ...string) (CommandProcess, error)

+ type CommandProcess interface

+ Kill func() error

+ Output func() string

+ Wait func() error

+ type DefaultCommandExecutor struct

+ func (e *DefaultCommandExecutor) StartCommand(name string, args ...string) (CommandProcess, error)

+ type Fetcher interface

+ Do func(req *http.Request) (*http.Response, error)

+ Get func(url string) (*http.Response, error)

+ type HTTPFetcher struct

+ func (h *HTTPFetcher) Do(req *http.Request) (*http.Response, error)

+ func (h *HTTPFetcher) Get(url string) (*http.Response, error)

+ type MockHTTPFetcher struct

+ Errors map[string]error

+ RequestedURLs []string

+ Responses map[string][]byte

+ func NewMockHTTPFetcher() *MockHTTPFetcher

+ func (m *MockHTTPFetcher) Do(req *http.Request) (*http.Response, error)

+ func (m *MockHTTPFetcher) Get(url string) (*http.Response, error)

+ func (m *MockHTTPFetcher) GetRequestedURLs() []string

+ func (m *MockHTTPFetcher) Reset()

+ func (m *MockHTTPFetcher) SetError(url string, err error)

+ func (m *MockHTTPFetcher) SetResponse(url string, response []byte)

+ type MockTaskNotificationSender struct

+ NotifyToDefaultCalls []string

+ NotifyWithTaskContextCalls []NotifyWithTaskContextCall

+ SupportHTMLMessageCalls []string

+ SupportHTMLMessageReturnValue bool

+ func NewMockTaskNotificationSender() *MockTaskNotificationSender

+ func (m *MockTaskNotificationSender) GetNotifyToDefaultCallCount() int

+ func (m *MockTaskNotificationSender) GetNotifyWithTaskContextCallCount() int

+ func (m *MockTaskNotificationSender) GetSupportHTMLMessageCallCount() int

+ func (m *MockTaskNotificationSender) NotifyToDefault(message string) bool

+ func (m *MockTaskNotificationSender) NotifyWithTaskContext(notifierID string, message string, taskCtx TaskContext) bool

+ func (m *MockTaskNotificationSender) Reset()

+ func (m *MockTaskNotificationSender) SupportHTMLMessage(notifierID string) bool

+ type NotifyWithTaskContextCall struct

+ Message string

+ NotifierID string

+ TaskCtx TaskContext

+ type RetryFetcher struct

+ func NewRetryFetcher(delegate Fetcher, maxRetries int, retryDelay time.Duration) *RetryFetcher

+ func (f *RetryFetcher) Do(req *http.Request) (*http.Response, error)

+ func (f *RetryFetcher) Get(url string) (*http.Response, error)

+ type TaskCanceler interface

+ TaskCancel func(taskInstanceID TaskInstanceID) (succeeded bool)

+ type TaskExecutor interface

+ TaskRun func(taskID TaskID, taskCommandID TaskCommandID, notifierID string, ...) (succeeded bool)

+ TaskRunWithContext func(taskID TaskID, taskCommandID TaskCommandID, taskCtx TaskContext, ...) (succeeded bool)

v0

v0.0.3

Feb 7, 2024

v0.0.2

Sep 13, 2023

v0.0.1

Sep 7, 2023

Changes in this version

+ const TaskCtxKeyElapsedTimeAfterRun

+ const TaskCtxKeyErrorOccurred

+ const TaskCtxKeyTaskCommandID

+ const TaskCtxKeyTaskID

+ const TaskCtxKeyTaskInstanceID

+ const TaskCtxKeyTitle

+ const TcidAlganicMallWatchAtoCream

+ const TcidAlganicMallWatchNewEvents

+ const TcidCovid19WatchResidualVaccine

+ const TcidJdcWatchNewOnlineEducation

+ const TcidJyiuWatchNewEducation

+ const TcidJyiuWatchNewNotice

+ const TcidLottoPrediction

+ const TcidNaverWatchNewPerformances

+ const TidAlganicMall

+ const TidCovid19

+ const TidJdc

+ const TidJyiu

+ const TidLotto

+ const TidNaver

+ var ErrNoImplementationForTaskCommand = errors.New("작업 커맨드에 대한 구현이 없습니다")

+ var ErrNotSupportedCommand = errors.New("지원되지 않는 작업 커맨드입니다")

+ var ErrNotSupportedTask = errors.New("지원되지 않는 작업입니다")

+ type TaskCommandID string

+ type TaskContext interface

+ Value func(key interface{}) interface{}

+ With func(key, val interface{}) TaskContext

+ WithError func() TaskContext

+ WithInstanceID func(taskInstanceID TaskInstanceID, elapsedTimeAfterRun int64) TaskContext

+ WithTask func(taskID TaskID, taskCommandID TaskCommandID) TaskContext

+ func NewContext() TaskContext

+ type TaskID string

+ const TcidNaverShoppingWatchPriceAny

+ const TidNaverShopping

+ type TaskInstanceID string

+ type TaskNotificationSender interface

+ NotifyToDefault func(message string) bool

+ NotifyWithTaskContext func(notifierID string, message string, taskCtx TaskContext) bool

+ SupportHTMLMessage func(notifierID string) bool

+ type TaskRunBy int

+ const TaskRunByScheduler

+ const TaskRunByUser

+ type TaskRunner interface

+ TaskCancel func(taskInstanceID TaskInstanceID) (succeeded bool)

+ TaskRun func(taskID TaskID, taskCommandID TaskCommandID, notifierID string, ...) (succeeded bool)

+ TaskRunWithContext func(taskID TaskID, taskCommandID TaskCommandID, taskCtx TaskContext, ...) (succeeded bool)

+ type TaskService struct

+ func NewService(config *g.AppConfig) *TaskService

+ func (s *TaskService) Run(serviceStopCtx context.Context, serviceStopWaiter *sync.WaitGroup)

+ func (s *TaskService) SetTaskNotificationSender(taskNotificiationSender TaskNotificationSender)

+ func (s *TaskService) TaskCancel(taskInstanceID TaskInstanceID) (succeeded bool)

+ func (s *TaskService) TaskRun(taskID TaskID, taskCommandID TaskCommandID, notifierID string, ...) (succeeded bool)

+ func (s *TaskService) TaskRunWithContext(taskID TaskID, taskCommandID TaskCommandID, taskCtx TaskContext, ...) (succeeded bool)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL