Compare commits
2 Commits
ec91990ea0
...
9677d5f554
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9677d5f554 | ||
|
|
c87f4a01ab |
@@ -41,6 +41,9 @@ spec:
|
||||
- containerPort: 8080
|
||||
name: web
|
||||
- containerPort: 1337
|
||||
name: rpc
|
||||
- containerPort: 1338
|
||||
name: quorum
|
||||
volumeMounts:
|
||||
- mountPath: "/data"
|
||||
name: data
|
||||
|
||||
@@ -83,9 +83,9 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
|
||||
remoteIndex: make(map[CartId]*RemoteGrainPool),
|
||||
}
|
||||
if d != nil {
|
||||
cartPurge := time.NewTicker(time.Minute)
|
||||
discoveryTimer := time.NewTicker(time.Second * 5)
|
||||
go func() {
|
||||
<-cartPurge.C
|
||||
<-discoveryTimer.C
|
||||
hosts, err := d.Discover()
|
||||
if err != nil {
|
||||
log.Printf("Error discovering hosts: %v\n", err)
|
||||
|
||||
Reference in New Issue
Block a user