Versions in this module Expand all Collapse all v0 v0.2.0 Dec 2, 2020 v0.1.0 Oct 28, 2019 Changes in this version + var ErrInvalidPartnerID = errors.New("partner id does not match") + func CreatePushSocket(url string) (mangos.Socket, error) + func CreateResponseWRP(msg *wrp.Message) *wrp.Message + func ParseBus(wrpBusOut chan wrp.Message, dataBusIn chan []byte, stopReading chan struct{}, ...) + func ReadPump(pullSock mangos.Socket, msgBus chan []byte, logger log.Logger) + func SendMessage(sock mangos.Socket, msg wrp.Message) error + func SetupFlagSet(fs *pflag.FlagSet) error + func WritePump(pushSock mangos.Socket, bus chan wrp.Message, stopWriting chan struct{}, ...) + type AllowMessage interface + Allow func(msg wrp.Message) error + type AllowMessageFunc func(msg wrp.Message) error + func BlockByPartnerID(partnerID string) AllowMessageFunc + func (allowFunc AllowMessageFunc) Allow(msg wrp.Message) error + type ClientConfig struct + Debug bool + Logger log.Logger + MSGHandler kratos.DownstreamHandler + Name string + ParodusURL string + Register time.Duration + ServiceURL string + type SendMessageHandler interface + SendMessage func(msg wrp.Message, c context.Context) error + func StartClient(config ClientConfig, lc fx.Lifecycle) (SendMessageHandler, error) + type SendMessageHandlerFunc func(msg wrp.Message, c context.Context) error + func (sendMessageHandlerFunc SendMessageHandlerFunc) SendMessage(msg wrp.Message, c context.Context) error
Go to main page