response

Documentation

Index

• Variables
• func WritePacket(p Packet, encoder *ch_encoding.Encoder, compress bool, revision uint64) (err error)
• type AggregateQueryPlanPacket
  • func (s *AggregateQueryPlanPacket) Close() error
  • func (s *AggregateQueryPlanPacket) String() string
• type DataPacket
  • func (s *DataPacket) Close() error
  • func (s *DataPacket) String() string
• type EndOfStreamPacket
  • func (s *EndOfStreamPacket) Close() error
  • func (s *EndOfStreamPacket) String() string
• type ExceptionPacket
  • func (s *ExceptionPacket) Close() error
  • func (s *ExceptionPacket) Error() string
  • func (s *ExceptionPacket) String() string
• type ExtremesPacket
  • func (s *ExtremesPacket) Close() error
  • func (s *ExtremesPacket) String() string
• type HelloPacket
  • func (s *HelloPacket) Close() error
  • func (s *HelloPacket) String() string
• type LogPacket
  • func (s *LogPacket) Close() error
  • func (s *LogPacket) String() string
• type Packet
  • func ReadPacket(decoder *ch_encoding.Decoder, compress bool, revision uint64) (Packet, error)
  • func ReadPacketWithLocation(decoder *ch_encoding.Decoder, compress bool, revision uint64, ...) (Packet, error)
• type PongPacket
  • func (p *PongPacket) Close() error
  • func (p *PongPacket) String() string
• type ProfilePacket
  • func (s *ProfilePacket) Close() error
  • func (s *ProfilePacket) String() string
• type ProgressPacket
  • func (s *ProgressPacket) Close() error
  • func (s *ProgressPacket) String() string
• type QueryMetadataPacket
  • func (s *QueryMetadataPacket) Close() error
  • func (s *QueryMetadataPacket) String() string
• type QueryPlanPacket
  • func (s *QueryPlanPacket) Close() error
  • func (s *QueryPlanPacket) String() string
• type TableColumnsPacket
  • func (s *TableColumnsPacket) Close() error
  • func (s *TableColumnsPacket) String() string
• type TotalsPacket
  • func (s *TotalsPacket) Close() error
  • func (s *TotalsPacket) String() string

Variables

var ErrTableStatusNotSupported = errors.ErrorfWithCaller("table status packet unsupported")

Functions

func WritePacket

func WritePacket(p Packet, encoder *ch_encoding.Encoder, compress bool, revision uint64) (err error)

Types

type AggregateQueryPlanPacket

type AggregateQueryPlanPacket struct {
	Plans []string
}

func (*AggregateQueryPlanPacket) Close

func (s *AggregateQueryPlanPacket) Close() error

func (*AggregateQueryPlanPacket) String

func (s *AggregateQueryPlanPacket) String() string

type DataPacket

type DataPacket struct {
	Table string
	Block *data.Block
}

func (*DataPacket) Close

func (s *DataPacket) Close() error

func (*DataPacket) String

func (s *DataPacket) String() string

type EndOfStreamPacket

type EndOfStreamPacket struct{}

func (*EndOfStreamPacket) Close

func (s *EndOfStreamPacket) Close() error

func (*EndOfStreamPacket) String

func (s *EndOfStreamPacket) String() string

type ExceptionPacket

type ExceptionPacket struct {
	Code       uint32
	Name       string
	Message    string
	StackTrace string
	Nested     *ExceptionPacket
}

func (*ExceptionPacket) Close

func (s *ExceptionPacket) Close() error

func (*ExceptionPacket) Error

func (s *ExceptionPacket) Error() string

func (*ExceptionPacket) String

func (s *ExceptionPacket) String() string

type ExtremesPacket

type ExtremesPacket struct {
	Table string
	Block *data.Block
}

func (*ExtremesPacket) Close

func (s *ExtremesPacket) Close() error

func (*ExtremesPacket) String

func (s *ExtremesPacket) String() string

type HelloPacket

type HelloPacket struct{}

func (*HelloPacket) Close

func (s *HelloPacket) Close() error

func (*HelloPacket) String

func (s *HelloPacket) String() string

type LogPacket

type LogPacket struct {
	Table string
	Block *data.Block
}

func (*LogPacket) Close

func (s *LogPacket) Close() error

func (*LogPacket) String

func (s *LogPacket) String() string

type Packet

type Packet interface {
	String() string
	Close() error
	// contains filtered or unexported methods
}

func ReadPacket

func ReadPacket(decoder *ch_encoding.Decoder, compress bool, revision uint64) (Packet, error)

func ReadPacketWithLocation

func ReadPacketWithLocation(decoder *ch_encoding.Decoder, compress bool, revision uint64, location *time.Location) (Packet, error)

type PongPacket

type PongPacket struct{}

func (*PongPacket) Close

func (p *PongPacket) Close() error

func (*PongPacket) String

func (p *PongPacket) String() string

type ProfilePacket

type ProfilePacket struct {
	Rows                      uint64
	Blocks                    uint64
	Bytes                     uint64
	AppliedLimit              bool
	RowsBeforeLimit           uint64
	CalculatedRowsBeforeLimit bool
}

func (*ProfilePacket) Close

func (s *ProfilePacket) Close() error

func (*ProfilePacket) String

func (s *ProfilePacket) String() string

type ProgressPacket

type ProgressPacket struct {
	Rows      uint64
	Bytes     uint64
	TotalRows uint64

	DiskCacheBytes uint64
}

func (*ProgressPacket) Close

func (s *ProgressPacket) Close() error

func (*ProgressPacket) String

func (s *ProgressPacket) String() string

type QueryMetadataPacket

type QueryMetadataPacket struct {
	QueryID string
}

func (*QueryMetadataPacket) Close

func (s *QueryMetadataPacket) Close() error

func (*QueryMetadataPacket) String

func (s *QueryMetadataPacket) String() string

type QueryPlanPacket

type QueryPlanPacket struct {
	Plans []string
}

func (*QueryPlanPacket) Close

func (s *QueryPlanPacket) Close() error

func (*QueryPlanPacket) String

func (s *QueryPlanPacket) String() string

type TableColumnsPacket

type TableColumnsPacket struct {
	Table       string
	Description string
}

func (*TableColumnsPacket) Close

func (s *TableColumnsPacket) Close() error

func (*TableColumnsPacket) String

func (s *TableColumnsPacket) String() string

type TotalsPacket

type TotalsPacket struct {
	Table string
	Block *data.Block
}

func (*TotalsPacket) Close

func (s *TotalsPacket) Close() error

func (*TotalsPacket) String

func (s *TotalsPacket) String() string