@@ -43,7 +43,7 @@ type S3Object struct {
4343 LastModified time.Time
4444}
4545
46- func NewS3Watcher (c interface {}) (Watcher , error ) {
46+ func newS3Watcher (c interface {}) (Watcher , error ) {
4747 var config * S3Configuration
4848 var ok bool
4949 if config , ok = c .(* S3Configuration ); ! ok {
@@ -128,7 +128,7 @@ func (u *S3Watcher) sync() {
128128
129129 fileList := make (map [string ]* S3Object , 0 )
130130
131- err := u .EnumerateFiles (u .config .BucketName , u .watchDir , func (page int64 , obj * ObjectInfo ) bool {
131+ err := u .enumerateFiles (u .config .BucketName , u .watchDir , func (page int64 , obj * ObjectInfo ) bool {
132132 // Get Info from S3 object
133133 upd , err := u .getInfoFromObject (obj )
134134 if err != nil {
@@ -240,7 +240,7 @@ func (u *S3Watcher) getInfoFromObject(obj *ObjectInfo) (*S3Object, error) {
240240 return upd , nil
241241}
242242
243- func (u * S3Watcher ) EnumerateFiles (bucket , prefix string , callback func (page int64 , object * ObjectInfo ) bool ) error {
243+ func (u * S3Watcher ) enumerateFiles (bucket , prefix string , callback func (page int64 , object * ObjectInfo ) bool ) error {
244244 doneCh := make (chan struct {})
245245 defer close (doneCh )
246246
@@ -266,5 +266,5 @@ func (u *S3Watcher) EnumerateFiles(bucket, prefix string, callback func(page int
266266}
267267
268268func init () {
269- supportedServices ["s3" ] = NewS3Watcher
269+ supportedServices ["s3" ] = newS3Watcher
270270}
0 commit comments