logs

package
v6.21.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2016 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewLoggregatorLogMessage

func NewLoggregatorLogMessage(m *logmessage.LogMessage) *loggregatorLogMessage

func NewNoaaLogMessage

func NewNoaaLogMessage(m *events.LogMessage) *noaaLogMessage

Types

type Loggable

type Loggable interface {
	ToLog(loc *time.Location) string
	ToSimpleLog() string
	GetSourceName() string
}

type LoggregatorConsumer

type LoggregatorConsumer interface {
	Tail(appGUID string, authToken string) (<-chan *logmessage.LogMessage, error)
	Recent(appGUID string, authToken string) ([]*logmessage.LogMessage, error)
	Close() error
	SetOnConnectCallback(func())
	SetDebugPrinter(loggregator_consumer.DebugPrinter)
}

type LoggregatorLogsRepository

type LoggregatorLogsRepository struct {
	BufferTime time.Duration
	// contains filtered or unexported fields
}

func (*LoggregatorLogsRepository) Close

func (repo *LoggregatorLogsRepository) Close()

func (*LoggregatorLogsRepository) RecentLogsFor

func (repo *LoggregatorLogsRepository) RecentLogsFor(appGUID string) ([]Loggable, error)

func (*LoggregatorLogsRepository) TailLogsFor

func (repo *LoggregatorLogsRepository) TailLogsFor(appGUID string, onConnect func(), logChan chan<- Loggable, errChan chan<- error)

type LoggregatorMessageQueue

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

func NewLoggregatorMessageQueue

func NewLoggregatorMessageQueue() *LoggregatorMessageQueue

func (*LoggregatorMessageQueue) EnumerateAndClear

func (pq *LoggregatorMessageQueue) EnumerateAndClear(onMessage func(*logmessage.LogMessage))

func (*LoggregatorMessageQueue) Len

func (pq *LoggregatorMessageQueue) Len() int

func (*LoggregatorMessageQueue) Less

func (pq *LoggregatorMessageQueue) Less(i, j int) bool

implement sort interface so we can sort messages as we receive them in PushMessage

func (*LoggregatorMessageQueue) PushMessage

func (pq *LoggregatorMessageQueue) PushMessage(message *logmessage.LogMessage)

func (*LoggregatorMessageQueue) Swap

func (pq *LoggregatorMessageQueue) Swap(i, j int)

type NoaaConsumer

type NoaaConsumer interface {
	TailingLogsWithoutReconnect(string, string) (<-chan *events.LogMessage, <-chan error)
	RecentLogs(appGUID string, authToken string) ([]*events.LogMessage, error)
	Close() error
	SetOnConnectCallback(cb func())
}

type NoaaLogsRepository

type NoaaLogsRepository struct {
	BufferTime time.Duration
	// contains filtered or unexported fields
}

func (*NoaaLogsRepository) Close

func (repo *NoaaLogsRepository) Close()

func (*NoaaLogsRepository) RecentLogsFor

func (repo *NoaaLogsRepository) RecentLogsFor(appGUID string) ([]Loggable, error)

func (*NoaaLogsRepository) TailLogsFor

func (repo *NoaaLogsRepository) TailLogsFor(appGUID string, onConnect func(), logChan chan<- Loggable, errChan chan<- error)

type NoaaMessageQueue

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

func NewNoaaMessageQueue

func NewNoaaMessageQueue() *NoaaMessageQueue

func (*NoaaMessageQueue) EnumerateAndClear

func (pq *NoaaMessageQueue) EnumerateAndClear(onMessage func(*events.LogMessage))

func (*NoaaMessageQueue) Len

func (pq *NoaaMessageQueue) Len() int

func (*NoaaMessageQueue) Less

func (pq *NoaaMessageQueue) Less(i, j int) bool

implement sort interface so we can sort messages as we receive them in PushMessage

func (*NoaaMessageQueue) PushMessage

func (pq *NoaaMessageQueue) PushMessage(message *events.LogMessage)

func (*NoaaMessageQueue) Swap

func (pq *NoaaMessageQueue) Swap(i, j int)

type Repository

type Repository interface {
	RecentLogsFor(appGUID string) ([]Loggable, error)
	TailLogsFor(appGUID string, onConnect func(), logChan chan<- Loggable, errChan chan<- error)
	Close()
}

Directories

Path Synopsis
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

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