cep/executor/processor.go

package executor

import (
	schemepkg "git.buran.team/main/cep/scheme"
)

type Processor interface {
	Process(buffer []byte) bool
}

func NewProcessor(processorScheme schemepkg.Processor) (Processor, error) {
	switch processorScheme.Kind {
	case schemepkg.PROCESSOR_KIND_MATCH:
		return NewMatchProcessor(processorScheme)

	case schemepkg.PROCESSOR_KIND_NOT_MATCH:
		return NewNotMatchProcessor(processorScheme)

	case schemepkg.PROCESSOR_KIND_EQUAL:
		return NewEqualProcessor(processorScheme)
	}

	return nil, ErrKindUnknown
}