logs

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

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 struct {
	BufferTime time.Duration
	// contains filtered or unexported fields
}