types

Documentation

Index

• Constants
• Variables
• type MessageQueue
  • func (r *MessageQueue) Dequeue() interface{}
  • func (r *MessageQueue) Enqueue(req interface{}) error
  • func (r *MessageQueue) Size() int
• type NotificationQueue
  • func (r *NotificationQueue) Dequeue() interface{}
  • func (r *NotificationQueue) Enqueue(req interface{}) error
  • func (r *NotificationQueue) Size() int
• type Queue

Constants

const (
	NotificationKickPlayer = "you have been kicked from the operation"
)

Variables

var MessageQueues map[string]Queue

var NotifQueues map[string]Queue

Types

type MessageQueue

type MessageQueue struct {
	Channel chan *rpcpb.Message
}

func (*MessageQueue) Dequeue

func (r *MessageQueue) Dequeue() interface{}

func (*MessageQueue) Enqueue

func (r *MessageQueue) Enqueue(req interface{}) error

func (*MessageQueue) Size

func (r *MessageQueue) Size() int

type NotificationQueue

type NotificationQueue struct {
	Channel chan *rpcpb.Notification
}

func (*NotificationQueue) Dequeue

func (r *NotificationQueue) Dequeue() interface{}

func (*NotificationQueue) Enqueue

func (r *NotificationQueue) Enqueue(req interface{}) error

func (*NotificationQueue) Size

func (r *NotificationQueue) Size() int

type Queue

type Queue interface {
	Enqueue(interface{}) error
	Dequeue() interface{}
	Size() int
}