Versions in this module Expand all Collapse all v0 v0.1.15 Nov 9, 2023 Changes in this version + func RegPubSubCreator(typeName string, creator PubSubCreatorFunc) + type KafkaPubSubClient struct + func (o *KafkaPubSubClient) Publish(subject string, msg interface{}) error + func (o *KafkaPubSubClient) QueueSubscribe(subject string, queue string, eventHandler PubSubEventHandler) + func (o *KafkaPubSubClient) Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error) + func (o *KafkaPubSubClient) RequestSubscribe(subject string, eventHandler PubSubReqEventHandler) + func (o *KafkaPubSubClient) Subscribe(subject string, eventHandler PubSubEventHandler) + type NatsPubSubClient struct + func (o *NatsPubSubClient) Publish(subject string, msg interface{}) error + func (o *NatsPubSubClient) QueueSubscribe(subject string, queue string, eventHandler PubSubEventHandler) + func (o *NatsPubSubClient) Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error) + func (o *NatsPubSubClient) RequestSubscribe(subject string, eventHandler PubSubReqEventHandler) + func (o *NatsPubSubClient) Subscribe(subject string, eventHandler PubSubEventHandler) + type PubSubClient interface + Publish func(subject string, msg interface{}) error + QueueSubscribe func(subject string, queue string, eventHandler PubSubEventHandler) + Request func(subject string, msg interface{}, timeOut ...time.Duration) (string, error) + RequestSubscribe func(subject string, eventHandler PubSubReqEventHandler) + Subscribe func(subject string, eventHandler PubSubEventHandler) + func Get(name ...string) PubSubClient + type PubSubCreatorFunc func(connString string) (PubSubClient, error) + type PubSubEventHandler func(name string, msg string) + type PubSubReqEventHandler func(name string, msg string) string
Go to main page