consume

type APIClient = event.APIClient

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

type Options struct {
	EventKey        string
	Params          map[string]string
	JQExpr          string
	Quiet           bool
	OutputDir       string
	Runtime         event.APIClient
	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
}

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

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