Documentation ¶
Index ¶
- Constants
- func FromJson(jsonStr string, obj interface{}) error
- func ToJson(obj interface{}) (string, error)
- type ElasticsearchRoute
- type ElasticsearchRouter
- type EsModelBaseRoute
- type EsModelOneManyRoute
- type EsModelOneOneRoute
- type EsModelRoute
- type EsModelRouter
- type KafkaRoute
- type KafkaRouter
- type MySQLRoute
- type MySQLRouter
- type RouteMatchers
Constants ¶
View Source
const ( EsModelOneOneObject = int64(1) EsModelOneOneExtend = int64(2) EsModelTypeMappingObject = "object" EsModelTypeMappingNested = "nested" EsModelVersion7 = "7" EsModelVersion6 = "6" EsModelRelationMain = 1 EsModelRelationOneOne = 2 EsModelRelationOneMany = 3 )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ElasticsearchRoute ¶ added in v0.9.35
type ElasticsearchRoute struct { RouteMatchers TargetIndex string TargetType string IgnoreNoPrimaryKey bool }
func NewElasticsearchRoutes ¶ added in v0.9.35
func NewElasticsearchRoutes(configData []map[string]interface{}) ([]*ElasticsearchRoute, error)
type ElasticsearchRouter ¶ added in v0.9.35
type ElasticsearchRouter []*ElasticsearchRoute
func (ElasticsearchRouter) Exists ¶ added in v0.9.35
func (r ElasticsearchRouter) Exists(msg *core.Msg) bool
func (ElasticsearchRouter) Match ¶ added in v0.9.35
func (r ElasticsearchRouter) Match(msg *core.Msg) (*ElasticsearchRoute, bool)
type EsModelBaseRoute ¶ added in v0.9.66
type EsModelBaseRoute struct { RouteMatchers DataBase string Table string PkColumn string ConvertColumn *map[string]string ExcludeColumn *map[string]string IncludeColumn *map[string]string RouteType int }
func NewEsModelBaseRoute ¶ added in v0.9.66
func NewEsModelBaseRoute(routeConfig map[string]interface{}, baseRoute *EsModelBaseRoute) (*EsModelBaseRoute, error)
type EsModelOneManyRoute ¶ added in v0.9.66
type EsModelOneManyRoute struct { EsModelBaseRoute FkColumn string PropertyName string }
func NewEsModelOneManyRoute ¶ added in v0.9.66
func NewEsModelOneManyRoute(routeConfig map[string]interface{}, manyRoute *EsModelOneManyRoute) (*EsModelOneManyRoute, error)
func NewEsModelOneManyRoutes ¶ added in v0.9.66
func NewEsModelOneManyRoutes(routeConfig map[string]interface{}) ([]*EsModelOneManyRoute, error)
type EsModelOneOneRoute ¶ added in v0.9.66
type EsModelOneOneRoute struct { EsModelOneManyRoute Mode int64 PropertyPre string }
func NewEsModelOneOneRoutes ¶ added in v0.9.66
func NewEsModelOneOneRoutes(routeConfig map[string]interface{}) ([]*EsModelOneOneRoute, error)
type EsModelRoute ¶ added in v0.9.66
type EsModelRoute struct { EsModelBaseRoute IndexName string TypeName string ShardsNum int64 ReplicasNum int64 EsVer string IgnoreNoPrimaryKey bool OneOne *[]*EsModelOneOneRoute OneMany *[]*EsModelOneManyRoute }
func NewEsModelRoutes ¶ added in v0.9.66
func NewEsModelRoutes(configData []map[string]interface{}) ([]*EsModelRoute, error)
type EsModelRouter ¶ added in v0.9.66
type EsModelRouter []*EsModelRoute
func (EsModelRouter) Match ¶ added in v0.9.66
func (r EsModelRouter) Match(msg *core.Msg) (*[]*EsModelRoute, bool)
type KafkaRoute ¶
type KafkaRoute struct { RouteMatchers DMLTargetTopic string }
func NewKafkaRoutes ¶
func NewKafkaRoutes(configData []map[string]interface{}) ([]*KafkaRoute, error)
type KafkaRouter ¶ added in v0.9.17
type KafkaRouter []*KafkaRoute
type MySQLRoute ¶
type MySQLRoute struct { RouteMatchers TargetSchema string TargetTable string }
func NewMySQLRoutes ¶
func NewMySQLRoutes(configData []map[string]interface{}) ([]*MySQLRoute, error)
type MySQLRouter ¶ added in v0.9.17
type MySQLRouter []*MySQLRoute
type RouteMatchers ¶
Click to show internal directories.
Click to hide internal directories.