kniv

type BaseArgs struct {
	QueueSize int
}

type BaseEvent struct {
	// contains filtered or unexported fields
}

type BaseProcessor struct {
	Name string
	Type string

	Process func(resource Event) ([]Event, error)
	// contains filtered or unexported fields
}

type CustomLogic interface {
	Run(payload EventPayload) (EventPayload, error)
}

type CustomLogicSetting struct {
	Type     logicType
	Commands []string
	Keys     []string
}

type CustomProcessor struct {
	*BaseProcessor
	// contains filtered or unexported fields
}

type CustomProcessorArgs struct {
	Logics []CustomLogicSetting
}

type CustomProcessorGenerator struct{}

type DelayProcessor struct {
	*BaseProcessor
	// contains filtered or unexported fields
}

type DelayProcessorArgs struct {
	BaseArgs         `mapstructure:",squash"`
	IntervalMilliSec time.Duration
	Group            []string
}

type DelayProcessorGenerator struct{}

type Dispatcher struct {
	// contains filtered or unexported fields
}

type DistinctLogic struct {
	// contains filtered or unexported fields
}

type Downloader struct {
	*BaseProcessor
	// contains filtered or unexported fields
}

type DownloaderArgs struct {
	BaseArgs
	RootDestination string
}

type DownloaderGenerator struct{}

type Event interface {
	GetId() uint64
	SetId(uint64)
	GetSourceId() uint64
	SetSourceId(uint64)
	PushRoute(route string)
	//GetRoutes() []string
	SetRoutes([]string)
	CopyRoutes() []string
	//PopLabel() Label
	//PushLabel(label Label)
	//PushLabels(labels Labels)
	//SetLabels(labels Labels)
	//CopyLabels() Labels
	//GetProduceLabels() Labels
	//PushProduceLabels()
	//GetLatestLabel() Label
	GetLabels() *Labels
	SetLabels(labels *Labels)
	SetPayload(payload EventPayload)
	GetPayload() EventPayload
	Copy() Event
}

type EventPayload map[string]interface{}

type FilterByJSLogic struct {
	// contains filtered or unexported fields
}

type Flow struct {
	Pipelines []*Pipeline
}

type FlowSetting interface {
	GetProcessorType() string
	GetName() string
	GetArgs() interface{}
}

type Job struct {
	ProcessorSetting `yaml:",inline"`
	Consume          []Label
	Produce          []Label
}

type Label string

type Labels []Label

type LogicType string

type Pipeline struct {
	Name string
	Jobs []*Job
}

type Processor interface {
	GetType() string
	GetName() string
	SetName(name string)
	Enqueue(resource Event)
	SetOutChannel(outChan chan Event)
	Start()
}

type ProcessorFactory struct {
	// contains filtered or unexported fields
}

type ProcessorGenerator interface {
	GetType() string
	Generate(intfArgs interface{}) (Processor, error)
}

type ProcessorSetting struct {
	ProcessorType string `yaml:"processor"`
	Name          string
	Args          interface{}
}

type SelectPayloadLogic struct {
	// contains filtered or unexported fields
}

type TransformByJSLogic struct {
	// contains filtered or unexported fields
}