Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DebugLevel bool
DebugLevel set to true will output extra information out workers flow.
Functions ¶
Types ¶
type MetricEntry ¶
type MetricEntry struct {
Username string `json:"username"`
Count int64 `json:"count"`
Metric string `json:"metric"`
Time time.Time `json:"time"`
}
MetricData
func MustUnmarshallFromJSON ¶
func MustUnmarshallFromJSON(b []byte) MetricEntry
MustUnmarshallFromJSON builds a MetricData from JSON buffer
type ProcesorFunc ¶
type RabbitMQConnector ¶
type RabbitMQConnector struct {
// contains filtered or unexported fields
}
func BuildRabbitMQConnector ¶
func (*RabbitMQConnector) Close ¶
func (m *RabbitMQConnector) Close() error
func (*RabbitMQConnector) Handle ¶
func (m *RabbitMQConnector) Handle(queueName string, f ProcesorFunc) error
func (*RabbitMQConnector) Publish ¶
func (m *RabbitMQConnector) Publish(b []byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.