internal

package
v0.0.0-...-bbbb84d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 16, 2026 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ProcessOne 

func ProcessOne(clientS3 *minio.Client, cfg *utils.S3, task *ConvertTask) error

func RegisterMetrics 

func RegisterMetrics()

func RetrieveS3File 

func RetrieveS3File(clientS3 *minio.Client, bucketName string, objectName string) (*minio.Object, string, error)

func StartProcessing 

func StartProcessing(sigchan chan os.Signal, wg *sync.WaitGroup, cfg *utils.Config)

Types

type ConvertTask 

type ConvertTask struct {
	FilenameProcessed string    `json:"filename_processed"`
	FilenameRaw       string    `json:"filename_raw"`
	Message           string    `json:"message"`
	QueuedAt          time.Time `json:"queued_at"`
	K                 int       `json:"k"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.