Home
last modified time | relevance | path

Searched refs:ServerName (Results 1 – 25 of 6076) sorted by relevance

12345678910>>...244

/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/
H A DTestServerName.java45 ServerName sn = ServerName.valueOf("asf000.sp2.ygridcore.net", 1, 1); in testGetHostNameMinusDomain()
51 ServerName sn = ServerName.valueOf("asf000.sp2.ygridcore.net", 1, 1); in testShortString()
55 sn = ServerName.valueOf("1.1.1.1", 1, 1); in testShortString()
72 ServerName sn = ServerName.valueOf(snStr); in testParseOfBytes()
79 ServerName.SERVERNAME_SEPARATOR + ServerName.NON_STARTCODE; in testParseOfBytes()
85 ServerName sn = ServerName.valueOf("www.example.org", 1234, 5678); in testServerName()
86 ServerName sn2 = ServerName.valueOf("www.example.org", 1234, 5678); in testServerName()
87 ServerName sn3 = ServerName.valueOf("www.example.org", 1234, 56789); in testServerName()
103 ServerName sn = ServerName.valueOf("www.example.org", 1234, 5678); in getServerStartcodeFromServerName()
112 ServerName lower = ServerName.valueOf("www.example.org", 1234, 5678); in testHostNameCaseSensitivity()
[all …]
H A DHBaseCluster.java147 for (ServerName server : getClusterStatus().getServers()) { in waitForRegionServerToStart()
179 public abstract void killZkNode(ServerName serverName) throws IOException; in killZkNode()
186 public abstract void stopZkNode(ServerName serverName) throws IOException; in stopZkNode()
201 public abstract void waitForZkNodeToStop(ServerName serverName, long timeout) in waitForZkNodeToStop()
209 public abstract void startDataNode(ServerName serverName) throws IOException; in startDataNode()
216 public abstract void killDataNode(ServerName serverName) throws IOException; in killDataNode()
223 public abstract void stopDataNode(ServerName serverName) throws IOException; in stopDataNode()
255 public abstract void killMaster(ServerName serverName) throws IOException; in killMaster()
261 public abstract void stopMaster(ServerName serverName) throws IOException; in stopMaster()
267 public abstract void waitForMasterToStop(ServerName serverName, long timeout) in waitForMasterToStop()
[all …]
H A DTestDrainingServer.java95 final ServerName SERVERNAME_A = ServerName.valueOf("mockserver_a.org", 1000, 8000); in testAssignmentManagerDoesntUseDrainingServer()
96 final ServerName SERVERNAME_B = ServerName.valueOf("mockserver_b.org", 1001, 8000); in testAssignmentManagerDoesntUseDrainingServer()
104 Map<ServerName, ServerLoad> onlineServers = new HashMap<ServerName, ServerLoad>(); in testAssignmentManagerDoesntUseDrainingServer()
172 final ServerName SERVERNAME_A = ServerName.valueOf("mockserverbulk_a.org", 1000, 8000); in testAssignmentManagerDoesntUseDrainedServerWithBulkAssign()
173 final ServerName SERVERNAME_B = ServerName.valueOf("mockserverbulk_b.org", 1001, 8000); in testAssignmentManagerDoesntUseDrainedServerWithBulkAssign()
174 final ServerName SERVERNAME_C = ServerName.valueOf("mockserverbulk_c.org", 1002, 8000); in testAssignmentManagerDoesntUseDrainedServerWithBulkAssign()
175 final ServerName SERVERNAME_D = ServerName.valueOf("mockserverbulk_d.org", 1003, 8000); in testAssignmentManagerDoesntUseDrainedServerWithBulkAssign()
177 final Map<HRegionInfo, ServerName> bulk = new HashMap<HRegionInfo, ServerName>(); in testAssignmentManagerDoesntUseDrainedServerWithBulkAssign()
179 Set<ServerName> bunchServersAssigned = new HashSet<ServerName>(); in testAssignmentManagerDoesntUseDrainedServerWithBulkAssign()
192 Map<ServerName, ServerLoad> onlineServers = new HashMap<ServerName, ServerLoad>(); in testAssignmentManagerDoesntUseDrainedServerWithBulkAssign()
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/
H A DFavoredNodeLoadBalancer.java85 Map<ServerName, ServerName> serverNameToServerNameWithoutCode = in balanceCluster()
86 new HashMap<ServerName, ServerName>(); in balanceCluster()
87 Map<ServerName, ServerName> serverNameWithoutCodeToServerName = in balanceCluster()
88 new HashMap<ServerName, ServerName>(); in balanceCluster()
91 ServerName s = ServerName.valueOf(sn.getHostname(), sn.getPort(), ServerName.NON_STARTCODE); in balanceCluster()
192 public ServerName randomAssignment(HRegionInfo regionInfo, List<ServerName> servers) { in randomAssignment()
267 private ServerName availableServersContains(List<ServerName> servers, ServerName favoredNode) { in availableServersContains()
278 ServerName secondaryHost, ServerName tertiaryHost) { in assignRegionToAvailableFavoredNode()
284 ServerName s; in assignRegionToAvailableFavoredNode()
317 Map<HRegionInfo, ServerName> primaryRSMap = new HashMap<HRegionInfo, ServerName>(); in roundRobinAssignmentImpl()
[all …]
H A DFavoredNodeAssignmentHelper.java166 ServerName[] servers = new ServerName[protoNodes.size()]; in getFavoredNodesList()
181 HBaseProtos.ServerName.Builder b = HBaseProtos.ServerName.newBuilder(); in getFavoredNodes()
358 Set<ServerName> serverSet = new HashSet<ServerName>(); in multiRackCaseWithRestrictions()
366 Set<ServerName> skipServerSet = new HashSet<ServerName>(); in multiRackCaseWithRestrictions()
425 Set<ServerName> serverSkipSet = new HashSet<ServerName>(); in multiRackCaseWithRestrictions()
439 ServerName primaryRS, in singleRackCase()
451 Set<ServerName> serverSkipSet = new HashSet<ServerName>(); in singleRackCase()
469 ServerName[] favoredNodes = new ServerName[2]; in singleRackCase()
486 ServerName[] favoredNodes = new ServerName[2]; in multiRackCase()
496 Set<ServerName> skipServerSet = new HashSet<ServerName>(); in multiRackCase()
[all …]
/dports/net-im/fractal/fractal-4.4.0/vendor/ruma-identifiers/src/
H A Dserver_name.rs15 pub struct ServerName(str); struct
17 impl ServerName { impl
42 impl Clone for Box<ServerName> {
48 impl ToOwned for ServerName { implementation
49 type Owned = Box<ServerName>;
56 impl From<&ServerName> for Box<ServerName> {
57 fn from(s: &ServerName) -> Self { in from()
115 impl AsRef<str> for ServerName { implementation
158 impl Display for ServerName { implementation
174 partial_eq_string!(ServerName);
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/
H A DDeadServer.java24 import org.apache.hadoop.hbase.ServerName;
54 private final Map<ServerName, Long> deadServers = new HashMap<ServerName, Long>();
77 ServerName sn = it.next(); in cleanPreviousInstance()
105 Set<ServerName> clone = new HashSet<ServerName>(deadServers.size()); in copyServerNames()
114 public synchronized void add(ServerName sn) { in add()
131 public synchronized void finish(ServerName sn) { in finish()
156 ServerName sn = it.next(); in cleanAllPreviousInstances()
165 for (ServerName sn : deadServers.keySet()) { in toString()
180 List<Pair<ServerName, Long>> res = new ArrayList<Pair<ServerName, Long>>(size()); in copyDeadServersSince()
203 new Comparator<Pair<ServerName, Long>>(){
[all …]
H A DAssignmentVerificationReport.java77 new HashSet<ServerName>();
79 new HashSet<ServerName>();
84 new HashSet<ServerName>();
87 new HashSet<ServerName>();
92 new HashSet<ServerName>();
95 new HashSet<ServerName>();
119 Map<ServerName, Set<ServerName>> primaryToSecTerRSMap = in fillUp()
120 new HashMap<ServerName, Set<ServerName>>(); in fillUp()
149 ServerName primaryRS = in fillUp()
345 Map<ServerName, Set<ServerName>> primaryToSecTerRSMap = in fillUpDispersion()
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/
H A DTestRegionPlacement2.java35 import org.apache.hadoop.hbase.ServerName;
74 List<ServerName> servers = new ArrayList<ServerName>(); in testFavoredNodesPresentForRoundRobinAssignment()
122 List<ServerName> favoredNodesNow = in testFavoredNodesPresentForRoundRobinAssignment()
134 List<ServerName> servers = new ArrayList<ServerName>(); in testFavoredNodesPresentForRandomAssignment()
175 private List<ServerName> removeMatchingServers(Collection<ServerName> serversWithoutStartCode, in removeMatchingServers()
176 List<ServerName> servers) { in removeMatchingServers()
177 List<ServerName> serversToRemove = new ArrayList<ServerName>(); in removeMatchingServers()
184 private List<ServerName> removeMatchingServers(ServerName serverWithoutStartCode, in removeMatchingServers()
185 List<ServerName> servers) { in removeMatchingServers()
186 List<ServerName> serversToRemove = new ArrayList<ServerName>(); in removeMatchingServers()
[all …]
H A DTestClusterStatusPublisher.java24 import org.apache.hadoop.hbase.ServerName;
51 return new ArrayList<Pair<ServerName, Long>>(); in testEmpty()
63 List<Pair<ServerName, Long>> res = new ArrayList<Pair<ServerName, Long>>(); in testMaxSend()
66 res.add(new Pair<ServerName, Long>(ServerName.valueOf("hn", 10, 10), 1L)); in testMaxSend()
89 List<Pair<ServerName, Long>> res = new ArrayList<Pair<ServerName, Long>>(); in testOrder()
91 res.add(new Pair<ServerName, Long>(ServerName.valueOf("hn" + i, 10, 10), 20L)); in testOrder()
100 List<ServerName> allSNS = csp.generateDeadServersListToSend(); in testOrder()
105 List<ServerName> nextMes = csp.generateDeadServersListToSend(); in testOrder()
107 for (ServerName sn : nextMes) { in testOrder()
116 for (ServerName sn : nextMes) { in testOrder()
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/federationsender/storage/
H A Dinterface.go32 GetAllJoinedHosts(ctx context.Context) ([]gomatrixserverlib.ServerName, error)
34 …GetJoinedHostsForRooms(ctx context.Context, roomIDs []string) ([]gomatrixserverlib.ServerName, err…
45 …CleanPDUs(ctx context.Context, serverName gomatrixserverlib.ServerName, receipts []*shared.Receipt… argument
46 …CleanEDUs(ctx context.Context, serverName gomatrixserverlib.ServerName, receipts []*shared.Receipt… argument
48 GetPendingPDUCount(ctx context.Context, serverName gomatrixserverlib.ServerName) (int64, error) argument
49 GetPendingEDUCount(ctx context.Context, serverName gomatrixserverlib.ServerName) (int64, error) argument
51 GetPendingPDUServerNames(ctx context.Context) ([]gomatrixserverlib.ServerName, error)
52 GetPendingEDUServerNames(ctx context.Context) ([]gomatrixserverlib.ServerName, error)
55 AddServerToBlacklist(serverName gomatrixserverlib.ServerName) error argument
56 RemoveServerFromBlacklist(serverName gomatrixserverlib.ServerName) error argument
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/
H A DTestFavoredNodeAssignmentHelper.java35 import org.apache.hadoop.hbase.ServerName;
48 private static List<ServerName> servers = new ArrayList<ServerName>();
50 List<ServerName>>();
58 ServerName server = ServerName.valueOf("foo" + i + ":1234", -1); in setupBeforeClass()
62 List<ServerName> servers = new ArrayList<ServerName>(); in setupBeforeClass()
70 List<ServerName> servers = new ArrayList<ServerName>(); in setupBeforeClass()
78 List<ServerName> servers = new ArrayList<ServerName>(); in setupBeforeClass()
91 List<ServerName> chosenServers = new ArrayList<ServerName>(); in getServersFromRack()
250 ServerName s = primaryRSMap.get(region); in testSecondaryAndTertiaryPlacementWithMoreThanOneServerInPrimaryRack()
267 Map<HRegionInfo, ServerName> primaryRSMap = new HashMap<HRegionInfo, ServerName>(); in secondaryAndTertiaryRSPlacementHelper()
[all …]
H A DTestBaseLoadBalancer.java63 private static final ServerName master = ServerName.valueOf("fake-master", 0, 1L);
66 private static ServerName[] servers = new ServerName[NUM_SERVERS];
184 Map<HRegionInfo, ServerName> existing = new TreeMap<HRegionInfo, ServerName>(); in testRetainAssignment()
348 List<ServerName> list = new ArrayList<ServerName>(); in getListOfServerNames()
369 List<ServerName> servers, Map<ServerName, List<HRegionInfo>> assignment) { in assertRetainedAssignment() argument
371 Set<ServerName> onlineServerSet = new TreeSet<ServerName>(servers); in assertRetainedAssignment()
383 for (ServerName s : servers) { in assertRetainedAssignment()
407 Map<ServerName, List<HRegionInfo>> clusterState = new HashMap<ServerName, List<HRegionInfo>>(); in testClusterServersWithSameHostPort()
412 List<ServerName> oldServers = new ArrayList<ServerName>(servers.size()); in testClusterServersWithSameHostPort()
413 for (ServerName sn : servers) { in testClusterServersWithSameHostPort()
[all …]
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/ra/src/
H A Dra_directory.erl78 ServerName, ClusterName) ->
81 case uid_of(System, ServerName) of
95 [{_, _, _, ServerName, _}] ->
108 when is_atom(ServerName) ->
125 when is_atom(ServerName) ->
141 [{_, _, _, ServerName, _}] -> ServerName;
163 uid_of(get_names(System), ServerName);
164 uid_of(#{directory_rev := Tbl}, ServerName) when is_atom(ServerName) ->
165 case dets:lookup(Tbl, ServerName) of
170 uid_of(SystemOrNames, {ServerName, _}) when is_atom(ServerName) ->
[all …]
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/sun/jvmstat/monitor/HostIdentifier/
H A Dtestcases88 <testcase id="12" HostIdentifierInput="//localhost/ServerName">
92 <HostIdentifier> //localhost/ServerName </HostIdentifier>
99 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
106 <HostIdentifier> //localhost:1234/ServerName </HostIdentifier>
113 <HostIdentifier> local://localhost/ServerName </HostIdentifier>
123 <testcase id="17" HostIdentifierInput="10.0.0.1/ServerName">
127 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
130 <testcase id="18" HostIdentifierInput="//10.0.0.1/ServerName">
134 <HostIdentifier> //10.0.0.1/ServerName </HostIdentifier>
141 <HostIdentifier> //10.0.0.1:1234/ServerName </HostIdentifier>
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/federationsender/storage/tables/
H A Dinterface.go29 …DeleteQueuePDUs(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName, jsonNID… argument
31 …SelectQueuePDUCount(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName) (in… argument
33 SelectQueuePDUServerNames(ctx context.Context, txn *sql.Tx) ([]gomatrixserverlib.ServerName, error)
38 …DeleteQueueEDUs(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName, jsonNID… argument
41 …SelectQueueEDUCount(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName) (in… argument
42 SelectQueueEDUServerNames(ctx context.Context, txn *sql.Tx) ([]gomatrixserverlib.ServerName, error)
57 SelectAllJoinedHosts(ctx context.Context) ([]gomatrixserverlib.ServerName, error)
58 …SelectJoinedHostsForRooms(ctx context.Context, roomIDs []string) ([]gomatrixserverlib.ServerName, …
62 InsertBlacklist(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName) error argument
63 …SelectBlacklist(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName) (bool, … argument
[all …]

12345678910>>...244