feat(sftp): add modtime as metadata. [redpanda-data#2955]

danriedl · Oct 30, 2024 · f75c3de · f75c3de
1 parent 1c5a28f
commit f75c3de
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/impl/sftp/input.go b/internal/impl/sftp/input.go
@@ -53,6 +53,7 @@ func sftpInputSpec() *service.ConfigSpec {
 This input adds the following metadata fields to each message:
 
 - sftp_path
+- sftp_modification_time
 
 You can access these metadata fields using xref:configuration:interpolation.adoc#bloblang-queries[function interpolation].`).
 		Fields(
@@ -295,6 +296,8 @@ func (s *sftpReader) ReadBatch(ctx context.Context) (service.MessageBatch, servi
 
 	for _, part := range parts {
 		part.MetaSetMut("sftp_path", currentPath)
+		fileInfo, _ := s.client.Stat(currentPath)
+		part.MetaSetMut("sftp_modification_time", fileInfo.ModTime())
 	}
 
 	return parts, func(ctx context.Context, res error) error {