Versions in this module Expand all Collapse all v0 v0.2.0 Oct 31, 2023 v0.1.0 Oct 28, 2023 Changes in this version + func NewActionExecutorCreator(logger *zap.SugaredLogger) domain.ActionExecutorCreator + func NewEventSource(stClient domain.SyncthingClient, logger *zap.SugaredLogger) domain.EventSource + type ActionExecutorCreator struct + func (c *ActionExecutorCreator) CreateExecutor(action *domain.HookAction, hookDef *domain.HookDefinition) (domain.EventHandler, error) + type ChannelCollector struct + func NewChannelCollector() *ChannelCollector + func (c *ChannelCollector) Destroy() + func (c *ChannelCollector) GetCh() domain.EventCh + func (c *ChannelCollector) Handle(event *domain.Event) + func (h *ChannelCollector) GetNext() domain.EventHandler + func (h *ChannelCollector) SetNext(next domain.EventHandler) + type CoolDownFilter struct + func NewCoolDownFilter(cooldown int64, logger *zap.SugaredLogger, options ...CoolDownFilterOption) *CoolDownFilter + func (h *CoolDownFilter) Destroy() + func (h *CoolDownFilter) GetNext() domain.EventHandler + func (h *CoolDownFilter) Handle(event *domain.Event) + func (h *CoolDownFilter) SetNext(next domain.EventHandler) + type CoolDownFilterOption func(opt *CoolDownFilterOptions) + func CoolDownFilterTimeProvider(provider domain.TimeProvider) CoolDownFilterOption + type CoolDownFilterOptions struct + type DirPathFilter struct + func NewDirPathFilter(basePath string, logger *zap.SugaredLogger, options ...DirPathFilterOption) *DirPathFilter + func (d *DirPathFilter) Handle(event *domain.Event) + func (h *DirPathFilter) Destroy() + func (h *DirPathFilter) GetNext() domain.EventHandler + func (h *DirPathFilter) SetNext(next domain.EventHandler) + type DirPathFilterOption func(opt *DirPathFilterOptions) + func DirPathFilterWithPathExtractor(pathExtractor func(event *domain.Event) (string, error)) DirPathFilterOption + type DirPathFilterOptions struct + BasePath string + DirPathExtractor func(event *domain.Event) (string, error) + Logger *zap.SugaredLogger + type EventSource struct + func (s *EventSource) Subscribe(eventType domain.EventType, params *domain.HookParameters, ...) (domain.EventCh, error) + func (s *EventSource) Unsubscribe(eventCh domain.EventCh) + type ExecExecutor struct + func NewExecExecutor(cmd []string, logger *zap.SugaredLogger, options ...ExecExecutorOption) *ExecExecutor + func (h *ExecExecutor) Destroy() + func (h *ExecExecutor) GetNext() domain.EventHandler + func (h *ExecExecutor) Handle(event *domain.Event) + func (h *ExecExecutor) SetNext(next domain.EventHandler) + type ExecExecutorOption func(opt *ExecExecutorOptions) + func ExecExecutorCmdExecutor(cmdExec cmdExecutor) ExecExecutorOption + type ExecExecutorOptions struct + type FolderIdFilter struct + func NewFolderIdFilter(folderId string, logger *zap.SugaredLogger, options ...FolderIdFilterOption) *FolderIdFilter + func (f *FolderIdFilter) Handle(event *domain.Event) + func (h *FolderIdFilter) Destroy() + func (h *FolderIdFilter) GetNext() domain.EventHandler + func (h *FolderIdFilter) SetNext(next domain.EventHandler) + type FolderIdFilterOption func(opt *FolderIdFilterOptions) + func FolderIdFilterWithFolderIdExtractor(folderIdExtractor func(event *domain.Event) (string, error)) FolderIdFilterOption + type FolderIdFilterOptions struct + FolderId string + FolderIdExtractor func(event *domain.Event) (string, error) + Logger *zap.SugaredLogger + type MockcmdExecutor struct + func NewMockcmdExecutor(t interface{ ... }) *MockcmdExecutor + func (_m *MockcmdExecutor) EXPECT() *MockcmdExecutor_Expecter + type MockcmdExecutor_Expecter struct + type MockcmdExecutor_exec_Call struct + func (_c *MockcmdExecutor_exec_Call) Return(_a0 error) *MockcmdExecutor_exec_Call + func (_c *MockcmdExecutor_exec_Call) Run(run func(name string, arg ...string)) *MockcmdExecutor_exec_Call + func (_c *MockcmdExecutor_exec_Call) RunAndReturn(run func(string, ...string) error) *MockcmdExecutor_exec_Call + type ToleranceFilter struct + func NewToleranceFilter(tolerance int64, logger *zap.SugaredLogger) *ToleranceFilter + func (h *ToleranceFilter) Destroy() + func (h *ToleranceFilter) GetNext() domain.EventHandler + func (h *ToleranceFilter) Handle(event *domain.Event) + func (h *ToleranceFilter) SetNext(next domain.EventHandler)