Home
last modified time | relevance | path

Searched refs:workerClient (Results 1 – 25 of 31) sorted by relevance

12

/dports/net/concourse-fly/concourse-6.7.1/atc/api/artifactserver/
H A Dserver.go10 workerClient worker.Client member
15 workerClient worker.Client,
19 workerClient: workerClient,
H A Dcreate.go33 volume, err := s.workerClient.CreateVolume(hLog, volumeSpec, workerSpec, db.VolumeTypeArtifact)
H A Dget.go39 workerVolume, found, err := s.workerClient.FindVolume(logger, team.ID(), artifactVolume.Handle())
/dports/misc/concourse/concourse-6.7.2/atc/api/artifactserver/
H A Dserver.go10 workerClient worker.Client member
15 workerClient worker.Client,
19 workerClient: workerClient,
H A Dcreate.go33 volume, err := s.workerClient.CreateVolume(hLog, volumeSpec, workerSpec, db.VolumeTypeArtifact)
H A Dget.go39 workerVolume, found, err := s.workerClient.FindVolume(logger, team.ID(), artifactVolume.Handle())
/dports/net/concourse-fly/concourse-6.7.1/atc/exec/
H A Dartifact_output_step.go26 workerClient worker.Client member
31 func NewArtifactOutputStep(plan atc.Plan, build db.Build, workerClient worker.Client, delegate Buil…
35 workerClient: workerClient,
54 volume, found, err := step.workerClient.FindVolume(logger, step.build.TeamID(), buildArtifact.ID())
H A Dartifact_input_step.go27 workerClient worker.Client member
32 func NewArtifactInputStep(plan atc.Plan, build db.Build, workerClient worker.Client, delegate Build…
36 workerClient: workerClient,
63 …_, found, err = step.workerClient.FindVolume(logger, createdVolume.TeamID(), createdVolume.Handle(…
H A Dput_step.go49 workerClient worker.Client member
62 workerClient worker.Client,
72 workerClient: workerClient,
190 result, err := step.workerClient.RunPutStep(
H A Dcheck_step.go28 workerClient worker.Client member
59 workerClient: client,
143 result, err := step.workerClient.RunCheckStep(
H A Dtask_step.go82 workerClient worker.Client member
95 workerClient worker.Client,
106 workerClient: workerClient,
160 taskConfigSource = FileConfigSource{ConfigPath: step.plan.ConfigPath, Client: step.workerClient}
251 result, err := step.workerClient.RunTaskStep(
H A Dget_step.go67 workerClient worker.Client member
92 workerClient: client,
191 getResult, err := step.workerClient.RunGetStep(
/dports/misc/concourse/concourse-6.7.2/atc/exec/
H A Dartifact_output_step.go26 workerClient worker.Client member
31 func NewArtifactOutputStep(plan atc.Plan, build db.Build, workerClient worker.Client, delegate Buil…
35 workerClient: workerClient,
54 volume, found, err := step.workerClient.FindVolume(logger, step.build.TeamID(), buildArtifact.ID())
H A Dartifact_input_step.go27 workerClient worker.Client member
32 func NewArtifactInputStep(plan atc.Plan, build db.Build, workerClient worker.Client, delegate Build…
36 workerClient: workerClient,
63 …_, found, err = step.workerClient.FindVolume(logger, createdVolume.TeamID(), createdVolume.Handle(…
H A Dput_step.go49 workerClient worker.Client member
62 workerClient worker.Client,
72 workerClient: workerClient,
190 result, err := step.workerClient.RunPutStep(
H A Dcheck_step.go28 workerClient worker.Client member
59 workerClient: client,
143 result, err := step.workerClient.RunCheckStep(
H A Dtask_step.go82 workerClient worker.Client member
95 workerClient worker.Client,
106 workerClient: workerClient,
160 taskConfigSource = FileConfigSource{ConfigPath: step.plan.ConfigPath, Client: step.workerClient}
251 result, err := step.workerClient.RunTaskStep(
H A Dget_step.go67 workerClient worker.Client member
92 workerClient: client,
191 getResult, err := step.workerClient.RunGetStep(
/dports/net/concourse-fly/concourse-6.7.1/atc/api/containerserver/
H A Dserver.go17 workerClient worker.Client member
29 workerClient worker.Client,
40 workerClient: workerClient,
/dports/misc/concourse/concourse-6.7.2/atc/api/containerserver/
H A Dserver.go17 workerClient worker.Client member
29 workerClient worker.Client,
40 workerClient: workerClient,
/dports/lang/go-devel/go-becaeea1199b875bc24800fa88f2f4fea119bf78/src/internal/fuzz/
H A Dworker.go58 client *workerClient // used to communicate with worker process
917 type workerClient struct { struct
929 func newWorkerClient(comm workerComm, m *mutator) *workerClient {
930 return &workerClient{workerComm: comm, m: m}
936 func (wc *workerClient) Close() error { argument
967 func (wc *workerClient) minimize(ctx context.Context, entryIn CorpusEntry, args minimizeArgs) (entr… argument
1053 func (wc *workerClient) fuzz(ctx context.Context, entryIn CorpusEntry, args fuzzArgs) (entryOut Cor… argument
1120 func (wc *workerClient) ping(ctx context.Context) error { argument
1130 func (wc *workerClient) callLocked(ctx context.Context, c call, resp any) (err error) { argument
/dports/net/concourse-fly/concourse-6.7.1/atc/api/
H A Dhandler.go61 workerClient worker.Client,
100 …containerServer := containerserver.NewServer(logger, workerClient, secretManager, varSourcePool, i…
104 artifactServer := artifactserver.NewServer(logger, workerClient)
/dports/misc/concourse/concourse-6.7.2/atc/api/
H A Dhandler.go61 workerClient worker.Client,
100 …containerServer := containerserver.NewServer(logger, workerClient, secretManager, varSourcePool, i…
104 artifactServer := artifactserver.NewServer(logger, workerClient)
/dports/devel/etcd/etcd-2.3.8/Godeps/_workspace/src/google.golang.org/grpc/benchmark/grpc_testing/
H A Dtest.pb.go722 type workerClient struct { struct
727 return &workerClient{cc}
730 func (c *workerClient) RunTest(ctx context.Context, opts ...grpc.CallOption) (Worker_RunTestClient,… argument
761 func (c *workerClient) RunServer(ctx context.Context, opts ...grpc.CallOption) (Worker_RunServerCli… argument
/dports/sysutils/docker-registry/distribution-2.7.1/vendor/google.golang.org/grpc/grpc-go-d3ddb4469d5a/benchmark/grpc_testing/
H A Dtest.pb.go722 type workerClient struct { struct
727 return &workerClient{cc}
730 func (c *workerClient) RunTest(ctx context.Context, opts ...grpc.CallOption) (Worker_RunTestClient,… argument
761 func (c *workerClient) RunServer(ctx context.Context, opts ...grpc.CallOption) (Worker_RunServerCli… argument

12