/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/ |
H A D | TestServerName.java | 45 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 D | HBaseCluster.java | 147 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 D | TestDrainingServer.java | 95 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 D | FavoredNodeLoadBalancer.java | 85 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 D | FavoredNodeAssignmentHelper.java | 166 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 D | server_name.rs | 15 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 D | DeadServer.java | 24 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 D | AssignmentVerificationReport.java | 77 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 D | TestRegionPlacement2.java | 35 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 D | TestClusterStatusPublisher.java | 24 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 D | interface.go | 32 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 D | TestFavoredNodeAssignmentHelper.java | 35 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 D | TestBaseLoadBalancer.java | 63 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 D | ra_directory.erl | 78 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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | testcases | 88 <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 D | interface.go | 29 …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 …]
|