consume

type APIClient = event.APIClient

type DirSink struct {
	Dir string
	// contains filtered or unexported fields
}

type Options struct {
	EventKey string
	// Def is the resolved declaration for EventKey. The caller resolves it
	// from the compiled catalog; this package validates and consumes it but
	// never looks anything up itself.
	Def    *event.KeyDefinition
	Params map[string]string
	// ParamsNormalized marks Params as already normalized by the declaration's
	// NormalizeParams hook (the deciding layer runs it on these exact values).
	// The host then skips the hook, keeping its run-once-per-consumer contract.
	ParamsNormalized bool
	JQExpr           string
	Quiet            bool
	OutputDir        string
	Runtime          event.APIClient
	// Prepare, when set, replaces the declaration's PreConsume hook as the
	// preparation to run when this consumer is first for its scope. The
	// application layer injects it so the strategy that was decided is the
	// strategy that executes; when nil, the declaration's own hook runs.
	Prepare         func(ctx context.Context) (func() error, error)
	Out             io.Writer // nil falls back to os.Stdout
	ErrOut          io.Writer
	RemoteAPIClient APIClient // nil disables remote-connection preflight

	MaxEvents int           // 0 = unlimited
	Timeout   time.Duration // 0 = no timeout
	IsTTY     bool
	// contains filtered or unexported fields
}

type Sink interface {
	Write(data json.RawMessage) error
}

type WriterSink struct {
	W      io.Writer
	Pretty bool
	ErrOut io.Writer
	// contains filtered or unexported fields
}