input

type ExceptionFunc func(data interface{}, errMsg error)

type Inputer interface {

	// Description the Inputer description.
	// This information will be printed when the Inputer is abnormal, which is convenient for debugging.
	Name() string

	// Run execute the user logics
	Run(ctx InputerContext) *InputerResult

	// Stop stop the run function
	Stop() error
}

type InputerContext interface {
}

type InputerKey string

type InputerParams struct {
	IsTiming  bool
	Frequency time.Duration
	Target    Inputer
	Kind      InputerType
	Putter    output.Puter
}

type InputerResult struct {
	Err error
}

type InputerStatus int

type InputerType int

type Manager interface {

	// AddInputer add a new inputer
	AddInputer(params InputerParams) InputerKey

	// RemoveInputer remove the Inputer by a WorkerKey
	RemoveInputer(key InputerKey)

	// Run start the business cycle until the stop method is called.
	Run(ctx context.Context, inputerCtx InputerContext)

	// Stop
	Stop() error
}

type MapInputer map[InputerKey]*wrapInputer