logs

Documentation

Index

• func NewLoggregatorLogMessage(m *logmessage.LogMessage) *loggregatorLogMessage
• func NewNoaaLogMessage(m *events.LogMessage) *noaaLogMessage
• type Loggable
• type LoggregatorConsumer
• type LoggregatorLogsRepository
  • func NewLoggregatorLogsRepository(config coreconfig.Reader, consumer consumer.LoggregatorConsumer, ...) *LoggregatorLogsRepository
  • func (repo *LoggregatorLogsRepository) Close()
  • func (repo *LoggregatorLogsRepository) RecentLogsFor(appGUID string) ([]Loggable, error)
  • func (repo *LoggregatorLogsRepository) TailLogsFor(appGUID string, onConnect func(), logChan chan<- Loggable, ...)
• type LoggregatorMessageQueue
  • func NewLoggregatorMessageQueue() *LoggregatorMessageQueue
  • func (pq *LoggregatorMessageQueue) EnumerateAndClear(onMessage func(*logmessage.LogMessage))
  • func (pq *LoggregatorMessageQueue) Len() int
  • func (pq *LoggregatorMessageQueue) Less(i, j int) bool
  • func (pq *LoggregatorMessageQueue) PushMessage(message *logmessage.LogMessage)
  • func (pq *LoggregatorMessageQueue) Swap(i, j int)
• type NoaaConsumer
• type NoaaLogsRepository
  • func NewNoaaLogsRepository(config coreconfig.Reader, consumer NoaaConsumer, ...) *NoaaLogsRepository
  • func (repo *NoaaLogsRepository) Close()
  • func (repo *NoaaLogsRepository) RecentLogsFor(appGUID string) ([]Loggable, error)
  • func (repo *NoaaLogsRepository) TailLogsFor(appGUID string, onConnect func(), logChan chan<- Loggable, ...)
• type NoaaMessageQueue
  • func NewNoaaMessageQueue() *NoaaMessageQueue
  • func (pq *NoaaMessageQueue) EnumerateAndClear(onMessage func(*events.LogMessage))
  • func (pq *NoaaMessageQueue) Len() int
  • func (pq *NoaaMessageQueue) Less(i, j int) bool
  • func (pq *NoaaMessageQueue) PushMessage(message *events.LogMessage)
  • func (pq *NoaaMessageQueue) Swap(i, j int)
• type Repository

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 NewLoggregatorLogsRepository

func NewLoggregatorLogsRepository(config coreconfig.Reader, consumer consumer.LoggregatorConsumer, refresher authentication.TokenRefresher) *LoggregatorLogsRepository

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 NewNoaaLogsRepository

func NewNoaaLogsRepository(config coreconfig.Reader, consumer NoaaConsumer, tr authentication.TokenRefresher) *NoaaLogsRepository

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()
}