broker

Documentation

Index

• type Broker
• type FakeBroker
  • func NewFakeBroker() *FakeBroker
  • func (b *FakeBroker) Publish(subject string, data []byte) error
  • func (b *FakeBroker) Request(subject string, data []byte) (*nats.Msg, error)
  • func (b *FakeBroker) SetRequestHandler(handler RequestHandler)
  • func (b *FakeBroker) Subscribe(subject string, handler nats.MsgHandler) error
  • func (b *FakeBroker) SubscribeQueue(subject, queue string, handler nats.MsgHandler) error
• type NatsBroker
  • func NewNatsBroker(cfg *NatsConfiguration) *NatsBroker
  • func (b *NatsBroker) Publish(subject string, data []byte) error
  • func (b *NatsBroker) Request(subject string, data []byte) (*nats.Msg, error)
  • func (b *NatsBroker) Subscribe(subject string, handler nats.MsgHandler) error
  • func (b *NatsBroker) SubscribeQueue(subject, queue string, handler nats.MsgHandler) error
• type NatsConfiguration
• type RequestHandler

Types

type Broker

type Broker interface {
	Publish(subject string, data []byte) error
	Request(subject string, data []byte) (*nats.Msg, error)
	Subscribe(subject string, handler nats.MsgHandler) error
	SubscribeQueue(subject, queue string, handler nats.MsgHandler) error
}

type FakeBroker

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

func NewFakeBroker

func NewFakeBroker() *FakeBroker

func (*FakeBroker) Publish

func (b *FakeBroker) Publish(subject string, data []byte) error

func (*FakeBroker) Request

func (b *FakeBroker) Request(subject string, data []byte) (*nats.Msg, error)

func (*FakeBroker) SetRequestHandler

func (b *FakeBroker) SetRequestHandler(handler RequestHandler)

func (*FakeBroker) Subscribe

func (b *FakeBroker) Subscribe(subject string, handler nats.MsgHandler) error

func (*FakeBroker) SubscribeQueue

func (b *FakeBroker) SubscribeQueue(subject, queue string, handler nats.MsgHandler) error

type NatsBroker

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

func NewNatsBroker

func NewNatsBroker(cfg *NatsConfiguration) *NatsBroker

func (*NatsBroker) Publish

func (b *NatsBroker) Publish(subject string, data []byte) error

func (*NatsBroker) Request

func (b *NatsBroker) Request(subject string, data []byte) (*nats.Msg, error)

func (*NatsBroker) Subscribe

func (b *NatsBroker) Subscribe(subject string, handler nats.MsgHandler) error

func (*NatsBroker) SubscribeQueue

func (b *NatsBroker) SubscribeQueue(subject, queue string, handler nats.MsgHandler) error

type NatsConfiguration

type NatsConfiguration struct {
	Nats *nats.Conn
}

type RequestHandler

type RequestHandler func(msg *nats.Msg) (*nats.Msg, error)