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 ¶
Types ¶
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 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 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 (*Queue) Initialize ¶
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)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.