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
}

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

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