/dports/net/concourse-fly/concourse-6.7.1/atc/api/artifactserver/ |
H A D | server.go | 10 workerClient worker.Client member 15 workerClient worker.Client, 19 workerClient: workerClient,
|
H A D | create.go | 33 volume, err := s.workerClient.CreateVolume(hLog, volumeSpec, workerSpec, db.VolumeTypeArtifact)
|
H A D | get.go | 39 workerVolume, found, err := s.workerClient.FindVolume(logger, team.ID(), artifactVolume.Handle())
|
/dports/misc/concourse/concourse-6.7.2/atc/api/artifactserver/ |
H A D | server.go | 10 workerClient worker.Client member 15 workerClient worker.Client, 19 workerClient: workerClient,
|
H A D | create.go | 33 volume, err := s.workerClient.CreateVolume(hLog, volumeSpec, workerSpec, db.VolumeTypeArtifact)
|
H A D | get.go | 39 workerVolume, found, err := s.workerClient.FindVolume(logger, team.ID(), artifactVolume.Handle())
|
/dports/net/concourse-fly/concourse-6.7.1/atc/exec/ |
H A D | artifact_output_step.go | 26 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 D | artifact_input_step.go | 27 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 D | put_step.go | 49 workerClient worker.Client member 62 workerClient worker.Client, 72 workerClient: workerClient, 190 result, err := step.workerClient.RunPutStep(
|
H A D | check_step.go | 28 workerClient worker.Client member 59 workerClient: client, 143 result, err := step.workerClient.RunCheckStep(
|
H A D | task_step.go | 82 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 D | get_step.go | 67 workerClient worker.Client member 92 workerClient: client, 191 getResult, err := step.workerClient.RunGetStep(
|
/dports/misc/concourse/concourse-6.7.2/atc/exec/ |
H A D | artifact_output_step.go | 26 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 D | artifact_input_step.go | 27 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 D | put_step.go | 49 workerClient worker.Client member 62 workerClient worker.Client, 72 workerClient: workerClient, 190 result, err := step.workerClient.RunPutStep(
|
H A D | check_step.go | 28 workerClient worker.Client member 59 workerClient: client, 143 result, err := step.workerClient.RunCheckStep(
|
H A D | task_step.go | 82 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 D | get_step.go | 67 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 D | server.go | 17 workerClient worker.Client member 29 workerClient worker.Client, 40 workerClient: workerClient,
|
/dports/misc/concourse/concourse-6.7.2/atc/api/containerserver/ |
H A D | server.go | 17 workerClient worker.Client member 29 workerClient worker.Client, 40 workerClient: workerClient,
|
/dports/lang/go-devel/go-becaeea1199b875bc24800fa88f2f4fea119bf78/src/internal/fuzz/ |
H A D | worker.go | 58 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 D | handler.go | 61 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 D | handler.go | 61 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 D | test.pb.go | 722 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 D | test.pb.go | 722 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
|