dtm

May 27, 2026

Changes in this version

type DTMClient

+ func (d *DTMClient) InitializeContext(ctx context.Context, plugin plugins.Plugin, rt plugins.Runtime) error

+ func (d *DTMClient) IsContextAware() bool

+ func (d *DTMClient) PluginProtocol() plugins.PluginProtocol

+ func (d *DTMClient) StartContext(ctx context.Context, _ plugins.Plugin) error

+ func (d *DTMClient) StopContext(ctx context.Context, _ plugins.Plugin) error

Mar 2, 2026

Changes in this version

+ var ErrNotImplemented = errors.New("lynx-dtm: feature not implemented")

+ func ValidateConfig(c *conf.DTM) error

type DTMClient

+ func (d *DTMClient) CheckHealth() error

+ func (d *DTMClient) Configure(c any) error

+ func (d *DTMClient) IsEnabled() bool

+ type DtmMetrics struct

+ func GetDtmMetrics() *DtmMetrics

+ func (m *DtmMetrics) DecActiveTransactions()

+ func (m *DtmMetrics) IncActiveTransactions()

+ func (m *DtmMetrics) IncBarrierOperations()

+ func (m *DtmMetrics) RecordGidRequest(status string)

+ func (m *DtmMetrics) RecordHealthCheck(status string)

+ func (m *DtmMetrics) RecordTransaction(txType, status string)

+ func (m *DtmMetrics) RecordTransactionDuration(txType, status string, duration float64)

Feb 10, 2026

Changes in this version

+ func CreateGrpcContext(ctx context.Context, gid string, transType string, branchID string, op string) context.Context

+ func ExtractGrpcTransInfo(ctx context.Context) (*dtmcli.BranchBarrier, error)

+ type BarrierHandler struct

+ func NewBarrierHandler(client *DTMClient) *BarrierHandler

+ func (b *BarrierHandler) CallWithDB(ctx context.Context, db *sql.DB, req *dtmcli.BranchBarrier, ...) error

+ func (b *BarrierHandler) CallWithTx(ctx context.Context, tx *sql.Tx, req *dtmcli.BranchBarrier, ...) error

+ func (b *BarrierHandler) CreateBarrierFromGin(c interface{}) (*dtmcli.BranchBarrier, error)

+ func (b *BarrierHandler) CreateBarrierFromGrpc(ctx context.Context) (*dtmcli.BranchBarrier, error)

+ func (b *BarrierHandler) HandleMsg(ctx context.Context, bb *dtmcli.BranchBarrier, db *sql.DB, ...) error

+ func (b *BarrierHandler) HandleSAGA(ctx context.Context, bb *dtmcli.BranchBarrier, db *sql.DB, ...) error

+ func (b *BarrierHandler) HandleTCCCancel(ctx context.Context, bb *dtmcli.BranchBarrier, db *sql.DB, ...) error

+ func (b *BarrierHandler) HandleTCCConfirm(ctx context.Context, bb *dtmcli.BranchBarrier, db *sql.DB, ...) error

+ func (b *BarrierHandler) HandleTCCTry(ctx context.Context, bb *dtmcli.BranchBarrier, db *sql.DB, ...) error

+ type DTMClient struct

+ func NewDTMClient() *DTMClient

+ func (d *DTMClient) CallBranch(ctx context.Context, body interface{}, tryURL string, confirmURL string, ...) (*dtmcli.BranchBarrier, error)

+ func (d *DTMClient) CleanupTasks() error

+ func (d *DTMClient) GenerateGid() string

+ func (d *DTMClient) GetConfig() *conf.DTM

+ func (d *DTMClient) GetGRPCServer() string

+ func (d *DTMClient) GetServerURL() string

+ func (d *DTMClient) InitializeResources(rt plugins.Runtime) error

+ func (d *DTMClient) NewMsg(gid string) *dtmcli.Msg

+ func (d *DTMClient) NewSaga(gid string) *dtmcli.Saga

+ func (d *DTMClient) NewTcc(gid string) *dtmcli.Tcc

+ func (d *DTMClient) NewXa(gid string) *dtmcli.Xa

+ func (d *DTMClient) StartupTasks() error

+ type ExampleService struct

+ func NewExampleService(dtmClient *DTMClient, db *sql.DB) *ExampleService

+ func (s *ExampleService) BarrierExample(ctx context.Context, bb *dtmcli.BranchBarrier) error

+ func (s *ExampleService) HandleTCCCancelExample(ctx context.Context, req map[string]interface{}) error

+ func (s *ExampleService) HandleTCCConfirmExample(ctx context.Context, req map[string]interface{}) error

+ func (s *ExampleService) HandleTCCTryExample(ctx context.Context, req map[string]interface{}) error

+ func (s *ExampleService) MessageExample(ctx context.Context, messageID string, content string) error

+ func (s *ExampleService) OrderExample(ctx context.Context, orderID string, userID string, productID string, ...) error

+ func (s *ExampleService) TransferExample(ctx context.Context, fromAccount, toAccount string, amount float64) error

+ func (s *ExampleService) WorkflowExample(ctx context.Context) error

+ type MsgBranch struct

+ Action string

+ Data interface{}

+ type SAGABranch struct

+ Action string

+ Compensate string

+ Data interface{}

+ type TCCBranch struct

+ Cancel string

+ Confirm string

+ Data interface{}

+ Try string

+ type TransactionHelper struct

+ func NewTransactionHelper(client *DTMClient) *TransactionHelper

+ func (h *TransactionHelper) CheckTransactionStatus(gid string) (string, error)

+ func (h *TransactionHelper) ExecuteMsg(ctx context.Context, gid string, queryPrepared string, branches []MsgBranch, ...) error

+ func (h *TransactionHelper) ExecuteSAGA(ctx context.Context, gid string, branches []SAGABranch, ...) error

+ func (h *TransactionHelper) ExecuteTCC(ctx context.Context, gid string, branches []TCCBranch, ...) error

+ func (h *TransactionHelper) ExecuteXA(ctx context.Context, gid string, branches []XABranch, opts *TransactionOptions) error

+ func (h *TransactionHelper) GenGid() (string, error)

+ func (h *TransactionHelper) MustGenGid() string

+ func (h *TransactionHelper) RegisterGrpcService(serviceName string, endpoint string) error

+ type TransactionOptions struct

+ BranchTimeout int64

+ Concurrent bool

+ CustomHeaders map[string]string

+ RetryInterval int64

+ TimeoutToFail int64

+ WaitResult bool

+ func DefaultTransactionOptions() *TransactionOptions

+ type TransactionType string

+ const TransTypeMsg

+ const TransTypeSAGA

+ const TransTypeTCC

+ const TransTypeXA

+ type XABranch struct

+ Action string

+ Data string