stream

Imports

• github.com/usedatabrew/tango
• gopkg.in/yaml.v3

Imports in module “github.com/usedatabrew/blink”

• github.com/usedatabrew/blink/config
• github.com/usedatabrew/blink/internal/message
• github.com/usedatabrew/blink/internal/metrics
• github.com/usedatabrew/blink/internal/metrics/influx
• github.com/usedatabrew/blink/internal/metrics/prometheus
• github.com/usedatabrew/blink/internal/processors
• github.com/usedatabrew/blink/internal/processors/http
• github.com/usedatabrew/blink/internal/processors/openai
• github.com/usedatabrew/blink/internal/processors/sql
• github.com/usedatabrew/blink/internal/schema
• github.com/usedatabrew/blink/internal/service_registry
• github.com/usedatabrew/blink/internal/sinks
• github.com/usedatabrew/blink/internal/sinks/kafka
• github.com/usedatabrew/blink/internal/sinks/postgres
• github.com/usedatabrew/blink/internal/sinks/stdout
• github.com/usedatabrew/blink/internal/sinks/websockets
• github.com/usedatabrew/blink/internal/sources
• github.com/usedatabrew/blink/internal/sources/mongo_stream
• github.com/usedatabrew/blink/internal/sources/postgres_cdc
• github.com/usedatabrew/blink/internal/stream_context

Standard library imports

• errors
• os
• regexp
• strings
• sync
• time