conn

type BackendConn interface {
	Connect(ctx context.Context) error
	ConnID() uint64
	ExecuteCmd(ctx context.Context, request []byte) error
	Query(ctx context.Context, stmt string) error
	PrepareStmt(ctx context.Context, stmt string) (stmtID uint32, err error)
	ExecuteStmt(ctx context.Context, stmtID uint32, args []any) error
	GetPreparedStmt(stmtID uint32) (text string, paramNum int, paramTypes []byte)
	Close()
}

type BackendConnManager interface {
	Connect(ctx context.Context, clientIO pnet.PacketIO, frontendTLSConfig, backendTLSConfig *tls.Config, username, password string) error
	ExecuteCmd(ctx context.Context, request []byte) error
	ConnectionID() uint64
	Close() error
}

type Conn interface {
	Run(ctx context.Context)
	ExecuteCmd(command *cmd.Command)
	Stop()
}

type ConnCreator func(connID uint64) Conn

type Exception interface {
	Type() ExceptionType
	Key() string
	ConnID() uint64
	Time() time.Time
}

type ExceptionType int

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

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

type ReplayStats struct {
	// ReplayedCmds is the number of executed commands.
	ReplayedCmds atomic.Uint64
	// PendingCmds is the number of decoded but not executed commands.
	PendingCmds atomic.Int64
}