logs.go RawHistoryFolder

1package out
2
3import (
4	"context"
5	"time"
6
7	"github.com/bnema/gordon/internal/domain"
8)
9
10// LogExporter ships log records to an external log backend (OTLP).
11// Export must not block on the network: implementations buffer and
12// drop on overload rather than slow down callers. Safe for concurrent use.
13type LogExporter interface {
14	Export(ctx context.Context, record domain.LogRecord)
15}
16
17// ContainerLogStreamer follows the demultiplexed output of one container.
18type ContainerLogStreamer interface {
19	// StreamContainerLogs calls emit for every line emitted after since,
20	// in order, and blocks until the stream ends (container stopped),
21	// ctx is canceled, or an error occurs. A missing container reports
22	// domain.ErrContainerNotFound.
23	StreamContainerLogs(ctx context.Context, containerID string, since time.Time, emit func(domain.ContainerLogLine)) error
24}