interfaces

type AMQPServiceInterface interface {
	PublishMessage(exchangeName string, topic string, message map[string]interface{})
}

type S3ServiceInterface interface {
	GenerateUploadPayload(ctx context.Context, data []byte, s3Path, filename string, metadata map[string]string) (*s3.PutObjectInput, error)
	BulkUploadFiles(ctx context.Context, payloads []*s3.PutObjectInput) ([]string, error)
	BulkDeleteFiles(ctx context.Context, uploadedKeys []string)
}