app

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.

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 CanReplicateFromGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func CliCmd(commandMap map[string]dtstruct.CommandDesc, cliParam *dtstruct.CliParam)
• func ClusterOSCReplicas(params martini.Params, r render.Render, req *http.Request)
• func DisableGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func EnableGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func ErrantGTIDInjectEmpty(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func ErrantGTIDResetMaster(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func FlushBinaryLogs(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func LastPseudoGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func LocateErrantGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func MasterEquivalent(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func MoveBelowGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func MoveReplicasGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func PurgeBinaryLogs(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func RegisterAPIRequest() map[string][]interface{}
• func RegisterWebRequest() map[string][]interface{}
• func RegroupReplicasBinlogServers(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func RegroupReplicasGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func RegroupReplicasPseudoGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func Repoint(params martini.Params, r render.Render, req *http.Request, user auth.User)
• func RestartReplicationStatements(params martini.Params, r render.Render, req *http.Request, user auth.User)

Functions

func CanReplicateFromGTID

func CanReplicateFromGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

CanReplicateFromGTID attempts to move an instance below another via GTID.

func CliCmd

func CliCmd(commandMap map[string]dtstruct.CommandDesc, cliParam *dtstruct.CliParam)

Cli initiates a command line interface, executing requested command.

func ClusterOSCReplicas

func ClusterOSCReplicas(params martini.Params, r render.Render, req *http.Request)

ClusterOSCReplicas returns heuristic list of OSC replicas

func DisableGTID

func DisableGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

DisableGTID attempts to disable GTID on a replica, and revert to binlog file:pos

func EnableGTID

func EnableGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

EnableGTID attempts to enable GTID on a replica

func ErrantGTIDInjectEmpty

func ErrantGTIDInjectEmpty(params martini.Params, r render.Render, req *http.Request, user auth.User)

ErrantGTIDInjectEmpty removes errant transactions by injecting and empty transaction on the cluster's master

func ErrantGTIDResetMaster

func ErrantGTIDResetMaster(params martini.Params, r render.Render, req *http.Request, user auth.User)

ErrantGTIDResetMaster removes errant transactions on a server by way of RESET MASTER

func FlushBinaryLogs

func FlushBinaryLogs(params martini.Params, r render.Render, req *http.Request, user auth.User)

FlushBinaryLogs runs a single FLUSH BINARY LOGS

func LastPseudoGTID

func LastPseudoGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

LastPseudoGTID attempts to find the last pseugo-gtid entry in an instance

func LocateErrantGTID

func LocateErrantGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

LocateErrantGTID identifies the binlog positions for errant GTIDs on an instance

func MasterEquivalent

func MasterEquivalent(params martini.Params, r render.Render, req *http.Request, user auth.User)

MasterEquivalent provides (possibly empty) list of master coordinates equivalent to the given ones

func MoveBelowGTID

func MoveBelowGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

MoveBelowGTID attempts to move an instance below another, via GTID

func MoveReplicasGTID

func MoveReplicasGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

MoveReplicasGTID attempts to move an instance below another, via GTID

func PurgeBinaryLogs

func PurgeBinaryLogs(params martini.Params, r render.Render, req *http.Request, user auth.User)

PurgeBinaryLogs purges binary logs up to given binlog file

func RegisterAPIRequest

func RegisterAPIRequest() map[string][]interface{}

func RegisterWebRequest

func RegisterWebRequest() map[string][]interface{}

func RegroupReplicasBinlogServers

func RegroupReplicasBinlogServers(params martini.Params, r render.Render, req *http.Request, user auth.User)

RegroupReplicasBinlogServers attempts to pick a replica of a given instance and make it take its siblings, efficiently, using GTID

func RegroupReplicasGTID

func RegroupReplicasGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

RegroupReplicasGTID attempts to pick a replica of a given instance and make it take its siblings, efficiently, using GTID

func RegroupReplicasPseudoGTID

func RegroupReplicasPseudoGTID(params martini.Params, r render.Render, req *http.Request, user auth.User)

RegroupReplicas attempts to pick a replica of a given instance and make it take its siblings, efficiently, using pseudo-gtid if necessary

func Repoint

func Repoint(params martini.Params, r render.Render, req *http.Request, user auth.User)

Repoint positiones a replica under another (or same) master with exact same coordinates. Useful for binlog servers

func RestartReplicationStatements

func RestartReplicationStatements(params martini.Params, r render.Render, req *http.Request, user auth.User)

RestartReplicationStatements receives a query to execute that requires a replication restart to apply. As an example, this may be `set global rpl_semi_sync_slave_enabled=1`. ham4db will check replication status on given host and will wrap with appropriate stop/start statements, if need be.