本文整理汇总了Golang中github.com/pachyderm/pachyderm/src/pps.ApiClient类的典型用法代码示例。如果您正苦于以下问题:Golang ApiClient类的具体用法?Golang ApiClient怎么用?Golang ApiClient使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了ApiClient类的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: GetPipelineGithub
func GetPipelineGithub(
apiClient pps.ApiClient,
contextDir string,
user string,
repository string,
branch string,
commitID string,
accessToken string,
) (*pps.GetPipelineResponse, error) {
return apiClient.GetPipeline(
context.Background(),
&pps.GetPipelineRequest{
PipelineSource: &pps.PipelineSource{
GithubPipelineSource: &pps.GithubPipelineSource{
ContextDir: contextDir,
User: user,
Repository: repository,
Branch: branch,
CommitId: commitID,
AccessToken: accessToken,
},
},
},
)
}
开发者ID:kunthar,项目名称:pachyderm,代码行数:25,代码来源:ppsutil.go
示例2: getFinalPipelineRunStatus
func getFinalPipelineRunStatus(apiClient pps.ApiClient, pipelineRunID string) (*pps.PipelineRunStatus, error) {
// TODO(pedge): not good
ticker := time.NewTicker(time.Second)
for i := 0; i < 60; i++ {
<-ticker.C
pipelineRunStatuses, err := apiClient.GetPipelineRunStatus(
context.Background(),
&pps.GetPipelineRunStatusRequest{
PipelineRunId: pipelineRunID,
},
)
if err != nil {
return nil, err
}
pipelineRunStatus := pipelineRunStatuses.PipelineRunStatus[0]
protolog.Printf("status at tick %d: %v\n", i, pipelineRunStatus)
switch pipelineRunStatus.PipelineRunStatusType {
case pps.PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_ERROR:
return pipelineRunStatus, nil
case pps.PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_SUCCESS:
return pipelineRunStatus, nil
}
}
return nil, fmt.Errorf("did not get final pipeline status for %s", pipelineRunID)
}
开发者ID:sr,项目名称:pachyderm,代码行数:25,代码来源:server_test.go
示例3: GetPipelineRunStatus
func GetPipelineRunStatus(
apiClient pps.ApiClient,
pipelineRunID string,
) (*pps.GetPipelineRunStatusResponse, error) {
return apiClient.GetPipelineRunStatus(
context.Background(),
&pps.GetPipelineRunStatusRequest{
PipelineRunId: pipelineRunID,
},
)
}
开发者ID:henrylee2cn,项目名称:pachyderm,代码行数:11,代码来源:ppsutil.go
示例4: GetVersion
func GetVersion(apiClient pps.ApiClient) (*pps.GetVersionResponse, error) {
return apiClient.GetVersion(
context.Background(),
&google_protobuf.Empty{},
)
}
开发者ID:plar,项目名称:pachyderm,代码行数:6,代码来源:ppsutil.go
示例5: testBasic
func testBasic(t *testing.T, apiClient pps.ApiClient) {
_ = os.RemoveAll("/tmp/pachyderm-test")
pipelineSource, err := apiClient.CreatePipelineSource(
context.Background(),
&pps.CreatePipelineSourceRequest{
PipelineSource: &pps.PipelineSource{
TypedPipelineSource: &pps.PipelineSource_GithubPipelineSource{
GithubPipelineSource: &pps.GithubPipelineSource{
ContextDir: "src/pps/server/testdata/basic",
User: "pachyderm",
Repository: "pachyderm",
Branch: "master",
},
},
},
},
)
require.NoError(t, err)
pipeline, err := apiClient.CreateAndGetPipeline(
context.Background(),
&pps.CreateAndGetPipelineRequest{
PipelineSourceId: pipelineSource.Id,
},
)
require.NoError(t, err)
pipelineRun, err := apiClient.CreatePipelineRun(
context.Background(),
&pps.CreatePipelineRunRequest{
PipelineId: pipeline.Id,
},
)
require.NoError(t, err)
_, err = apiClient.StartPipelineRun(
context.Background(),
&pps.StartPipelineRunRequest{
PipelineRunId: pipelineRun.Id,
},
)
require.NoError(t, err)
pipelineRunID := pipelineRun.Id
pipelineRunStatus, err := getFinalPipelineRunStatus(apiClient, pipelineRunID)
require.NoError(t, err)
require.Equal(t, pps.PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_SUCCESS, pipelineRunStatus.PipelineRunStatusType)
matches, err := filepath.Glob("/tmp/pachyderm-test/1-out/*")
require.NoError(t, err)
require.Equal(
t,
[]string{
"/tmp/pachyderm-test/1-out/1.txt",
"/tmp/pachyderm-test/1-out/10.txt",
"/tmp/pachyderm-test/1-out/2.txt",
"/tmp/pachyderm-test/1-out/20.txt",
"/tmp/pachyderm-test/1-out/3.txt",
"/tmp/pachyderm-test/1-out/30.txt",
"/tmp/pachyderm-test/1-out/4.txt",
"/tmp/pachyderm-test/1-out/40.txt",
"/tmp/pachyderm-test/1-out/5.txt",
"/tmp/pachyderm-test/1-out/50.txt",
},
matches,
)
matches, err = filepath.Glob("/tmp/pachyderm-test/2-out/*")
require.NoError(t, err)
require.Equal(
t,
[]string{
"/tmp/pachyderm-test/2-out/1.txt.copy",
"/tmp/pachyderm-test/2-out/10.txt.copy",
"/tmp/pachyderm-test/2-out/2.txt.copy",
"/tmp/pachyderm-test/2-out/20.txt.copy",
"/tmp/pachyderm-test/2-out/3.txt.copy",
"/tmp/pachyderm-test/2-out/30.txt.copy",
"/tmp/pachyderm-test/2-out/4.txt.copy",
"/tmp/pachyderm-test/2-out/40.txt.copy",
"/tmp/pachyderm-test/2-out/5.txt.copy",
"/tmp/pachyderm-test/2-out/50.txt.copy",
},
matches,
)
matches, err = filepath.Glob("/tmp/pachyderm-test/3-out/*")
require.NoError(t, err)
require.Equal(
t,
[]string{
"/tmp/pachyderm-test/3-out/1.txt.copy3",
"/tmp/pachyderm-test/3-out/10.txt.copy3",
"/tmp/pachyderm-test/3-out/2.txt.copy3",
"/tmp/pachyderm-test/3-out/20.txt.copy3",
"/tmp/pachyderm-test/3-out/3.txt.copy3",
"/tmp/pachyderm-test/3-out/30.txt.copy3",
"/tmp/pachyderm-test/3-out/4.txt.copy3",
"/tmp/pachyderm-test/3-out/40.txt.copy3",
"/tmp/pachyderm-test/3-out/5.txt.copy3",
"/tmp/pachyderm-test/3-out/50.txt.copy3",
},
matches,
)
matches, err = filepath.Glob("/tmp/pachyderm-test/4-out/*")
require.NoError(t, err)
require.Equal(
//.........这里部分代码省略.........
开发者ID:sr,项目名称:pachyderm,代码行数:101,代码来源:server_test.go
注:本文中的github.com/pachyderm/pachyderm/src/pps.ApiClient类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论