dispatcher

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

type Event struct {
	Name string
}

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

type Message struct {
	ID              string
	Publisher       nats.JetStreamContext
	Msg             *nats.Msg
	Event           string
	Product         *Product
	Rule            *rule_manager.Rule
	Data            MessageRawData
	Raw             []byte
	Partition       int32
	ProductEvent    *gravity_sdk_types_product_event.ProductEvent
	RawProductEvent []byte
	TargetSchema    *schemer.Schema
	OutputMsg       *nats.Msg
	Ignore          bool
}

type MessageRawData struct {
	Event      string `json:"event"`
	RawPayload []byte `json:"payload"`
	//	PrimaryKey []byte
	Payload map[string]interface{}
}

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

type Product struct {
	ID        string
	Domain    string
	Name      string
	Enabled   bool
	Rules     *rule_manager.RuleManager
	Schema    *schemer.Schema
	IsRunning bool
	// contains filtered or unexported fields
}

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

type ProductSetting struct {
	Name        string                `json:"name"`
	Description string                `json:"desc"`
	Enabled     bool                  `json:"enabled"`
	Rules       *rule_manager.RuleSet `json:"rules"`
}

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