Fix bugs of replicaton

This commit is contained in:
Wenkai Yin 2017-12-08 15:30:41 +08:00
parent fe10c2e7f5
commit 76c88d8d49

View File

@ -83,7 +83,7 @@ func NewDefaultController(cfg ControllerConfig) *DefaultController {
triggerManager: trigger.NewManager(cfg.CacheCapacity),
}
endpoint := config.InternalJobServiceURL()
endpoint := "http://jobservice"
client := client.NewAuthorizedClient(auth.NewSecretAuthorizer(config.UISecret()))
ctl.replicator = replicator.NewDefaultReplicator(endpoint, client)