Documentation
¶
Overview ¶
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
* Copyright 2020-2021 the original author(https://github.com/wj596) * * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p>
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Elastic6Endpoint ¶
type Elastic6Endpoint struct {
// contains filtered or unexported fields
}
func (*Elastic6Endpoint) Close ¶
func (s *Elastic6Endpoint) Close()
func (*Elastic6Endpoint) Connect ¶
func (s *Elastic6Endpoint) Connect() error
func (*Elastic6Endpoint) Consume ¶
func (s *Elastic6Endpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*Elastic6Endpoint) Ping ¶
func (s *Elastic6Endpoint) Ping() error
func (*Elastic6Endpoint) Stock ¶
func (s *Elastic6Endpoint) Stock(rows []*model.RowRequest) int64
type Elastic7Endpoint ¶
type Elastic7Endpoint struct {
// contains filtered or unexported fields
}
func (*Elastic7Endpoint) Close ¶
func (s *Elastic7Endpoint) Close()
func (*Elastic7Endpoint) Connect ¶
func (s *Elastic7Endpoint) Connect() error
func (*Elastic7Endpoint) Consume ¶
func (s *Elastic7Endpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*Elastic7Endpoint) Ping ¶
func (s *Elastic7Endpoint) Ping() error
func (*Elastic7Endpoint) Stock ¶
func (s *Elastic7Endpoint) Stock(rows []*model.RowRequest) int64
type Endpoint ¶
type Endpoint interface {
Connect() error
Ping() error
Consume(mysql.Position, []*model.RowRequest) error
Stock([]*model.RowRequest) int64
Close()
}
func NewEndpoint ¶
type KafkaEndpoint ¶
type KafkaEndpoint struct {
// contains filtered or unexported fields
}
func (*KafkaEndpoint) Close ¶
func (s *KafkaEndpoint) Close()
func (*KafkaEndpoint) Connect ¶
func (s *KafkaEndpoint) Connect() error
func (*KafkaEndpoint) Consume ¶
func (s *KafkaEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*KafkaEndpoint) Ping ¶
func (s *KafkaEndpoint) Ping() error
func (*KafkaEndpoint) Stock ¶
func (s *KafkaEndpoint) Stock(rows []*model.RowRequest) int64
type MongoEndpoint ¶
type MongoEndpoint struct {
// contains filtered or unexported fields
}
func (*MongoEndpoint) Close ¶
func (s *MongoEndpoint) Close()
func (*MongoEndpoint) Connect ¶
func (s *MongoEndpoint) Connect() error
func (*MongoEndpoint) Consume ¶
func (s *MongoEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*MongoEndpoint) Ping ¶
func (s *MongoEndpoint) Ping() error
func (*MongoEndpoint) Stock ¶
func (s *MongoEndpoint) Stock(rows []*model.RowRequest) int64
type RabbitEndpoint ¶
type RabbitEndpoint struct {
// contains filtered or unexported fields
}
func (*RabbitEndpoint) Close ¶
func (s *RabbitEndpoint) Close()
func (*RabbitEndpoint) Connect ¶
func (s *RabbitEndpoint) Connect() error
func (*RabbitEndpoint) Consume ¶
func (s *RabbitEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*RabbitEndpoint) Ping ¶
func (s *RabbitEndpoint) Ping() error
func (*RabbitEndpoint) Stock ¶
func (s *RabbitEndpoint) Stock(rows []*model.RowRequest) int64
type RedisEndpoint ¶
type RedisEndpoint struct {
// contains filtered or unexported fields
}
func (*RedisEndpoint) Close ¶
func (s *RedisEndpoint) Close()
func (*RedisEndpoint) Connect ¶
func (s *RedisEndpoint) Connect() error
func (*RedisEndpoint) Consume ¶
func (s *RedisEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*RedisEndpoint) Ping ¶
func (s *RedisEndpoint) Ping() error
func (*RedisEndpoint) Stock ¶
func (s *RedisEndpoint) Stock(rows []*model.RowRequest) int64
type RocketEndpoint ¶
type RocketEndpoint struct {
// contains filtered or unexported fields
}
func (*RocketEndpoint) Close ¶
func (s *RocketEndpoint) Close()
func (*RocketEndpoint) Connect ¶
func (s *RocketEndpoint) Connect() error
func (*RocketEndpoint) Consume ¶
func (s *RocketEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*RocketEndpoint) Ping ¶
func (s *RocketEndpoint) Ping() error
func (*RocketEndpoint) Stock ¶
func (s *RocketEndpoint) Stock(rows []*model.RowRequest) int64
type ScriptEndpoint ¶
type ScriptEndpoint struct {
}
func (*ScriptEndpoint) Close ¶
func (s *ScriptEndpoint) Close()
func (*ScriptEndpoint) Connect ¶
func (s *ScriptEndpoint) Connect() error
func (*ScriptEndpoint) Consume ¶
func (s *ScriptEndpoint) Consume(from mysql.Position, rows []*model.RowRequest) error
func (*ScriptEndpoint) Ping ¶
func (s *ScriptEndpoint) Ping() error
func (*ScriptEndpoint) Stock ¶
func (s *ScriptEndpoint) Stock(rows []*model.RowRequest) int64
Source Files