From ee148b4d18535ee26bce4b90380d91a1d9e4ac15 Mon Sep 17 00:00:00 2001 From: Darren Shepherd Date: Tue, 28 Nov 2017 18:58:13 -0700 Subject: [PATCH] Startup helper method --- controller/starter.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/controller/starter.go b/controller/starter.go index 31cc069d..2c488a17 100644 --- a/controller/starter.go +++ b/controller/starter.go @@ -11,6 +11,13 @@ type Starter interface { Start(ctx context.Context, threadiness int) error } +func SyncThenSync(ctx context.Context, threadiness int, starters ...Starter) error { + if err := Sync(ctx, starters...); err != nil { + return err + } + return Start(ctx, threadiness, starters...) +} + func Sync(ctx context.Context, starters ...Starter) error { eg, _ := errgroup.WithContext(ctx) for _, starter := range starters {