mod_body_process

type BPError struct {
	Err error
}

type BodyProcessConfig struct {
	Dec  string
	Enc  string
	Proc []ProcConf // processing steps
}

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

type ConfModBodyProcess struct {
	Basic struct {
		ProductRulePath string
	}

	Log struct {
		OpenDebug bool
	}
}

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

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

type Event interface {
	// GetType() string
	// GetData() []byte
	ToBytes() []byte // 转换为字节数组
}

type EventDecoder interface {
	// return:
	//  events, nil - len(events) > 0, success
	//  events, nil - len(events) = 0, 没有更多数据, eof
	//  nil, error - 发生错误
	Decode() ([]Event, error)
}

type EventDecoderFac func(source io.Reader) (EventDecoder, error)

type EventDecoderFacWithReq func(source io.Reader, req bfe_basic.Request) (EventDecoder, error)

type EventEncoder interface {
	Encode(events []Event) (int, error)
}

type EventEncoderFac func(dest io.Writer) (EventEncoder, error)

type EventProcessor interface {
	Process(events []Event) ([]Event, error)
}

type EventProcessorFunc func([]Event) ([]Event, error)

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

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

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

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

type ModuleBodyProcessState struct {
	ReqTotal   *metrics.Counter
	ReqProcess *metrics.Counter
	ResProcess *metrics.Counter
}

type ProcConf struct {
	Name   string
	Params []string
}

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

type ProductRules map[string]processRuleList

type ProductRulesFile map[string]processRuleFileList

type RawEvent []byte

type RejectionError struct {
	Message    string
	StatusCode int
}

type SSEEvent struct {
	ID    string
	Event string
	Data  []byte
	Retry int
	// contains filtered or unexported fields
}

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

type TextFilterContactItem struct {
	ContactType   string
	ContactString string
	Position      string
}

type TextFilterDetailItem struct {
	RiskLevel string
	RiskCode  string
	Position  string
	Text      string
}

type TextFilterResult struct {
	Code           int32
	Message        string
	RequestId      string
	RiskLevel      string
	RiskCode       string
	SentimentScore float32
	ResultText     string

	Details  []TextFilterDetailItem
	Contacts []TextFilterContactItem
}