utils

Documentation

Index

• Variables
• type AMQPQueue
• type CKPTEvent
• type EventType
• type RMQ
  • func NewRMQ(url string, queue string) *RMQ
  • func (rmq *RMQ) Consume() (<-chan amqp.Delivery, error)
  • func (rmq *RMQ) Publish(event CKPTEvent) error

Variables

var TypeNames = []string{
	"news",
	"tournament",
	"catering",
	"location",
	"player",
}

Types

type AMQPQueue

type AMQPQueue interface {
	Publish(CKPTEvent) error
	Consume() (<-chan amqp.Delivery, error)
}

An interface for a message queue

type CKPTEvent

type CKPTEvent struct {
	Type         EventType   `json:"type"`
	RestrictedTo []uuid.UUID `json:"restricted_to"`
	Subject      string      `json:"subject"`
	Message      string      `json:"message"`
}

type EventType

type EventType int

const (
	NEWS_EVENT EventType = iota
	TOURNAMENT_EVENT
	CATERING_EVENT
	LOCATION_EVENT
	PLAYER_EVENT = 4
)

type RMQ

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

func NewRMQ

func NewRMQ(url string, queue string) *RMQ

func (*RMQ) Consume

func (rmq *RMQ) Consume() (<-chan amqp.Delivery, error)

func (*RMQ) Publish

func (rmq *RMQ) Publish(event CKPTEvent) error