Versions in this module Expand all Collapse all v1 v1.0.7 Jun 6, 2022 Changes in this version + type Elastic6Endpoint struct + func (s *Elastic6Endpoint) Close() + func (s *Elastic6Endpoint) Connect() error + func (s *Elastic6Endpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *Elastic6Endpoint) Ping() error + func (s *Elastic6Endpoint) Stock(rows []*model.RowRequest) int64 + type Elastic7Endpoint struct + func (s *Elastic7Endpoint) Close() + func (s *Elastic7Endpoint) Connect() error + func (s *Elastic7Endpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *Elastic7Endpoint) Ping() error + func (s *Elastic7Endpoint) Stock(rows []*model.RowRequest) int64 + type Endpoint interface + Close func() + Connect func() error + Consume func(mysql.Position, []*model.RowRequest) error + Ping func() error + Stock func([]*model.RowRequest) int64 + func NewEndpoint(ds *canal.Canal) Endpoint + type KafkaEndpoint struct + func (s *KafkaEndpoint) Close() + func (s *KafkaEndpoint) Connect() error + func (s *KafkaEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *KafkaEndpoint) Ping() error + func (s *KafkaEndpoint) Stock(rows []*model.RowRequest) int64 + type MongoEndpoint struct + func (s *MongoEndpoint) Close() + func (s *MongoEndpoint) Connect() error + func (s *MongoEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *MongoEndpoint) Ping() error + func (s *MongoEndpoint) Stock(rows []*model.RowRequest) int64 + type RabbitEndpoint struct + func (s *RabbitEndpoint) Close() + func (s *RabbitEndpoint) Connect() error + func (s *RabbitEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *RabbitEndpoint) Ping() error + func (s *RabbitEndpoint) Stock(rows []*model.RowRequest) int64 + type RedisEndpoint struct + func (s *RedisEndpoint) Close() + func (s *RedisEndpoint) Connect() error + func (s *RedisEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *RedisEndpoint) Ping() error + func (s *RedisEndpoint) Stock(rows []*model.RowRequest) int64 + type RocketEndpoint struct + func (s *RocketEndpoint) Close() + func (s *RocketEndpoint) Connect() error + func (s *RocketEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *RocketEndpoint) Ping() error + func (s *RocketEndpoint) Stock(rows []*model.RowRequest) int64 + type ScriptEndpoint struct + func (s *ScriptEndpoint) Close() + func (s *ScriptEndpoint) Connect() error + func (s *ScriptEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error + func (s *ScriptEndpoint) Ping() error + func (s *ScriptEndpoint) Stock(rows []*model.RowRequest) int64
Go to main page