yqlclient

type Client struct {
	// contains filtered or unexported fields
}

type ClientOptions struct {
	// Token to use. If empty, authentication would not be used.
	Token string

	// Client to use. Defaults to http.DefaultClient.
	Client *http.Client

	// TracerProvider is a tracer provider. Defaults to otel.GetTracerProvider.
	TracerProvider trace.TracerProvider
	// MeterProvider is a meter provider. Defaults to otel.GetMeterProvider.
	MeterProvider metric.MeterProvider
}

type Error struct {
	Err ytqueryapi.Error
}

type ExecuteQueryParams struct {
	// PollInterval is a query result polling interval. Defaults to 1s.
	PollInterval time.Duration

	// AbortTimeout sets timeout for aborting query. Defaults to 10s.
	AbortTimeout time.Duration

	// Engine to run query. Defaults to YQL.
	Engine ytqueryapi.Engine
}

type ResultFormat[T any] interface {
	Format() ytqueryapi.OutputFormat
	Iter(r io.Reader) (iterators.Iterator[T], error)
}

type YSONFormat[T any] struct{}