query

package

v0.0.2 Latest Latest Go to latest Published: Nov 4, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Opts struct {
	BufferSize int
	HTTPClient *http.Client
	QueryID    string
	Headers    map[string]string
}

Opts ...

type Request struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Request ...

func NewRequest(ctx context.Context, cfg config.ClickHouse, opts Opts) (*Request, error)

New начинает отправлять запрос в КХ

func (req *Request) Close() error

Close ...

func (req *Request) Finish() (*Response, error)

Finish завершает запрос и начинает вычитывать ответ

func (req *Request) Write(p []byte) (int, error)

Write ...

func (req *Request) WriteByte(b byte) error

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

Response ...

func (resp *Response) Close() error

Close вычитывает остатки из body

func (resp *Response) Read(p []byte) (int, error)

Read читает данные из ответа