forked from SW/traefik
Watch bool
This commit is contained in:
@@ -8,6 +8,7 @@ import(
|
||||
)
|
||||
|
||||
type DockerProvider struct {
|
||||
Watch bool
|
||||
Endpoint string
|
||||
dockerClient *docker.Client
|
||||
}
|
||||
@@ -15,7 +16,9 @@ type DockerProvider struct {
|
||||
func (provider *DockerProvider) Provide(serviceChan chan<- *Service){
|
||||
provider.dockerClient, _ = docker.NewClient(provider.Endpoint)
|
||||
dockerEvents := make(chan *docker.APIEvents)
|
||||
provider.dockerClient.AddEventListener(dockerEvents)
|
||||
if(provider.Watch) {
|
||||
provider.dockerClient.AddEventListener(dockerEvents)
|
||||
}
|
||||
go func() {
|
||||
for {
|
||||
event := <-dockerEvents
|
||||
|
||||
5
file.go
5
file.go
@@ -10,6 +10,7 @@ import (
|
||||
)
|
||||
|
||||
type FileProvider struct {
|
||||
Watch bool
|
||||
Filename string
|
||||
}
|
||||
|
||||
@@ -45,7 +46,9 @@ func (provider *FileProvider) Provide(serviceChan chan<- *Service){
|
||||
}
|
||||
}()
|
||||
|
||||
err = watcher.Add(filepath.Dir(file.Name()))
|
||||
if(provider.Watch){
|
||||
err = watcher.Add(filepath.Dir(file.Name()))
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
log.Println(err)
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
#[docker]
|
||||
#endpoint = "unix:///var/run/docker.sock"
|
||||
[docker]
|
||||
endpoint = "unix:///var/run/docker.sock"
|
||||
watch = true
|
||||
|
||||
[file]
|
||||
filename = "file.toml"
|
||||
#[file]
|
||||
#filename = "file.toml"
|
||||
#watch = true
|
||||
Reference in New Issue
Block a user