package io

import "github.com/ClickHouse/clickhouse-go/v2/lib/io"

Index ¶

• type Stream
• func NewStream(rw io.ReadWriter) *Stream
• func (s *Stream) Close() error
• func (s *Stream) Compress(v bool)
• func (s *Stream) Flush() error
• func (s *Stream) Read(p []byte) (int, error)
• func (s *Stream) Write(p []byte) (int, error)

Types ¶

type Stream ¶

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

func NewStream ¶

func NewStream(rw io.ReadWriter) *Stream

func (*Stream) Close ¶

func (s *Stream) Close() error

func (*Stream) Compress ¶

func (s *Stream) Compress(v bool)

func (*Stream) Flush ¶

func (s *Stream) Flush() error

func (*Stream) Read ¶

func (s *Stream) Read(p []byte) (int, error)

func (*Stream) Write ¶

func (s *Stream) Write(p []byte) (int, error)

Source Files ¶

stream.go