topicmapper

type Policy struct {
	Name       string         `yaml:"name" jsonschema:"required"`
	TopicIndex int            `yaml:"topicIndex" jsonschema:"required"`
	Route      []TopicRe      `yaml:"route" jsonschema:"required"`
	Headers    map[int]string `yaml:"headers" jsonschema:"required"`
}

type PolicyRe struct {
	Name      string `yaml:"name" jsonschema:"required"`
	MatchExpr string `yaml:"matchExpr" jsonschema:"required"`
}

type SetKV struct {
	Topic   string `yaml:"topic" jsonschema:"topic"`
	Headers string `yaml:"headers" jsonschema:"headers"`
}

type Spec struct {
	MatchIndex int         `yaml:"matchIndex" jsonschema:"required"`
	Route      []*PolicyRe `yaml:"route" jsonschema:"required"`
	Policies   []*Policy   `yaml:"policies" jsonschema:"required"`
	SetKV      *SetKV      `yaml:"setKV" jsonschema:"required"`
}

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

type TopicRe struct {
	Topic string   `yaml:"topic" jsonschema:"required"`
	Exprs []string `yaml:"exprs" jsonschema:"required"`
}