Documentation ¶
Index ¶
Constants ¶
View Source
const ( // RetryDelay 初始重试延迟,用于消息处理时的重试策略 RetryDelay = time.Millisecond // MaxRetryAttempts 最大重试次数 MaxRetryAttempts = 1 )
Variables ¶
This section is empty.
Functions ¶
func InjectServerSync ¶
func InjectServerSync(s *ServerSync)
func LoadServerSync ¶
func LoadServerSync() baseiface.ISingleton
Types ¶
type ServerSync ¶
type ServerSync struct { basedto.BaseEntitySingle *goproxy.GonatsProxy }
func NewServerSync ¶
func NewServerSync() *ServerSync
func (*ServerSync) StartServer ¶
func (self *ServerSync) StartServer() error
Click to show internal directories.
Click to hide internal directories.