rabbitmq

package

v1.0.4 Latest Latest Go to latest Published: Apr 9, 2021 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/thantai574/rpc

Links

Open Source Insights

Documentation ¶

Index ¶

func Instance(ctx context.Context, opt rpc.Options, logger rpc.ILogger) rpc.Irpc
type RabbitEventServer
type RabbitMsg

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Instance ¶

func Instance(ctx context.Context, opt rpc.Options, logger rpc.ILogger) rpc.Irpc

Types ¶

type RabbitEventServer ¶

type RabbitEventServer struct {
	WhereExchange   string
	WhereRoutingKey string
	Function        func(ctx context.Context) (msg proto.Message, err error)
}

func (RabbitEventServer) GetExchange ¶

func (this RabbitEventServer) GetExchange() string

func (RabbitEventServer) GetRoutingKey ¶

func (this RabbitEventServer) GetRoutingKey() string

func (RabbitEventServer) GetRpcServer ¶

func (this RabbitEventServer) GetRpcServer() func(ctx context.Context) (msg proto.Message, err error)

type RabbitMsg ¶

type RabbitMsg struct {
	WhereExchange   string
	WhereRoutingKey string
	Msg             proto.Message
	ReplyMsg        proto.Message // Pointer
	Reply           bool
	Timeout         time.Duration
}

func (RabbitMsg) GetExchange ¶

func (this RabbitMsg) GetExchange() string

func (RabbitMsg) GetMsg ¶

func (this RabbitMsg) GetMsg() proto.Message

func (RabbitMsg) GetReplyMsg ¶

func (this RabbitMsg) GetReplyMsg() proto.Message

func (RabbitMsg) GetRoutingKey ¶

func (this RabbitMsg) GetRoutingKey() string

func (RabbitMsg) GetTimeout ¶

func (this RabbitMsg) GetTimeout() time.Duration

func (RabbitMsg) HaveReply ¶

func (this RabbitMsg) HaveReply() bool

Source Files ¶

View all Source files

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