gamq

package module
v0.2.1-alpha Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 30, 2015 License: MIT Imports: 10 Imported by: 0

README

gamq

Build Status Coverage Status

Documentation

Index

Constants

View Source
const (
	UNRECOGNISEDCOMMANDTEXT = "Unrecognised command"
	HELPSTRING              = `` /* 189-byte string literal not displayed */

)
View Source
const (
	MetricsQueueName = "metrics"
)

Variables

This section is empty.

Functions

func SetConfig

func SetConfig(givenConfig *Config)

Types

type Client

type Client struct {
	Name   string
	Writer *bufio.Writer
	Reader *bufio.Reader
	Closed *chan bool
}

type Config

type Config struct {
	Port             int
	ProfilingEnabled bool
	StatsDEndpoint   string
}
var Configuration *Config

type ConnectionManager

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

func (*ConnectionManager) Initialize

func (manager *ConnectionManager) Initialize()

type DummyMessageHandler

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

func (*DummyMessageHandler) Initialize

func (dmh *DummyMessageHandler) Initialize(input <-chan *string) chan *string

type MessageHandler

type MessageHandler interface {
	Initialize(<-chan string) chan<- string
}

type MessageQueue

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

A goroutine safe FIFO, based on https://github.com/hishboy/gocommons/blob/06389f1595e56cd7c27d9dc9fe48fc771db1b5ef/lang/queue.go

func NewMessageQueue

func NewMessageQueue() *MessageQueue

func (*MessageQueue) Len

func (q *MessageQueue) Len() uint64

func (*MessageQueue) Peek

func (q *MessageQueue) Peek() *string

func (*MessageQueue) Poll

func (q *MessageQueue) Poll() *string

func (*MessageQueue) Push

func (q *MessageQueue) Push(item *string)

type MessageShipper

type MessageShipper struct {
	ClientName   string
	CloseChannel chan bool
	// contains filtered or unexported fields
}

func (*MessageShipper) Initialize

func (shipper *MessageShipper) Initialize(inputChannel chan *string, subscriber *Client)

type Metric

type Metric struct {
	Value int64
	Name  string
	Type  string
}

type MetricsManager

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

func (*MetricsManager) Initialize

func (m *MetricsManager) Initialize(givenQueueManager *QueueManager) chan<- *Metric

type Queue

type Queue struct {
	Name string
	// contains filtered or unexported fields
}

func (*Queue) AddSubscriber

func (q *Queue) AddSubscriber(givenSubscriber *Client)

func (*Queue) Close

func (q *Queue) Close()

func (*Queue) Initialize

func (q *Queue) Initialize(metricsChannel chan<- *Metric, closingChannel chan<- *string)

func (*Queue) Publish

func (q *Queue) Publish(givenMessage *string)

type QueueManager

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

func (*QueueManager) CloseQueue

func (qm *QueueManager) CloseQueue(queueName string)

func (*QueueManager) Initialize

func (qm *QueueManager) Initialize()

func (*QueueManager) Publish

func (qm *QueueManager) Publish(queueName string, message *string)

func (*QueueManager) Subscribe

func (qm *QueueManager) Subscribe(queueName string, client *Client)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL