tx

package

v0.9.7 Latest Latest Go to latest Published: Dec 4, 2015 License: GPL-2.0 Imports: 6 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/unirita/cuto

Links

Open Source Insights

Documentation ¶

Overview ¶

トランザクション機能を提供するパッケージ。

Index ¶

func InsertJob(conn db.IConnection, job *db.JobResult, mutex *sync.Mutex) error
func UpdateJob(conn db.IConnection, job *db.JobResult, mutex *sync.Mutex) error
type JobMap
type ResultMap
- func ResumeJobNetwork(nid int, dbname string) (*ResultMap, error)
- func StartJobNetwork(jobnetName string, dbname string) (*ResultMap, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InsertJob ¶

func InsertJob(conn db.IConnection, job *db.JobResult, mutex *sync.Mutex) error

JOBテーブルへINSERTする。

param - conn DBコネクション

param - job JOBレコード構造体ポインタ

func UpdateJob ¶

func UpdateJob(conn db.IConnection, job *db.JobResult, mutex *sync.Mutex) error

JOBテーブルへUPDATEする。

param - conn DBコネクション

param - job JOBレコード構造体ポインタ

Types ¶

type JobMap ¶

type JobMap map[string]*db.JobResult

ジョブIDをキーに持つ

type ResultMap ¶

type ResultMap struct {
	JobnetResult *db.JobNetworkResult // ジョブネットワーク情報の構造体。
	Jobresults   JobMap               // ジョブネットワーク内のジョブ状態を保存するMap。
	// contains filtered or unexported fields
}

ジョブ実行結果を保持する。

func ResumeJobNetwork ¶

func ResumeJobNetwork(nid int, dbname string) (*ResultMap, error)

ジョブネットワークの実行結果を復元する。

func StartJobNetwork ¶

func StartJobNetwork(jobnetName string, dbname string) (*ResultMap, error)

ジョブネットワークの開始状態を記録する。

param : jobnetName ジョブネットワーク名。

param : dbname データベース名。

return : ジョブ実行結果を保持する構造体ポインタ。

return : error

func (*ResultMap) EndJobNetwork ¶

func (r *ResultMap) EndJobNetwork(status int, detail string) error

ネットワーク終了時に結果情報を設定する。同時にDBコネクションも切断する。

param : status ジョブネットワークのステータス。

param : detail ジョブネットワークに記録する詳細メッセージ。

return : error

func (*ResultMap) GetConnection ¶

func (r *ResultMap) GetConnection() db.IConnection

DBコネクションを返す。

func (*ResultMap) SetConnection ¶

func (r *ResultMap) SetConnection(conn db.IConnection)

DBコネクションを外部から渡す。テスト用のメソッド。

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL