Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NatsJsConsumer ¶ added in v0.0.17
type NatsJsConsumer struct {
// contains filtered or unexported fields
}
func NewNatsJsConsumer ¶ added in v0.0.17
func NewNatsJsConsumer(cfg *messaging.BrokerConfig, subCfg *messaging.NatsJsConsumerConfig, logger log.Logger) (*NatsJsConsumer, func(), error)
type NatsJsPublisher ¶
type NatsJsPublisher struct {
// contains filtered or unexported fields
}
func NewNatsJsPublisher ¶
func NewNatsJsPublisher(cfg *messaging.BrokerConfig, logger log.Logger) (*NatsJsPublisher, func(), error)
func (*NatsJsPublisher) Publish ¶
func (n *NatsJsPublisher) Publish(topic string, data []byte) error
func (*NatsJsPublisher) PublishEvent ¶
func (n *NatsJsPublisher) PublishEvent(topic string, event *cloudevents.Event) error
func (*NatsJsPublisher) PublishMessage ¶
func (n *NatsJsPublisher) PublishMessage(topic string, msg *message.Message) error
Source Files
Click to show internal directories.
Click to hide internal directories.