nats

Documentation

Index

• type DeliveryPubSub
  • func NewDeliveryPubSub(natsConn stan.Conn, groupSvc messenger.GroupServicer, ...) *DeliveryPubSub
  • func (ps *DeliveryPubSub) Shutdown(ctx context.Context) error
  • func (ps *DeliveryPubSub) SubscribeMSGChatroom(ctx context.Context)

Types

type DeliveryPubSub

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

func NewDeliveryPubSub

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

func (*DeliveryPubSub) Shutdown

func (ps *DeliveryPubSub) Shutdown(ctx context.Context) error

func (*DeliveryPubSub) SubscribeMSGChatroom

func (ps *DeliveryPubSub) SubscribeMSGChatroom(ctx context.Context)