msgpub

type Client interface {
	Publish(ctx context.Context, in *PublishRequest) (*types.Value, error)
}

type PublishRequest struct {
	//
	//数据
	Data *types.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data" form:"data"`
	//
	//系统名称
	System string `protobuf:"bytes,2,opt,name=system,proto3" json:"system" form:"system"`
	//
	//topic
	Topic                string   `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic" form:"topic"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type PublishResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *types.Value `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

type Service interface {
	Publish(context.Context, *PublishRequest) (*types.Value, error)
}