cliasync

package
v1.0.1-rel-02 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 12, 2024 License: AFL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InjectCliAsync

func InjectCliAsync(s *CliAsync)

func LoadCliAsync

func LoadCliAsync() baseiface.ISingleton

Types

type CliAsync

type CliAsync struct {
	*goproxy.GonatsProxy
	basedto.BaseEntitySingle
}

CliAsync 是一个实现异步客户端功能的结构体, 继承自 goproxy.GonatsProxy 以使用 NATS 连接功能, 并集成 basedto.BaseEntitySingle 以使用基础实体单例功

func FindBeanCliAsync

func FindBeanCliAsync() *CliAsync

FindBeanCliAsync

func NewCliAsync

func NewCliAsync() *CliAsync

func (*CliAsync) Publish

func (this *CliAsync) Publish(msg *gomsg.GonatsMsg) error

Publish 将指定的消息发布到NATS服务器。 参数 msg 为要发布的消息体,类型为 *gomsg.GonatsMsg。 返回值为执行过程中可能出现的错误。

func (*CliAsync) PublishNats

func (this *CliAsync) PublishNats(msg *gomsg.GonatsMsg) error

this is now nats msg std

Jump to

Keyboard shortcuts

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