gamq

README

gamq

Documentation

Index

• func SetConfig(givenConfig *Config)
• type Client
  • func NewClient(givenName string, givenWriter *bufio.Writer, givenReader *bufio.Reader) *Client
• type Config
• type ConnectionManager
  • func NewConnectionManager() *ConnectionManager
  • func (manager *ConnectionManager) Start()
• type MessageHandler
• type Metric
  • func NewMetric(givenName string, givenType string, givenValue int64) *Metric
• type MetricsManager
  • func NewMetricsManager(givenQueueManager *queueManager) *MetricsManager

Functions

func SetConfig

func SetConfig(givenConfig *Config)

Types

type Client

type Client struct {
	Name         string
	Writer       *bufio.Writer
	Reader       *bufio.Reader
	Closed       *chan bool
	AckRequested bool
	// contains filtered or unexported fields
}

func NewClient

func NewClient(givenName string, givenWriter *bufio.Writer, givenReader *bufio.Reader) *Client

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 NewConnectionManager

func NewConnectionManager() *ConnectionManager

func (*ConnectionManager) Start

func (manager *ConnectionManager) Start()

type MessageHandler

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

type Metric

type Metric struct {
	Value int64
	Name  string
	Type  string
}

Metric represents StatsD metric

func NewMetric

func NewMetric(givenName string, givenType string, givenValue int64) *Metric

NewMetric constructs a new Metric object from the given parameters

type MetricsManager

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

func NewMetricsManager

func NewMetricsManager(givenQueueManager *queueManager) *MetricsManager