starting polling trigger by default

pull/43/head
Karolis Rusenas 2017-07-23 18:15:16 +01:00
parent df28e2e598
commit 48fddbaf90
4 changed files with 9 additions and 7 deletions

View File

@ -20,8 +20,8 @@ spec:
- image: karolisr/keel:0.3.1
imagePullPolicy: Always
env:
- name: POLL
value: "1"
# - name: POLL
# value: "1"
- name: PUBSUB
value: "1"
# Enable/disable Helm provider

View File

@ -57,7 +57,7 @@ func main() {
"version": ver.Version,
"go_version": ver.GoVersion,
"arch": ver.Arch,
}).Info("Keel starting..")
}).Info("keel starting..")
if os.Getenv(EnvDebug) != "" {
log.SetLevel(log.DebugLevel)
@ -230,7 +230,7 @@ func setupTriggers(ctx context.Context, providers provider.Providers) (teardown
go subManager.Start(ctx)
}
if os.Getenv(EnvTriggerPoll) != "" {
if os.Getenv(EnvTriggerPoll) != "0" {
registryClient := registry.New()
watcher := poll.NewRepositoryWatcher(providers, registryClient)

View File

@ -28,7 +28,7 @@ func New(providers []Provider) *DefaultProviders {
for _, p := range providers {
pvs[p.GetName()] = p
log.Infof("provider.DefaultProviders: provider '%s' registered", p.GetName())
log.Infof("provider.defaultProviders: provider '%s' registered", p.GetName())
}
return &DefaultProviders{
@ -51,7 +51,7 @@ func (p *DefaultProviders) Submit(event types.Event) error {
"provider": provider.GetName(),
"event": event.Repository,
"trigger": event.TriggerName,
}).Error("provider.DefaultProviders: submit event failed")
}).Error("provider.defaultProviders: submit event failed")
}
}
@ -67,7 +67,7 @@ func (p *DefaultProviders) TrackedImages() ([]*types.TrackedImage, error) {
log.WithFields(log.Fields{
"error": err,
"provider": provider.GetName(),
}).Error("provider.DefaultProviders: failed to get tracked images")
}).Error("provider.defaultProviders: failed to get tracked images")
continue
}
trackedImages = append(trackedImages, ti...)

View File

@ -51,6 +51,8 @@ func (s *DefaultManager) Start(ctx context.Context) error {
// setting root context
s.ctx = ctx
log.Info("trigger.poll.manager: polling trigger configured")
// initial scan
err := s.scan(ctx)
if err != nil {