nats

Documentation

Index

• type NATSExchange
  • func NewNATSExchange(conn *nats.Conn) (*NATSExchange, error)
  • func (n *NATSExchange) PublishSendScanToWorkerMessage(ctx context.Context, worker *queries.Worker, ...) error
  • func (n *NATSExchange) ReceiveSendScanToWorkerMessage(ctx context.Context, worker *queries.Worker) (messages.SendScanToWorkerMessage, bool, error)

Types

type NATSExchange

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

func NewNATSExchange

func NewNATSExchange(conn *nats.Conn) (*NATSExchange, error)

func (*NATSExchange) PublishSendScanToWorkerMessage

func (n *NATSExchange) PublishSendScanToWorkerMessage(ctx context.Context, worker *queries.Worker, message messages.SendScanToWorkerMessage) error

func (*NATSExchange) ReceiveSendScanToWorkerMessage

func (n *NATSExchange) ReceiveSendScanToWorkerMessage(ctx context.Context, worker *queries.Worker) (messages.SendScanToWorkerMessage, bool, error)