import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
public Statistics statsContainer(String id) throws IOException {
    this.readWriteLock.readLock().lock();

    try {
        StatsCmd statsCmd = this.dockerClient.statsCmd(id);
        CountDownLatch countDownLatch = new CountDownLatch(1);
        StatsLogsResultCallback statslogs = new StatsLogsResultCallback(countDownLatch);
        try {
            StatsLogsResultCallback statscallback = statsCmd.exec(statslogs);
            countDownLatch.await(5, TimeUnit.SECONDS);
            statscallback.close();
        } catch (InterruptedException e) {
            throw new IOException(e);
        }
        return statslogs.getStatistics();
    } finally {
        this.readWriteLock.readLock().unlock();
    }
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
public void setupMocks() {
    Mockito.when(dockerClient.statsCmd(Matchers.any(StatsCallback.class))).thenAnswer(new Answer<StatsCmd>() {
        public StatsCmd answer(InvocationOnMock invocation) {
            Object[] args = invocation.getArguments();
            callback = (StatsCallback)args[0];
            return statsCmd;
        }
    });
    
  
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
@Override
protected AbstractCallbackNotifier<Statistics> callbackNotifier(StatsCmd command,
        ResultCallback<Statistics> resultCallback) {

    WebTarget webTarget = getBaseResource().path("/containers/{id}/stats").resolveTemplate("id",
            command.getContainerId());

    LOGGER.trace("GET: {}", webTarget);

    return new GETCallbackNotifier<Statistics>(new JsonStreamProcessor<Statistics>(Statistics.class),
            resultCallback, webTarget.request());
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
@Override
public StatsCmd.Exec createStatsCmdExec() {
    return new StatsCmdExec(getBaseResource(), getDockerClientConfig());
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
@Override
public StatsCmd statsCmd(String containerId) {
    return new StatsCmdImpl(getDockerCmdExecFactory().createStatsCmdExec(), containerId);
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
public StatsCmdImpl(StatsCmd.Exec exec, String containerId) {
    super(exec);
    withContainerId(containerId);
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
@Override
public StatsCmd withContainerId(String containerId) {
    checkNotNull(containerId, "containerId was not specified");
    this.containerId = containerId;
    return this;
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
@Override
public StatsCmd.Exec createStatsCmdExec() {
    return delegate.createStatsCmdExec();
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
@Override
protected Void execute0(StatsCmd command, ResultCallback<Statistics> resultCallback) {

    WebTarget webTarget = getBaseResource().path("/containers/{id}/stats").resolveTemplate("id",
            command.getContainerId());

    LOGGER.trace("GET: {}", webTarget);

    webTarget.request().get(new TypeReference<Statistics>() {
    }, resultCallback);

    return null;
}
 

import com.github.dockerjava.api.command.StatsCmd; //导入依赖的package包/类
StatsCmd statsCmd(String containerId);