Documentation
¶
Index ¶
- Variables
- func CronExpiredTrans(num int)
- func CronTransOnce() (gid string)
- func CronUpdateTopicsMap()
- func CronUpdateTopicsMapOnce()
- func GenGid() string
- func GetStore() storage.Store
- func NewAsyncContext(ctx context.Context) context.Context
- func PopulateDB(skipDrop bool)
- func StartSvr() *gin.Engine
- func Subscribe(topic, url, remark string) error
- func Unsubscribe(topic, url string) error
- type Subscriber
- type Topic
- type TransBranch
- type TransGlobal
Constants ¶
This section is empty.
Variables ¶
var CronForwardDuration = time.Duration(0)
CronForwardDuration will be set in test. cron will fetch trans which expire in CronForwardDuration
var NowForwardDuration = time.Duration(0)
NowForwardDuration will be set in test, trans may be timeout
var TransProcessedTestChan chan string
TransProcessedTestChan only for test usage. when transaction processed once, write gid to this chan
var UpdateBranchAsyncInterval = 200 * time.Millisecond
UpdateBranchAsyncInterval interval to flush branch
var Version = ""
Version store the passin version for dtm server
Functions ¶
func CronExpiredTrans ¶
func CronExpiredTrans(num int)
CronExpiredTrans cron expired trans, num == -1 indicate for ever
func CronTransOnce ¶
func CronTransOnce() (gid string)
CronTransOnce cron expired trans. use expireIn as expire time
func CronUpdateTopicsMap ¶ added in v1.16.4
func CronUpdateTopicsMap()
CronUpdateTopicsMap cron updates topics map
func CronUpdateTopicsMapOnce ¶ added in v1.17.4
func CronUpdateTopicsMapOnce()
CronUpdateTopicsMapOnce cron updates topics map once
func NewAsyncContext ¶ added in v1.17.4
NewAsyncContext create a new async context the context will not be canceled when the parent context is canceled
func Unsubscribe ¶ added in v1.16.4
Unsubscribe unsubscribes the topic
Types ¶
type Subscriber ¶ added in v1.16.4
Subscriber define subscriber info
type Topic ¶ added in v1.16.4
type Topic struct {
Name string `json:"k"`
Subscribers []Subscriber `json:"v"`
Version uint64 `json:"version"`
}
Topic define topic info
type TransGlobal ¶
type TransGlobal struct {
storage.TransGlobalStore
ReqExtra map[string]string `json:"req_extra"`
Context context.Context
// contains filtered or unexported fields
}
TransGlobal global transaction
func GetTransGlobal ¶
func GetTransGlobal(gid string) *TransGlobal
GetTransGlobal construct trans from db
func TransFromContext ¶
func TransFromContext(c *gin.Context) *TransGlobal
TransFromContext TransFromContext
func TransFromDtmRequest ¶
func TransFromDtmRequest(ctx context.Context, c *dtmgpb.DtmRequest) *TransGlobal
TransFromDtmRequest TransFromContext
func TransFromJrpcParams ¶ added in v1.13.1
func TransFromJrpcParams(params interface{}) *TransGlobal
TransFromJrpcParams construct TransGlobal from jrpc params
func (*TransGlobal) Process ¶
func (t *TransGlobal) Process(branches []TransBranch) error
Process process global transaction once
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
boltdb
package boltdb implement the storage for boltdb
|
package boltdb implement the storage for boltdb |
|
redis
package reds implement the storage for reds
|
package reds implement the storage for reds |
|
sql
package boltdb implement the storage for sql database
|
package boltdb implement the storage for sql database |