Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TailCutter ¶
type TailCutter struct {
*worker.BaseSchedulerDispatcher[string]
// contains filtered or unexported fields
}
func NewTailCutter ¶
func NewTailCutter( name string, config *TailCutterConfig, tailGetUC usecase.TailGetUseCase[string], tailCutUC usecase.TailCutUseCase[string], log logger.Logger, ) *TailCutter
func (*TailCutter) GetConfig ¶
func (tc *TailCutter) GetConfig() *TailCutterConfig
type TailCutterConfig ¶
type TailCutterConfig struct {
*worker.BaseSchedulerDispatcherConfig
// contains filtered or unexported fields
}
func NewTailCutterConfig ¶
func NewTailCutterConfig( schedulerDispatcherConf *worker.BaseSchedulerDispatcherConfig, dataInterval time.Duration, cutEnabled bool, ) *TailCutterConfig
Source Files
Click to show internal directories.
Click to hide internal directories.