server

Documentation

Index

• type Broker
  • func (b *Broker) Call(producerName string, funName string, data *[]byte) (*[]byte, error)
  • func (b *Broker) LogErr(err error)
  • func (b *Broker) New(args ...interface{})

Types

type Broker

type Broker struct {
	Producers map[string]client.Producer
	Consumer  *client.Consumer

	Logger logger.Logger
	// contains filtered or unexported fields
}

func (*Broker) Call

func (b *Broker) Call(producerName string, funName string, data *[]byte) (*[]byte, error)

func (*Broker) LogErr

func (b *Broker) LogErr(err error)

func (*Broker) New

func (b *Broker) New(args ...interface{})

！！请直接在demo中查看创建的例子 @title Broker.New @description 创建Broker @auth loveward 2020-12-27 12:06 @param addr string 监听地址 @param port int 端口 @param producers map[string]client.Producer 生产者集合 @param consumer *client.Consumer 消费者 @param Logger logger.Logger 日志