Documentation
¶
Overview ¶
Copyright 2021 SANGFOR TECHNOLOGIES
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.
Index ¶
- func AddInstances(instMap *dtstruct.InstanceKeyMap, instances []*mdtstruct.MysqlInstance)
- func FilterInstancesByPattern(instances []*mdtstruct.MysqlInstance, pattern string) []*mdtstruct.MysqlInstance
- func GetInstanceBinlogEntryKey(instanceKey *dtstruct.InstanceKey, entry string) string
- func RemoveInstance(instances []*mdtstruct.MysqlInstance, instanceKey *dtstruct.InstanceKey) []*mdtstruct.MysqlInstance
- func RemoveNilInstances(instances []*mdtstruct.MysqlInstance) []*mdtstruct.MysqlInstance
- func SpecialEventToSkip(event *dtstruct.BinlogEvent) bool
- func ToInstanceHander(mis []*mdtstruct.MysqlInstance) []dtstruct.InstanceAdaptor
- func ToMysqlInstance(ihs []dtstruct.InstanceAdaptor) []*mdtstruct.MysqlInstance
- func UnrecoverableError(err error) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddInstances ¶
func AddInstances(instMap *dtstruct.InstanceKeyMap, instances []*mdtstruct.MysqlInstance)
AddInstances adds keys of all given instances to this map
func FilterInstancesByPattern ¶
func FilterInstancesByPattern(instances []*mdtstruct.MysqlInstance, pattern string) []*mdtstruct.MysqlInstance
FilterInstancesByPattern will filter given array of instances according to regular expression pattern
func GetInstanceBinlogEntryKey ¶
func GetInstanceBinlogEntryKey(instanceKey *dtstruct.InstanceKey, entry string) string
func RemoveInstance ¶
func RemoveInstance(instances []*mdtstruct.MysqlInstance, instanceKey *dtstruct.InstanceKey) []*mdtstruct.MysqlInstance
removeInstance will remove an instance from a list of instances
func RemoveNilInstances ¶
func RemoveNilInstances(instances []*mdtstruct.MysqlInstance) []*mdtstruct.MysqlInstance
removeNilInstances
func SpecialEventToSkip ¶
func SpecialEventToSkip(event *dtstruct.BinlogEvent) bool
check if the event is one we want to skip.
func ToInstanceHander ¶
func ToInstanceHander(mis []*mdtstruct.MysqlInstance) []dtstruct.InstanceAdaptor
func ToMysqlInstance ¶
func ToMysqlInstance(ihs []dtstruct.InstanceAdaptor) []*mdtstruct.MysqlInstance
func UnrecoverableError ¶
Is this an error which means that we shouldn't try going more queries for this discovery attempt?
Types ¶
This section is empty.
Source Files