nats

Documentation

Index

• type DeliverySubscriber
  • func NewDeliverySubscriber(natsConn stan.Conn, groupSvc messenger.GroupServicer, ...) *DeliverySubscriber
  • func (sub *DeliverySubscriber) Shutdown(ctx context.Context) error
  • func (sub *DeliverySubscriber) SubscribeDeliverySubject(ctx context.Context)
• type MessagePublisher
  • func NewMessagePublisher(natsConn stan.Conn) *MessagePublisher
  • func (pub *MessagePublisher) PublishToDeliveryChannel(msg *messenger.Message) error

Types

type DeliverySubscriber

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

func NewDeliverySubscriber

func NewDeliverySubscriber(natsConn stan.Conn, groupSvc messenger.GroupServicer, routerClient routerProto.RouterServiceClient, gatewayJobClient gatewayProto.JobServiceClient) *DeliverySubscriber

func (*DeliverySubscriber) Shutdown

func (sub *DeliverySubscriber) Shutdown(ctx context.Context) error

func (*DeliverySubscriber) SubscribeDeliverySubject

func (sub *DeliverySubscriber) SubscribeDeliverySubject(ctx context.Context)

type MessagePublisher

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

func NewMessagePublisher

func NewMessagePublisher(natsConn stan.Conn) *MessagePublisher

func (*MessagePublisher) PublishToDeliveryChannel

func (pub *MessagePublisher) PublishToDeliveryChannel(msg *messenger.Message) error