service

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>

Index

• func Close()
• func Initialize() error
• func StartUp()
• type ClusterService
  • func ClusterServiceIns() *ClusterService
  • func (s *ClusterService) Nodes() []string
• type StockService
  • func NewStockService() *StockService
  • func (s *StockService) Close()
  • func (s *StockService) Run() error
• type TransferService
  • func TransferServiceIns() *TransferService
  • func (s *TransferService) Close()
  • func (s *TransferService) Position() (mysql.Position, error)
  • func (s *TransferService) StartUp()

Functions

func Close

func Close()

func Initialize

func Initialize() error

func StartUp

func StartUp()

Types

type ClusterService

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

func ClusterServiceIns

func ClusterServiceIns() *ClusterService

func (*ClusterService) Nodes

func (s *ClusterService) Nodes() []string

type StockService

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

存量数据

func NewStockService

func NewStockService() *StockService

func (*StockService) Close

func (s *StockService) Close()

func (*StockService) Run

func (s *StockService) Run() error

type TransferService

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

func TransferServiceIns

func TransferServiceIns() *TransferService

func (*TransferService) Close

func (s *TransferService) Close()

func (*TransferService) Position

func (s *TransferService) Position() (mysql.Position, error)

func (*TransferService) StartUp

func (s *TransferService) StartUp()