nsq

Documentation

Index

• Constants
• func NewConsumer(topic string, channel string, handle nsq.HandlerFunc)
• func Start(c *gin.Context)
• type Bar
  • func (b *Bar) BarFuncAdd(argOne, argTwo float64) float64
• type Consumer
  • func (*Consumer) HandleMessage(msg *nsq.Message) error
• type Foo
  • func (f *Foo) FooFuncSwap(argOne, argTwo string) (string, string)

Constants

const (
	Addr4150 = "127.0.0.1:4150"
	Addr4161 = "127.0.0.1:4161"
)

Functions

func NewConsumer

func NewConsumer(topic string, channel string, handle nsq.HandlerFunc)

初始化消费者

func Start

func Start(c *gin.Context)

Types

type Bar

type Bar struct {
}

func (*Bar) BarFuncAdd

func (b *Bar) BarFuncAdd(argOne, argTwo float64) float64

type Consumer

type Consumer struct{}

消费者

func (*Consumer) HandleMessage

func (*Consumer) HandleMessage(msg *nsq.Message) error

处理消息

type Foo

type Foo struct {
}

func (*Foo) FooFuncSwap

func (f *Foo) FooFuncSwap(argOne, argTwo string) (string, string)