client

type Config struct {
	Broker    string
	Port      int
	ClientID  string
	Username  string
	Password  string
	SelfTopic string
	CallBack  func(msg *RequestMsg) (*[]byte, error)
	Logger    logger.Logger
}

type Data struct {
	Key     []byte
	Columns string
}

type RequestMsg struct {
	MsgId     string
	Data      Data
	FromTopic string
}

type RespondMsg struct {
	RequestMsg     RequestMsg
	Code           float64
	Data           []byte
	ReplyFromTopic string
	Err            error
}

type ZClient struct {
	Logger logger.Logger

	CallBack func(msg *RequestMsg) (*[]byte, error)
	// contains filtered or unexported fields
}

type ZMsg struct {
	MsgType    int
	MsgContent []byte
}