logs

Documentation

Index

• func NewNoaaLogMessage(m *events.LogMessage) *noaaLogMessage
• type Loggable
• 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 NewNoaaLogMessage

func NewNoaaLogMessage(m *events.LogMessage) *noaaLogMessage

Types

type Loggable

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

type NoaaConsumer

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

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, retryTimeout time.Duration) *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()
}