本文整理汇总了Golang中github.com/outbrain/orchestrator/go/db.QueryOrchestratorRowsMap函数的典型用法代码示例。如果您正苦于以下问题:Golang QueryOrchestratorRowsMap函数的具体用法?Golang QueryOrchestratorRowsMap怎么用?Golang QueryOrchestratorRowsMap使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了QueryOrchestratorRowsMap函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: ReadClusterPoolInstances
func ReadClusterPoolInstances(clusterName string) (*PoolInstancesMap, error) {
var poolInstancesMap = make(PoolInstancesMap)
query := fmt.Sprintf(`
select
database_instance_pool.*
from
database_instance
join database_instance_pool using (hostname, port)
where
database_instance.cluster_name = '%s'
`, clusterName)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
pool := m.GetString("pool")
hostname := m.GetString("hostname")
port := m.GetInt("port")
if _, ok := poolInstancesMap[pool]; !ok {
poolInstancesMap[pool] = [](*InstanceKey){}
}
poolInstancesMap[pool] = append(poolInstancesMap[pool], &InstanceKey{Hostname: hostname, Port: port})
return nil
})
if err != nil {
return nil, err
}
return &poolInstancesMap, nil
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:30,代码来源:pool_dao.go
示例2: ReadReplicationAnalysisChangelog
// readRecoveries reads recovery entry/audit entires from topology_recovery
func ReadReplicationAnalysisChangelog() ([]ReplicationAnalysisChangelog, error) {
res := []ReplicationAnalysisChangelog{}
query := `
select
hostname,
port,
group_concat(analysis_timestamp,';',analysis order by changelog_id) as changelog
from
database_instance_analysis_changelog
group by
hostname, port
`
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
analysisChangelog := ReplicationAnalysisChangelog{}
analysisChangelog.AnalyzedInstanceKey.Hostname = m.GetString("hostname")
analysisChangelog.AnalyzedInstanceKey.Port = m.GetInt("port")
analysisChangelog.Changelog = m.GetString("changelog")
res = append(res, analysisChangelog)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:rlowe,项目名称:orchestrator,代码行数:29,代码来源:analysis_dao.go
示例3: readAgentBasicInfo
// readAgentBasicInfo returns the basic data for an agent directly from backend table (no agent access)
func readAgentBasicInfo(hostname string) (Agent, string, error) {
agent := Agent{}
token := ""
query := fmt.Sprintf(`
select
hostname,
port,
token,
last_submitted,
mysql_port
from
host_agent
where
hostname = '%s'
`, hostname)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
agent.Hostname = m.GetString("hostname")
agent.Port = m.GetInt("port")
agent.LastSubmitted = m.GetString("last_submitted")
agent.MySQLPort = m.GetInt64("mysql_port")
token = m.GetString("token")
return nil
})
if err != nil {
return agent, "", err
}
if token == "" {
return agent, "", log.Errorf("Cannot get agent/token: %s", hostname)
}
return agent, token, nil
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:34,代码来源:agent_dao.go
示例4: getHostAttributesByClause
func getHostAttributesByClause(whereClause string) ([]HostAttributes, error) {
res := []HostAttributes{}
query := fmt.Sprintf(`
select
hostname,
attribute_name,
attribute_value,
submit_timestamp ,
ifnull(expire_timestamp, '') as expire_timestamp
from
host_attributes
%s
order by
hostname, attribute_name
`, whereClause)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
hostAttributes := HostAttributes{}
hostAttributes.Hostname = m.GetString("hostname")
hostAttributes.AttributeName = m.GetString("attribute_name")
hostAttributes.AttributeValue = m.GetString("attribute_value")
hostAttributes.SubmitTimestamp = m.GetString("submit_timestamp")
hostAttributes.ExpireTimestamp = m.GetString("expire_timestamp")
res = append(res, hostAttributes)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:33,代码来源:attributes_dao.go
示例5: ReadAgents
// ReadAgents returns a list of all known agents
func ReadAgents() ([]Agent, error) {
res := []Agent{}
query := `
select
hostname,
port,
token,
last_submitted,
mysql_port
from
host_agent
order by
hostname
`
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
agent := Agent{}
agent.Hostname = m.GetString("hostname")
agent.Port = m.GetInt("port")
agent.MySQLPort = m.GetInt64("mysql_port")
agent.Token = ""
agent.LastSubmitted = m.GetString("last_submitted")
res = append(res, agent)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:BrianIp,项目名称:orchestrator,代码行数:33,代码来源:agent_dao.go
示例6: ReadMaintenanceInstanceKey
// ReadMaintenanceInstanceKey will return the instanceKey for active maintenance by maintenanceToken
func ReadMaintenanceInstanceKey(maintenanceToken int64) (*InstanceKey, error) {
var res *InstanceKey
query := fmt.Sprintf(`
select
hostname, port
from
database_instance_maintenance
where
database_instance_maintenance_id = %d `,
maintenanceToken)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
instanceKey, merr := NewInstanceKeyFromStrings(m.GetString("hostname"), m.GetString("port"))
if merr != nil {
return merr
}
res = instanceKey
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:26,代码来源:maintenance_dao.go
示例7: ReadSeedStates
// SeedOperationState reads states for a given seed operation
func ReadSeedStates(seedId int64) ([]SeedOperationState, error) {
res := []SeedOperationState{}
query := fmt.Sprintf(`
select
agent_seed_state_id,
agent_seed_id,
state_timestamp,
state_action,
error_message
from
agent_seed_state
where
agent_seed_id = %d
order by
agent_seed_state_id desc
`, seedId)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
seedState := SeedOperationState{}
seedState.SeedStateId = m.GetInt64("agent_seed_state_id")
seedState.SeedId = m.GetInt64("agent_seed_id")
seedState.StateTimestamp = m.GetString("state_timestamp")
seedState.Action = m.GetString("state_action")
seedState.ErrorMessage = m.GetString("error_message")
res = append(res, seedState)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:34,代码来源:agent_dao.go
示例8: ReadAllClusterPoolInstances
func ReadAllClusterPoolInstances() ([](*ClusterPoolInstance), error) {
var result [](*ClusterPoolInstance) = [](*ClusterPoolInstance){}
query := `
select
cluster_name,
ifnull(alias, cluster_name) as alias,
database_instance_pool.*
from
database_instance
join database_instance_pool using (hostname, port)
left join cluster_alias using (cluster_name)
`
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
clusterPoolInstance := ClusterPoolInstance{
ClusterName: m.GetString("cluster_name"),
ClusterAlias: m.GetString("alias"),
Pool: m.GetString("pool"),
Hostname: m.GetString("hostname"),
Port: m.GetInt("port"),
}
result = append(result, &clusterPoolInstance)
return nil
})
if err != nil {
return nil, err
}
return result, nil
}
开发者ID:0-T-0,项目名称:orchestrator,代码行数:31,代码来源:pool_dao.go
示例9: DeleteInvalidHostnameResolves
// DeleteInvalidHostnameResolves removes invalid resolves. At this time these are:
// - infinite loop resolves (A->B and B->A), remove earlier mapping
func DeleteInvalidHostnameResolves() error {
var invalidHostnames []string
query := `
select
early.hostname
from
hostname_resolve as latest
join hostname_resolve early on (latest.resolved_hostname = early.hostname and latest.hostname = early.resolved_hostname)
where
latest.hostname != latest.resolved_hostname
and latest.resolved_timestamp > early.resolved_timestamp
`
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
invalidHostnames = append(invalidHostnames, m.GetString("hostname"))
return nil
})
if err != nil {
return err
}
for _, invalidHostname := range invalidHostnames {
_, err = db.ExecOrchestrator(`
delete
from hostname_resolve
where
hostname = ?`,
invalidHostname,
)
log.Errore(err)
}
return err
}
开发者ID:0-T-0,项目名称:orchestrator,代码行数:36,代码来源:resolve_dao.go
示例10: ReadLongRunningProcesses
// ReadLongRunningProcesses returns the list of current known long running processes of all instances
func ReadLongRunningProcesses(filter string) ([]Process, error) {
longRunningProcesses := []Process{}
filterClause := ""
if filter != "" {
filterClause = fmt.Sprintf(`
where
hostname like '%%%s%%'
or process_user like '%%%s%%'
or process_host like '%%%s%%'
or process_db like '%%%s%%'
or process_command like '%%%s%%'
or process_state like '%%%s%%'
or process_info like '%%%s%%'
`, filter, filter, filter, filter, filter, filter, filter)
}
query := fmt.Sprintf(`
select
hostname,
port,
process_id,
process_started_at,
process_user,
process_host,
process_db,
process_command,
process_time_seconds,
process_state,
process_info
from
database_instance_long_running_queries
%s
order by
process_time_seconds desc
`, filterClause)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
process := Process{}
process.InstanceHostname = m.GetString("hostname")
process.InstancePort = m.GetInt("port")
process.Id = m.GetInt64("process_id")
process.User = m.GetString("process_user")
process.Host = m.GetString("process_host")
process.Db = m.GetString("process_db")
process.Command = m.GetString("process_command")
process.Time = m.GetInt64("process_time_seconds")
process.State = m.GetString("process_state")
process.Info = m.GetString("process_info")
process.StartedAt = m.GetString("process_started_at")
longRunningProcesses = append(longRunningProcesses, process)
return nil
})
if err != nil {
log.Errore(err)
}
return longRunningProcesses, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:60,代码来源:process_dao.go
示例11: GetEquivalentMasterCoordinates
func GetEquivalentMasterCoordinates(instanceCoordinates *InstanceBinlogCoordinates) (result [](*InstanceBinlogCoordinates), err error) {
query := fmt.Sprintf(`
select
master1_hostname as hostname,
master1_port as port,
master1_binary_log_file as binlog_file,
master1_binary_log_pos as binlog_pos
from
master_position_equivalence
where
master2_hostname = '%s'
and master2_port = '%d'
and master2_binary_log_file = '%s'
and master2_binary_log_pos = '%d'
union
select
master2_hostname as hostname,
master2_port as port,
master2_binary_log_file as binlog_file,
master2_binary_log_pos as binlog_pos
from
master_position_equivalence
where
master1_hostname = '%s'
and master1_port = '%d'
and master1_binary_log_file = '%s'
and master1_binary_log_pos = '%d'
`,
instanceCoordinates.Key.Hostname,
instanceCoordinates.Key.Port,
instanceCoordinates.Coordinates.LogFile,
instanceCoordinates.Coordinates.LogPos,
instanceCoordinates.Key.Hostname,
instanceCoordinates.Key.Port,
instanceCoordinates.Coordinates.LogFile,
instanceCoordinates.Coordinates.LogPos)
err = db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
equivalentCoordinates := InstanceBinlogCoordinates{}
equivalentCoordinates.Key.Hostname = m.GetString("hostname")
equivalentCoordinates.Key.Port = m.GetInt("port")
equivalentCoordinates.Coordinates.LogFile = m.GetString("binlog_file")
equivalentCoordinates.Coordinates.LogPos = m.GetInt64("binlog_pos")
result = append(result, &equivalentCoordinates)
return nil
})
if err != nil {
return nil, err
}
return result, nil
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:54,代码来源:master_equivalence_dao.go
示例12: ReadPendingAsyncRequests
func ReadPendingAsyncRequests(limit int) (res [](*AsyncRequest), err error) {
limitClause := ""
if limit > 0 {
limitClause = fmt.Sprintf("limit %d", limit)
}
query := fmt.Sprintf(`
select
request_id,
command,
hostname,
port,
destination_hostname,
destination_port,
pattern,
gtid_hint,
story
from
async_request
where
begin_timestamp IS NULL
order by
request_id asc
%s
`, limitClause)
err = db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
asyncRequest := NewEmptyAsyncRequest()
asyncRequest.Id = m.GetInt64("request_id")
asyncRequest.Command = m.GetString("command")
asyncRequest.OperatedInstanceKey = &inst.InstanceKey{}
asyncRequest.OperatedInstanceKey.Hostname = m.GetString("hostname")
asyncRequest.OperatedInstanceKey.Port = m.GetInt("port")
if m.GetString("destination_hostname") != "" {
asyncRequest.DestinationKey = &inst.InstanceKey{}
asyncRequest.DestinationKey.Hostname = m.GetString("destination_hostname")
asyncRequest.DestinationKey.Port = m.GetInt("destination_port")
}
asyncRequest.Pattern = m.GetString("pattern")
asyncRequest.GTIDHint = inst.OperationGTIDHint(m.GetString("gtid_hint"))
asyncRequest.Story = m.GetString("story")
res = append(res, asyncRequest)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:52,代码来源:async_request_dao.go
示例13: readFailureDetections
// readRecoveries reads recovery entry/audit entires from topology_recovery
func readFailureDetections(whereCondition string, limit string) ([]TopologyRecovery, error) {
res := []TopologyRecovery{}
query := fmt.Sprintf(`
select
detection_id,
hostname,
port,
in_active_period as is_active,
start_active_period,
end_active_period_unixtime,
processing_node_hostname,
processcing_node_token,
analysis,
cluster_name,
cluster_alias,
count_affected_slaves,
slave_hosts
from
topology_failure_detection
%s
order by
detection_id desc
%s
`, whereCondition, limit)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
failureDetection := TopologyRecovery{}
failureDetection.Id = m.GetInt64("detection_id")
failureDetection.IsActive = m.GetBool("is_active")
failureDetection.RecoveryStartTimestamp = m.GetString("start_active_period")
failureDetection.ProcessingNodeHostname = m.GetString("processing_node_hostname")
failureDetection.ProcessingNodeToken = m.GetString("processcing_node_token")
failureDetection.AnalysisEntry.AnalyzedInstanceKey.Hostname = m.GetString("hostname")
failureDetection.AnalysisEntry.AnalyzedInstanceKey.Port = m.GetInt("port")
failureDetection.AnalysisEntry.Analysis = inst.AnalysisCode(m.GetString("analysis"))
failureDetection.AnalysisEntry.ClusterDetails.ClusterName = m.GetString("cluster_name")
failureDetection.AnalysisEntry.ClusterDetails.ClusterAlias = m.GetString("cluster_alias")
failureDetection.AnalysisEntry.CountSlaves = m.GetUint("count_affected_slaves")
failureDetection.AnalysisEntry.ReadSlaveHostsFromString(m.GetString("slave_hosts"))
failureDetection.AnalysisEntry.ClusterDetails.ReadRecoveryInfo()
res = append(res, failureDetection)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:53,代码来源:topology_recovery_dao.go
示例14: ReadRecentAudit
// ReadRecentAudit returns a list of audit entries order chronologically descending, using page number.
func ReadRecentAudit(instanceKey *InstanceKey, page int) ([]Audit, error) {
res := []Audit{}
var whereCondition string
if instanceKey != nil {
whereCondition = fmt.Sprintf(`where hostname='%s' and port='%d'`, instanceKey.Hostname, instanceKey.Port)
}
query := fmt.Sprintf(`
select
audit_id,
audit_timestamp,
audit_type,
hostname,
port,
message
from
audit
%s
order by
audit_timestamp desc
limit %d
offset %d
`, whereCondition, config.Config.AuditPageSize, page*config.Config.AuditPageSize)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
audit := Audit{}
audit.AuditId = m.GetInt64("audit_id")
audit.AuditTimestamp = m.GetString("audit_timestamp")
audit.AuditType = m.GetString("audit_type")
audit.AuditInstanceKey.Hostname = m.GetString("hostname")
audit.AuditInstanceKey.Port = m.GetInt("port")
audit.Message = m.GetString("message")
res = append(res, audit)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:42,代码来源:audit_dao.go
示例15: ReadActiveMaintenance
// ReadActiveMaintenance returns the list of currently active maintenance entries
func ReadActiveMaintenance() ([]Maintenance, error) {
res := []Maintenance{}
query := fmt.Sprintf(`
select
database_instance_maintenance_id,
hostname,
port,
begin_timestamp,
timestampdiff(second, begin_timestamp, now()) as seconds_elapsed,
maintenance_active,
owner,
reason
from
database_instance_maintenance
where
maintenance_active = 1
order by
database_instance_maintenance_id
`)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
maintenance := Maintenance{}
maintenance.MaintenanceId = m.GetUint("database_instance_maintenance_id")
maintenance.Key.Hostname = m.GetString("hostname")
maintenance.Key.Port = m.GetInt("port")
maintenance.BeginTimestamp = m.GetString("begin_timestamp")
maintenance.SecondsElapsed = m.GetUint("seconds_elapsed")
maintenance.IsActive = m.GetBool("maintenance_active")
maintenance.Owner = m.GetString("owner")
maintenance.Reason = m.GetString("reason")
res = append(res, maintenance)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:41,代码来源:maintenance_dao.go
示例16: readAllHostnameResolves
func readAllHostnameResolves() ([]HostnameResolve, error) {
res := []HostnameResolve{}
query := `
select
hostname,
resolved_hostname
from
hostname_resolve
`
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
hostnameResolve := HostnameResolve{hostname: m.GetString("hostname"), resolvedHostname: m.GetString("resolved_hostname")}
res = append(res, hostnameResolve)
return nil
})
readAllResolvedHostnamesCounter.Inc(1)
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:0-T-0,项目名称:orchestrator,代码行数:22,代码来源:resolve_dao.go
示例17: ElectedNode
// ElectedNode returns the details of the elected node, as well as answering the question "is this process the elected one"?
func ElectedNode() (hostname string, token string, isElected bool, err error) {
query := `
select
hostname,
token
from
active_node
where
anchor = 1
`
err = db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
hostname = m.GetString("hostname")
token = m.GetString("token")
return nil
})
if err != nil {
log.Errore(err)
}
isElected = (hostname == ThisHostname && token == ProcessToken.Hash)
return hostname, token, isElected, err
}
开发者ID:0-T-0,项目名称:orchestrator,代码行数:23,代码来源:election_dao.go
示例18: readAvailableNodes
func readAvailableNodes() ([]string, error) {
res := []string{}
query := fmt.Sprintf(`
select
concat(hostname, ';', token) as node
from
node_health
where
last_seen_active > now() - interval %d second
order by
hostname
`, registrationPollSeconds*2)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
res = append(res, m.GetString("node"))
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:is00hcw,项目名称:orchestrator,代码行数:22,代码来源:health_dao.go
示例19: ReadOutdatedAgentsHosts
// ReadOutdatedAgentsHosts returns agents that need to be updated
func ReadOutdatedAgentsHosts() ([]string, error) {
res := []string{}
query := fmt.Sprintf(`
select
hostname
from
host_agent
where
IFNULL(last_checked < now() - interval %d minute, true)
`,
config.Config.AgentPollMinutes)
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
hostname := m.GetString("hostname")
res = append(res, hostname)
return nil
})
if err != nil {
log.Errore(err)
}
return res, err
}
开发者ID:dveeden,项目名称:orchestrator,代码行数:23,代码来源:agent_dao.go
示例20: ReadClusterAliases
// ReadClusterAliases reads the entrie cluster name aliases mapping
func ReadClusterAliases() error {
updatedMap := make(map[string]string)
query := `
select
cluster_name,
alias
from
cluster_alias
`
err := db.QueryOrchestratorRowsMap(query, func(m sqlutils.RowMap) error {
updatedMap[m.GetString("cluster_name")] = m.GetString("alias")
return nil
})
if err != nil {
log.Errore(err)
}
clusterAliasMapMutex.Lock()
defer clusterAliasMapMutex.Unlock()
clusterAliasMap = updatedMap
return err
}
开发者ID:rlowe,项目名称:orchestrator,代码行数:23,代码来源:cluster_alias_dao.go
注:本文中的github.com/outbrain/orchestrator/go/db.QueryOrchestratorRowsMap函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论