logtest

Mar 6, 2026

Changes in this version

+ func ContextWithCancel(ctx context.Context) (*types.PluginContext, context.CancelFunc)

+ func ContextWithCancelFrom(h *Harness) *types.PluginContext

+ func Line(content string, opts ...LineOption) string

+ func MultiSourceBuilder(sourceIDs ...string) logs.SourceBuilderFunc

+ func SingleSourceBuilder(sourceID string, labels map[string]string) logs.SourceBuilderFunc

+ type Harness struct

+ func Mount(t *testing.T, opts ...HarnessOption) *Harness

+ func (h *Harness) AssertEventTypes(expected ...logs.LogStreamEventType)

+ func (h *Harness) Close()

+ func (h *Harness) CloseSession(sessionID string)

+ func (h *Harness) CloseSource(sourceID string)

+ func (h *Harness) CreateSession(resourceKey string, opts ...SessionOption) *logs.LogSession

+ func (h *Harness) FeedLine(sourceID string, line string)

+ func (h *Harness) GetSession(sessionID string) *logs.LogSession

+ func (h *Harness) Manager() *logs.Manager

+ func (h *Harness) Output() *RecordingOutput

+ func (h *Harness) WaitForEvent(eventType logs.LogStreamEventType, timeout time.Duration) *logs.LogStreamEvent

+ func (h *Harness) WaitForLines(count int, timeout time.Duration) []logs.LogLine

+ func (h *Harness) WaitForStatus(status logs.LogSessionStatus, timeout time.Duration) bool

+ type HarnessOption func(*harnessConfig)

+ func WithResolver(resourceKey string, resolver logs.SourceResolver) HarnessOption

+ func WithSource(sourceID string, src *TestLogSource) HarnessOption

+ type LineOption func(*lineConfig)

+ func WithLevel(_ logs.LogLevel) LineOption

+ func WithTimestamp(t time.Time) LineOption

+ type RecordingOutput struct

+ func NewRecordingOutput() *RecordingOutput

+ func (r *RecordingOutput) Events() []logs.LogStreamEvent

+ func (r *RecordingOutput) Lines() []logs.LogLine

+ func (r *RecordingOutput) OnEvent(_ string, event logs.LogStreamEvent)

+ func (r *RecordingOutput) OnLine(line logs.LogLine)

+ func (r *RecordingOutput) RecordEvent(event logs.LogStreamEvent)

+ func (r *RecordingOutput) RecordLine(line logs.LogLine)

+ func (r *RecordingOutput) RecordStatus(status logs.LogSessionStatus)

+ func (r *RecordingOutput) Statuses() []logs.LogSessionStatus

+ func (r *RecordingOutput) WaitForEvent(eventType logs.LogStreamEventType, timeout time.Duration) *logs.LogStreamEvent

+ func (r *RecordingOutput) WaitForLines(count int, timeout time.Duration) []logs.LogLine

+ func (r *RecordingOutput) WaitForStatus(status logs.LogSessionStatus, timeout time.Duration) bool

+ type SessionOption func(*sessionConfig)

+ func WithResourceData(data map[string]interface{}) SessionOption

+ func WithResourceID(id string) SessionOption

+ func WithSessionOptions(opts logs.LogSessionOptions) SessionOption

+ type TestLogSource struct

+ ConnectDelay time.Duration

+ ErrOnConnect error

+ Events chan logs.LogStreamEvent

+ Lines chan string

+ func NewTestLogSource() *TestLogSource

+ func (s *TestLogSource) HandlerFunc() logs.LogHandlerFunc

+ func (s *TestLogSource) ReaderFunc(pctx *types.PluginContext) (io.ReadCloser, error)