data_handler

type Event struct {
	PrimaryKey string
	PipelineID int32
	Payload    Payload
	Rule       *Rule
	Meta       map[string][]byte
}

type Field struct {
	Name    string      `json:"name"`
	Value   interface{} `json:"value"`
	Primary bool        `json:"primary,omitempty"`
}

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

type MappingConfig struct {
	Source  string `json:"source"`
	Target  string `json:"target"`
	Primary bool   `json:"primary"`
}

type Payload map[string]interface{}

type Projection struct {
	EventName  string            `json:"event"`
	Collection string            `json:"collection"`
	Method     string            `json:"method"`
	PrimaryKey string            `json:"primaryKey"`
	Fields     []Field           `json:"fields"`
	Meta       map[string][]byte `json:"meta"`
}

type RawData struct {
	EventName string
	Payload   []byte
	Meta      map[string][]byte
}

type Request struct {
	PipelineID int32
	Payload    []byte
}

type Rule struct {
	Event      string          `json:"event"`
	Collection string          `json:"collection"`
	Method     string          `json:"method"`
	PrimaryKey string          `json:"primaryKey"`
	Mapping    []MappingConfig `json:"mapping"`
}

type RuleConfig struct {
	Rules []*Rule `json:"rules"`
}

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