Home
last modified time | relevance | path

Searched refs:ClientService (Results 1 – 25 of 159) sorted by relevance

1234567

/dports/misc/amanda-server/amanda-3.3.9/installcheck/
H A DAmanda_ClientService.pl27 use Amanda::ClientService;
47 my $cs = Amanda::ClientService->new();
104 $cs = Amanda::ClientService->new();
108 $cs = Amanda::ClientService->new();
112 $cs = Amanda::ClientService->new();
116 $cs = Amanda::ClientService->new();
121 $cs = Amanda::ClientService->new();
132 my $cs = Amanda::ClientService->new();
190 my $cs = Amanda::ClientService->new();
207 my $cs = Amanda::ClientService->new();
[all …]
H A Dnoop.pl27 use Installcheck::ClientService;
57 $service = Installcheck::ClientService->new(
/dports/misc/amanda-client/amanda-3.3.9/installcheck/
H A DAmanda_ClientService.pl27 use Amanda::ClientService;
47 my $cs = Amanda::ClientService->new();
104 $cs = Amanda::ClientService->new();
108 $cs = Amanda::ClientService->new();
112 $cs = Amanda::ClientService->new();
116 $cs = Amanda::ClientService->new();
121 $cs = Amanda::ClientService->new();
132 my $cs = Amanda::ClientService->new();
190 my $cs = Amanda::ClientService->new();
207 my $cs = Amanda::ClientService->new();
[all …]
H A Dnoop.pl27 use Installcheck::ClientService;
57 $service = Installcheck::ClientService->new(
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/test/java/org/apache/hadoop/hbase/client/
H A DTestMetricsConnection.java23 import org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ClientService;
71 ClientService.getDescriptor().findMethodByName("Get"), in testStaticMetrics()
75 ClientService.getDescriptor().findMethodByName("Scan"), in testStaticMetrics()
79 ClientService.getDescriptor().findMethodByName("Multi"), in testStaticMetrics()
83 ClientService.getDescriptor().findMethodByName("Mutate"), in testStaticMetrics()
90 ClientService.getDescriptor().findMethodByName("Mutate"), in testStaticMetrics()
97 ClientService.getDescriptor().findMethodByName("Mutate"), in testStaticMetrics()
104 ClientService.getDescriptor().findMethodByName("Mutate"), in testStaticMetrics()
H A DTestClientNoCluster.java56 import org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ClientService;
262 final ClientService.BlockingInterface stub;
269 this.stub = Mockito.mock(ClientService.BlockingInterface.class); in ScanOpenNextThenExceptionThenRecoverConnection()
294 final ClientService.BlockingInterface stub;
301 this.stub = Mockito.mock(ClientService.BlockingInterface.class); in RegionServerStoppedOnScannerOpenConnection()
326 final ClientService.BlockingInterface stub;
332 this.stub = Mockito.mock(ClientService.BlockingInterface.class); in RpcTimeoutConnection()
354 final Map<ServerName, ClientService.BlockingInterface> serversByClient;
369 new HashMap<ServerName, ClientService.BlockingInterface>(serverCount); in ManyServersManyRegionsConnection()
381 ClientService.BlockingInterface stub = null; in getClient()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/rm/
H A DTestRMCommunicator.java22 import org.apache.hadoop.mapreduce.v2.app.client.ClientService;
40 public MockRMCommunicator(ClientService clientService, AppContext context) { in MockRMCommunicator()
51 ClientService mockClientService = mock(ClientService.class); in testRMContainerAllocatorExceptionIsHandled()
73 ClientService mockClientService = mock(ClientService.class); in testRMContainerAllocatorYarnRuntimeExceptionIsHandled()
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-proto-0.1.1/src/simple/pipeline/
H A Dclient.rs58 type BindClient = ClientService<T, P>;
61 ClientService { in bind_client()
89 pub struct ClientService<T, P> where T: 'static, P: ClientProto<T> { struct
93 impl<T, P> Clone for ClientService<T, P> where T: 'static, P: ClientProto<T> { implementation
95 ClientService { in clone()
101 impl<T, P> Service for ClientService<T, P> where T: 'static, P: ClientProto<T> { implementation
114 impl<T, P> fmt::Debug for ClientService<T, P> implementation
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-proto-0.1.1/src/simple/multiplex/
H A Dclient.rs59 type BindClient = ClientService<T, P>;
62 ClientService { in bind_client()
90 pub struct ClientService<T, P> where T: 'static, P: ClientProto<T> { struct
94 impl<T, P> Service for ClientService<T, P> where T: 'static, P: ClientProto<T> { argument
107 impl<T, P> Clone for ClientService<T, P> where T: 'static, P: ClientProto<T> { implementation
109 ClientService { in clone()
115 impl<T, P> fmt::Debug for ClientService<T, P> implementation
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-proto-0.1.1/src/simple/multiplex/
H A Dclient.rs59 type BindClient = ClientService<T, P>;
62 ClientService { in bind_client()
90 pub struct ClientService<T, P> where T: 'static, P: ClientProto<T> { struct
94 impl<T, P> Service for ClientService<T, P> where T: 'static, P: ClientProto<T> { argument
107 impl<T, P> Clone for ClientService<T, P> where T: 'static, P: ClientProto<T> { implementation
109 ClientService { in clone()
115 impl<T, P> fmt::Debug for ClientService<T, P> implementation
/dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-proto-0.1.1/src/simple/pipeline/
H A Dclient.rs58 type BindClient = ClientService<T, P>;
61 ClientService { in bind_client()
89 pub struct ClientService<T, P> where T: 'static, P: ClientProto<T> { struct
93 impl<T, P> Clone for ClientService<T, P> where T: 'static, P: ClientProto<T> { argument
95 ClientService { in clone()
101 impl<T, P> Service for ClientService<T, P> where T: 'static, P: ClientProto<T> { implementation
114 impl<T, P> fmt::Debug for ClientService<T, P> implementation
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/alertmanager/api/v2/client/
H A Dalertmanager_client.go125 Alert alert.ClientService
127 Alertgroup alertgroup.ClientService
129 General general.ClientService
131 Receiver receiver.ClientService
133 Silence silence.ClientService
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/prometheus/alertmanager/api/v2/client/
H A Dalertmanager_client.go125 Alert alert.ClientService
127 Alertgroup alertgroup.ClientService
129 General general.ClientService
131 Receiver receiver.ClientService
133 Silence silence.ClientService
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/client/
H A DConnectionUtils.java31 import org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ClientService;
119 final ClientService.BlockingInterface client) { in createShortCircuitHConnection()
128 public ClientService.BlockingInterface getClient( in createShortCircuitHConnection()
149 final AdminService.BlockingInterface admin, final ClientService.BlockingInterface client)
162 public ClientService.BlockingInterface getClient(ServerName sn) throws IOException {
H A DRegionServerCallable.java30 import org.apache.hadoop.hbase.protobuf.generated.ClientProtos.ClientService;
51 private ClientService.BlockingInterface stub;
91 protected ClientService.BlockingInterface getStub() { in getStub()
95 void setStub(final ClientService.BlockingInterface stub) { in setStub()
/dports/dns/blocky/blocky-0.17/vendor/github.com/asaskevich/EventBus/
H A Dclient.go28 service *ClientService
37 client.service = &ClientService{client, &sync.WaitGroup{}, false}
109 type ClientService struct { struct
116 func (service *ClientService) PushEvent(arg *ClientArg, reply *bool) error { argument
/dports/www/beehive/beehive-0.4.0/vendor/github.com/asaskevich/EventBus/
H A Dclient.go28 service *ClientService
37 client.service = &ClientService{client, &sync.WaitGroup{}, false}
109 type ClientService struct { struct
116 func (service *ClientService) PushEvent(arg *ClientArg, reply *bool) error { argument
/dports/www/aquatone/aquatone-1.7.0/vendor/github.com/asaskevich/EventBus/
H A Dclient.go28 service *ClientService
37 client.service = &ClientService{client, &sync.WaitGroup{}, false}
109 type ClientService struct { struct
116 func (service *ClientService) PushEvent(arg *ClientArg, reply *bool) error { argument
/dports/mail/geary/geary-40.0/test/mock/
H A Dmock-client-service.vala8 public class Mock.ClientService : Geary.ClientService {
11 public ClientService(Geary.AccountInformation account,
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/
H A DTestMetaTableLocator.java114 final ClientProtos.ClientService.BlockingInterface client = in testMetaLookup()
115 Mockito.mock(ClientProtos.ClientService.BlockingInterface.class); in testMetaLookup()
150 final ClientProtos.ClientService.BlockingInterface client = in testInterruptWaitOnMeta()
151 Mockito.mock(ClientProtos.ClientService.BlockingInterface.class); in testInterruptWaitOnMeta()
182 final ClientProtos.ClientService.BlockingInterface implementation = in testVerifyMetaRegionLocationWithException()
183 Mockito.mock(ClientProtos.ClientService.BlockingInterface.class); in testVerifyMetaRegionLocationWithException()
312 final ClientProtos.ClientService.BlockingInterface client) in mockConnection()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/alertmanager/api/v2/client/alertgroup/
H A Dalertgroup_client.go30 func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {
43 type ClientService interface { interface
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/alertmanager/api/v2/client/general/
H A Dgeneral_client.go30 func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {
43 type ClientService interface { interface
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/alertmanager/api/v2/client/receiver/
H A Dreceiver_client.go30 func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {
43 type ClientService interface { interface
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/prometheus/alertmanager/api/v2/client/alertgroup/
H A Dalertgroup_client.go30 func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {
43 type ClientService interface { interface
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/prometheus/alertmanager/api/v2/client/general/
H A Dgeneral_client.go30 func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {
43 type ClientService interface { interface

1234567