文件名称：pubsub
文件大小：5KB
文件格式：ZIP
更新时间：2024-03-30 11:22:56
Go
pubsub 包主 import ( "context" "fmt" "github.com/qosimmax/pubsub/events" "github.com/qosimmax/pubsub/pkg/kafka" ) type Order struct { } type Customer struct { } func (o *Order) create(ctx context.Context, payload []byte) ([]byte, error) { fmt.Println("ORDER", string(payload)) return nil, nil } func (c *Customer) create(ctx context.Context, payload []byte) ([]byte, error) { fmt.Println("CUSTO
【文件预览】：
pubsub-master
----go.mod(90B)
----pkg()
--------kafka()
----go.sum(2KB)
----events()
--------pubsub.go(286B)
--------router.go(2KB)
----README.md(950B)
----.gitignore(12B)