pub(open) trait Message {
  fn encode(Self) -> Bytes raise WireError
  fn decode(BytesView) -> Self raise WireError
  fn describe(Self) -> String
}

pub(open) trait Transport : 
@moonbitlang/async/io.Reader
Reader + 
@moonbitlang/async/io.Writer
Writer {
  fn close(Self) -> Unit
}

pub(all) suberror WireError {
  PgServer(String)
  Connect(String)
  Auth(String)
  Parse(String)
  InvalidMessage(String)
  IO(String)
}

pub(all) enum AuthMethod {
  Ok
  CleartextPassword
  MD5Password
  SASL
  SASLContinue
  SASLFinal
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct AuthenticationCleartextPassword {
}

pub(all) struct AuthenticationMD5Password {
  salt : Bytes
}

pub(all) struct AuthenticationOk {
}

pub(all) struct AuthenticationSASL {
  mechanisms : Array[String]
}

pub(all) struct AuthenticationSASLContinue {
  data : Bytes
}

pub(all) struct AuthenticationSASLFinal {
  data : Bytes
}

pub(all) struct BackendKeyData {
  pid : Int
  secret_key : Int
}

pub(all) enum BackendMessage {
  AuthenticationOk(AuthenticationOk)
  AuthenticationCleartextPassword(AuthenticationCleartextPassword)
  AuthenticationMD5Password(AuthenticationMD5Password)
  AuthenticationSASL(AuthenticationSASL)
  AuthenticationSASLContinue(AuthenticationSASLContinue)
  AuthenticationSASLFinal(AuthenticationSASLFinal)
  BackendKeyData(BackendKeyData)
  ReadyForQuery(ReadyForQuery)
  ParameterStatus(ParameterStatus)
  ErrorResponse(ErrorResponse)
  NoticeResponse(NoticeResponse)
  RowDescription(RowDescription)
  DataRow(DataRow)
  CommandComplete(CommandComplete)
  EmptyQueryResponse(EmptyQueryResponse)
  ParseComplete(ParseComplete)
  BindComplete(BindComplete)
  CloseComplete(CloseComplete)
  ParameterDescription(ParameterDescription)
  NoData(NoData)
  PortalSuspended(PortalSuspended)
  CopyInResponse(CopyInResponse)
  CopyOutResponse(CopyOutResponse)
  CopyBothResponse(CopyBothResponse)
  CopyData(CopyData)
  CopyDone(CopyDone)
  NotificationResponse(NotificationResponse)
  NegotiateProtocolVersion(NegotiateProtocolVersion)
  Unknown(Byte, BytesView)
}

pub(all) struct Bind {
  portal : String
  statement : String
  param_formats : Array[Int]
  params : Array[Bytes?]
  result_formats : Array[Int]
}

pub(all) struct BindComplete {
}

pub(all) struct BytesMut {
  // private fields
}

pub(all) struct Close {
  variant : Byte
  name : String
}

pub(all) struct CloseComplete {
}

pub(all) struct CommandComplete {
  tag : CommandTag
}

pub struct CommandTag {
  tag : String
}

pub(all) struct Config {
  host : String
  hostaddr : String?
  port : Int
  user : String
  database : String?
  password : String?
  sslmode : String
  sslrootcert : String?
  sslcert : String?
  sslkey : String?
  application_name : String?
  connect_timeout : Int
  statement_timeout : Int
  target_session_attrs : String
  trace : Bool
}

pub(all) struct ConnParam {
  key : String
  value : String
}

pub enum ConnStatus {
  Connecting
  Closed
  Idle
  Busy
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct CopyBothResponse {
  overall_format : Int
  column_formats : Array[Int]
}

pub(all) struct CopyData {
  data : Bytes
}

pub(all) struct CopyDone {
}

pub(all) struct CopyFail {
  message : String
}

pub(all) struct CopyInResponse {
  overall_format : Int
  column_formats : Array[Int]
}

pub(all) struct CopyOutResponse {
  overall_format : Int
  column_formats : Array[Int]
}

pub(all) struct DataRow {
  values : Array[Bytes?]
}

pub(all) struct Describe {
  variant : Byte
  name : String
}

pub(all) struct EmptyQueryResponse {
}

pub(all) struct ErrorField {
  field_type : Byte
  value : String
} derive(
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct ErrorResponse {
  fields : Array[ErrorField]
}

pub(all) struct Execute {
  portal : String
  max_rows : Int
}

pub(all) struct FieldDescription {
  name : String
  table_oid : Int
  attr_num : Int
  type_oid : Int
  typlen : Int
  typmod : Int
  format : Int
}

pub(all) struct Flush {
}

pub(all) struct NegotiateProtocolVersion {
  newest_minor_version : Int
  options : Array[String]
}

pub(all) struct NoData {
}

pub(all) struct NoticeResponse {
  fields : Array[ErrorField]
}

pub(all) struct NotificationResponse {
  pid : Int
  channel : String
  payload : String
}

pub(all) struct ParameterDescription {
  param_types : Array[Int]
}

pub(all) struct ParameterStatus {
  name : String
  value : String
}

pub(all) struct Parse {
  name : String
  query : String
  param_types : Array[Int]
}

pub(all) struct ParseComplete {
}

pub(all) struct PasswordMessage {
  password : String
}

pub(all) struct PortalSuspended {
}

pub enum ProtocolVersion {
  V3_0
  V3_2
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct Query {
  sql : String
}