def run(self, conn, qps, size, duration):
    size = (size or self.size)
    if (duration is None):
        duration = self.duration
    labels = self.run_id
    labels += ('_qps_' + str(qps))
    labels += ('_c_' + str(conn))
    labels += ('_' + str(size))
    labels += '_'
    labels += self.mixer_mode
    if (self.labels is not None):
        labels += ('_' + self.labels)
    grpc = ''
    if (self.mode == 'grpc'):
        grpc = '-grpc -ping'
    fortio_cmd = ('fortio load -c {conn} -qps {qps} -t {duration}s -a -r {r} {grpc} -httpbufferkb=128 ' + '-labels {labels}').format(conn=conn, qps=qps, duration=duration, r=self.r, grpc=grpc, labels=labels)
    if self.run_ingress:
        kubectl_exec(self.client.name, self.ingress(fortio_cmd))
        if self.perf_record:
            run_perf(self.mesh, self.server.name, (labels + '_srv_ingress'), duration=40)
    if self.run_serversidecar:
        kubectl_exec(self.client.name, self.serversidecar(fortio_cmd))
        if self.perf_record:
            run_perf(self.mesh, self.server.name, (labels + '_srv_serveronly'), duration=40)
    if self.run_clientsidecar:
        kubectl_exec(self.client.name, self.bothsidecar(fortio_cmd))
        if self.perf_record:
            run_perf(self.mesh, self.server.name, (labels + '_srv_bothsidecars'), duration=40)
    if self.run_baseline:
        kubectl_exec(self.client.name, self.nosidecar(fortio_cmd))
def run(self, conn, qps, size, duration):
    size = (size or self.size)
    if (duration is None):
        duration = self.duration
    labels = self.run_id
    labels += ('_qps_' + str(qps))
    labels += ('_c_' + str(conn))
    labels += ('_' + str(size))
    labels += '_'
    labels += self.mixer_mode
    if (self.labels is not None):
        labels += ('_' + self.labels)
    grpc = 
    if (self.mode == 'grpc'):
        grpc = '-grpc -ping'
    fortio_cmd = ('fortio load -c {conn} -qps {qps} -t {duration}s -a -r {r} {grpc} -httpbufferkb=128 ' + '-labels {labels}').format(conn=conn, qps=qps, duration=duration, r=self.r, grpc=grpc, labels=labels)
    if self.run_ingress:
        kubectl_exec(self.client.name, self.ingress(fortio_cmd))
        if self.perf_record:
            run_perf(self.mesh, self.server.name, (labels + '_srv_ingress'), duration=40)
    if self.run_serversidecar:
        kubectl_exec(self.client.name, self.serversidecar(fortio_cmd))
        if self.perf_record:
            run_perf(self.mesh, self.server.name, (labels + '_srv_serveronly'), duration=40)
    if self.run_clientsidecar:
        kubectl_exec(self.client.name, self.bothsidecar(fortio_cmd))
        if self.perf_record:
            run_perf(self.mesh, self.server.name, (labels + '_srv_bothsidecars'), duration=40)
    if self.run_baseline:
        kubectl_exec(self.client.name, self.nosidecar(fortio_cmd))