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