mirrors/woodpecker
1
0
Fork 0
mirror of https://github.com/woodpecker-ci/woodpecker.git synced 2024-06-16 04:10:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #2294 from jmccann/keepalive

Browse source 
Add keepalive to agents
This commit is contained in:
Brad Rydzewski 2018-01-08 11:00:28 -08:00 committed by GitHub
parent e582c20812 164fd0ad3f
commit fc22c5b39a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 15 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
cmd/drone-agent/agent.go
View file

@ -12,6 +12,7 @@ import (
"time"
"google.golang.org/grpc"
"google.golang.org/grpc/keepalive"
"google.golang.org/grpc/metadata"
"github.com/cncd/pipeline/pipeline"
@ -75,6 +76,10 @@ func loop(c *cli.Context) error {
username: c.String("username"),
password: c.String("password"),
}),
grpc.WithKeepaliveParams(keepalive.ClientParameters{
Time: c.Duration("keepalive-time"),
Timeout: c.Duration("keepalive-timeout"),
}),
)
if err != nil {

10
cmd/drone-agent/main.go
View file

@ -80,6 +80,16 @@ func main() {
Name: "healthcheck",
Usage: "enables the healthcheck endpoint",
},
cli.DurationFlag{
EnvVar: "DRONE_KEEPALIVE_TIME",
Name: "keepalive-time",
Usage: "after a duration of this time if the agent doesn't see any activity it pings the server to see if the transport is still alive",
},
cli.DurationFlag{
EnvVar: "DRONE_KEEPALIVE_TIMEOUT",
Name: "keepalive-timeout",
Usage: "after having pinged for keepalive check, the client waits for a duration of Timeout and if no activity is seen even after that the connection is closed.",
},
}
if err := app.Run(os.Args); err != nil {