pubsub

Documentation

Index

• type NatsPublishClient
• type NatsPublishClientImpl
  • func NewNatsPublishClientImpl(logger *zap.SugaredLogger) *NatsPublishClientImpl
  • func (impl *NatsPublishClientImpl) Publish(req *PublishRequest) error
• type PublishRequest

Types

type NatsPublishClient

type NatsPublishClient interface {
	Publish(req *PublishRequest) error
}

type NatsPublishClientImpl

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

func NewNatsPublishClientImpl

func NewNatsPublishClientImpl(logger *zap.SugaredLogger) *NatsPublishClientImpl

func (*NatsPublishClientImpl) Publish

func (impl *NatsPublishClientImpl) Publish(req *PublishRequest) error

TODO : adhiran : check the req.topic. We dont have dynamic topics listed in stream subjects arrary.So this might fail in subscription if the subject name passed is not listed

type PublishRequest

type PublishRequest struct {
	Topic   string          `json:"topic"`
	Payload json.RawMessage `json:"payload"`
}