Versions in this module Expand all Collapse all v1 v1.1.0 Aug 14, 2015 Changes in this version + var ErrBadRequest = errors.New("bad client request") + var ErrBadResponse = errors.New("bad server response") + var ErrLostConnection = errors.New("remote server terminated connection unexpectedly") + var ErrNotFound = ErrNotOK + var ErrNotOK = errors.New("unknown issue when making HTTP request to Loggregator") + var KeepAlive = 25 * time.Second + func SortContainerMetrics(messages []*events.ContainerMetric) []*events.ContainerMetric + func SortRecent(messages []*events.LogMessage) []*events.LogMessage + type Consumer struct + func NewConsumer(trafficControllerUrl string, tlsConfig *tls.Config, ...) *Consumer + func (cnsmr *Consumer) Close() error + func (cnsmr *Consumer) ContainerMetrics(appGuid string, authToken string) ([]*events.ContainerMetric, error) + func (cnsmr *Consumer) Firehose(subscriptionId string, authToken string, outputChan chan<- *events.Envelope, ...) + func (cnsmr *Consumer) FirehoseWithoutReconnect(subscriptionId string, authToken string, outputChan chan<- *events.Envelope) error + func (cnsmr *Consumer) RecentLogs(appGuid string, authToken string) ([]*events.LogMessage, error) + func (cnsmr *Consumer) SetDebugPrinter(debugPrinter DebugPrinter) + func (cnsmr *Consumer) SetOnConnectCallback(cb func()) + func (cnsmr *Consumer) Stream(appGuid string, authToken string, outputChan chan<- *events.Envelope, ...) + func (cnsmr *Consumer) StreamWithoutReconnect(appGuid string, authToken string, outputChan chan<- *events.Envelope) error + func (cnsmr *Consumer) TailingLogs(appGuid string, authToken string, outputChan chan<- *events.LogMessage, ...) + func (cnsmr *Consumer) TailingLogsWithoutReconnect(appGuid string, authToken string, outputChan chan<- *events.LogMessage) error + type DebugPrinter interface + Print func(title, dump string)