queue

Documentation

Index

• type ChanSliceByte
• type Queuer
  • func NewQueueRabbitMQ(ctx context.Context, conf config.RabbitMQ) (Queuer, error)
  • func NewQueueStub(ctx context.Context) (Queuer, error)

Types

type ChanSliceByte

type ChanSliceByte struct {
	Ch    chan []byte
	Close func()
}

type Queuer

type Queuer interface {
	NewMessageListener(rooms []entities.Room, conn *ws.WS) ChanSliceByte
	PushMessage(msg *entities.Message, skpipConn *ws.WS) error
	PushNotification(notification *entities.Notification, skpipConn *ws.WS) error
	Close()
}

func NewQueueRabbitMQ

func NewQueueRabbitMQ(ctx context.Context, conf config.RabbitMQ) (Queuer, error)

NewOperationDatastoreExternal get operation external api

func NewQueueStub

func NewQueueStub(ctx context.Context) (Queuer, error)

NewOperationDatastoreExternal get operation external api