go_order_processing_queue

README

go-order-processing_queue

Order processing system with golang use go-nsq

Usage

go test --cmd sender --nsqd_address 127.0.0.1

go test --cmd consumer --nsqd_address 127.0.0.1

NSQD

docker-compose with nsqd change hostname & broadcast address to use

Documentation

Index

• Constants
• func Start()
• type OrderData

Constants

const (
	FlagCMD         = "cmd"
	FlagNSQDAddress = "nsqd_address"
)

Functions

func Start

func Start()

Types

type OrderData

type OrderData struct {
	UserName   string  `json:"user_name"`
	OrderID    string  `json:"order_id"`
	OrderType  string  `json:"order_type"`
	OrderState int     `json:"order_state"` // 0.default 1.processing 2.complete 3.rollback
	Memo       string  `json:"memo"`
	Money      float64 `json:"money"`
}