diff --git a/pkg/sync/file/filepath_sync.go b/pkg/sync/file/filepath_sync.go index c88316555..31df41454 100644 --- a/pkg/sync/file/filepath_sync.go +++ b/pkg/sync/file/filepath_sync.go @@ -17,8 +17,7 @@ import ( ) type Sync struct { - URI string - + URI string Logger *logger.Logger ProviderArgs sync.ProviderArgs // FileType indicates the file type e.g., json, yaml/yml etc., diff --git a/pkg/sync/kubernetes/kubernetes_sync.go b/pkg/sync/kubernetes/kubernetes_sync.go index c06195bd2..ac37eb117 100644 --- a/pkg/sync/kubernetes/kubernetes_sync.go +++ b/pkg/sync/kubernetes/kubernetes_sync.go @@ -30,7 +30,6 @@ type Sync struct { ProviderArgs sync.ProviderArgs client client.Client URI string - Source string ready bool } @@ -39,7 +38,7 @@ func (k *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error if err != nil { return err } - dataSync <- sync.DataSync{FlagData: fetch, Source: k.Source, Type: sync.ALL} + dataSync <- sync.DataSync{FlagData: fetch, Source: k.URI, Type: sync.ALL} return nil } @@ -61,7 +60,7 @@ func (k *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error { return err } - dataSync <- sync.DataSync{FlagData: fetch, Source: k.Source, Type: sync.ALL} + dataSync <- sync.DataSync{FlagData: fetch, Source: k.URI, Type: sync.ALL} notifies := make(chan INotify) @@ -81,7 +80,7 @@ func (k *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error { continue } - dataSync <- sync.DataSync{FlagData: msg, Source: k.Source, Type: sync.ALL} + dataSync <- sync.DataSync{FlagData: msg, Source: k.URI, Type: sync.ALL} case DefaultEventTypeModify: k.Logger.Debug("Configuration modified") msg, err := k.fetch(ctx) @@ -90,7 +89,7 @@ func (k *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error { continue } - dataSync <- sync.DataSync{FlagData: msg, Source: k.Source, Type: sync.ALL} + dataSync <- sync.DataSync{FlagData: msg, Source: k.URI, Type: sync.ALL} case DefaultEventTypeDelete: k.Logger.Debug("configuration deleted") case DefaultEventTypeReady: