| Safe Haskell | Safe-Inferred |
|---|---|
| Language | Haskell2010 |
ClickHaskell.NativeProtocol
Synopsis
- latestSupportedRevision :: ProtocolRevision
- data ClientPacketType
- type family PacketTypeNumber (packetType :: ClientPacketType) where ...
- data Packet (packetType :: ClientPacketType) = MkPacket
- packetNumVal :: forall packetType. KnownNat (PacketTypeNumber packetType) => UVarInt
- data HelloParameters = MkHelloParameters {}
- mkHelloPacket :: HelloParameters -> HelloPacket
- data HelloPacket = MkHelloPacket {}
- mkAddendum :: Addendum
- data Addendum = MkAddendum {}
- mkPingPacket :: PingPacket
- data PingPacket = MkPingPacket {}
- mkQueryPacket :: ProtocolRevision -> ChString -> ChString -> QueryPacket
- data QueryPacket = MkQueryPacket {
- query_packet :: Packet Query
- query_id :: ChString
- client_info :: ClientInfo `SinceRevision` DBMS_MIN_REVISION_WITH_CLIENT_INFO
- settings :: DbSettings
- interserver_secret :: ChString `SinceRevision` DBMS_MIN_REVISION_WITH_INTERSERVER_SECRET
- query_stage :: QueryStage
- compression :: UVarInt
- query :: ChString
- parameters :: QueryParameters `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_PARAMETERS
- data DbSettings = MkDbSettings
- data QueryParameters = MkQueryParameters
- data QueryStage
- queryStageCode :: QueryStage -> UVarInt
- data Flags
- flagCode :: Flags -> ChUInt64
- data ClientInfo = MkClientInfo {
- query_kind :: QueryKind
- initial_user :: ChString
- initial_query_id :: ChString
- initial_adress :: ChString
- initial_time :: ChInt64 `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_INITIAL_QUERY_START_TIME
- interface_type :: ChUInt8
- os_user :: ChString
- hostname :: ChString
- client_name :: ChString
- client_major :: UVarInt
- client_minor :: UVarInt
- client_revision :: ProtocolRevision
- quota_key :: ChString `SinceRevision` DBMS_MIN_REVISION_WITH_QUOTA_KEY_IN_CLIENT_INFO
- distrubuted_depth :: UVarInt `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_DISTRIBUTED_DEPTH
- client_patch :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_VERSION_PATCH
- open_telemetry :: ChUInt8 `SinceRevision` DBMS_MIN_REVISION_WITH_OPENTELEMETRY
- collaborate_with_initiator :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_PARALLEL_REPLICAS
- count_participating_replicas :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_PARALLEL_REPLICAS
- number_of_current_replica :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_PARALLEL_REPLICAS
- data QueryKind
- mkDataPacket :: ChString -> UVarInt -> UVarInt -> DataPacket
- data DataPacket = MkDataPacket {}
- data BlockInfo = MkBlockInfo {
- field_num1 :: UVarInt
- is_overflows :: ChUInt8
- field_num2 :: UVarInt
- bucket_num :: ChInt32
- eof :: UVarInt
- data ServerPacketType where
- HelloResponse :: HelloResponse -> ServerPacketType
- DataResponse :: DataPacket -> ServerPacketType
- Exception :: ExceptionPacket -> ServerPacketType
- Progress :: ProgressPacket -> ServerPacketType
- Pong :: ServerPacketType
- EndOfStream :: ServerPacketType
- ProfileInfo :: ProfileInfo -> ServerPacketType
- Totals :: ServerPacketType
- Extremes :: ServerPacketType
- TablesStatusResponse :: ServerPacketType
- Log :: ServerPacketType
- TableColumns :: TableColumns -> ServerPacketType
- UUIDs :: ServerPacketType
- ReadTaskRequest :: ServerPacketType
- ProfileEvents :: ServerPacketType
- UnknownPacket :: UVarInt -> ServerPacketType
- data HelloResponse = MkHelloResponse {
- server_name :: ChString
- server_version_major :: UVarInt
- server_version_minor :: UVarInt
- server_revision :: ProtocolRevision
- server_parallel_replicas_proto :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_VERSIONED_PARALLEL_REPLICAS_PROTOCOL
- server_timezone :: ChString `SinceRevision` DBMS_MIN_REVISION_WITH_SERVER_TIMEZONE
- server_display_name :: ChString `SinceRevision` DBMS_MIN_REVISION_WITH_SERVER_DISPLAY_NAME
- server_version_patch :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_VERSION_PATCH
- proto_send_chunked_srv :: ChString `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_CHUNKED_PACKETS
- proto_recv_chunked_srv :: ChString `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_CHUNKED_PACKETS
- password_complexity_rules :: [PasswordComplexityRules] `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_PASSWORD_COMPLEXITY_RULES
- read_nonce :: ChUInt64 `SinceRevision` DBMS_MIN_REVISION_WITH_INTERSERVER_SECRET_V2
- data PasswordComplexityRules = MkPasswordComplexityRules {}
- data ExceptionPacket = MkExceptionPacket {}
- data ProgressPacket = MkProgressPacket {
- rows :: UVarInt
- bytes :: UVarInt
- total_rows :: UVarInt
- total_bytes :: UVarInt `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_TOTAL_BYTES_IN_PROGRESS
- wrote_rows :: UVarInt `SinceRevision` DBMS_MIN_PROTOCOL_VERSION_WITH_TOTAL_BYTES_IN_PROGRESS
- wrote_bytes :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_CLIENT_WRITE_INFO
- elapsed_ns :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_CLIENT_WRITE_INFO
- data ProfileInfo = MkProfileInfo {
- rows :: UVarInt
- blocks :: UVarInt
- bytes :: UVarInt
- applied_limit :: ChUInt8
- rows_before_limit :: UVarInt
- calculated_rows_before_limit :: ChUInt8
- applied_aggregation :: ChUInt8 `SinceRevision` DBMS_MIN_REVISION_WITH_ROWS_BEFORE_AGGREGATION
- rows_before_aggregation :: UVarInt `SinceRevision` DBMS_MIN_REVISION_WITH_ROWS_BEFORE_AGGREGATION
- data TableColumns = MkTableColumns {}
- clientMajorVersion :: UVarInt
- clientMinorVersion :: UVarInt
- clientPatchVersion :: UVarInt
- clientNameAndVersion :: ChString
Compatibility
Client packets
data ClientPacketType Source #
Constructors
| Hello | |
| Query | |
| Data | |
| Cancel | |
| Ping | |
| TablesStatusRequest | |
| KeepAlive | |
| Scalar | |
| IgnoredPartUUIDs | |
| ReadTaskResponse | |
| MergeTreeReadTaskResponse | |
| SSHChallengeRequest | |
| SSHChallengeResponse |
Instances
| Enum ClientPacketType Source # | |
Defined in ClickHaskell.NativeProtocol Methods succ :: ClientPacketType -> ClientPacketType # pred :: ClientPacketType -> ClientPacketType # toEnum :: Int -> ClientPacketType # fromEnum :: ClientPacketType -> Int # enumFrom :: ClientPacketType -> [ClientPacketType] # enumFromThen :: ClientPacketType -> ClientPacketType -> [ClientPacketType] # enumFromTo :: ClientPacketType -> ClientPacketType -> [ClientPacketType] # enumFromThenTo :: ClientPacketType -> ClientPacketType -> ClientPacketType -> [ClientPacketType] # | |
| Show ClientPacketType Source # | |
Defined in ClickHaskell.NativeProtocol Methods showsPrec :: Int -> ClientPacketType -> ShowS # show :: ClientPacketType -> String # showList :: [ClientPacketType] -> ShowS # | |
type family PacketTypeNumber (packetType :: ClientPacketType) where ... Source #
Equations
data Packet (packetType :: ClientPacketType) Source #
Constructors
| MkPacket |
Instances
| Deserializable (Packet packetType) Source # | |
Defined in ClickHaskell.NativeProtocol Methods deserialize :: ProtocolRevision -> Get (Packet packetType) Source # | |
| KnownNat (PacketTypeNumber packetType) => Serializable (Packet packetType) Source # | |
Defined in ClickHaskell.NativeProtocol | |
| KnownNat (PacketTypeNumber packetType) => Show (Packet packetType) Source # | |
packetNumVal :: forall packetType. KnownNat (PacketTypeNumber packetType) => UVarInt Source #
Hello
data HelloParameters Source #
Constructors
| MkHelloParameters | |
data HelloPacket Source #
Constructors
| MkHelloPacket | |
Fields | |
Instances
Constructors
| MkAddendum | |
Instances
| Serializable Addendum Source # | |
Defined in ClickHaskell.NativeProtocol | |
| Generic Addendum Source # | |
| type Rep Addendum Source # | |
Defined in ClickHaskell.NativeProtocol type Rep Addendum = D1 ('MetaData "Addendum" "ClickHaskell.NativeProtocol" "ClickHaskell-0.1.0-JmQ4pBuN19B8vUyif6bZBj" 'False) (C1 ('MetaCons "MkAddendum" 'PrefixI 'True) (S1 ('MetaSel ('Just "quota_key") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (SinceRevision ChString DBMS_MIN_PROTOCOL_VERSION_WITH_QUOTA_KEY)))) | |
Ping
data PingPacket Source #
Constructors
| MkPingPacket | |
Fields | |
Instances
| Serializable PingPacket Source # | |
Defined in ClickHaskell.NativeProtocol Methods serialize :: ProtocolRevision -> PingPacket -> Builder Source # | |
| Generic PingPacket Source # | |
Defined in ClickHaskell.NativeProtocol Associated Types type Rep PingPacket :: Type -> Type # | |
| type Rep PingPacket Source # | |
Defined in ClickHaskell.NativeProtocol type Rep PingPacket = D1 ('MetaData "PingPacket" "ClickHaskell.NativeProtocol" "ClickHaskell-0.1.0-JmQ4pBuN19B8vUyif6bZBj" 'False) (C1 ('MetaCons "MkPingPacket" 'PrefixI 'True) (S1 ('MetaSel ('Just "packet_type") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Packet 'Ping)))) | |
Query
mkQueryPacket :: ProtocolRevision -> ChString -> ChString -> QueryPacket Source #
data QueryPacket Source #
Constructors
Instances
data DbSettings Source #
Constructors
| MkDbSettings |
Instances
| Serializable DbSettings Source # | |
Defined in ClickHaskell.NativeProtocol Methods serialize :: ProtocolRevision -> DbSettings -> Builder Source # | |
data QueryParameters Source #
Constructors
| MkQueryParameters |
Instances
| Serializable QueryParameters Source # | |
Defined in ClickHaskell.NativeProtocol Methods serialize :: ProtocolRevision -> QueryParameters -> Builder Source # | |
data QueryStage Source #
Constructors
| FetchColumns | |
| WithMergeableState | |
| Complete | |
| WithMergeableStateAfterAggregation | |
| WithMergeableStateAfterAggregationAndLimit |
Instances
| Serializable QueryStage Source # | |
Defined in ClickHaskell.NativeProtocol Methods serialize :: ProtocolRevision -> QueryStage -> Builder Source # | |
| Enum QueryStage Source # | |
Defined in ClickHaskell.NativeProtocol Methods succ :: QueryStage -> QueryStage # pred :: QueryStage -> QueryStage # toEnum :: Int -> QueryStage # fromEnum :: QueryStage -> Int # enumFrom :: QueryStage -> [QueryStage] # enumFromThen :: QueryStage -> QueryStage -> [QueryStage] # enumFromTo :: QueryStage -> QueryStage -> [QueryStage] # enumFromThenTo :: QueryStage -> QueryStage -> QueryStage -> [QueryStage] # | |
queryStageCode :: QueryStage -> UVarInt Source #
data ClientInfo Source #
Constructors
Instances
Constructors
| NoQuery | |
| InitialQuery | |
| SecondaryQuery |
Instances
| Serializable QueryKind Source # | |
Defined in ClickHaskell.NativeProtocol | |
| Enum QueryKind Source # | |
Defined in ClickHaskell.NativeProtocol Methods succ :: QueryKind -> QueryKind # pred :: QueryKind -> QueryKind # fromEnum :: QueryKind -> Int # enumFrom :: QueryKind -> [QueryKind] # enumFromThen :: QueryKind -> QueryKind -> [QueryKind] # enumFromTo :: QueryKind -> QueryKind -> [QueryKind] # enumFromThenTo :: QueryKind -> QueryKind -> QueryKind -> [QueryKind] # | |
Data
mkDataPacket :: ChString -> UVarInt -> UVarInt -> DataPacket Source #
data DataPacket Source #
Constructors
| MkDataPacket | |
Fields
| |
Instances
Constructors
| MkBlockInfo | |
Fields
| |
Instances
| Deserializable BlockInfo Source # | |
Defined in ClickHaskell.NativeProtocol Methods | |
| Serializable BlockInfo Source # | |
Defined in ClickHaskell.NativeProtocol | |
| Generic BlockInfo Source # | |
| Show BlockInfo Source # | |
| type Rep BlockInfo Source # | |
Defined in ClickHaskell.NativeProtocol type Rep BlockInfo = D1 ('MetaData "BlockInfo" "ClickHaskell.NativeProtocol" "ClickHaskell-0.1.0-JmQ4pBuN19B8vUyif6bZBj" 'False) (C1 ('MetaCons "MkBlockInfo" 'PrefixI 'True) ((S1 ('MetaSel ('Just "field_num1") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UVarInt) :*: S1 ('MetaSel ('Just "is_overflows") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChUInt8)) :*: (S1 ('MetaSel ('Just "field_num2") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UVarInt) :*: (S1 ('MetaSel ('Just "bucket_num") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChInt32) :*: S1 ('MetaSel ('Just "eof") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UVarInt))))) | |
Server packets
data ServerPacketType where Source #
Constructors
Instances
| Deserializable ServerPacketType Source # | |
Defined in ClickHaskell.NativeProtocol Methods deserialize :: ProtocolRevision -> Get ServerPacketType Source # | |
| Show ServerPacketType Source # | |
Defined in ClickHaskell.NativeProtocol Methods showsPrec :: Int -> ServerPacketType -> ShowS # show :: ServerPacketType -> String # showList :: [ServerPacketType] -> ShowS # | |
HelloResponse
data HelloResponse Source #
Constructors
Instances
data PasswordComplexityRules Source #
Constructors
| MkPasswordComplexityRules | |
Fields | |
Instances
Exception
data ExceptionPacket Source #
Constructors
| MkExceptionPacket | |
Instances
Progress
data ProgressPacket Source #
Constructors
Instances
ProfileInfo
data ProfileInfo Source #
Constructors
Instances
TableColumns
data TableColumns Source #
Constructors
| MkTableColumns | |
Fields | |
Instances
| Deserializable TableColumns Source # | |
Defined in ClickHaskell.NativeProtocol Methods deserialize :: ProtocolRevision -> Get TableColumns Source # | |
| Generic TableColumns Source # | |
Defined in ClickHaskell.NativeProtocol Associated Types type Rep TableColumns :: Type -> Type # | |
| Show TableColumns Source # | |
Defined in ClickHaskell.NativeProtocol Methods showsPrec :: Int -> TableColumns -> ShowS # show :: TableColumns -> String # showList :: [TableColumns] -> ShowS # | |
| type Rep TableColumns Source # | |
Defined in ClickHaskell.NativeProtocol type Rep TableColumns = D1 ('MetaData "TableColumns" "ClickHaskell.NativeProtocol" "ClickHaskell-0.1.0-JmQ4pBuN19B8vUyif6bZBj" 'False) (C1 ('MetaCons "MkTableColumns" 'PrefixI 'True) (S1 ('MetaSel ('Just "table_name") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChString) :*: S1 ('MetaSel ('Just "table_columns") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChString))) | |