hgearman-clientはどのように機能しますか？

Question

残念なことに、パッケージhgearmanはテストや例を提供せず、gearman job serverにジョブを入れるにはconnectGearmanとsubmitJobをどのように組み合わせるべきか自分では解決できません。

connectGearmanの結果は次のとおりです。

ghci> conn <- connectGearman (B.pack "x") ("localhost"::HostName) (4730::Port) 
ghci> :t conn 
conn :: Either GearmanError GearmanClient 

しかしsubmitJobはStateTを扱うプライベート関数submitを使用しています。だから私はconnectGearmanの結果がS.StateT GearmanClient IOに包まれるべきであると推測することができます。以下は

Answer 1

Gearmanクライアントの私の実装です：

{-# LANGUAGE DeriveDataTypeable #-} 
import Control.Exception (Exception, IOException, catch, throwIO) 
import qualified Data.ByteString.Char8 as B 
import Data.Typeable  (Typeable) 
import qualified Network.Gearman.Client as C 
import Network.Gearman.Internal (Function, GearmanClient, GearmanError, Port, withGearman) 
import Network.Socket (HostName) 

data ConnectException = ConnectException HostName Port IOException 
    deriving (Show, Typeable) 
instance Exception ConnectException 

main :: IO() 
main = do 
    c <- C.connectGearman (B.pack "client-id") host port `catch` \e -> throwIO (ConnectException host port e) 
    either (error . B.unpack) return c 
    >>= submitFooJob 
    >>= either(error . B.unpack) (putStrLn . B.unpack) 
    return() 
    where 
     host = "localhost"::HostName 
     port = 4730::Port 
     submitFooJob :: GearmanClient -> IO (Either GearmanError B.ByteString) 
     submitFooJob gc = withGearman gc $ C.submitJob (B.pack "foo"::Function) (B.pack "bar")