Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.1.5

Dec 14, 2020

Changes in this version

+ const CronPeriod

v0.1.4

Dec 9, 2020

v0.1.3

Nov 1, 2020

v0.1.2

Sep 1, 2020

Changes in this version

+ const ALWAYS_RETRY_BOUNDARY

+ const ClientIdSplitChar

+ const DbkeysSplitChar

+ const IpPortSplitChar

+ const RPC_REQUEST_TIMEOUT

+ func SetServerGrpool()

+ type ATCore struct

+ func (core *ATCore) LockQuery(branchType meta.BranchType, resourceId string, xid string, lockKeys string) bool

+ type AbstractCore struct

+ MessageSender ServerMessageSender

+ type DefaultCoordinator struct

+ func NewDefaultCoordinator(conf config.ServerConfig) *DefaultCoordinator

+ func (coordinator *DefaultCoordinator) OnCheckMessage(rpcMessage protocal.RpcMessage, session getty.Session)

+ func (coordinator *DefaultCoordinator) OnClose(session getty.Session)

+ func (coordinator *DefaultCoordinator) OnCron(session getty.Session)

+ func (coordinator *DefaultCoordinator) OnError(session getty.Session, err error)

+ func (coordinator *DefaultCoordinator) OnMessage(session getty.Session, pkg interface{})

+ func (coordinator *DefaultCoordinator) OnOpen(session getty.Session) error

+ func (coordinator *DefaultCoordinator) OnRegRmMessage(rpcMessage protocal.RpcMessage, session getty.Session)

+ func (coordinator *DefaultCoordinator) OnRegTmMessage(rpcMessage protocal.RpcMessage, session getty.Session)

+ func (coordinator *DefaultCoordinator) OnTrxMessage(rpcMessage protocal.RpcMessage, session getty.Session)

+ func (coordinator *DefaultCoordinator) SendASyncRequest(session getty.Session, message interface{}) error

+ func (coordinator *DefaultCoordinator) SendResponse(request protocal.RpcMessage, session getty.Session, msg interface{})

+ func (coordinator *DefaultCoordinator) SendSyncRequest(resourceId string, clientId string, message interface{}) (interface{}, error)

+ func (coordinator *DefaultCoordinator) SendSyncRequestByGetty(session getty.Session, message interface{}) (interface{}, error)

+ func (coordinator *DefaultCoordinator) SendSyncRequestByGettyWithTimeout(session getty.Session, message interface{}, timeout time.Duration) (interface{}, error)

+ func (coordinator *DefaultCoordinator) SendSyncRequestWithTimeout(resourceId string, clientId string, message interface{}, timeout time.Duration) (interface{}, error)

+ func (coordinator *DefaultCoordinator) Stop()

+ type DefaultCore struct

+ func (core *DefaultCore) Begin(applicationId string, transactionServiceGroup string, name string, ...) (string, error)

+ func (core *DefaultCore) BranchRegister(branchType meta.BranchType, resourceId string, clientId string, xid string, ...) (int64, error)

+ func (core *DefaultCore) BranchReport(branchType meta.BranchType, xid string, branchId int64, ...) error

+ func (core *DefaultCore) Commit(xid string) (meta.GlobalStatus, error)

+ func (core *DefaultCore) GetStatus(xid string) (meta.GlobalStatus, error)

+ func (core *DefaultCore) GlobalReport(xid string, globalStatus meta.GlobalStatus) (meta.GlobalStatus, error)

+ func (core *DefaultCore) LockQuery(branchType meta.BranchType, resourceId string, xid string, lockKeys string) (bool, error)

+ func (core *DefaultCore) Rollback(xid string) (meta.GlobalStatus, error)

+ type GettySessionManager struct

+ TransactionServiceGroup string

+ Version string

+ var SessionManager GettySessionManager

+ func (manager *GettySessionManager) GetContextFromIdentified(session getty.Session) *RpcContext

+ func (manager *GettySessionManager) GetGettySession(resourceId string, clientId string) (getty.Session, error)

+ func (manager *GettySessionManager) GetRmSessions() map[string]getty.Session

+ func (manager *GettySessionManager) GetRoleFromGettySession(session getty.Session) meta.TransactionRole

+ func (manager *GettySessionManager) GetSameClientGettySession(session getty.Session) getty.Session

+ func (manager *GettySessionManager) IsRegistered(session getty.Session) bool

+ func (manager *GettySessionManager) RegisterRmGettySession(request protocal.RegisterRMRequest, session getty.Session)

+ func (manager *GettySessionManager) RegisterTmGettySession(request protocal.RegisterTMRequest, session getty.Session)

+ func (manager *GettySessionManager) ReleaseGettySession(session getty.Session)

+ type RpcContext struct

+ ApplicationId string

+ ClientId string

+ ClientRole meta.TransactionRole

+ ResourceSets *model.Set

+ Session getty.Session

+ TransactionServiceGroup string

+ Version string

+ func NewRpcContext(opts ...RpcContextOption) *RpcContext

+ func (context *RpcContext) AddResource(resource string)

+ func (context *RpcContext) AddResources(resources *model.Set)

+ type RpcContextOption func(ctx *RpcContext)

+ func WithRpcContextApplicationId(applicationId string) RpcContextOption

+ func WithRpcContextClientId(clientId string) RpcContextOption

+ func WithRpcContextClientRole(clientRole meta.TransactionRole) RpcContextOption

+ func WithRpcContextResourceSet(resourceSet *model.Set) RpcContextOption

+ func WithRpcContextSession(session getty.Session) RpcContextOption

+ func WithRpcContextTxServiceGroup(txServiceGroup string) RpcContextOption

+ func WithRpcContextVersion(version string) RpcContextOption

+ type SAGACore struct

+ type Server struct

+ func NewServer() *Server

+ func (s *Server) Start(addr string)

+ func (s *Server) Stop()

+ type ServerMessageListener interface

+ OnCheckMessage func(request protocal.RpcMessage, session getty.Session)

+ OnRegRmMessage func(request protocal.RpcMessage, session getty.Session)

+ OnRegTmMessage func(request protocal.RpcMessage, session getty.Session)

+ OnTrxMessage func(rpcMessage protocal.RpcMessage, session getty.Session)

+ type ServerMessageSender interface

+ SendASyncRequest func(session getty.Session, message interface{}) error

+ SendResponse func(request protocal.RpcMessage, session getty.Session, msg interface{})

+ SendSyncRequest func(resourceId string, clientId string, message interface{}) (interface{}, error)

+ SendSyncRequestByGetty func(session getty.Session, message interface{}) (interface{}, error)

+ SendSyncRequestByGettyWithTimeout func(session getty.Session, message interface{}, timeout time.Duration) (interface{}, error)

+ SendSyncRequestWithTimeout func(resourceId string, clientId string, message interface{}, timeout time.Duration) (interface{}, error)

+ type TCInboundHandler interface

+ type TransactionCoordinator interface

+ func NewCore(sender ServerMessageSender) TransactionCoordinator

+ type TransactionCoordinatorInbound interface

+ type TransactionCoordinatorOutbound interface