Commitb660daf

committed

Fixed type conversion interface error

1 parent424cca8 commitb660dafCopy full SHA for b660daf

File tree

-4

lines changed

-4

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -11,8 +11,8 @@ import (`
`11`	`11`	`// PluginGRPC is the Gaia plugin interface used for communication`
`12`	`12`	`// with the plugin.`
`13`	`13`	`typePluginGRPCinterface {`
`14`		`-GetJobs() (*proto.Plugin_GetJobsClient,error)`
`15`		`-ExecuteJob(jobproto.Job) (proto.Empty,error)`
	`14`	`+GetJobs() (proto.Plugin_GetJobsClient,error)`
	`15`	`+ExecuteJob(jobproto.Job) (proto.JobResult,error)`
`16`	`16`	`}`
`17`	`17`
`18`	`18`	`// GRPCClient represents gRPC client`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@ import (`
`11`	`11`	`)`
`12`	`12`
`13`	`13`	`const (`
`14`		`-pluginMapKey="plugin"`
	`14`	`+pluginMapKey="Plugin"`
`15`	`15`	`)`
`16`	`16`
`17`	`17`	`varhandshake= plugin.HandshakeConfig{`
`@@ -96,7 +96,7 @@ func (p *Plugin) GetJobs() ([]gaia.Job, error) {`
`96`	`96`
`97`	`97`	`// receive all jobs`
`98`	`98`	`for {`
`99`		`-job,err:=(*stream).Recv()`
	`99`	`+job,err:=stream.Recv()`
`100`	`100`
`101`	`101`	`// Got all jobs`
`102`	`102`	`iferr==io.EOF {`

Comments

(0)