Versions in this module Expand all Collapse all v0 v0.1.0 Mar 4, 2026 Changes in this version + const LevelDebug + const LevelError + const LevelInfo + const LevelWarn + type DockerSource struct + func NewDockerSource(services []string) (*DockerSource, error) + func (d *DockerSource) Close() error + func (d *DockerSource) Name() string + func (d *DockerSource) Stream(ctx context.Context) (<-chan LogEntry, error) + func (d *DockerSource) WatchNewContainers(ctx context.Context) + type FileSource struct + func NewFileSource(patterns []string) (*FileSource, error) + func NewFileSourceFromStart(patterns []string) (*FileSource, error) + func (f *FileSource) Close() error + func (f *FileSource) Name() string + func (f *FileSource) Stream(ctx context.Context) (<-chan LogEntry, error) + type KubeOptions struct + Container string + Kubeconfig string + Labels string + Namespace string + PodPrefix string + type KubeSource struct + func NewKubeSource(opts KubeOptions) (*KubeSource, error) + func (k *KubeSource) Close() error + func (k *KubeSource) Name() string + func (k *KubeSource) Stream(ctx context.Context) (<-chan LogEntry, error) + type LogEntry struct + Fields map[string]any + Level string + Message string + Raw string + Service string + Timestamp time.Time + type Source interface + Close func() error + Name func() string + Stream func(ctx context.Context) (<-chan LogEntry, error) + type StdinSource struct + func NewStdinSource() *StdinSource + func (s *StdinSource) Close() error + func (s *StdinSource) Name() string + func (s *StdinSource) Stream(ctx context.Context) (<-chan LogEntry, error)
Go to main page