pubsub

type KafkaPubSubClient struct {
	// contains filtered or unexported fields
}

type NatsPubSubClient struct {
	// contains filtered or unexported fields
}

type PubSubClient interface {
	Publish(subject string, msg interface{}) error
	Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error)
	Subscribe(subject string, eventHandler PubSubEventHandler)
	RequestSubscribe(subject string, eventHandler PubSubReqEventHandler)
	QueueSubscribe(subject string, queue string, eventHandler PubSubEventHandler)
}

type PubSubCreatorFunc func(connString string) (PubSubClient, error)

type PubSubEventHandler func(name string, msg string)

type PubSubReqEventHandler func(name string, msg string) string