logs

package
v7.0.0-beta.26+incompa... Latest Latest
Warning

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

Go to latest
Published: Oct 8, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

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